Name | Description | Type | Package | Framework |
AccumulativeTupleBuffer | This interface is used during Reduce phrase to process tuples in batch mode. | Interface | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
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 |
|
Add | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
BinaryComparisonOperator | This is a base class for all binary comparison operators. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
BinaryExpressionOperator | A base class for all Binary expression operators. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | 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 |
|
ComparisonOperator | This is an interface for all comparison operators. | Interface | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
CompiledAutomaton | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex | Apache Pig |
|
CompiledRegex | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex | Apache Pig |
|
ConfigurationUtil | | Class | org.apache.pig.backend.hadoop.datastorage | Apache Pig |
|
ConstantExpression | This class implements a Constant of any type. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
CountingMap | | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig |
|
DateTimeWritable | Writable for Double values. | Class | org.apache.pig.backend.hadoop | Apache Pig |
|
DateTimeWritable .Comparator | A Comparator optimized for DateTimeWritable. | Class | org.apache.pig.backend.hadoop.DateTimeWritable | 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 |
|
Divide | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | 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 |
|
DotPOPrinter | This class can print a physical plan in the DOT format. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans | Apache Pig |
|
DoubleWritable | Writable for Double values. | Class | org.apache.pig.backend.hadoop | Apache Pig |
|
DoubleWritable .Comparator | A Comparator optimized for DoubleWritable. | Class | org.apache.pig.backend.hadoop.DoubleWritable | 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 |
|
EqualToExpr | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
ExpressionOperator | A base class for all types of expressions. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
GreaterThanExpr | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
GTOrEqualToExpr | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
HadoopExecutableManager | HadoopExecutableManager is a specialization of ExecutableManager and provides HDFS-specific support for secondary | Class | org.apache.pig.backend.hadoop.streaming | Apache Pig |
|
HBaseBinaryConverter | | Class | org.apache.pig.backend.hadoop.hbase | Apache Pig |
|
HBaseStorage | A HBase implementation of LoadFunc and StoreFunc. | Class | org.apache.pig.backend.hadoop.hbase | Apache Pig |
|
HBaseTableInputFormat | | Class | org.apache.pig.backend.hadoop.hbase | Apache Pig |
|
HBaseTableInputFormat .HBaseTableIFBuilder | | Class | org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat | Apache Pig |
|
HConfiguration | | Class | org.apache.pig.backend.hadoop.datastorage | Apache Pig |
|
HDataStorage | | Class | org.apache.pig.backend.hadoop.datastorage | Apache Pig |
|
HDataType | A class of helper methods for converting from pig data types to hadoop data types, and vice versa. | Class | org.apache.pig.backend.hadoop | Apache Pig |
|
HDirectory | | Class | org.apache.pig.backend.hadoop.datastorage | Apache Pig |
|
HExecutionEngine | | Class | org.apache.pig.backend.hadoop.executionengine | Apache Pig |
|
HFile | | Class | org.apache.pig.backend.hadoop.datastorage | Apache Pig |
|
HJob | | Class | org.apache.pig.backend.hadoop.executionengine | Apache Pig |
|
HPath | | Class | org.apache.pig.backend.hadoop.datastorage | Apache Pig |
|
HSeekableInputStream | | Class | org.apache.pig.backend.hadoop.datastorage | 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 |
|
LessThanExpr | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
LimitAdjuster | | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
|
LogicalToPhysicalTranslatorException | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer | Apache Pig |
|
LTOrEqualToExpr | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
MapRedResult | | Class | org.apache.pig.backend.hadoop.executionengine | 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 |
|
MapRedUtil | | Class | org.apache.pig.backend.hadoop.executionengine.util | 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 |
|
Mod | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
MonitoredUDFExecutor | MonitoredUDF is used to watch execution of a UDF, and kill it if the UDF takes an exceedingly long time. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.util | Apache Pig |
|
MonitoredUDFExecutor .ErrorCallback | UDF authors can optionally extend this class and provide the class of their custom callbacks in the annotation to perform their own handling of errors and timeouts. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.util.MonitoredUDFExecutor | 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 |
|
Multiply | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
NativeMapReduceOper | | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
|
NonConstantRegex | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex | Apache Pig |
|
NotEqualToExpr | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
PatternNode | Used for finding/representing a pattern in the plan This class represents a node in the pattern | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans | Apache Pig |
|
PatternPlan | Used for finding/representing a pattern in the plan This class represents the pattern | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans | Apache Pig |
|
PhyPlanSetter | Sets the parent plan for all Physical Operators. | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
|
PhyPlanVisitor | The visitor class for the Physical Plan. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans | Apache Pig |
|
PhysicalOperator | This is the base class for all operators. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer | Apache Pig |
|
PhysicalOperator .OriginalLocation | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator | Apache Pig |
|
PhysicalPlan | The base class for all types of physical plans. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans | 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 |
|
PigLogger | | Interface | org.apache.pig.backend.hadoop.executionengine.physicalLayer | 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 |
|
PigProgressable | Pig's progress indicator. | Interface | org.apache.pig.backend.hadoop.executionengine.physicalLayer | 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 |
|
PlanHelper | Utility class with a few helper functions to deal with physical plans. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.util | Apache Pig |
|
PlanPrinter | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans | Apache Pig |
|
POAnd | Boolean and operator. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POBinCond | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POCast | This is just a cast that converts DataByteArray into either String or Integer. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POCollectedGroup | The collected group operator is a special operator used when users give the hint 'using "collected"' in a group by clause. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POCombinerPackage | The package operator that packages the globally rearranged tuples into output format after the combiner stage. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POCounter | This operator is part of the RANK operator implementation. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POCross | Recover this class for nested cross operation. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
PODemux | The MapReduce Demultiplexer operator. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
PODistinct | Find the distinct set of tuples in a bag. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POFilter | This is an implementation of the Filter operator. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POForEach | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POFRJoin | The operator models the join keys using the Local Rearrange operators which are configured with the plan specified by the user. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POGlobalRearrange | Dummy operator to test MRCompiler. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POIsNull | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POJoinPackage | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POLimit | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POLoad | The load operator which is used in two ways: 1) As a local operator it can be used to load files | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POLocalRearrange | The local rearrange operator is a part of the co-group implementation. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POMapLookUp | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POMergeCogroup | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POMergeJoin | This operator implements merge join algorithm to do map side joins. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POMergeJoin .TuplesToSchemaTupleList | This is a class that extends ArrayList, making it easy to provide on the fly conversion from Tuple to SchemaTuple. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin | Apache Pig |
|
POMultiQueryPackage | The package operator that packages the globally rearranged tuples into output format as required by multi-query de-multiplexer. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
PONative | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
PONegative | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
PONot | Boolean not operator. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POOptimizedForEach | A specialized version of POForeach with the difference that in getNext(), it knows that "input" has already been | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POOr | Boolean or operator. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POPackage | The package operator that packages the globally rearranged tuples into | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POPackage .PackageType | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage | 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 |
|
POPackageLite | This package operator is a specialization of POPackage operator used for the specific | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POPartialAgg | Do partial aggregation in map plan. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POPartitionRearrange | The partition rearrange operator is a part of the skewed join implementation. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POPreCombinerLocalRearrange | A specialized local rearrange operator which behaves like the regular local rearrange in the getNext() | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POPrinter | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer | Apache Pig |
|
POProject | Projects the specified column from the input tuple. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
PORank | This operator is part of the RANK operator implementation. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
PORegexp | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
PORelationToExprProject | used *ONLY* in the following case: This project is Project(*) introduced after a relational operator | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POSkewedJoin | The PhysicalOperator that represents a skewed join. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POSort | This implementation is applicable for both the physical plan and for the local backend, as the conversion of physical to mapreduce would see the SORT | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POSortedDistinct | This operator is a variation of PODistinct, the input to this operator must be sorted already. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POSplit | The MapReduce Split operator. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POStatus | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer | Apache Pig |
|
POStore | The store operator which is used in two ways: 1) As a local operator it can be used to store files | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POStoreImpl | This class is used to specify the actual behavior of the store operator just when ready to start execution. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POStream | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POUnion | The union operator that combines the two inputs into a single stream. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | Apache Pig |
|
POUserComparisonFunc | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
POUserFunc | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
ProgressableReporter | | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | Apache Pig |
|
RegexInit | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex | Apache Pig |
|
Result | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer | 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 |
|
Subtract | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | 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 |
|
UnaryComparisonOperator | This is a base class for all unary comparison operators. | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
UnaryExpressionOperator | | Class | org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators | Apache Pig |
|
WeightedRangePartitioner | | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig |