| 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 |
|
| BackendException | | Class | org.apache.pig.backend | 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 |
|
| ContainerDescriptor | | Interface | org.apache.pig.backend.datastorage | Apache Pig |
|
| CountingMap | | Class | org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners | Apache Pig |
|
| DataStorage | DataStorage provides an abstraction of a generic container. | Interface | org.apache.pig.backend.datastorage | Apache Pig |
|
| DataStorageException | | Class | org.apache.pig.backend.datastorage | 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 |
|
| ElementDescriptor | DataStorageElementDescriptor provides methods necessary to manage an element in a DataStorage. | Interface | org.apache.pig.backend.datastorage | 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 |
|
| ExecException | | Class | org.apache.pig.backend.executionengine | Apache Pig |
|
| ExecJob | Abstraction on a job that the execution engine runs. | Interface | org.apache.pig.backend.executionengine | Apache Pig |
|
| ExecJob .JOB_STATUS | | Class | org.apache.pig.backend.executionengine.ExecJob | 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 |
|
| ImmutableOutputStream | | Class | org.apache.pig.backend.datastorage | 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 |
|
| SeekableInputStream | Unix-like API for an input stream that supports random access. | Class | org.apache.pig.backend.datastorage | Apache Pig |
|
| SeekableInputStream .FLAGS | | Class | org.apache.pig.backend.datastorage.SeekableInputStream | 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 |