----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/59530/#review176232 -----------------------------------------------------------
Ship it! Ship It! - Rohini Palaniswamy On May 25, 2017, 7:13 a.m., Nandor Kollar wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/59530/ > ----------------------------------------------------------- > > (Updated May 25, 2017, 7:13 a.m.) > > > Review request for pig, liyun zhang, Rohini Palaniswamy, and Adam Szita. > > > Repository: pig-git > > > Description > ------- > > Upgrade to Spark 2.1 API using shims. > > > Diffs > ----- > > build.xml 4040fce > ivy/spark2.properties PRE-CREATION > > shims/src/spark1/org/apache/pig/backend/hadoop/executionengine/spark/JobMetricsListener.java > PRE-CREATION > > shims/src/spark1/org/apache/pig/backend/hadoop/executionengine/spark/converter/AbstractFlatMapFunction.java > PRE-CREATION > > shims/src/spark1/org/apache/pig/backend/hadoop/executionengine/spark/converter/AbstractLimitConverter.java > PRE-CREATION > > shims/src/spark1/org/apache/pig/backend/hadoop/executionengine/spark/converter/AbstractPairFlatMapFunction.java > PRE-CREATION > > shims/src/spark1/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinUtil.java > PRE-CREATION > shims/src/spark1/org/apache/pig/tools/pigstats/spark/SparkJobStats.java > PRE-CREATION > > shims/src/spark2/org/apache/pig/backend/hadoop/executionengine/spark/JobMetricsListener.java > PRE-CREATION > > shims/src/spark2/org/apache/pig/backend/hadoop/executionengine/spark/converter/AbstractFlatMapFunction.java > PRE-CREATION > > shims/src/spark2/org/apache/pig/backend/hadoop/executionengine/spark/converter/AbstractLimitConverter.java > PRE-CREATION > > shims/src/spark2/org/apache/pig/backend/hadoop/executionengine/spark/converter/AbstractPairFlatMapFunction.java > PRE-CREATION > > shims/src/spark2/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinUtil.java > PRE-CREATION > shims/src/spark2/org/apache/pig/tools/pigstats/spark/SparkJobStats.java > PRE-CREATION > > src/org/apache/pig/backend/hadoop/executionengine/spark/JobMetricsListener.java > f813412 > src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java > c6351e0 > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/CollectedGroupConverter.java > 83311df > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java > 382258e > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java > b58415e > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java > f571b80 > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LimitConverter.java > fe1b54c > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeCogroupConverter.java > adf78ec > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java > d1c43b1 > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PoissonSampleConverter.java > e003bbd > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java > 00d29b4 > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java > c55ba31 > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java > baabfa0 > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SparkSampleSortConverter.java > 3166fdc > > src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java > 3a50d48 > src/org/apache/pig/tools/pigstats/spark/SparkJobStats.java c8cc031 > > > Diff: https://reviews.apache.org/r/59530/diff/2/ > > > Testing > ------- > > > Thanks, > > Nandor Kollar > >
