Search Java Classes and Packages
#Org.apache.pig.backend.hadoop.executionengine.mapReduceLayer Classes and Interfaces - 104 results found.
| Name | Description | Type | Package | Framework |
| AccumulatorOptimizer | A visitor to optimize plans that determines if a reduce plan can run in accumulative mode. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| ColumnChainInfo | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| ColumnInfo | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| CombinerOptimizer | Optimize map reduce plans to use the combiner where possible. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| CountingMap | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig | |
| DiscreteProbabilitySampleGenerator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig | |
| DistinctCombiner | A special implementation of combiner used only for distinct. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| DistinctCombiner .Combine | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.DistinctCombiner | Apache Pig | |
| DotMRPrinter | This class can print an MR plan in the DOT format. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig |
| DotMRPrinter .InnerOperator | Helper class to represent the relationship of map, reduce and combine phases in an MR operator. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter | Apache Pig |
| DotMRPrinter .InnerPlan | Helper class to represent the relationship of map, reduce and combine phases in an MR operator. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter | Apache Pig |
| EndOfAllInputSetter | This visitor visits the MRPlan and does the following for each MROper: If the map plan or the reduce plan of the MROper has | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig |
| IllustrateDummyReporter | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| InputSizeReducerEstimator | Class that estimates the number of reducers based on input size. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| JobControlCompiler | This is compiler class that takes an MROperPlan and converts it into a JobControl object with the relevant dependency info | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| JobControlCompiler .PigBagWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigBooleanWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigCharArrayWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigDateTimeWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigDBAWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigDoubleWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigFloatWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingBagWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingBooleanWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingCharArrayWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingDateTimeWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingDBAWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingDoubleWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingFloatWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingIntWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingLongWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingPartitionWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigGroupingTupleWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigIntWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigLongWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigSecondaryKeyGroupComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigTupleWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobControlCompiler .PigWritableComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler | Apache Pig | |
| JobCreationException | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| KeyTypeDiscoveryVisitor | A visitor to figure out the type of the key for the map plan this is needed when the key is null to create | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| Launcher | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| LimitAdjuster | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| MapReduceLauncher | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| MapReduceOper | An operator model for a Map Reduce job. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| MapReducePOStoreImpl | This class is used to have a POStore write to DFS via a output collector/record writer. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| MergeJoinIndexer | Merge Join indexer is used to generate on the fly index for doing Merge Join efficiently. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| MRCompiler | The compiler that compiles a given physical plan into a DAG of MapReduce operators which can then | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| MRCompilerException | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| MROperPlan | A Plan used to create the plan of Map Reduce Operators which can be | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig |
| MROpPlanVisitor | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig | |
| MRPrinter | A visitor mechanism printing out the logical plan. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig |
| MRUtil | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| NativeMapReduceOper | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PhyPlanSetter | Sets the parent plan for all Physical Operators. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigBooleanRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigBytesRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigCombiner | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigCombiner .Combine | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigCombiner | Apache Pig | |
| PigDateTimeRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigDoubleRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigFileInputFormat | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigFloatRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigGenericMapBase | This class is the base class for PigMapBase, which has slightly difference among different versions of hadoop. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigGenericMapReduce | This class is the static Mapper & Reducer classes that are used by Pig to execute Pig Map Reduce jobs. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigGenericMapReduce .Map | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce | Apache Pig | |
| PigGenericMapReduce .MapWithComparator | This "specialized" map class is ONLY to be used in pig queries with order by a udf. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce | Apache Pig |
| PigGenericMapReduce .MapWithPartitionIndex | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce | Apache Pig | |
| PigGenericMapReduce .Reduce | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce | Apache Pig | |
| PigGenericMapReduce .ReduceWithComparator | This "specialized" reduce class is ONLY to be used in pig queries with order by a udf. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce | Apache Pig |
| PigHadoopLogger | A singleton class that implements the PigLogger interface for use in map reduce context. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigInputFormat | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigIntRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigLongRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigMapOnly | This class is the static Mapper class used by Pig to execute Pig map only jobs. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigMapOnly .Map | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapOnly | Apache Pig | |
| PigMapReduceCounter | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigMapReduceCounter .PigMapCounter | This class is the used only for simple RANK operation, namely row number mode. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduceCounter | Apache Pig |
| PigMapReduceCounter .PigReduceCounter | This class is the used for RANK BY operations, independently if it is dense or not. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduceCounter | Apache Pig |
| PigOutputCommitter | A specialization of the default FileOutputCommitter to allow pig to inturn delegate calls to the OutputCommiter(s) of the | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigOutputFormat | The better half of PigInputFormat which is responsible for the Store functionality. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigOutputFormat .PigRecordWriter | Wrapper class which will delegate calls to the actual RecordWriter - this should only get called in the single store case. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat | Apache Pig |
| PigRecordReader | A wrapper around the actual RecordReader and loadfunc - this is needed for 1) To intercept the initialize call from hadoop and initialize the underlying | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigReducerEstimator | Interface to implement when you want to use a custom approach to estimating the number of reducers for a job. | Interface | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigSecondaryKeyComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigSequenceFileInputFormat | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigSplit | The main split class that maintains important information about the input split. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| PigTextInputFormat | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigTextOutputFormat | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigTextOutputFormat .PigLineRecordWriter | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextOutputFormat | Apache Pig | |
| PigTextRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigTupleDefaultRawComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| PigTupleSortComparator | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| POPackageAnnotator | This visitor visits the MRPlan and does the following - visits the POPackage in the reduce plan and finds the corresponding | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig |
| ProgressableReporter | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| RunJarSecurityManager | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| SampleOptimizer | A visitor to optimize plans that have a sample job that immediately follows a load/store only MR job. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
| ScalarPhyFinder | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig | |
| SecondaryKeyOptimizer | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| SecondaryKeyPartitioner | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig | |
| SkewedPartitioner | This class is used by skewed join. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig |
| SortKeyInfo | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| UDFFinder | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans | Apache Pig | |
| UDFFinishVisitor | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig | |
| WeightedRangePartitioner | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig | |