Revision 1796639

Jump to revision:
Author:	szita
Date:	Mon May 29 15:00:39 2017 UTC (6 years, 11 months ago)
Changed paths:	198 (showing only 100; show all)
Log Message:	PIG-4059: Pig On Spark

Changed paths

Path	Details
pig/trunk/CHANGES.txt	modified , text changed
pig/trunk/bin/pig	modified , text changed
pig/trunk/build.xml	modified , text changed
pig/trunk/ivy/libraries.properties	modified , text changed
pig/trunk/ivy.xml	modified , text changed
pig/trunk/src/META-INF/services/org.apache.pig.ExecType	modified , text changed
pig/trunk/src/docs/src/documentation/content/xdocs/start.xml	modified , text changed
pig/trunk/src/org/apache/pig/PigConfiguration.java	modified , text changed
pig/trunk/src/org/apache/pig/PigWarning.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/AccumulatorOptimizer.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NoopFilterRemover.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/NoopFilterRemoverUtil.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigHadoopLogger.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigInputFormat.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/PigSplit.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/mapReduceLayer/SecondaryKeyOptimizerMR.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/PhysicalOperator.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/expressionOperators/POUserFunc.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/plans/PhyPlanVisitor.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/plans/PhysicalPlan.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POBroadcastSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POCollectedGroup.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoin.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POFRJoinSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POForEach.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeCogroup.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POMergeJoin.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POPoissonSample.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POSort.java	modified , text changed
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/JobGraphBuilder.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/JobMetricsListener.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/KryoSerializer.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/MapReducePartitionerWrapper.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkEngineConf.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkExecType.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkExecutionEngine.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLauncher.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkLocalExecType.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPOUserFuncVisitor.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigContext.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigRecordReader.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkPigSplit.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/SparkUtil.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/UDFJarsFinder.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/BroadcastConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/CollectedGroupConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/CounterConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ForEachConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/IndexedKey.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/IteratorTransform.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/JoinGroupSparkConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LimitConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeCogroupConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/OutputConsumerIterator.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PigSecondaryKeyComparatorSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PoissonSampleConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RDDConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/ReduceByConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SparkSampleSortConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/NativeSparkOperator.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POJoinGroupSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POPoissonSampleSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POReduceBySpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POSampleSortSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/AccumulatorOptimizer.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/CombinerOptimizer.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/JoinGroupOptimizerSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/MultiQueryOptimizerSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/NoopFilterRemover.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/ParallelismSetter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/SecondaryKeyOptimizerSpark.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/optimizer/SparkSecondaryKeyOptimizerUtil.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/plan/	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/plan/DotSparkPrinter.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkCompiler.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkCompilerException.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkOpPlanVisitor.java	added
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/spark/plan/SparkOperPlan.java	added
[...]