This is an automated email from the ASF dual-hosted git repository.
djkevincr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gora.git
The following commit(s) were added to refs/heads/master by this push:
new 504833f GORA-320 Hive backend support in Gora (#187)
504833f is described below
commit 504833f99f9bffd3b92bd46a48daebdabf1ccd57
Author: Chanaka Balasooriya
AuthorDate: Tue Aug 27 21:39:55 2019 +0530
GORA-320 Hive backend support in Gora (#187)
* GORA 320 Hive backend support for Gora
* Add type safety issues
* Configure hive embedded server for testing
* Support delete queries in gora-hive
* Moving hive dependencies to parent pom
* Add hive test server
* Resolve hive dependency issues
* Remove gora-hive test profile
---
.../org/apache/gora/store/DataStoreTestUtil.java | 10 +-
gora-hive/pom.xml | 217 +
.../java/org/apache/gora/hive/package-info.java| 21 +
.../java/org/apache/gora/hive/query/HiveQuery.java | 40 ++
.../org/apache/gora/hive/query/HiveResult.java | 79
.../org/apache/gora/hive/query/package-info.java | 21 +
.../apache/gora/hive/store/HiveDataContext.java| 256 ++
.../org/apache/gora/hive/store/HiveMapping.java| 95
.../apache/gora/hive/store/HiveMappingBuilder.java | 157 +++
.../java/org/apache/gora/hive/store/HiveStore.java | 374 +++
.../gora/hive/store/HiveStoreParameters.java | 123 +
.../org/apache/gora/hive/store/package-info.java | 21 +
.../apache/gora/hive/util/HiveQueryBuilder.java| 521 +
.../apache/gora/hive/util/HiveResultParser.java| 243 ++
.../org/apache/gora/hive/util/package-info.java| 22 +
.../org/apache/gora/hive/GoraHiveTestDriver.java | 49 ++
.../java/org/apache/gora/hive/package-info.java| 21 +
.../org/apache/gora/hive/store/TestHiveStore.java | 171 +++
.../org/apache/gora/hive/store/package-info.java | 21 +
.../org/apache/gora/hive/util/HiveTestServer.java | 109 +
.../org/apache/gora/hive/util/package-info.java| 21 +
gora-hive/src/test/resources/gora-hive-mapping.xml | 45 ++
gora-hive/src/test/resources/gora.properties | 28 ++
gora-hive/src/test/resources/hive-site.xml | 85
pom.xml| 75 ++-
25 files changed, 2817 insertions(+), 8 deletions(-)
diff --git
a/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
b/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
index bb935ba..a452999 100644
--- a/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
+++ b/gora-core/src/test/java/org/apache/gora/store/DataStoreTestUtil.java
@@ -105,7 +105,7 @@ public class DataStoreTestUtil {
return employee;
}
- private static WebPage createWebPage() {
+ public static WebPage createWebPage() {
WebPage webpage = WebPage.newBuilder().build();
webpage.setUrl(new Utf8("url.."));
webpage.setContent(ByteBuffer.wrap("test
content".getBytes(Charset.defaultCharset(;
@@ -338,7 +338,7 @@ public class DataStoreTestUtil {
* @param employee
* @param after
*/
- private static void assertEqualEmployeeObjects(Employee employee, Employee
after) {
+ public static void assertEqualEmployeeObjects(Employee employee, Employee
after) {
//for (int i = 1; i < employee.SCHEMA$.getFields().size(); i++) {
// for (int j = 1; j < after.SCHEMA$.getFields().size(); j++) {
//assertEquals(employee.SCHEMA$.getFields().get(i),
after.SCHEMA$.getFields().get(j));
@@ -388,7 +388,7 @@ public class DataStoreTestUtil {
* @param beforeWebPage
* @param afterWebPage
*/
- private static void assertEqualWebPageObjects(WebPage beforeWebPage, WebPage
afterWebPage) {
+ public static void assertEqualWebPageObjects(WebPage beforeWebPage, WebPage
afterWebPage) {
//check url field
CharSequence beforeUrl = beforeWebPage.getUrl();
CharSequence afterUrl = afterWebPage.getUrl();
@@ -424,7 +424,7 @@ public class DataStoreTestUtil {
* @param beforeMetadata
* @param afterMetadata
*/
- private static void assertEqualMetadataObjects(Metadata beforeMetadata,
Metadata afterMetadata) {
+ public static void assertEqualMetadataObjects(Metadata beforeMetadata,
Metadata afterMetadata) {
//check version field
int beforeVersion = beforeMetadata.getVersion();
int afterVersion = afterMetadata.getVersion();
@@ -767,7 +767,7 @@ public class DataStoreTestUtil {
" actual=" + CONTENTS[i] + " i=" + i
, Arrays.equals( toByteArray(page.getContent() )
, CONTENTS[i].getBytes(Charset.defaultCharset(;
-
+
List parsedContent = page.getParsedContent();
assertNotNull(parsedContent);
assertTrue(parsedContent.size() > 0);
diff --git a/gora-hive/pom.xml
