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); }