diff --git a/build.xml b/build.xml
index 84e4b5e125..32581e4896 100644
--- a/build.xml
+++ b/build.xml
@@ -31,15 +31,15 @@
-
+
-
-
+
+
@@ -69,7 +69,7 @@
-
+
@@ -84,7 +84,7 @@
-
+
@@ -247,7 +247,7 @@
-
+
diff --git a/ivy.xml b/ivy.xml
index 3f2c94373b..b969ad6092 100644
--- a/ivy.xml
+++ b/ivy.xml
@@ -405,7 +405,7 @@
-
+
diff --git a/ivy/libraries.properties b/ivy/libraries.properties
index a0eb00acd2..787367a710 100644
--- a/ivy/libraries.properties
+++ b/ivy/libraries.properties
@@ -38,7 +38,7 @@ checkstyle.version=4.2
ivy.version=2.2.0
jasper.version=6.1.14
groovy.version=2.4.5
-guava.version=11.0
+guava.version=23.0
hadoop-common.version=2.7.3
hadoop-hdfs.version=2.7.3
hadoop-mapreduce.version=2.7.3
@@ -91,7 +91,7 @@ jansi.version=1.9
asm.version=3.3.1
snappy-java.version=1.1.1.3
tez.version=0.7.0
-parquet-pig-bundle.version=1.2.3
+parquet-pig-bundle.version=1.9.0
snappy.version=0.2
leveldbjni.version=1.8
curator.version=2.6.0
diff --git a/src/org/apache/pig/builtin/ParquetLoader.java b/src/org/apache/pig/builtin/ParquetLoader.java
index 76516e3b1c..1a245de688 100644
--- a/src/org/apache/pig/builtin/ParquetLoader.java
+++ b/src/org/apache/pig/builtin/ParquetLoader.java
@@ -27,7 +27,7 @@
import org.apache.pig.impl.util.JarManager;
/**
- * Wrapper class which will delegate calls to parquet.pig.ParquetLoader
+ * Wrapper class which will delegate calls to org.apache.parquet.pig.ParquetLoader
*/
public class ParquetLoader extends LoadFuncMetadataWrapper implements LoadPushDown {
@@ -37,12 +37,12 @@ public ParquetLoader() throws FrontendException {
public ParquetLoader(String requestedSchemaStr) throws FrontendException {
try {
- init(new parquet.pig.ParquetLoader(requestedSchemaStr));
+ init(new org.apache.parquet.pig.ParquetLoader(requestedSchemaStr));
}
// if compile time dependency not found at runtime
catch (NoClassDefFoundError e) {
throw new FrontendException(String.format("Cannot instantiate class %s (%s)",
- getClass().getName(), "parquet.pig.ParquetLoader"), 2259, e);
+ getClass().getName(), "org.apache.parquet.pig.ParquetLoader"), 2259, e);
}
}
@@ -52,7 +52,7 @@ private void init(LoadMetadata loadMetadata) {
@Override
public void setLocation(String location, Job job) throws IOException {
- JarManager.addDependencyJars(job, parquet.Version.class);
+ JarManager.addDependencyJars(job, org.apache.parquet.Version.class);
super.setLocation(location, job);
}
diff --git a/src/org/apache/pig/builtin/ParquetStorer.java b/src/org/apache/pig/builtin/ParquetStorer.java
index 2052236eae..755fe16842 100644
--- a/src/org/apache/pig/builtin/ParquetStorer.java
+++ b/src/org/apache/pig/builtin/ParquetStorer.java
@@ -25,18 +25,18 @@
import org.apache.pig.impl.util.JarManager;
/**
- * Wrapper class which will delegate calls to parquet.pig.ParquetStorer
+ * Wrapper class which will delegate calls to org.apache.parquet.pig.ParquetStorer
*/
public class ParquetStorer extends StoreFuncMetadataWrapper {
public ParquetStorer() throws FrontendException {
try {
- init(new parquet.pig.ParquetStorer());
+ init(new org.apache.parquet.pig.ParquetStorer());
}
// if compile time dependency not found at runtime
catch (NoClassDefFoundError e) {
throw new FrontendException(String.format("Cannot instantiate class %s (%s)",
- getClass().getName(), "parquet.pig.ParquetStorer"), 2259, e);
+ getClass().getName(), "org.apache.parquet.pig.ParquetStorer"), 2259, e);
}
}
@@ -49,7 +49,7 @@ private void init(StoreMetadata storeMetadata) {
*/
@Override
public void setStoreLocation(String location, Job job) throws IOException {
- JarManager.addDependencyJars(job, parquet.Version.class);
+ JarManager.addDependencyJars(job, org.apache.parquet.Version.class);
super.setStoreLocation(location, job);
}