A B C D E F G H I J K L M N O P Q R S T U V W X Z

A

abortTask(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
ABS - Class in org.apache.pig.piggybank.evaluation.math
math.ABS implements a binding to the Java function Math.abs(double) for computing the absolute value of the argument.
ABS() - Constructor for class org.apache.pig.piggybank.evaluation.math.ABS
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.AddExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.AndExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.BagDereferenceExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.BinCondExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.CastExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.ConstantExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.DivideExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.EqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.GreaterThanEqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.GreaterThanExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.IsNullExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.LessThanEqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.LessThanExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.MapLookupExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.ModExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.MultiplyExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.NegativeExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.NotEqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.NotExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.OrExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.ProjectExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.RegexExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.SubtractExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.expression.UserFuncExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOCogroup
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOFilter
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOForEach
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOGenerate
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOInnerLoad
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOJoin
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOLoad
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOSplit
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOSplitOutput
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOStore
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.logical.relational.LOUnion
 
accept(PlanVisitor) - Method in class org.apache.pig.experimental.plan.Operator
Accept a visitor at this node in the graph.
accumChild(List<ExpressionOperator>, Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumChild(List<ExpressionOperator>, DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Drive all the UDFs in accumulative mode
accumulate(Tuple) - Method in interface org.apache.pig.Accumulator
Pass tuples to the UDF.
accumulate(Tuple) - Method in class org.apache.pig.builtin.AVG
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.COUNT
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.COUNT_STAR
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.DoubleAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.DoubleMax
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.DoubleMin
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.DoubleSum
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.FloatAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.FloatMax
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.FloatMin
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.FloatSum
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.IntAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.IntMax
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.IntMin
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.IntSum
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.LongAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.LongMax
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.LongMin
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.LongSum
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.MAX
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.MIN
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.StringMax
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.StringMin
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.SUM
 
accumulateStats() - Method in class org.apache.pig.tools.pigstats.PigStats
 
AccumulativeBag - Class in org.apache.pig.data
 
AccumulativeBag(AccumulativeTupleBuffer, int) - Constructor for class org.apache.pig.data.AccumulativeBag
 
AccumulativeTupleBuffer - Interface in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
This interface is used during Reduce phrase to process tuples in batch mode.
Accumulator<T> - Interface in org.apache.pig
 
AccumulatorOptimizer - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
A visitor to optimize plans that determines if a reduce plan can run in accumulative mode.
AccumulatorOptimizer(MROperPlan) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.AccumulatorOptimizer
 
ACOS - Class in org.apache.pig.piggybank.evaluation.math
math.ACOS implements a binding to the Java function Math.acos(double) for computing the arc cosine of value of the argument.
ACOS() - Constructor for class org.apache.pig.piggybank.evaluation.math.ACOS
 
actionPerformed(ActionEvent) - Method in class org.apache.pig.tools.streams.StreamGenerator
 
activeScopes() - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
List scopes that are active in the back-end
activeScopes() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
add(BlockDistribution) - Method in class org.apache.hadoop.zebra.io.BlockDistribution
Add another block distribution to this one.
add(Schema.ColumnSchema) - Method in class org.apache.hadoop.zebra.schema.Schema
add a column
Add - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
 
Add(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
Add(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
add(Tuple) - Method in class org.apache.pig.data.AccumulativeBag
 
add(Tuple) - Method in interface org.apache.pig.data.DataBag
Add a tuple to the bag.
add(Tuple) - Method in class org.apache.pig.data.DefaultAbstractBag
Add a tuple to the bag.
add(Tuple) - Method in class org.apache.pig.data.DistinctDataBag
 
add(Tuple) - Method in class org.apache.pig.data.InternalCachedBag
 
add(Tuple) - Method in class org.apache.pig.data.InternalDistinctBag
 
add(Tuple) - Method in class org.apache.pig.data.InternalSortedBag
 
add(Tuple) - Method in class org.apache.pig.data.NonSpillableDataBag
 
add(Tuple) - Method in class org.apache.pig.data.ReadOnceBag
 
add(Tuple) - Method in class org.apache.pig.data.SingleTupleBag
 
add(Operator) - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
Add a new operator to the plan.
add(Operator) - Method in interface org.apache.pig.experimental.plan.OperatorPlan
Add a new operator to the plan.
add(Operator) - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
add(Schema.FieldSchema) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
add(E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Insert an operator into the plan.
add(E) - Method in class org.apache.pig.impl.util.IdentityHashSet
 
add(LoadPushDown.RequiredField) - Method in class org.apache.pig.LoadPushDown.RequiredFieldList
 
addAlias(String, Schema.FieldSchema) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
addAll(DataBag) - Method in class org.apache.pig.data.AccumulativeBag
 
addAll(DataBag) - Method in interface org.apache.pig.data.DataBag
Add contents of a bag to the bag.
addAll(DataBag) - Method in class org.apache.pig.data.DefaultAbstractBag
Add contents of a bag to the bag.
addAll(Collection<Tuple>) - Method in class org.apache.pig.data.DefaultAbstractBag
Add contents of a container to the bag.
addAll(DataBag) - Method in class org.apache.pig.data.DistinctDataBag
 
addAll(DataBag) - Method in class org.apache.pig.data.InternalCachedBag
 
addAll(Collection<Tuple>) - Method in class org.apache.pig.data.InternalCachedBag
 
addAll(DataBag) - Method in class org.apache.pig.data.InternalDistinctBag
 
addAll(Collection<Tuple>) - Method in class org.apache.pig.data.InternalDistinctBag
 
addAll(DataBag) - Method in class org.apache.pig.data.InternalSortedBag
 
addAll(Collection<Tuple>) - Method in class org.apache.pig.data.InternalSortedBag
 
addAll(DataBag) - Method in class org.apache.pig.data.NonSpillableDataBag
 
addAll(DataBag) - Method in class org.apache.pig.data.ReadOnceBag
 
addAll(DataBag) - Method in class org.apache.pig.data.SingleTupleBag
 
addAll(Collection<? extends E>) - Method in class org.apache.pig.impl.util.IdentityHashSet
 
addAsLeaf(E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Utility method heavily used in the MRCompiler Adds the leaf operator to the plan and connects all existing leaves to the new leaf
addEmptyBagOuterJoin(PhysicalPlan, Schema) - Static method in class org.apache.pig.impl.util.CompilerUtils
 
AddExpression - Class in org.apache.pig.experimental.logical.expression
Add Operator
AddExpression(OperatorPlan, byte, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.AddExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
addField(LogicalSchema.LogicalFieldSchema) - Method in class org.apache.pig.experimental.logical.relational.LogicalSchema
Add a field to this schema.
AddForEach - Class in org.apache.pig.experimental.logical.rules
 
AddForEach(String) - Constructor for class org.apache.pig.experimental.logical.rules.AddForEach
 
AddForEach.AddForEachTransformer - Class in org.apache.pig.experimental.logical.rules
 
AddForEach.AddForEachTransformer() - Constructor for class org.apache.pig.experimental.logical.rules.AddForEach.AddForEachTransformer
 
addHandleSpec(StreamingCommand.Handle, StreamingCommand.HandleSpec) - Method in class org.apache.pig.impl.streaming.StreamingCommand
Attach a StreamingCommand.HandleSpec to a given StreamingCommand.Handle
addInputPlan(PhysicalPlan, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
addIsKeyWrappedList(List<Boolean>) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
Adds a list of IsKeyWrapped boolean values
addJar(String) - Method in class org.apache.pig.impl.PigContext
 
addJar(URL) - Method in class org.apache.pig.impl.PigContext
 
addJobConf(Configuration) - Method in class org.apache.pig.impl.util.UDFContext
Adds the JobConf to this singleton.
addOutput(LogicalOperator) - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
addPackage(POPackage) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
Appends the specified package object to the end of the package list.
addPackage(POPackage, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
Appends the specified package object to the end of the package list.
addPathToCache(String) - Method in class org.apache.pig.impl.streaming.StreamingCommand
Add a file to be cached on execute nodes on the cluster.
addPathToShip(String) - Method in class org.apache.pig.impl.streaming.StreamingCommand
Add a file to be shipped to the cluster.
addPathToSkip(String) - Method in class org.apache.pig.impl.PigContext
Add a path to be skipped while automatically shipping binaries for streaming.
addPathToSkip(String) - Method in class org.apache.pig.PigServer
Add a path to be skipped while automatically shipping binaries for streaming.
addPlan(PhysicalPlan) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODemux
Appends the specified plan at the end of the list.
addPlan(PhysicalPlan) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSplit
Appends the specified plan to the end of the nested input plan list
addPlanTransformListener(PlanTransformListener) - Method in class org.apache.pig.experimental.plan.optimizer.PlanOptimizer
Adds a listener to the optimization.
addPruneMap(LogicalOperator, List<Pair<Integer, Integer>>) - Method in class org.apache.pig.impl.logicalLayer.ColumnPruner
 
addSchema(Schema) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSkewedJoin
 
advance() - Method in interface org.apache.hadoop.zebra.io.TableScanner
Advance cursor to the next Row.
advance() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
Move the cursor to the next key-value pair.
Algebraic - Interface in org.apache.pig
An interface to declare that an EvalFunc's calculation can be decomposed into intitial, intermediate, and final steps.
alias - Variable in class org.apache.pig.backend.hadoop.executionengine.HJob
 
alias - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
alias - Variable in class org.apache.pig.experimental.logical.relational.LogicalRelationalOperator
 
alias - Variable in class org.apache.pig.experimental.logical.relational.LogicalSchema.LogicalFieldSchema
 
alias - Variable in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Alias for this field.
AllExpressionVisitor - Class in org.apache.pig.experimental.logical.optimizer
A visitor that walks a logical plan and then applies a given LogicalExpressionVisitor to all expressions it encounters.
AllExpressionVisitor(OperatorPlan, PlanWalker) - Constructor for class org.apache.pig.experimental.logical.optimizer.AllExpressionVisitor
 
allInputFromPredecessorConsumed - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
allOutputFromBinaryProcessed - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
AllSameVisitor - Class in org.apache.pig.experimental.logical.optimizer
A visitor that walks the logical plan and calls the same method on every type of node.
AllSameVisitor(OperatorPlan, PlanWalker) - Constructor for class org.apache.pig.experimental.logical.optimizer.AllSameVisitor
 
alreadyClosed - Variable in class org.apache.pig.impl.streaming.InputHandler
 
alreadyClosed - Variable in class org.apache.pig.impl.streaming.OutputHandler
 
AmendableTuple - Class in org.apache.pig.data
 
AmendableTuple(int, Object) - Constructor for class org.apache.pig.data.AmendableTuple
 
AndExpression - Class in org.apache.pig.experimental.logical.expression
Boolean and expression.
AndExpression(OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.AndExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
annotate(String, Object) - Method in class org.apache.pig.experimental.plan.Operator
Add an annotation to a node in the plan.
annotations - Variable in class org.apache.pig.experimental.plan.Operator
 
append(EncodingOutputStream, Tuple) - Method in class org.apache.hadoop.zebra.pig.comparator.LeafExpr
 
append(byte[], byte[]) - Method in class org.apache.hadoop.zebra.tfile.TFile.Writer
Adding a new key-value pair to the TFile.
append(byte[], int, int, byte[], int, int) - Method in class org.apache.hadoop.zebra.tfile.TFile.Writer
Adding a new key-value pair to TFile.
append(Object) - Method in class org.apache.pig.data.DefaultTuple
Append a field to a tuple.
append(Object) - Method in class org.apache.pig.data.TargetedTuple
 
append(Object) - Method in interface org.apache.pig.data.Tuple
Append a field to a tuple.
append(Object) - Method in class org.apache.pig.pen.util.ExampleTuple
 
appendLeafGenerator(List<LeafGenerator>, int, int, boolean, boolean) - Method in class org.apache.hadoop.zebra.pig.comparator.ComparatorExpr
 
appendLeafGenerator(List<LeafGenerator>, int, int, boolean, boolean) - Method in class org.apache.hadoop.zebra.pig.comparator.LeafExpr
 
appendLeafGenerator(List<LeafGenerator>, int, int, boolean, boolean) - Method in class org.apache.hadoop.zebra.pig.comparator.NegateExpr
 
appendLeafGenerator(List<LeafGenerator>, int, int, boolean, boolean) - Method in class org.apache.hadoop.zebra.pig.comparator.TupleExpr
 
appendObject(EncodingOutputStream, Object) - Method in class org.apache.hadoop.zebra.pig.comparator.BagExpr
 
appendObject(EncodingOutputStream, Object) - Method in class org.apache.hadoop.zebra.pig.comparator.BytesExpr
 
appendObject(EncodingOutputStream, Object) - Method in class org.apache.hadoop.zebra.pig.comparator.FixedLengthPrimitive
 
appendObject(EncodingOutputStream, Object) - Method in class org.apache.hadoop.zebra.pig.comparator.LeafExpr
 
appendObject(EncodingOutputStream, Object) - Method in class org.apache.hadoop.zebra.pig.comparator.StringExpr
 
ARITY - Class in org.apache.pig.builtin
 
ARITY() - Constructor for class org.apache.pig.builtin.ARITY
 
asCollection(String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asCollection(String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asContainer(String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
Created an entity handle for a container.
asContainer(ContainerDescriptor) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asContainer(String, String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asContainer(ContainerDescriptor, String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asContainer(ContainerDescriptor, ContainerDescriptor) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asContainer(String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asContainer(ContainerDescriptor) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asContainer(String, String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asContainer(ContainerDescriptor, String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asContainer(ContainerDescriptor, ContainerDescriptor) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asElement(String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
Creates an entity handle for an object (no containment relation) from a String
asElement(ElementDescriptor) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asElement(String, String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asElement(ContainerDescriptor, String) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asElement(ContainerDescriptor, ElementDescriptor) - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
asElement(String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asElement(ElementDescriptor) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asElement(String, String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asElement(ContainerDescriptor, String) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
asElement(ContainerDescriptor, ElementDescriptor) - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
ASIN - Class in org.apache.pig.piggybank.evaluation.math
math.ASIN implements a binding to the Java function Math.asin(double) for computing the arc sine of value of the argument.
ASIN() - Constructor for class org.apache.pig.piggybank.evaluation.math.ASIN
 
ATAN - Class in org.apache.pig.piggybank.evaluation.math
math.ATAN implements a binding to the Java function Math.atan(double) for computing the arc tangent of value of the argument.
ATAN() - Constructor for class org.apache.pig.piggybank.evaluation.math.ATAN
 
ATAN2 - Class in org.apache.pig.piggybank.evaluation.math
math.ATAN2 implements a binding to the Java function Math.atan2(double,double).
ATAN2() - Constructor for class org.apache.pig.piggybank.evaluation.math.ATAN2
 
atEnd() - Method in interface org.apache.hadoop.zebra.io.TableScanner
Test whether the cursor is at the end of the scan range.
atEnd() - Method in class org.apache.hadoop.zebra.mapred.TableRecordReader
Deprecated. Check if the end of the input has been reached
atEnd() - Method in class org.apache.hadoop.zebra.mapreduce.TableRecordReader
Check if the end of the input has been reached
atEnd() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
Is cursor at the end location?
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
Overridden since the attachment of the new input should cause the old processing to end.
attachInput(Tuple, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
Shorts the input path of this operator by providing the input tuple directly
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
 
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup
Overridden since the attachment of the new input should cause the old processing to end.
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
Overridden since the attachment of the new input should cause the old processing to end.
attachInput(PigNullableWritable, Iterator<NullableTuple>) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
 
attachInput(PigNullableWritable, Iterator<NullableTuple>) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
Attaches the required inputs
attachInput(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange
Overridden since the attachment of the new input should cause the old processing to end.
attachInputToPlans(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
AugmentBaseDataVisitor - Class in org.apache.pig.pen
 
AugmentBaseDataVisitor(LogicalPlan, Map<LOLoad, DataBag>, Map<LogicalOperator, DataBag>) - Constructor for class org.apache.pig.pen.AugmentBaseDataVisitor
 
available() - Method in class org.apache.pig.backend.hadoop.datastorage.HSeekableInputStream
 
available() - Method in class org.apache.pig.impl.io.FileLocalizer.DataStorageInputStreamIterator
 
AVG - Class in org.apache.pig.builtin
Generates the average of the values of the first field of a tuple.
AVG() - Constructor for class org.apache.pig.builtin.AVG
 
AVG.Final - Class in org.apache.pig.builtin
 
AVG.Final() - Constructor for class org.apache.pig.builtin.AVG.Final
 
AVG.Initial - Class in org.apache.pig.builtin
 
AVG.Initial() - Constructor for class org.apache.pig.builtin.AVG.Initial
 
AVG.Intermediate - Class in org.apache.pig.builtin
 
AVG.Intermediate() - Constructor for class org.apache.pig.builtin.AVG.Intermediate
 
avgRecordSize - Variable in class org.apache.pig.ResourceStatistics
 

B

BackendException - Exception in org.apache.pig.backend
 
BackendException() - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with null as the error message.
BackendException(String) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(Throwable) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified cause.
BackendException(String, Throwable) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int, Throwable) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int, byte) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int, byte, Throwable) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int, boolean) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int, byte, boolean) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message and cause.
BackendException(String, int, byte, boolean, String) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
BackendException(String, int, byte, boolean, String, Throwable) - Constructor for exception org.apache.pig.backend.BackendException
Create a new BackendException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
backendException - Variable in class org.apache.pig.backend.hadoop.executionengine.HJob
 
BAG - Static variable in class org.apache.pig.data.DataType
 
bagComparator(int, ComparatorExpr) - Static method in class org.apache.hadoop.zebra.pig.comparator.ExprUtils
Make a bag comparator expression.
BagDereferenceExpression - Class in org.apache.pig.experimental.logical.expression
This is a special case Expression and violates some of the rules of an Expression.
BagDereferenceExpression(OperatorPlan, byte, int, ProjectExpression) - Constructor for class org.apache.pig.experimental.logical.expression.BagDereferenceExpression
 
BagDereferenceExpression(OperatorPlan, byte, List<Integer>, ProjectExpression) - Constructor for class org.apache.pig.experimental.logical.expression.BagDereferenceExpression
 
BagExpr - Class in org.apache.hadoop.zebra.pig.comparator
 
BagExpr(int, ComparatorExpr) - Constructor for class org.apache.hadoop.zebra.pig.comparator.BagExpr
 
bagFactory - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
BagFactory - Class in org.apache.pig.data
Factory for constructing different types of bags.
BagFactory() - Constructor for class org.apache.pig.data.BagFactory
 
BagFormat - Class in org.apache.pig.impl.util
 
BagFormat() - Constructor for class org.apache.pig.impl.util.BagFormat
 
bags - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
BagSize - Class in org.apache.pig.builtin
Generates the size of the first field of a tuple.
BagSize() - Constructor for class org.apache.pig.builtin.BagSize
 
Base - Class in org.apache.pig.piggybank.evaluation.math
base class for math udfs
Base() - Constructor for class org.apache.pig.piggybank.evaluation.math.Base
 
BaseOperatorPlan - Class in org.apache.pig.experimental.plan
 
BaseOperatorPlan() - Constructor for class org.apache.pig.experimental.plan.BaseOperatorPlan
 
BasicTable - Class in org.apache.hadoop.zebra.io
A materialized table that consists of one or more tightly coupled Column Groups.
BasicTable.Reader - Class in org.apache.hadoop.zebra.io
BasicTable reader.
BasicTable.Reader(Path, Configuration) - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Reader
Create a BasicTable reader.
BasicTable.Reader(Path, String[], Configuration) - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Reader
 
BasicTable.Reader.RangeSplit - Class in org.apache.hadoop.zebra.io
A range-based split on the metaReadertable.The content of the split is implementation-dependent.
BasicTable.Reader.RangeSplit() - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Reader.RangeSplit
Default constructor.
BasicTable.Reader.RowSplit - Class in org.apache.hadoop.zebra.io
A row-based split on the zebra table;
BasicTable.Reader.RowSplit() - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Reader.RowSplit
Default constructor.
BasicTable.Writer - Class in org.apache.hadoop.zebra.io
BasicTable writer.
BasicTable.Writer(Path, String, String, String, String, Configuration) - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Writer
Create a BasicTable writer.
BasicTable.Writer(Path, String, String, Configuration) - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Writer
a wrapper to support backward compatible constructor
BasicTable.Writer(Path, Configuration) - Constructor for class org.apache.hadoop.zebra.io.BasicTable.Writer
/** Reopen an already created BasicTable for writing.
BasicTableOutputFormat - Class in org.apache.hadoop.zebra.mapred
Deprecated. 
BasicTableOutputFormat() - Constructor for class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated.  
BasicTableOutputFormat - Class in org.apache.hadoop.zebra.mapreduce
OutputFormat class for creating a BasicTable.
BasicTableOutputFormat() - Constructor for class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
 
BasicTableStatus - Class in org.apache.hadoop.zebra.io
Status of a BasicTable.
BasicTableStatus() - Constructor for class org.apache.hadoop.zebra.io.BasicTableStatus
 
BIGCHARARRAY - Static variable in class org.apache.pig.data.DataType
 
Bin - Class in org.apache.pig.piggybank.evaluation.decode
Syntax: String Bin(arithmetic_expression, string1, ,..., stringN, sentinelN, default_string). Logic: if (arithmetic_expression<=sentinel1) return string1;
......
Bin() - Constructor for class org.apache.pig.piggybank.evaluation.decode.Bin
 
BinaryComparisonOperator - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
This is a base class for all binary comparison operators.
BinaryComparisonOperator(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
 
BinaryComparisonOperator(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
 
BinaryExpression - Class in org.apache.pig.experimental.logical.expression
Superclass for all binary expressions
BinaryExpression(String, OperatorPlan, byte, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.BinaryExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
BinaryExpressionOperator - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
A base class for all Binary expression operators.
BinaryExpressionOperator(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator
 
BinaryExpressionOperator(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator
 
BinaryExpressionOperator - Class in org.apache.pig.impl.logicalLayer
This abstract class represents the logical Binary Expression Operator The binary operator has two operands and an operator.
BinaryExpressionOperator(LogicalPlan, OperatorKey, int) - Constructor for class org.apache.pig.impl.logicalLayer.BinaryExpressionOperator
 
BinaryExpressionOperator(LogicalPlan, OperatorKey) - Constructor for class org.apache.pig.impl.logicalLayer.BinaryExpressionOperator
 
binaryInputQueue - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
binaryOutputQueue - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
BinCond - Class in org.apache.pig.piggybank.evaluation.decode
Syntax: String BinCond(boolean_expression1, mapping_string1, ..., boolean_expressionN, mapping_stringN, other_string). Logic: if (boolean_expression1) return mapping_string1;
......
BinCond() - Constructor for class org.apache.pig.piggybank.evaluation.decode.BinCond
 
BinCondExpression - Class in org.apache.pig.experimental.logical.expression
 
BinCondExpression(OperatorPlan, byte, LogicalExpression, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.BinCondExpression
Will add this operator to the plan and connect it to the left and right hand side operators and the condition operator
bindTo(OutputStream) - Method in class org.apache.pig.impl.streaming.FileInputHandler
 
bindTo(String, BufferedPositionedInputStream, long, long) - Method in class org.apache.pig.impl.streaming.FileOutputHandler
 
bindTo(OutputStream) - Method in class org.apache.pig.impl.streaming.InputHandler
Bind the InputHandler to the OutputStream from which it reads input and sends it to the managed process.
bindTo(String, BufferedPositionedInputStream, long, long) - Method in class org.apache.pig.impl.streaming.OutputHandler
Bind the OutputHandler to the InputStream from which to read the output data of the managed process.
BinStorage - Class in org.apache.pig.builtin
 
BinStorage() - Constructor for class org.apache.pig.builtin.BinStorage
Simple binary nested reader format
BinStorageInputFormat - Class in org.apache.pig.impl.io
 
BinStorageInputFormat() - Constructor for class org.apache.pig.impl.io.BinStorageInputFormat
 
BinStorageOutputFormat - Class in org.apache.pig.impl.io
 
BinStorageOutputFormat() - Constructor for class org.apache.pig.impl.io.BinStorageOutputFormat
 
BinStorageRecordReader - Class in org.apache.pig.impl.io
Treats keys as offset in file and value as line.
BinStorageRecordReader() - Constructor for class org.apache.pig.impl.io.BinStorageRecordReader
 
BinStorageRecordWriter - Class in org.apache.pig.impl.io
 
BinStorageRecordWriter(DataOutputStream) - Constructor for class org.apache.pig.impl.io.BinStorageRecordWriter
 
BLOCK_REPLICATION_KEY - Static variable in interface org.apache.pig.backend.datastorage.ElementDescriptor
Available from getConfiguration as a String and getStatistics as a Short.
BLOCK_SIZE_KEY - Static variable in interface org.apache.pig.backend.datastorage.ElementDescriptor
Available from getConfiguration as a String and getStatistics as a Long.
BlockDistribution - Class in org.apache.hadoop.zebra.io
Class used to convey the information of how on-disk data that fall in a specific split are distributed across hosts.
BlockDistribution() - Constructor for class org.apache.hadoop.zebra.io.BlockDistribution
 
BOOLEAN - Static variable in class org.apache.pig.data.DataType
 
BooleanExpr - Class in org.apache.hadoop.zebra.pig.comparator
 
BooleanExpr(int) - Constructor for class org.apache.hadoop.zebra.pig.comparator.BooleanExpr
 
BoundedByteArrayOutputStream - Class in org.apache.hadoop.zebra.tfile
A byte array backed output stream with a limit.
BoundedByteArrayOutputStream(int) - Constructor for class org.apache.hadoop.zebra.tfile.BoundedByteArrayOutputStream
Create a BoundedByteArrayOutputStream with the specified capacity
BoundedByteArrayOutputStream(int, int) - Constructor for class org.apache.hadoop.zebra.tfile.BoundedByteArrayOutputStream
Create a BoundedByteArrayOutputStream with the specified capacity and limit.
breadthFirst() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PlanPrinter
 
buffer() - Method in class org.apache.hadoop.zebra.tfile.ByteArray
 
buffer() - Method in interface org.apache.hadoop.zebra.tfile.RawComparable
Get the underlying byte array.
buffer - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
BufferedPositionedInputStream - Class in org.apache.pig.impl.io
 
BufferedPositionedInputStream(InputStream, long) - Constructor for class org.apache.pig.impl.io.BufferedPositionedInputStream
 
BufferedPositionedInputStream(InputStream) - Constructor for class org.apache.pig.impl.io.BufferedPositionedInputStream
 
BUG - Static variable in exception org.apache.pig.PigException
 
buildPattern() - Method in class org.apache.pig.experimental.logical.rules.FilterAboveForeach
 
buildPattern() - Method in class org.apache.pig.experimental.logical.rules.MergeFilter
 
buildPattern() - Method in class org.apache.pig.experimental.logical.rules.PushUpFilter
 
buildPattern() - Method in class org.apache.pig.experimental.logical.rules.SplitFilter
 
buildPattern() - Method in class org.apache.pig.experimental.logical.rules.WholePlanRule
 
buildPattern() - Method in class org.apache.pig.experimental.plan.optimizer.Rule
Build the pattern that this rule will look for
buildRuleSets() - Method in class org.apache.pig.experimental.logical.optimizer.LogicalPlanOptimizer
 
BYTE - Static variable in class org.apache.pig.data.DataType
 
ByteArray - Class in org.apache.hadoop.zebra.tfile
Adaptor class to wrap byte-array backed objects (including java byte array) as RawComparable objects.
ByteArray(BytesWritable) - Constructor for class org.apache.hadoop.zebra.tfile.ByteArray
Constructing a ByteArray from a BytesWritable.
ByteArray(byte[]) - Constructor for class org.apache.hadoop.zebra.tfile.ByteArray
Wrap a whole byte array as a RawComparable.
ByteArray(byte[], int, int) - Constructor for class org.apache.hadoop.zebra.tfile.ByteArray
Wrap a partial byte array as a RawComparable.
BYTEARRAY - Static variable in class org.apache.pig.data.DataType
 
ByteExpr - Class in org.apache.hadoop.zebra.pig.comparator
 
ByteExpr(int) - Constructor for class org.apache.hadoop.zebra.pig.comparator.ByteExpr
 
bytes - Variable in class org.apache.hadoop.zebra.pig.comparator.FixedLengthPrimitive
 
BytesExpr - Class in org.apache.hadoop.zebra.pig.comparator
 
BytesExpr(int) - Constructor for class org.apache.hadoop.zebra.pig.comparator.BytesExpr
 
bytesToBag(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToBag(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Bag
bytesToBag(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToBag(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToBag(byte[], ResourceSchema.ResourceFieldSchema) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to bag value.
bytesToBigCharArray(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToBoolean(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToCharArray(byte[]) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToCharArray(byte[]) - Method in class org.apache.pig.builtin.TextLoader
Cast data from bytes to chararray value.
bytesToCharArray(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToCharArray(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToCharArray(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to chararray value.
bytesToDouble(byte[]) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToDouble(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Double
bytesToDouble(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToDouble(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to double value.
bytesToFloat(byte[]) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToFloat(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Float
bytesToFloat(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToFloat(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to float value.
bytesToInteger(byte[]) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToInteger(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Integer
bytesToInteger(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToInteger(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to integer value.
bytesToInternalMap(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToLong(byte[]) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToLong(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Long
bytesToLong(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToLong(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to long value.
bytesToMap(byte[]) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToMap(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Map
bytesToMap(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToMap(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToMap(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to map value.
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.BinStorage
 
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Tuple
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToTuple(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in interface org.apache.pig.LoadCaster
Cast data from bytes to tuple value.
bytesToWritable(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 

C

c - Variable in class org.apache.hadoop.zebra.pig.comparator.BagExpr
 
calcCastString() - Method in class org.apache.pig.ResourceSchema.ResourceFieldSchema
 
calculateProgress(JobControl, JobClient) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
Compute the progress of the current job submitted through the JobControl object jc to the JobClient jobClient
canonicalName - Variable in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Canonical name.
CanonicalNamer - Class in org.apache.pig.impl.logicalLayer
A visitor to walk the logical plan and give canonical names fields.
CanonicalNamer() - Constructor for class org.apache.pig.impl.logicalLayer.CanonicalNamer
 
canonicalNamer - Static variable in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Canonical namer object to generate new canonical names on request.
capacity() - Method in class org.apache.pig.PigServer
Returns the unused byte capacity of an HDFS filesystem.
cast() - Method in class org.apache.pig.impl.plan.ProjectionMap.Column
Check if the column is cast
castable(Schema, Schema) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema
Recursively compare two schemas to check if the input schema can be cast to the cast schema
castable(Schema.FieldSchema, Schema.FieldSchema) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Recursively compare two schemas to check if the input schema can be cast to the cast schema
CastExpression - Class in org.apache.pig.experimental.logical.expression
 
CastExpression(OperatorPlan, byte, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.CastExpression
 
CastFinder - Class in org.apache.pig.impl.logicalLayer
A visitor to track the casts in a plan.
CastFinder(LogicalPlan) - Constructor for class org.apache.pig.impl.logicalLayer.CastFinder
 
castLookup - Static variable in class org.apache.pig.impl.logicalLayer.validators.TypeCheckingVisitor
 
CastUtils - Class in org.apache.pig.impl.util
 
CastUtils() - Constructor for class org.apache.pig.impl.util.CastUtils
 
CBRT - Class in org.apache.pig.piggybank.evaluation.math
math.CBRT implements a binding to the Java function Math.cbrt(double) for computing the cube root of the argument.
CBRT() - Constructor for class org.apache.pig.piggybank.evaluation.math.CBRT
 
CEIL - Class in org.apache.pig.piggybank.evaluation.math
math.CEIL implements a binding to the Java function Math.ceil(double).
CEIL() - Constructor for class org.apache.pig.piggybank.evaluation.math.CEIL
 
cel - Variable in class org.apache.hadoop.zebra.pig.comparator.BagExpr
 
CGSchema - Class in org.apache.hadoop.zebra.types
ColumnGroup Schema.
CGSchema() - Constructor for class org.apache.hadoop.zebra.types.CGSchema
 
CGSchema(Schema, boolean, String) - Constructor for class org.apache.hadoop.zebra.types.CGSchema
 
CGSchema(Schema, boolean, String, String, String, String, String, String, short) - Constructor for class org.apache.hadoop.zebra.types.CGSchema
 
chainOfProjects(LogicalPlan) - Static method in class org.apache.pig.impl.logicalLayer.LogicalPlan
A utility method to check if a plan contains a chain of projection operators with or without casts
changes() - Method in class org.apache.pig.impl.plan.ProjectionMap
 
CHARARRAY - Static variable in class org.apache.pig.data.DataType
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.logical.rules.AddForEach.AddForEachTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.logical.rules.ColumnMapKeyPrune.ColumnMapKeyPruneTransformer
 
check() - Method in class org.apache.pig.experimental.logical.rules.ColumnPruneHelper
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.logical.rules.FilterAboveForeach.FilterAboveForEachTransformer
 
check() - Method in class org.apache.pig.experimental.logical.rules.MapKeysPruneHelper
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.logical.rules.MergeFilter.MergeFilterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.logical.rules.PushUpFilter.PushUpFilterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.logical.rules.SplitFilter.SplitFilterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.experimental.plan.optimizer.Transformer
check if the transform should be done.
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.ImplicitSplitInserter
 
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.OpLimitOptimizer
 
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.PartitionFilterOptimizer
 
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.PruneColumns
 
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.PushDownForeachFlatten
 
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.PushUpFilter
 
check(List<LogicalOperator>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.TypeCastInserter
 
check(List<O>) - Method in class org.apache.pig.impl.plan.optimizer.Transformer
check if the transform should be done.
checkCompatible(Tuple, Schema) - Static method in class org.apache.hadoop.zebra.types.TypesUtils
Check whether the input row object is compatible with the expected schema
checkEquality(LogicalRelationalOperator) - Method in class org.apache.pig.experimental.logical.relational.LogicalRelationalOperator
Do some basic equality checks on two relational operators.
checkLeafIsStore(PhysicalPlan, PigContext) - Static method in class org.apache.pig.backend.executionengine.util.ExecTools
 
checkNullAndClass(Object, Object) - Static method in class org.apache.pig.impl.util.Utils
This method is a helper for classes to implement Object.equals(java.lang.Object) The method checks whether the two arguments are both null or both not null and whether they are of the same class
checkNullEquals(Object, Object, boolean) - Static method in class org.apache.pig.impl.util.Utils
This method is a helper for classes to implement Object.equals(java.lang.Object) checks if two objects are equals - two levels of checks are made - first if both are null or not null.
checkOutputSpecs(FileSystem, JobConf) - Method in class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated. Note: we perform the Initialization of the table here.
checkOutputSpecs(JobContext) - Method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
Note: we perform the Initialization of the table here.
checkOutputSpecs(JobContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat
 
checkSchema(ResourceSchema) - Method in class org.apache.hadoop.zebra.pig.TableStorer
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.BinStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.PigStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.StoreFunc
Set the schema for data to be stored.
checkSchema(ResourceSchema) - Method in interface org.apache.pig.StoreFuncInterface
Set the schema for data to be stored.
childExpr() - Method in class org.apache.hadoop.zebra.pig.comparator.NegateExpr
 
childrenExpr() - Method in class org.apache.hadoop.zebra.pig.comparator.TupleExpr
Get the children expressions.
classloader - Static variable in class org.apache.pig.impl.logicalLayer.LogicalPlanBuilder
 
cleanup() - Method in interface org.apache.pig.Accumulator
Called after getValue() to prepare processing for next key.
cleanUp() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReducePOStoreImpl
 
cleanup(Reducer<PigNullableWritable, NullableTuple, PigNullableWritable, Writable>.Context) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigCombiner.Combine
Will be called once all the intermediate keys and values are processed.
cleanup(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
Will be called when all the tuples in the input are done.
cleanup(Reducer<PigNullableWritable, NullableTuple, PigNullableWritable, Writable>.Context) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce.Reduce
Will be called once all the intermediate keys and values are processed.
cleanUp() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
To perform cleanup when there is an error.
cleanUp() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStoreImpl
To perform cleanup when there is an error.
cleanup() - Method in class org.apache.pig.builtin.AVG
 
cleanup() - Method in class org.apache.pig.builtin.COUNT
 
cleanup() - Method in class org.apache.pig.builtin.COUNT_STAR
 
cleanup() - Method in class org.apache.pig.builtin.DoubleAvg
 
cleanup() - Method in class org.apache.pig.builtin.DoubleMax
 
cleanup() - Method in class org.apache.pig.builtin.DoubleMin
 
cleanup() - Method in class org.apache.pig.builtin.DoubleSum
 
cleanup() - Method in class org.apache.pig.builtin.FloatAvg
 
cleanup() - Method in class org.apache.pig.builtin.FloatMax
 
cleanup() - Method in class org.apache.pig.builtin.FloatMin
 
cleanup() - Method in class org.apache.pig.builtin.FloatSum
 
cleanup() - Method in class org.apache.pig.builtin.IntAvg
 
cleanup() - Method in class org.apache.pig.builtin.IntMax
 
cleanup() - Method in class org.apache.pig.builtin.IntMin
 
cleanup() - Method in class org.apache.pig.builtin.IntSum
 
cleanup() - Method in class org.apache.pig.builtin.LongAvg
 
cleanup() - Method in class org.apache.pig.builtin.LongMax
 
cleanup() - Method in class org.apache.pig.builtin.LongMin
 
cleanup() - Method in class org.apache.pig.builtin.LongSum
 
cleanup() - Method in class org.apache.pig.builtin.MAX
 
cleanup() - Method in class org.apache.pig.builtin.MIN
 
cleanup() - Method in class org.apache.pig.builtin.StringMax
 
cleanup() - Method in class org.apache.pig.builtin.StringMin
 
cleanup() - Method in class org.apache.pig.builtin.SUM
 
cleanupJob(JobContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.BinStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.PigStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.StoreFunc
This method will be called by Pig if the job which contains this store fails.
cleanupOnFailure(String, Job) - Method in interface org.apache.pig.StoreFuncInterface
This method will be called by Pig if the job which contains this store fails.
cleanupOnFailureImpl(String, Job) - Static method in class org.apache.pig.StoreFunc
Implementation for StoreFunc.cleanupOnFailure(String, Job)
clear() - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.AccumulativeTupleBuffer
Clear internal buffer, this should be called after all data are retreived
clear() - Method in class org.apache.pig.data.AccumulativeBag
 
clear() - Method in interface org.apache.pig.data.DataBag
Clear out the contents of the bag, both on disk and in memory.
clear() - Method in class org.apache.pig.data.DefaultAbstractBag
Clear out the contents of the bag, both on disk and in memory.
clear() - Method in class org.apache.pig.data.InternalCachedBag
 
clear() - Method in class org.apache.pig.data.NonSpillableDataBag
 
clear() - Method in class org.apache.pig.data.ReadOnceBag
 
clear() - Method in class org.apache.pig.data.SingleTupleBag
 
clear() - Method in class org.apache.pig.impl.util.IdentityHashSet
 
clear() - Method in class org.apache.pig.impl.util.MultiMap
 
clearDeleteOnFail() - Static method in class org.apache.pig.impl.io.FileLocalizer
 
clearDone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POUnion
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnChainInfo
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.EqualToExpr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.GreaterThanExpr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.GTOrEqualToExpr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LessThanExpr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LTOrEqualToExpr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Mod
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.NotEqualToExpr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POAnd
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POIsNull
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONegative
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONot
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POOr
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORelationToExprProject
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLimit
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrangeForIllustrate
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POOptimizedForEach
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPartitionRearrange
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort
 
clone() - Method in class org.apache.pig.FuncSpec
 
clone() - Method in class org.apache.pig.impl.logicalLayer.BinaryExpressionOperator
 
clone() - Method in class org.apache.pig.impl.logicalLayer.ExpressionOperator
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOBinCond
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOCast
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOConst
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LODistinct
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOGenerate
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LogicalPlan
Do not use the clone method directly.
clone() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOMapLookup
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOUnion
 
clone() - Method in class org.apache.pig.impl.logicalLayer.LOUserFunc
 
clone() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
Make a deep copy of a schema.
clone() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Make a deep copy of this FieldSchema and return it.
clone() - Method in class org.apache.pig.impl.logicalLayer.UnaryExpressionOperator
 
clone() - Method in class org.apache.pig.impl.plan.Operator
 
clone() - Method in class org.apache.pig.impl.plan.optimizer.RuleOperator
 
clone() - Method in class org.apache.pig.impl.streaming.StreamingCommand
 
clone() - Method in class org.apache.pig.impl.streaming.StreamingCommand.HandleSpec
 
clone() - Method in class org.apache.pig.ResourceStatistics
 
cloneHelper(BinaryComparisonOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
 
cloneHelper(BinaryExpressionOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator
 
cloneHelper(UnaryExpressionOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.UnaryExpressionOperator
 
cloneHelper(PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
clonePlan(String) - Method in class org.apache.pig.PigServer
 
close() - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Close the BasicTable for reading.
close() - Method in class org.apache.hadoop.zebra.io.BasicTable.Writer
Close the BasicTable for writing.
close(JobConf) - Static method in class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated. Close the output BasicTable, No more rows can be added into the table.
close() - Method in class org.apache.hadoop.zebra.mapred.TableRecordReader
Deprecated.  
close(JobContext) - Static method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
Close the output BasicTable, No more rows can be added into the table.
close() - Method in class org.apache.hadoop.zebra.mapreduce.TableRecordReader
 
close() - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
close() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Close the reader.
close() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
Close the scanner.
close() - Method in class org.apache.hadoop.zebra.tfile.TFile.Writer
Close the Writer.
close() - Method in interface org.apache.pig.backend.datastorage.DataStorage
Clean-up and releasing of resources.
close() - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
Clean-up and releasing of resources.
close() - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
close() - Method in class org.apache.pig.backend.hadoop.datastorage.HSeekableInputStream
 
close() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
close(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat.PigRecordWriter
 
close() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader
 
close() - Method in class org.apache.pig.backend.hadoop.streaming.HadoopExecutableManager
 
close() - Method in class org.apache.pig.impl.builtin.DefaultIndexableLoader
 
close() - Method in class org.apache.pig.impl.io.BinStorageRecordReader
 
close(TaskAttemptContext) - Method in class org.apache.pig.impl.io.BinStorageRecordWriter
 
close() - Method in class org.apache.pig.impl.io.BufferedPositionedInputStream
 
close() - Method in class org.apache.pig.impl.io.FileLocalizer.DataStorageInputStreamIterator
 
close(Process) - Method in class org.apache.pig.impl.streaming.DefaultInputHandler
 
close() - Method in class org.apache.pig.impl.streaming.ExecutableManager
Close and cleanup the ExecutableManager.
close(Process) - Method in class org.apache.pig.impl.streaming.FileInputHandler
 
close(Process) - Method in class org.apache.pig.impl.streaming.InputHandler
Close the InputHandler since there is no more input to be sent to the managed process.
close() - Method in class org.apache.pig.impl.streaming.OutputHandler
Close the OutputHandler.
close() - Method in interface org.apache.pig.IndexableLoadFunc
A method called by the pig runtime to give an opportunity for implementations to perform cleanup actions like closing the underlying input stream.
close() - Method in class org.apache.pig.piggybank.storage.hiverc.HiveRCRecordReader
 
close() - Method in class org.apache.pig.piggybank.storage.XMLLoader.XMLFileRecordReader
 
CmdLineParser - Class in org.apache.pig.tools.cmdline
 
CmdLineParser(String[]) - Constructor for class org.apache.pig.tools.cmdline.CmdLineParser
 
CmdLineParser.ValueExpected - Enum in org.apache.pig.tools.cmdline
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapOnly.Map
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce.Map
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce.MapWithComparator
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce.MapWithPartitionIndex
 
collect(String, CompilationMessageCollector.MessageType) - Method in class org.apache.pig.impl.plan.CompilationMessageCollector
 
collect(String, CompilationMessageCollector.MessageType, Enum) - Method in class org.apache.pig.impl.plan.CompilationMessageCollector
 
CollectableLoadFunc - Interface in org.apache.pig
This interface implemented by LoadFunc implementations indicates to Pig that it has the capability to load data such that all instances of a key will occur in same split.
COLUMN_DELIMITER - Static variable in class org.apache.hadoop.zebra.schema.Schema
 
ColumnChainInfo - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
 
ColumnChainInfo() - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnChainInfo
 
ColumnExpression - Class in org.apache.pig.experimental.logical.expression
Super class for all column expressions, including projection, constants, and deferences.
ColumnExpression(String, OperatorPlan, byte) - Constructor for class org.apache.pig.experimental.logical.expression.ColumnExpression
 
ColumnInfo - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
 
ColumnInfo(boolean, List<Integer>, byte) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnInfo
 
ColumnMapKeyPrune - Class in org.apache.pig.experimental.logical.rules
This Rule prunes columns and map keys and set to loader.
ColumnMapKeyPrune(String) - Constructor for class org.apache.pig.experimental.logical.rules.ColumnMapKeyPrune
 
ColumnMapKeyPrune.ColumnMapKeyPruneTransformer - Class in org.apache.pig.experimental.logical.rules
 
ColumnMapKeyPrune.ColumnMapKeyPruneTransformer() - Constructor for class org.apache.pig.experimental.logical.rules.ColumnMapKeyPrune.ColumnMapKeyPruneTransformer
 
ColumnPruneHelper - Class in org.apache.pig.experimental.logical.rules
Helper class used by ColumnMapKeyPrune to figure out what columns can be pruned.
ColumnPruneHelper(OperatorPlan) - Constructor for class org.apache.pig.experimental.logical.rules.ColumnPruneHelper
 
ColumnPruner - Class in org.apache.pig.impl.logicalLayer
 
ColumnPruner(LogicalPlan) - Constructor for class org.apache.pig.impl.logicalLayer.ColumnPruner
 
columns - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
ColumnType - Enum in org.apache.hadoop.zebra.schema
Zebra Column Type
combinable() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
combine(DataBag) - Static method in class org.apache.pig.builtin.AVG
 
combine(DataBag) - Static method in class org.apache.pig.builtin.DoubleAvg
 
combine(DataBag) - Static method in class org.apache.pig.builtin.FloatAvg
 
combine(DataBag) - Static method in class org.apache.pig.builtin.IntAvg
 
combine(DataBag) - Static method in class org.apache.pig.builtin.LongAvg
 
combine(DataBag) - Static method in class org.apache.pig.piggybank.evaluation.stats.COR
combine results of different data chunk
combine(DataBag) - Static method in class org.apache.pig.piggybank.evaluation.stats.COV
combine results of different data chunk
CombinedLogLoader - Class in org.apache.pig.piggybank.storage.apachelog
CombinedLogLoader is used to load logs based on Apache's combined log format, based on a format like LogFormat "%h %l %u %t \"%r\" %>s %b \"%{Referer}i\" \"%{User-Agent}i\"" combined The log filename ends up being access_log from a line like CustomLog logs/combined_log combined Example: raw = LOAD 'combined_log' USING org.apache.pig.piggybank.storage.apachelog.CombinedLogLoader AS (remoteAddr, remoteLogname, user, time, method, uri, proto, status, bytes, referer, userAgent);
CombinedLogLoader() - Constructor for class org.apache.pig.piggybank.storage.apachelog.CombinedLogLoader
 
combinePlan - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
 
CombinerOptimizer - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Optimize map reduce plans to use the combiner where possible.
CombinerOptimizer(MROperPlan, String) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer
 
CombinerOptimizer(MROperPlan, String, CompilationMessageCollector) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer
 
command - Variable in class org.apache.pig.impl.streaming.ExecutableManager
 
Command - Class in org.apache.pig.tools.grunt
 
Command() - Constructor for class org.apache.pig.tools.grunt.Command
 
commitTask(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
CommonLogLoader - Class in org.apache.pig.piggybank.storage.apachelog
CommonLogLoader is used to load logs based on Apache's common log format, based on a format like LogFormat "%h %l %u %t \"%r\" %>s %b" common The log filename ends up being access_log from a line like CustomLog logs/access_log common Example: raw = LOAD 'access_log' USING org.apache.pig.piggybank.storage.apachelog.CommongLogLoader AS (remoteAddr, remoteLogname, user, time, method, uri, proto, bytes);
CommonLogLoader() - Constructor for class org.apache.pig.piggybank.storage.apachelog.CommonLogLoader
 
CommonNodeFinder - Class in org.apache.pig.impl.plan.optimizer
 
CommonNodeFinder(RulePlan) - Constructor for class org.apache.pig.impl.plan.optimizer.CommonNodeFinder
 
COMPARATOR_JCLASS - Static variable in class org.apache.hadoop.zebra.tfile.TFile
comparator prefix: java class
COMPARATOR_MEMCMP - Static variable in class org.apache.hadoop.zebra.tfile.TFile
comparator: memcmp
ComparatorExpr - Class in org.apache.hadoop.zebra.pig.comparator
Base class for comparator expressions
ComparatorExpr() - Constructor for class org.apache.hadoop.zebra.pig.comparator.ComparatorExpr
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.DoubleWritable.Comparator
 
compare(WritableComparable, WritableComparable) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler.PigSecondaryKeyGroupComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler.PigWritableComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBytesRawComparator
Compare two NullableBytesWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBytesRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigDoubleRawComparator
Compare two NullableIntWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigDoubleRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigFloatRawComparator
Compare two NullableIntWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigFloatRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigIntRawComparator
Compare two NullableIntWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigIntRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigLongRawComparator
Compare two NullableIntWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigLongRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSecondaryKeyComparator
 
compare(Object, Object, int, int, boolean[], boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSecondaryKeyComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextRawComparator
Compare two NullableTextWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTupleRawComparator
Compare two NullableTuples as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTupleRawComparator
 
compare(Tuple, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort.SortComparator
 
compare(Tuple, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort.UDFSortComparator
 
compare(WritableComparable, WritableComparable) - Method in class org.apache.pig.ComparisonFunc
 
compare(Tuple, Tuple) - Method in class org.apache.pig.ComparisonFunc
This callback method must be implemented by all subclasses.
compare(Object, Object) - Static method in class org.apache.pig.data.DataType
/** Compare two objects to each other.
compare(Object, Object, byte, byte) - Static method in class org.apache.pig.data.DataType
 
compareTo(SortedTableSplitComparable) - Method in class org.apache.hadoop.zebra.mapreduce.SortedTableSplitComparable
 
compareTo(Schema) - Method in class org.apache.hadoop.zebra.schema.Schema
 
compareTo(byte[]) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Compare the entry key to another key.
compareTo(byte[], int, int) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Compare the entry key to another key.
compareTo(RawComparable) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Compare an entry with a RawComparable object.
compareTo(Utils.Version) - Method in class org.apache.hadoop.zebra.tfile.Utils.Version
Compare this version with another version.
compareTo(ElementDescriptor) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
compareTo(Object) - Method in class org.apache.pig.backend.hadoop.DoubleWritable
 
compareTo(Object) - Method in class org.apache.pig.data.AccumulativeBag
 
compareTo(Object) - Method in class org.apache.pig.data.DataByteArray
Compare two byte arrays.
compareTo(Object) - Method in class org.apache.pig.data.DefaultAbstractBag
This method is potentially very expensive since it may require a sort of the bag; don't call it unless you have to.
compareTo(Object) - Method in class org.apache.pig.data.DefaultTuple
 
compareTo(Object) - Method in class org.apache.pig.data.NonSpillableDataBag
 
compareTo(Object) - Method in class org.apache.pig.data.ReadOnceBag
 
compareTo(Object) - Method in class org.apache.pig.data.SingleTupleBag
 
compareTo(Object) - Method in class org.apache.pig.data.TargetedTuple
 
compareTo(FileSplitComparable) - Method in class org.apache.pig.FileSplitComparable
 
compareTo(Object) - Method in class org.apache.pig.impl.io.NullablePartitionWritable
 
compareTo(Object) - Method in class org.apache.pig.impl.io.PigNullableWritable
Compare two nullable objects.
compareTo(Operator) - Method in class org.apache.pig.impl.plan.Operator
 
compareTo(OperatorKey) - Method in class org.apache.pig.impl.plan.OperatorKey
 
compareTo(StreamingCommand.HandleSpec) - Method in class org.apache.pig.impl.streaming.StreamingCommand.HandleSpec
 
compareTo(Object) - Method in class org.apache.pig.pen.util.ExampleTuple
 
ComparisonFunc - Class in org.apache.pig
 
ComparisonFunc() - Constructor for class org.apache.pig.ComparisonFunc
 
ComparisonOperator - Interface in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
This is an interface for all comparison operators.
compatibleWith(Utils.Version) - Method in class org.apache.hadoop.zebra.tfile.Utils.Version
Test compatibility.
CompilationMessageCollector - Class in org.apache.pig.impl.plan
This class is used for collecting all messages (error + warning) in compilation process.
CompilationMessageCollector() - Constructor for class org.apache.pig.impl.plan.CompilationMessageCollector
 
CompilationMessageCollector.Message - Class in org.apache.pig.impl.plan
 
CompilationMessageCollector.Message(String, CompilationMessageCollector.MessageType) - Constructor for class org.apache.pig.impl.plan.CompilationMessageCollector.Message
 
CompilationMessageCollector.Message(String, CompilationMessageCollector.MessageType, Enum) - Constructor for class org.apache.pig.impl.plan.CompilationMessageCollector.Message
 
CompilationMessageCollector.MessageType - Enum in org.apache.pig.impl.plan
 
compile(LogicalPlan, Properties) - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
Compiles a logical plan into a physical plan, given a set of configuration properties that apply at the plan-level.
compile(LogicalPlan, Properties) - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
compile(MROperPlan, String) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler
Compiles all jobs that have no dependencies removes them from the plan and returns.
compile() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
The front-end method that the user calls to compile the plan.
CompilerUtils - Class in org.apache.pig.impl.util
 
CompilerUtils() - Constructor for class org.apache.pig.impl.util.CompilerUtils
 
compileSet(String) - Static method in class org.apache.pig.piggybank.storage.hiverc.HiveRCSchemaUtil
Returns a set of columns, with the column names strimmed
complete(String, int, List) - Method in class org.apache.pig.tools.grunt.PigCompletor
 
complete(String, int, List) - Method in class org.apache.pig.tools.grunt.PigCompletorAliases
 
completionNotification(Object) - Method in interface org.apache.pig.backend.executionengine.ExecJob
hook for asynchronous notification of job completion pushed from the back-end
completionNotification(Object) - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
COMPRESSION_GZ - Static variable in class org.apache.hadoop.zebra.tfile.TFile
compression: gzip
COMPRESSION_LZO - Static variable in class org.apache.hadoop.zebra.tfile.TFile
compression: lzo
COMPRESSION_NONE - Static variable in class org.apache.hadoop.zebra.tfile.TFile
compression: none
computeAll(DataBag, DataBag) - Static method in class org.apache.pig.piggybank.evaluation.stats.COR
compute sum(XY), sum(X), sum(Y), sum(XX), sum(YY) from given data sets
computeAll(DataBag, DataBag) - Static method in class org.apache.pig.piggybank.evaluation.stats.COV
compute sum(XY), sum(X), sum(Y) from given data sets
computeSamples(ArrayList<Pair<FileSpec, Boolean>>, PigContext) - Method in class org.apache.pig.impl.builtin.PoissonSampleLoader
Computes the number of samples for the loader
computeSamples(ArrayList<Pair<FileSpec, Boolean>>, PigContext) - Method in class org.apache.pig.impl.builtin.SampleLoader
 
computeTimeSpent(TaskReport[]) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
 
CONCAT - Class in org.apache.pig.builtin
Generates the concatenation of the first two fields of a tuple.
CONCAT() - Constructor for class org.apache.pig.builtin.CONCAT
 
conf - Variable in class org.apache.hadoop.zebra.mapreduce.ZebraOutputPartition
 
ConfigurationUtil - Class in org.apache.pig.backend.hadoop.datastorage
 
ConfigurationUtil() - Constructor for class org.apache.pig.backend.hadoop.datastorage.ConfigurationUtil
 
ConfigurationValidator - Class in org.apache.pig.impl.util
 
ConfigurationValidator() - Constructor for class org.apache.pig.impl.util.ConfigurationValidator
 
configure(POStream) - Method in class org.apache.pig.backend.hadoop.streaming.HadoopExecutableManager
 
configure(POStream) - Method in class org.apache.pig.impl.streaming.ExecutableManager
Configure and initialize the ExecutableManager.
configure(Properties) - Static method in class org.apache.pig.impl.util.SpillableMemoryManager
 
connect(PhysicalOperator, PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
 
connect(Operator, int, Operator, int) - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
Connect two operators in the plan, controlling which position in the edge lists that the from and to edges are placed.
connect(Operator, Operator) - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
Connect two operators in the plan.
connect(Operator, int, Operator, int) - Method in interface org.apache.pig.experimental.plan.OperatorPlan
Connect two operators in the plan, controlling which position in the edge lists that the from and to edges are placed.
connect(Operator, Operator) - Method in interface org.apache.pig.experimental.plan.OperatorPlan
Connect two operators in the plan.
connect(Operator, int, Operator, int) - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
connect(Operator, Operator) - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
connect() - Method in class org.apache.pig.impl.PigContext
 
connect(E, E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Create an edge between two nodes.
connectMapToReduceLimitedSort(MapReduceOper, MapReduceOper) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
ConstantExpression - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
This class implements a Constant of any type.
ConstantExpression(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
ConstantExpression(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
ConstantExpression - Class in org.apache.pig.experimental.logical.expression
A constant
ConstantExpression(OperatorPlan, byte, Object) - Constructor for class org.apache.pig.experimental.logical.expression.ConstantExpression
Adds expression to the plan
ConstantSize - Class in org.apache.pig.builtin
Generates the size of the first field of a tuple.
ConstantSize() - Constructor for class org.apache.pig.builtin.ConstantSize
 
constructLROutput(List<Result>, List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
constructLROutput(List<Result>, List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrangeForIllustrate
 
constructLROutput(List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange
 
constructOutput(List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup
 
constructPROutput(List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPartitionRearrange
 
constructSignature(String, String, FuncSpec) - Static method in class org.apache.pig.impl.logicalLayer.LOStore
 
consumeInputBag(Result) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
ContainerDescriptor - Interface in org.apache.pig.backend.datastorage
 
contains(Object) - Method in class org.apache.pig.impl.util.IdentityHashSet
 
containsAll(Collection<?>) - Method in class org.apache.pig.impl.util.IdentityHashSet
 
containsKey(K) - Method in class org.apache.pig.impl.util.MultiMap
 
containsValue(V) - Method in class org.apache.pig.impl.util.MultiMap
 
containUDF() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
check whether this expression contains any UDF this is called if reducer is run as accumulative mode in this case, all UDFs must be called
contentLength - Variable in class org.apache.pig.backend.hadoop.datastorage.HSeekableInputStream
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.BooleanExpr
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.ByteExpr
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.DoubleExpr
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.FixedLengthPrimitive
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.FloatExpr
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.IntExpr
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.LongExpr
 
convertValue(byte[], Object) - Method in class org.apache.hadoop.zebra.pig.comparator.ShortExpr
 
copy(ElementDescriptor, Properties, boolean) - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
Copy entity from an existing one, possibly residing in a different Data Storage.
copy(ElementDescriptor, boolean) - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
 
copy(ContainerDescriptor, Properties, boolean) - Method in class org.apache.pig.backend.hadoop.datastorage.HDirectory
 
copy(ElementDescriptor, Properties, boolean) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
copy(ElementDescriptor, boolean) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
copy(String, String, boolean) - Method in class org.apache.pig.impl.PigContext
 
copySign - Class in org.apache.pig.piggybank.evaluation.math
math.copySign implements a binding to the Java function Math.copySign(double,double).
copySign() - Constructor for class org.apache.pig.piggybank.evaluation.math.copySign
 
COR - Class in org.apache.pig.piggybank.evaluation.stats
Computes the correlation between sets of data.
COR() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COR
 
COR(String...) - Constructor for class org.apache.pig.piggybank.evaluation.stats.COR
 
COR.Final - Class in org.apache.pig.piggybank.evaluation.stats
 
COR.Final() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COR.Final
 
COR.Final(String...) - Constructor for class org.apache.pig.piggybank.evaluation.stats.COR.Final
 
COR.Initial - Class in org.apache.pig.piggybank.evaluation.stats
 
COR.Initial() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COR.Initial
 
COR.Intermed - Class in org.apache.pig.piggybank.evaluation.stats
 
COR.Intermed() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COR.Intermed
 
COS - Class in org.apache.pig.piggybank.evaluation.math
math.COS implements a binding to the Java function Math.cos(double).
COS() - Constructor for class org.apache.pig.piggybank.evaluation.math.COS
 
COSH - Class in org.apache.pig.piggybank.evaluation.math
math.COSH implements a binding to the Java function Math.cosh(double).
COSH() - Constructor for class org.apache.pig.piggybank.evaluation.math.COSH
 
count(Tuple) - Static method in class org.apache.pig.builtin.AVG
 
COUNT - Class in org.apache.pig.builtin
Generates the count of the values of the first field of a tuple.
COUNT() - Constructor for class org.apache.pig.builtin.COUNT
 
count(Tuple) - Static method in class org.apache.pig.builtin.DoubleAvg
 
count(Tuple) - Static method in class org.apache.pig.builtin.FloatAvg
 
count(Tuple) - Static method in class org.apache.pig.builtin.IntAvg
 
count(Tuple) - Static method in class org.apache.pig.builtin.LongAvg
 
COUNT.Final - Class in org.apache.pig.builtin
 
COUNT.Final() - Constructor for class org.apache.pig.builtin.COUNT.Final
 
COUNT.Initial - Class in org.apache.pig.builtin
 
COUNT.Initial() - Constructor for class org.apache.pig.builtin.COUNT.Initial
 
COUNT.Intermediate - Class in org.apache.pig.builtin
 
COUNT.Intermediate() - Constructor for class org.apache.pig.builtin.COUNT.Intermediate
 
COUNT_STAR - Class in org.apache.pig.builtin
Generates the count of the values of the first field of a tuple.
COUNT_STAR() - Constructor for class org.apache.pig.builtin.COUNT_STAR
 
COUNT_STAR.Final - Class in org.apache.pig.builtin
 
COUNT_STAR.Final() - Constructor for class org.apache.pig.builtin.COUNT_STAR.Final
 
COUNT_STAR.Initial - Class in org.apache.pig.builtin
 
COUNT_STAR.Initial() - Constructor for class org.apache.pig.builtin.COUNT_STAR.Initial
 
COUNT_STAR.Intermediate - Class in org.apache.pig.builtin
 
COUNT_STAR.Intermediate() - Constructor for class org.apache.pig.builtin.COUNT_STAR.Intermediate
 
CountingMap<K> - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners
 
CountingMap() - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.CountingMap
 
COV - Class in org.apache.pig.piggybank.evaluation.stats
Computes the covariance between sets of data.
COV() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COV
 
COV(String...) - Constructor for class org.apache.pig.piggybank.evaluation.stats.COV
 
COV.Final - Class in org.apache.pig.piggybank.evaluation.stats
 
COV.Final() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COV.Final
 
COV.Final(String...) - Constructor for class org.apache.pig.piggybank.evaluation.stats.COV.Final
 
COV.Initial - Class in org.apache.pig.piggybank.evaluation.stats
 
COV.Initial() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COV.Initial
 
COV.Intermed - Class in org.apache.pig.piggybank.evaluation.stats
 
COV.Intermed() - Constructor for class org.apache.pig.piggybank.evaluation.stats.COV.Intermed
 
create(FileSystem, Path) - Method in class org.apache.hadoop.zebra.types.CGSchema
 
create(Properties) - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
Opens a stream onto which an entity can be written to.
create() - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
 
create(Properties) - Method in class org.apache.pig.backend.hadoop.datastorage.HDirectory
 
create(Properties) - Method in class org.apache.pig.backend.hadoop.datastorage.HFile
 
create(Properties) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
create() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
create(String, PigContext) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
create(String, boolean, PigContext) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
createBag() - Static method in class org.apache.hadoop.zebra.types.TypesUtils
Create a PIG Bag object.
createBag(Schema) - Static method in class org.apache.hadoop.zebra.types.TypesUtils
 
createCl(String) - Method in class org.apache.pig.impl.PigContext
Creates a Classloader based on the passed jarFile and any extra jar files.
createExecutableManager() - Method in class org.apache.pig.impl.PigContext
Create a new ExecutableManager depending on the ExecType.
createInputHandler(StreamingCommand) - Static method in class org.apache.pig.impl.streaming.HandlerFactory
Create an InputHandler for the given input specification of the StreamingCommand.
createJar(OutputStream, Set<String>, PigContext) - Static method in class org.apache.pig.impl.util.JarManager
Create a jarfile in a temporary path, that is a merge of all the jarfiles containing the functions and the core pig classes.
createKey() - Method in class org.apache.hadoop.zebra.mapred.TableRecordReader
Deprecated.  
createMetaBlock(String) - Method in class org.apache.hadoop.zebra.io.BasicTable.Writer
Obtain an output stream for creating a Meta Block with the specific name.
createOutputHandler(StreamingCommand) - Static method in class org.apache.pig.impl.streaming.HandlerFactory
Create an OutputHandler for the given output specification of the StreamingCommand.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.hadoop.zebra.mapreduce.TableInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.pig.impl.io.BinStorageInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.pig.piggybank.storage.hiverc.HiveRCInputFormat
Initialises an instance of HiveRCRecordReader.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.pig.piggybank.storage.XMLLoader.XMLFileInputFormat
 
createScanner() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get a scanner than can scan the whole TFile.
createScanner(byte[], byte[]) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Deprecated. Use TFile.Reader.createScannerByKey(byte[], byte[]) instead.
createScanner(RawComparable, RawComparable) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Deprecated. Use TFile.Reader.createScannerByKey(RawComparable, RawComparable) instead.
createScannerByByteRange(long, long) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get a scanner that covers a portion of TFile based on byte offsets.
createScannerByKey(byte[], byte[]) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get a scanner that covers a portion of TFile based on keys.
createScannerByKey(RawComparable, RawComparable) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get a scanner that covers a specific key range.
createScannerByRecordNum(long, long) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Create a scanner that covers a range of records.
createStoreFunc(POStore) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReducePOStoreImpl
 
createStoreFunc(POStore) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStoreImpl
Set up the storer
createTableRecordReader(JobContext, String) - Static method in class org.apache.hadoop.zebra.mapreduce.TableInputFormat
Get a TableRecordReader on a single split
createTuple(Schema) - Static method in class org.apache.hadoop.zebra.types.TypesUtils
Create a tuple based on a schema
createTuple(int) - Static method in class org.apache.hadoop.zebra.types.TypesUtils
create a tuple based on number of columns
createTuple(Object[]) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
createTuple(byte[]) - Method in class org.apache.pig.piggybank.storage.XMLLoader
 
createValue() - Method in class org.apache.hadoop.zebra.mapred.TableRecordReader
Deprecated.  
createZebraProjection(String) - Static method in class org.apache.hadoop.zebra.mapred.ZebraProjection
 
createZebraProjection(String) - Static method in class org.apache.hadoop.zebra.mapreduce.ZebraProjection
 
createZebraSchema(String) - Static method in class org.apache.hadoop.zebra.mapred.ZebraSchema
 
createZebraSchema(String) - Static method in class org.apache.hadoop.zebra.mapreduce.ZebraSchema
 
createZebraSortInfo(String, Class<? extends RawComparator<Object>>) - Static method in class org.apache.hadoop.zebra.mapred.ZebraSortInfo
 
createZebraSortInfo(String, Class<? extends RawComparator<Object>>) - Static method in class org.apache.hadoop.zebra.mapreduce.ZebraSortInfo
 
createZebraStorageHint(String) - Static method in class org.apache.hadoop.zebra.mapred.ZebraStorageHint
 
createZebraStorageHint(String) - Static method in class org.apache.hadoop.zebra.mapreduce.ZebraStorageHint
 
currentOp - Variable in class org.apache.pig.experimental.logical.expression.ExpToPhyTranslationVisitor
 
currentOp - Variable in class org.apache.pig.experimental.logical.optimizer.AllExpressionVisitor
 
currentPlan - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.LogToPhyTranslationVisitor
 
currentPlan - Variable in class org.apache.pig.experimental.logical.expression.ExpToPhyTranslationVisitor
 
currentPlan - Variable in class org.apache.pig.experimental.logical.relational.LogToPhyTranslationVisitor
 
currentPlan - Variable in class org.apache.pig.experimental.plan.optimizer.Rule
 
currentPlans - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.LogToPhyTranslationVisitor
 
currentPlans - Variable in class org.apache.pig.experimental.logical.expression.ExpToPhyTranslationVisitor
 
currentPlans - Variable in class org.apache.pig.experimental.logical.relational.LogToPhyTranslationVisitor
 
currentWalker - Variable in class org.apache.pig.experimental.plan.PlanVisitor
Guaranteed to always point to the walker currently being used.
CustomFormatToISO - Class in org.apache.pig.piggybank.evaluation.datetime.convert
CustomFormatToISO converts arbitrary date formats to ISO format.
CustomFormatToISO() - Constructor for class org.apache.pig.piggybank.evaluation.datetime.convert.CustomFormatToISO
 

D

data - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
DataBag - Interface in org.apache.pig.data
A collection of Tuples.
DataByteArray - Class in org.apache.pig.data
An implementation of byte array.
DataByteArray() - Constructor for class org.apache.pig.data.DataByteArray
Default constructor.
DataByteArray(byte[]) - Constructor for class org.apache.pig.data.DataByteArray
Construct a byte array using the provided bytes as the content.
DataByteArray(DataByteArray, DataByteArray) - Constructor for class org.apache.pig.data.DataByteArray
Construct a byte array concatenating the two provided byte arrays as the content.
DataByteArray(byte[], int, int) - Constructor for class org.apache.pig.data.DataByteArray
Construct a byte array using a portion of the provided bytes as content.
DataByteArray(String) - Constructor for class org.apache.pig.data.DataByteArray
Construct a byte array from a String.
DataReaderWriter - Class in org.apache.pig.data
A class to handle reading and writing of intermediate results of data types.
DataReaderWriter() - Constructor for class org.apache.pig.data.DataReaderWriter
 
DataStorage - Interface in org.apache.pig.backend.datastorage
DataStorage provides an abstraction of a generic container.
DataStorageException - Exception in org.apache.pig.backend.datastorage
 
DataStorageException() - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with null as the error message.
DataStorageException(String) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(Throwable) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified cause.
DataStorageException(String, Throwable) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int, Throwable) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int, byte) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int, byte, Throwable) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int, boolean) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int, byte, boolean) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message and cause.
DataStorageException(String, int, byte, boolean, String) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
DataStorageException(String, int, byte, boolean, String, Throwable) - Constructor for exception org.apache.pig.backend.datastorage.DataStorageException
Create a new DataStorageException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
DataType - Class in org.apache.pig.data
A class of static final values used to encode data type and a number of static helper funcitons for manipulating data objects.
DataType() - Constructor for class org.apache.pig.data.DataType
 
DateExtractor - Class in org.apache.pig.piggybank.evaluation.util.apachelogparser
DateExtractor has four different constructors which each allow for different functionality.
DateExtractor() - Constructor for class org.apache.pig.piggybank.evaluation.util.apachelogparser.DateExtractor
forms the formats based on default incomingDateFormat and default outgoingDateFormat
DateExtractor(String) - Constructor for class org.apache.pig.piggybank.evaluation.util.apachelogparser.DateExtractor
forms the formats based on passed outgoingDateString and the default incomingDateFormat
DateExtractor(String, String) - Constructor for class org.apache.pig.piggybank.evaluation.util.apachelogparser.DateExtractor
forms the formats based on passed incomingDateString and outgoingDateString
DateExtractor(String, String, String) - Constructor for class org.apache.pig.piggybank.evaluation.util.apachelogparser.DateExtractor
forms the formats based on passed incomingDateString and outgoingDateString
DAY_DATE_COLUMN - Static variable in class org.apache.pig.piggybank.storage.HiveColumnarLoader
 
debugOff() - Method in class org.apache.pig.PigServer
 
debugOn() - Method in class org.apache.pig.PigServer
 
Decode - Class in org.apache.pig.piggybank.evaluation.decode
Syntax: String Decode(expression, value1, mapping_string1, ..., valueN, mapping_stringN, other_string). Logic: if (expression==value1) return mapping_string1;
......
Decode() - Constructor for class org.apache.pig.piggybank.evaluation.decode.Decode
 
decodeBytes(String) - Static method in class org.apache.pig.impl.util.ObjectSerializer
 
DEFAULT_CHUNK_SIZE - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POJoinPackage
 
DEFAULT_COMPARATOR - Static variable in class org.apache.hadoop.zebra.types.SortInfo
 
DEFAULT_PARALLELISM - Static variable in class org.apache.pig.impl.builtin.GFCross
 
DEFAULT_PERCENT_MEMUSAGE - Static variable in class org.apache.pig.impl.builtin.PartitionSkewedKeys
 
DEFAULT_REPLICATION_FACTOR_KEY - Static variable in interface org.apache.pig.backend.datastorage.DataStorage
 
DEFAULT_SCOPE - Static variable in class org.apache.pig.experimental.plan.PlanVisitor
 
DefaultAbstractBag - Class in org.apache.pig.data
Default implementation of DataBag.
DefaultAbstractBag() - Constructor for class org.apache.pig.data.DefaultAbstractBag
 
DefaultAbstractBag.BagDelimiterTuple - Class in org.apache.pig.data
 
DefaultAbstractBag.BagDelimiterTuple() - Constructor for class org.apache.pig.data.DefaultAbstractBag.BagDelimiterTuple
 
DefaultAbstractBag.EndBag - Class in org.apache.pig.data
 
DefaultAbstractBag.EndBag() - Constructor for class org.apache.pig.data.DefaultAbstractBag.EndBag
 
DefaultAbstractBag.StartBag - Class in org.apache.pig.data
 
DefaultAbstractBag.StartBag() - Constructor for class org.apache.pig.data.DefaultAbstractBag.StartBag
 
DefaultBagFactory - Class in org.apache.pig.data
Default implementation of BagFactory.
DefaultDataBag - Class in org.apache.pig.data
An unordered collection of Tuples (possibly) with multiples.
DefaultDataBag() - Constructor for class org.apache.pig.data.DefaultDataBag
 
DefaultDataBag(List<Tuple>) - Constructor for class org.apache.pig.data.DefaultDataBag
This constructor creates a bag out of an existing list of tuples by taking ownership of the list and NOT copying the contents of the list.
DefaultIndexableLoader - Class in org.apache.pig.impl.builtin
Used by MergeJoin .
DefaultIndexableLoader(String, String, String, String, String) - Constructor for class org.apache.pig.impl.builtin.DefaultIndexableLoader
 
DefaultInputHandler - Class in org.apache.pig.impl.streaming
DefaultInputHandler handles the input for the Pig-Streaming executable in a synchronous manner by feeding it input via its stdin.
DefaultInputHandler() - Constructor for class org.apache.pig.impl.streaming.DefaultInputHandler
 
DefaultInputHandler(StreamingCommand.HandleSpec) - Constructor for class org.apache.pig.impl.streaming.DefaultInputHandler
 
defaultNumGroups - Static variable in class org.apache.pig.impl.builtin.GFAny
 
DefaultOutputHandler - Class in org.apache.pig.impl.streaming
FileOutputHandler handles the output from the Pig-Streaming executable in an synchronous manner by reading its output via its stdout.
DefaultOutputHandler() - Constructor for class org.apache.pig.impl.streaming.DefaultOutputHandler
 
DefaultOutputHandler(StreamingCommand.HandleSpec) - Constructor for class org.apache.pig.impl.streaming.DefaultOutputHandler
 
defaultParallel - Variable in class org.apache.pig.impl.PigContext
 
DefaultTuple - Class in org.apache.pig.data
A default implementation of Tuple.
DefaultTuple() - Constructor for class org.apache.pig.data.DefaultTuple
Default constructor.
DefaultTupleFactory - Class in org.apache.pig.data
Default implementation of TupleFactory.
delete() - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
Remove entity from the Data Storage.
delete() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
delete(String, PigContext) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
DELETED_CG_SEPARATOR_PER_TABLE - Static variable in class org.apache.hadoop.zebra.io.BasicTable
 
deleteFile(String) - Method in class org.apache.pig.PigServer
 
deleteTempFiles() - Static method in class org.apache.pig.impl.io.FileLocalizer
 
DependencyOrderLimitedWalker<O extends Operator,P extends OperatorPlan<O>> - Class in org.apache.pig.pen.util
 
DependencyOrderLimitedWalker(O, P) - Constructor for class org.apache.pig.pen.util.DependencyOrderLimitedWalker
 
DependencyOrderWalker - Class in org.apache.pig.experimental.plan
A walker to walk graphs in dependency order.
DependencyOrderWalker(OperatorPlan) - Constructor for class org.apache.pig.experimental.plan.DependencyOrderWalker
 
DependencyOrderWalker<O extends Operator,P extends OperatorPlan<O>> - Class in org.apache.pig.impl.plan
DependencyOrderWalker traverses the graph in such a way that no node is visited before all the nodes it depends on have been visited.
DependencyOrderWalker(P) - Constructor for class org.apache.pig.impl.plan.DependencyOrderWalker
 
DependencyOrderWalkerWOSeenChk<O extends Operator,P extends OperatorPlan<O>> - Class in org.apache.pig.impl.plan
DependencyOrderWalker traverses the graph in such a way that no node is visited before all the nodes it depends on have been visited.
DependencyOrderWalkerWOSeenChk(P) - Constructor for class org.apache.pig.impl.plan.DependencyOrderWalkerWOSeenChk
 
depthFirst() - Method in class org.apache.pig.impl.plan.optimizer.RulePlanPrinter
 
depthFirst() - Method in class org.apache.pig.impl.plan.PlanPrinter
 
depthFirstLP() - Method in class org.apache.pig.impl.logicalLayer.LOPrinter
 
depthFirstPP() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PlanPrinter
 
DepthFirstWalker - Class in org.apache.pig.experimental.plan
Do a depth first traversal of the graph.
DepthFirstWalker(OperatorPlan) - Constructor for class org.apache.pig.experimental.plan.DepthFirstWalker
 
DepthFirstWalker<O extends Operator,P extends OperatorPlan<O>> - Class in org.apache.pig.impl.plan
DepthFirstWalker traverses a plan in a depth first manner.
DepthFirstWalker(P) - Constructor for class org.apache.pig.impl.plan.DepthFirstWalker
 
DerivedDataVisitor - Class in org.apache.pig.pen
 
DerivedDataVisitor(LogicalPlan, PigContext, Map<LOLoad, DataBag>, Map<LogicalOperator, PhysicalOperator>, PhysicalPlan) - Constructor for class org.apache.pig.pen.DerivedDataVisitor
 
DerivedDataVisitor(LogicalOperator, PigContext, Map<LOLoad, DataBag>, Map<LogicalOperator, PhysicalOperator>, PhysicalPlan) - Constructor for class org.apache.pig.pen.DerivedDataVisitor
 
deserialize(byte[]) - Method in class org.apache.pig.builtin.PigStreaming
 
deserialize(String) - Static method in class org.apache.pig.impl.util.ObjectSerializer
 
deserialize() - Method in class org.apache.pig.impl.util.UDFContext
Populate the udfConfs field.
deserialize(byte[]) - Method in interface org.apache.pig.StreamToPig
Given a byte array from a streaming executable, produce a tuple.
deserializer - Variable in class org.apache.pig.impl.streaming.OutputHandler
 
detachInput() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
Detaches any tuples that are attached
detachInput() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
 
detachInput() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
attachInput's better half!
detailedMessage - Variable in exception org.apache.pig.PigException
 
determineErrorSource(int) - Static method in exception org.apache.pig.PigException
A static method to determine the error source given the error code
determineFieldSchema(ResourceSchema.ResourceFieldSchema) - Static method in class org.apache.pig.data.DataType
Determine the field schema of an ResourceFieldSchema
determineFieldSchema(Object) - Static method in class org.apache.pig.data.DataType
Determine the field schema of an object
DIFF - Class in org.apache.pig.builtin
DIFF compares the fields of a tuple with arity 2.
DIFF() - Constructor for class org.apache.pig.builtin.DIFF
 
DiffDate - Class in org.apache.pig.piggybank.evaluation.datetime
Syntax: int DiffDate(String yyyymmdd1, String yyyymmdd2). Input: date string in "yyyymmdd" format. Output: (date1-date2) in days, can be negative.
DiffDate() - Constructor for class org.apache.pig.piggybank.evaluation.datetime.DiffDate
 
discardBatch() - Method in class org.apache.pig.PigServer
Discards a batch of Pig commands.
disconnect(Operator, Operator) - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
Disconnect two operators in the plan.
disconnect(Operator, Operator) - Method in interface org.apache.pig.experimental.plan.OperatorPlan
Disconnect two operators in the plan.
disconnect(Operator, Operator) - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
disconnect(E, E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Remove an edge from between two nodes.
DiscreteProbabilitySampleGenerator - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners
 
DiscreteProbabilitySampleGenerator(long, float[]) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.DiscreteProbabilitySampleGenerator
 
DiscreteProbabilitySampleGenerator(float[]) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.DiscreteProbabilitySampleGenerator
 
display() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.CountingMap
 
DisplayExamples - Class in org.apache.pig.pen.util
 
DisplayExamples() - Constructor for class org.apache.pig.pen.util.DisplayExamples
 
distinct - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
 
Distinct - Class in org.apache.pig.builtin
Find the distinct set of tuples in a bag.
Distinct() - Constructor for class org.apache.pig.builtin.Distinct
 
Distinct.Final - Class in org.apache.pig.builtin
 
Distinct.Final() - Constructor for class org.apache.pig.builtin.Distinct.Final
 
Distinct.Initial - Class in org.apache.pig.builtin
 
Distinct.Initial() - Constructor for class org.apache.pig.builtin.Distinct.Initial
 
Distinct.Intermediate - Class in org.apache.pig.builtin
 
Distinct.Intermediate() - Constructor for class org.apache.pig.builtin.Distinct.Intermediate
 
DistinctCombiner - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
A special implementation of combiner used only for distinct.
DistinctCombiner() - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.DistinctCombiner
 
DistinctCombiner.Combine - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
 
DistinctCombiner.Combine() - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.DistinctCombiner.Combine
 
DistinctDataBag - Class in org.apache.pig.data
An unordered collection of Tuples with no multiples.
DistinctDataBag() - Constructor for class org.apache.pig.data.DistinctDataBag
 
Divide - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
 
Divide(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
Divide(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
DivideExpression - Class in org.apache.pig.experimental.logical.expression
Divide Operator
DivideExpression(OperatorPlan, byte, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.DivideExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
doAllPredecessors(Operator, Set<Operator>, Collection<Operator>) - Method in class org.apache.pig.experimental.plan.DependencyOrderWalker
 
doAllPredecessors(O, Set<O>, Collection<O>) - Method in class org.apache.pig.impl.plan.DependencyOrderWalker
 
doAllSuccessors(Operator, Set<Operator>, Collection<Operator>) - Method in class org.apache.pig.experimental.plan.ReverseDependencyOrderWalker
 
doAllSuccessors(O, Set<O>, Collection<O>) - Method in class org.apache.pig.impl.plan.ReverseDependencyOrderWalker
 
doInsertBetween(E, E, E, boolean) - Method in class org.apache.pig.impl.plan.OperatorPlan
 
DotLOPrinter - Class in org.apache.pig.impl.logicalLayer
This class can print a logical plan in the DOT format.
DotLOPrinter(LogicalPlan, PrintStream) - Constructor for class org.apache.pig.impl.logicalLayer.DotLOPrinter
 
DotMRPrinter - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
This class can print an MR plan in the DOT format.
DotMRPrinter(MROperPlan, PrintStream) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter
 
DotMRPrinter.InnerOperator - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
Helper class to represent the relationship of map, reduce and combine phases in an MR operator.
DotMRPrinter.InnerOperator(PhysicalPlan, String) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter.InnerOperator
 
DotMRPrinter.InnerPlan - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
Helper class to represent the relationship of map, reduce and combine phases in an MR operator.
DotMRPrinter.InnerPlan(PhysicalPlan, PhysicalPlan, PhysicalPlan) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter.InnerPlan
 
DotPlanDumper<E extends Operator,P extends OperatorPlan<E>,N extends Operator,S extends OperatorPlan<N>> - Class in org.apache.pig.impl.plan
This class puts everything that is needed to dump a plan in a format readable by graphviz's dot algorithm.
DotPlanDumper(P, PrintStream) - Constructor for class org.apache.pig.impl.plan.DotPlanDumper
 
DotPlanDumper(P, PrintStream, boolean, Set<Operator>, Set<Operator>, Set<Operator>) - Constructor for class org.apache.pig.impl.plan.DotPlanDumper
 
DotPOPrinter - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
This class can print a physical plan in the DOT format.
DotPOPrinter(PhysicalPlan, PrintStream) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.DotPOPrinter
 
DotPOPrinter(PhysicalPlan, PrintStream, boolean, Set<Operator>, Set<Operator>, Set<Operator>) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.DotPOPrinter
 
DOUBLE - Static variable in class org.apache.pig.data.DataType
 
DoubleAbs - Class in org.apache.pig.piggybank.evaluation.math
math.ABS implements a binding to the Java function Math.abs(double) for computing the absolute value of the argument.
DoubleAbs() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleAbs
 
DoubleAvg - Class in org.apache.pig.builtin
Generates the average of the values of the first field of a tuple.
DoubleAvg() - Constructor for class org.apache.pig.builtin.DoubleAvg
 
DoubleAvg.Final - Class in org.apache.pig.builtin
 
DoubleAvg.Final() - Constructor for class org.apache.pig.builtin.DoubleAvg.Final
 
DoubleAvg.Initial - Class in org.apache.pig.builtin
 
DoubleAvg.Initial() - Constructor for class org.apache.pig.builtin.DoubleAvg.Initial
 
DoubleAvg.Intermediate - Class in org.apache.pig.builtin
 
DoubleAvg.Intermediate() - Constructor for class org.apache.pig.builtin.DoubleAvg.Intermediate
 
DoubleBase - Class in org.apache.pig.piggybank.evaluation.math
base class for math udfs that return Double value
DoubleBase() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleBase
 
DoubleCopySign - Class in org.apache.pig.piggybank.evaluation.math
math.copySign implements a binding to the Java function Math.copySign(double,double).
DoubleCopySign() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleCopySign
 
DoubleDoubleBase - Class in org.apache.pig.piggybank.evaluation.math
base class for math udfs that return Double value
DoubleDoubleBase() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleDoubleBase
 
DoubleExpr - Class in org.apache.hadoop.zebra.pig.comparator
 
DoubleGetExponent - Class in org.apache.pig.piggybank.evaluation.math
math.getExponent implements a binding to the Java function Math.getExponent(double).
DoubleGetExponent() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleGetExponent
 
DoubleMax - Class in org.apache.pig.builtin
Generates the max of the values of the first field of a tuple.
DoubleMax() - Constructor for class org.apache.pig.builtin.DoubleMax
 
DoubleMax - Class in org.apache.pig.piggybank.evaluation.math
math.max implements a binding to the Java function Math.max(int,int) for computing the the max value of the arguments.
DoubleMax() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleMax
 
DoubleMax.Final - Class in org.apache.pig.builtin
 
DoubleMax.Final() - Constructor for class org.apache.pig.builtin.DoubleMax.Final
 
DoubleMax.Initial - Class in org.apache.pig.builtin
 
DoubleMax.Initial() - Constructor for class org.apache.pig.builtin.DoubleMax.Initial
 
DoubleMax.Intermediate - Class in org.apache.pig.builtin
 
DoubleMax.Intermediate() - Constructor for class org.apache.pig.builtin.DoubleMax.Intermediate
 
DoubleMin - Class in org.apache.pig.builtin
Generates the min of the Double values in the first field of a tuple.
DoubleMin() - Constructor for class org.apache.pig.builtin.DoubleMin
 
DoubleMin - Class in org.apache.pig.piggybank.evaluation.math
math.min implements a binding to the Java function Math.min(int,int) for computing the the min value of the arguments.
DoubleMin() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleMin
 
DoubleMin.Final - Class in org.apache.pig.builtin
 
DoubleMin.Final() - Constructor for class org.apache.pig.builtin.DoubleMin.Final
 
DoubleMin.Initial - Class in org.apache.pig.builtin
 
DoubleMin.Initial() - Constructor for class org.apache.pig.builtin.DoubleMin.Initial
 
DoubleMin.Intermediate - Class in org.apache.pig.builtin
 
DoubleMin.Intermediate() - Constructor for class org.apache.pig.builtin.DoubleMin.Intermediate
 
DoubleNextAfter - Class in org.apache.pig.piggybank.evaluation.math
math.nextAfter implements a binding to the Java function Math.nextAfter(double,double).
DoubleNextAfter() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleNextAfter
 
DoubleNextup - Class in org.apache.pig.piggybank.evaluation.math
math.NEXTUP implements a binding to the Java function Math.nextUp(double).
DoubleNextup() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleNextup
 
DoubleRound - Class in org.apache.pig.piggybank.evaluation.math
math.ROUND implements a binding to the Java function Math.round(double).
DoubleRound() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleRound
 
DoubleSignum - Class in org.apache.pig.piggybank.evaluation.math
math.SIGNUM implements a binding to the Java function Math.signum(double).
DoubleSignum() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleSignum
 
DoubleSum - Class in org.apache.pig.builtin
Generates the sum of the values of the first field of a tuple.
DoubleSum() - Constructor for class org.apache.pig.builtin.DoubleSum
 
DoubleSum.Final - Class in org.apache.pig.builtin
 
DoubleSum.Final() - Constructor for class org.apache.pig.builtin.DoubleSum.Final
 
DoubleSum.Initial - Class in org.apache.pig.builtin
 
DoubleSum.Initial() - Constructor for class org.apache.pig.builtin.DoubleSum.Initial
 
DoubleSum.Intermediate - Class in org.apache.pig.builtin
 
DoubleSum.Intermediate() - Constructor for class org.apache.pig.builtin.DoubleSum.Intermediate
 
DoubleUlp - Class in org.apache.pig.piggybank.evaluation.math
math.ULP implements a binding to the Java function Math.ulp(double).
DoubleUlp() - Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleUlp
 
DoubleWritable - Class in org.apache.pig.backend.hadoop
Writable for Double values.
DoubleWritable() - Constructor for class org.apache.pig.backend.hadoop.DoubleWritable
 
DoubleWritable(double) - Constructor for class org.apache.pig.backend.hadoop.DoubleWritable
 
DoubleWritable.Comparator - Class in org.apache.pig.backend.hadoop
A Comparator optimized for DoubleWritable.
DoubleWritable.Comparator() - Constructor for class org.apache.pig.backend.hadoop.DoubleWritable.Comparator
 
drop(Path, Configuration) - Static method in class org.apache.hadoop.zebra.io.BasicTable
Drop a Basic Table, all files consisting of the BasicTable will be removed.
drop(FileSystem, Path) - Static method in class org.apache.hadoop.zebra.types.CGSchema
 
dropColumnGroup(Path, Configuration, String) - Static method in class org.apache.hadoop.zebra.io.BasicTable
Deletes the data for column group specified by cgName.
ds - Variable in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
dummyBag - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyBool - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyDBA - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyDouble - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyFloat - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyInt - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyLong - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyMap - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyString - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dummyTuple - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
dump() - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dump(PrintStream) - Method in class org.apache.pig.impl.plan.OperatorPlan
 
dump() - Method in class org.apache.pig.impl.plan.PlanDumper
This is the public interface.
dumpEdge(Operator, Operator) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpEdge(Operator, Operator) - Method in class org.apache.pig.impl.plan.PlanDumper
Will be called to dump the edges of the plan.
dumpInfo(String, PrintStream, Configuration) - Static method in class org.apache.hadoop.zebra.io.BasicTable
 
dumpInfo(String, PrintStream, Configuration, int) - Static method in class org.apache.hadoop.zebra.io.BasicTable
 
dumpInvisibleOperators(E) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpMultiInputNestedOperator(E, MultiMap<E, S>) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpMultiInputNestedOperator(E, MultiMap<E, S>) - Method in class org.apache.pig.impl.plan.PlanDumper
Will be called when an operator has nested plans, which are connected to one of the multiple inputs.
dumpMultiOutputNestedOperator(E, Collection<S>) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpMultiOutputNestedOperator(E, Collection<S>) - Method in class org.apache.pig.impl.plan.PlanDumper
Will be called for nested operators, where the plans represent how the output of the operator is processed.
dumpNestedOperator(E, Collection<S>) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpNestedOperator(E, Collection<S>) - Method in class org.apache.pig.impl.plan.PlanDumper
Will be called for nested operators.
dumpOperator(E) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpOperator(E) - Method in class org.apache.pig.impl.plan.PlanDumper
Will be called to dump a simple operator
dumpSchema(String) - Method in class org.apache.pig.PigServer
 
dumpTimers(PrintStream) - Method in class org.apache.pig.tools.timer.PerformanceTimerFactory
Call print on all of the known performance timers.
dumpTimers() - Method in class org.apache.pig.tools.timer.PerformanceTimerFactory
 
duplicate() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 

E

el - Variable in class org.apache.hadoop.zebra.pig.comparator.BagExpr
 
ElementDescriptor - Interface in org.apache.pig.backend.datastorage
DataStorageElementDescriptor provides methods necessary to manage an element in a DataStorage.
encodeBytes(byte[]) - Static method in class org.apache.pig.impl.util.ObjectSerializer
 
end - Variable in class org.apache.pig.builtin.BinStorage
 
END_OF_INP_IN_MAP - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler
 
endBag - Static variable in class org.apache.pig.data.DefaultAbstractBag
 
endOfAllInput - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
 
EndOfAllInputSetter - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
This visitor visits the MRPlan and does the following for each MROper: If the map plan or the reduce plan of the MROper has an end of all input flag present in it, this marks in the MROper whether the map has an end of all input flag set or if the reduce has an end of all input flag set.
EndOfAllInputSetter(MROperPlan) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.EndOfAllInputSetter
 
EndOfOpts - Static variable in class org.apache.pig.tools.cmdline.CmdLineParser
 
ensureAllKeyInstancesInSameSplit() - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
ensureAllKeyInstancesInSameSplit() - Method in interface org.apache.pig.CollectableLoadFunc
When this method is called, Pig is communicating to Loader that it must load data such that all instances of a key are in same split.
entry() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
Get an entry to access the key and value.
equalByteArrays(byte[], byte[]) - Static method in class org.apache.pig.data.DataType
 
EqualExpression - Class in org.apache.pig.experimental.logical.expression
Equality test expression.
EqualExpression(OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.experimental.logical.expression.EqualExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
equals(Object) - Method in class org.apache.hadoop.zebra.mapreduce.SortedTableSplitComparable
 
equals(Schema.ColumnSchema, Schema.ColumnSchema) - Static method in class org.apache.hadoop.zebra.schema.Schema.ColumnSchema
Compare two field schema for equality
equals(Object) - Method in class org.apache.hadoop.zebra.schema.Schema
 
equals(Object) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Compare whether this and other points to the same key value.
equals(Object) - Method in class org.apache.hadoop.zebra.tfile.Utils.Version
 
equals(Object) - Method in class org.apache.hadoop.zebra.types.CGSchema
 
equals(String[], String) - Method in class org.apache.hadoop.zebra.types.SortInfo
Check if the two SortInfo objects are equal
equals(Object) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
equals(Object) - Method in class org.apache.pig.backend.hadoop.DoubleWritable
Returns true iff o is a DoubleWritable with the same value.
equals(Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnChainInfo
 
equals(Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnInfo
 
equals(Object) - Method in class org.apache.pig.builtin.PigStorage
 
equals(PigStorage) - Method in class org.apache.pig.builtin.PigStorage
 
equals(Object) - Method in class org.apache.pig.data.AccumulativeBag
 
equals(Object) - Method in class org.apache.pig.data.DataByteArray
 
equals(Object) - Method in class org.apache.pig.data.DefaultAbstractBag
 
equals(Object) - Method in class org.apache.pig.data.DefaultTuple
 
equals(Object) - Method in class org.apache.pig.data.NonSpillableDataBag
 
equals(Object) - Method in class org.apache.pig.data.ReadOnceBag
 
equals(Object) - Method in class org.apache.pig.data.SingleTupleBag
 
equals(Object) - Method in class org.apache.pig.data.TargetedTuple
 
equals(Object) - Method in class org.apache.pig.FileSplitComparable
 
equals(Object) - Method in class org.apache.pig.FuncSpec
 
equals(Object) - Method in class org.apache.pig.impl.io.FileSpec
 
equals(Object) - Method in class org.apache.pig.impl.io.PigNullableWritable
 
equals(Object) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
For two schemas to be equal, they have to be deeply equal.
equals(Schema, Schema, boolean, boolean) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema
Recursively compare two schemas for equality
equals(Object) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Two field schemas are equal if types and schemas are equal in all levels.
equals(Schema.FieldSchema, Schema.FieldSchema, boolean, boolean) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Compare two field schema for equality
equals(Object) - Method in class org.apache.pig.impl.plan.Operator
Compares to Operators based on their opKey
equals(Object) - Method in class org.apache.pig.impl.plan.OperatorKey
 
equals(Object) - Method in class org.apache.pig.impl.streaming.StreamingCommand.HandleSpec
 
equals(Object) - Method in class org.apache.pig.impl.util.Pair
 
equals(Object) - Method in class org.apache.pig.piggybank.storage.XMLLoader
to check for equality
equals(XMLLoader) - Method in class org.apache.pig.piggybank.storage.XMLLoader
to check for equality
equals(ResourceSchema, ResourceSchema) - Static method in class org.apache.pig.ResourceSchema
 
equals(Object) - Method in class org.apache.pig.ResourceStatistics
 
equals(Object) - Method in class org.apache.pig.ResourceStatistics.ResourceFieldStatistics
 
equals(Object) - Method in class org.apache.pig.SortColInfo
 
equals(Object) - Method in class org.apache.pig.SortInfo
 
EqualToExpr - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
 
EqualToExpr(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.EqualToExpr
 
EqualToExpr(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.EqualToExpr
 
EquivalenceClasses - Class in org.apache.pig.pen
 
EquivalenceClasses() - Constructor for class org.apache.pig.pen.EquivalenceClasses
 
ERROR - Static variable in class org.apache.pig.data.DataType
 
ERROR - Static variable in exception org.apache.pig.PigException
 
errorCode - Variable in exception org.apache.pig.PigException
 
errorInMap - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
 
errorInReduce - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce.Reduce
 
errorSource - Variable in exception org.apache.pig.PigException
 
EvalFunc<T> - Class in org.apache.pig
The class is used to implement functions to be applied to a dataset.
EvalFunc() - Constructor for class org.apache.pig.EvalFunc
 
evaluateIsolatedOperator(LOCogroup, List<DataBag>) - Method in class org.apache.pig.pen.DerivedDataVisitor
 
evaluateIsolatedOperator(LOCogroup) - Method in class org.apache.pig.pen.DerivedDataVisitor
 
ExampleGenerator - Class in org.apache.pig.pen
 
ExampleGenerator(LogicalPlan, PigContext) - Constructor for class org.apache.pig.pen.ExampleGenerator
 
ExampleTuple - Class in org.apache.pig.pen.util
 
ExampleTuple() - Constructor for class org.apache.pig.pen.util.ExampleTuple
 
ExampleTuple(Tuple) - Constructor for class org.apache.pig.pen.util.ExampleTuple
 
exec() - Method in class org.apache.pig.backend.hadoop.streaming.HadoopExecutableManager
 
exec(Tuple) - Method in class org.apache.pig.builtin.ARITY
 
exec(Tuple) - Method in class org.apache.pig.builtin.AVG
 
exec(Tuple) - Method in class org.apache.pig.builtin.AVG.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AVG.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.AVG.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.BagSize
 
exec(Tuple) - Method in class org.apache.pig.builtin.CONCAT
 
exec(Tuple) - Method in class org.apache.pig.builtin.ConstantSize
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT_STAR
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT_STAR.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT_STAR.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.COUNT_STAR.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DIFF
Compares a tuple with two fields.
exec(Tuple) - Method in class org.apache.pig.builtin.Distinct
 
exec(Tuple) - Method in class org.apache.pig.builtin.Distinct.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.Distinct.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.Distinct.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleAvg
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleAvg.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleAvg.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleAvg.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMax
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMax.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMax.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMax.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMin
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMin.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMin.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleMin.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleSum
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleSum.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleSum.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleSum.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatAvg
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatAvg.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatAvg.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatAvg.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMax
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMax.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMax.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMax.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMin
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMin.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMin.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatMin.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatSum
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatSum.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatSum.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatSum.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntAvg
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntAvg.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntAvg.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntAvg.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMax
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMax.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMax.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMax.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMin
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMin.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMin.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntMin.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntSum
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntSum.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntSum.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.IntSum.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.IsEmpty
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongAvg
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongAvg.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongAvg.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongAvg.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMax
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMax.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMax.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMax.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMin
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMin.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMin.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongMin.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongSum
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongSum.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongSum.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongSum.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.MapSize
 
exec(Tuple) - Method in class org.apache.pig.builtin.MAX
 
exec(Tuple) - Method in class org.apache.pig.builtin.MAX.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.MAX.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.MAX.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.MIN
 
exec(Tuple) - Method in class org.apache.pig.builtin.MIN.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.MIN.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.MIN.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.RANDOM
 
exec(Tuple) - Method in class org.apache.pig.builtin.SIZE
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringConcat
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMax
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMax.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMax.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMax.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMin
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMin.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMin.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringMin.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.StringSize
 
exec(Tuple) - Method in class org.apache.pig.builtin.SUM
 
exec(Tuple) - Method in class org.apache.pig.builtin.SUM.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.SUM.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.SUM.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOKENIZE
 
exec(Tuple) - Method in class org.apache.pig.builtin.TupleSize
 
exec(Tuple) - Method in class org.apache.pig.EvalFunc
This callback method must be implemented by all subclasses.
exec(Tuple) - Method in class org.apache.pig.impl.builtin.FindQuantiles
first field in the input tuple is the number of quantiles to generate second field is the *sorted* bag of samples
exec(Tuple) - Method in class org.apache.pig.impl.builtin.GetMemNumRows
 
exec(Tuple) - Method in class org.apache.pig.impl.builtin.GFAny
 
exec(Tuple) - Method in class org.apache.pig.impl.builtin.GFCross
 
exec(Tuple) - Method in class org.apache.pig.impl.builtin.GFReplicate
 
exec(Tuple) - Method in class org.apache.pig.impl.builtin.PartitionSkewedKeys
first field in the input tuple is the number of reducers second field is the *sorted* bag of samples this should be called only once
exec() - Method in class org.apache.pig.impl.streaming.ExecutableManager
Start execution of the external process.
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.convert.CustomFormatToISO
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.convert.ISOToUnix
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.convert.UnixToISO
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.DiffDate
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.decode.Bin
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.decode.BinCond
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.decode.Decode
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.ABS
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.copySign
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleAbs
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleBase
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleCopySign
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleDoubleBase
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleGetExponent
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleMax
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleMin
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleNextAfter
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleNextup
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleRound
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleSignum
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.DoubleUlp
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatAbs
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatCopySign
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatGetExponent
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatMax
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatMin
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatNextAfter
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatNextup
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatRound
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatSignum
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.FloatUlp
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.getExponent
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.IntAbs
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.IntMax
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.IntMin
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.LongAbs
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.LongMax
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.LongMin
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.MAX
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.MIN
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.nextAfter
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.NEXTUP
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.RANDOM
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.ROUND
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.SCALB
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.SIGNUM
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.math.ULP
java level API
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField.Final
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField.Initial
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COR
Function to compute correlation between data sets.
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COR.Final
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COR.Initial
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COR.Intermed
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COV
Function to compute covariance between data sets.
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COV.Final
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COV.Initial
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.stats.COV.Intermed
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.HashFNV
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.HashFNV1
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.HashFNV2
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.INDEXOF
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.LASTINDEXOF
Finds the last location of a substring in a given string.
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.LcFirst
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.LENGTH
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.LookupInFiles
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.LOWER
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.RegexExtract
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.RegexExtractAll
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.RegexMatch
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.REPLACE
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.Reverse
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.Split
Wrapper around Java's String.split
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.SUBSTRING
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.Trim
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.UcFirst
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.string.UPPER
Upper-cases an input string.
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.DateExtractor
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.HostExtractor
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.SearchEngineExtractor
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.SearchTermExtractor
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.SearchQuery
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.Top
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.Top.Final
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.Top.Initial
 
exec(Tuple) - Method in class org.apache.pig.piggybank.evaluation.util.Top.Intermed
 
exec() - Method in class org.apache.pig.tools.grunt.Grunt
 
ExecException - Exception in org.apache.pig.backend.executionengine
 
ExecException() - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with null as the error message.
ExecException(String) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(Throwable) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified cause.
ExecException(String, Throwable) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int, Throwable) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int, byte) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int, byte, Throwable) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int, boolean) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int, byte, boolean) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message and cause.
ExecException(String, int, byte, boolean, String) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
ExecException(String, int, byte, boolean, String, Throwable) - Constructor for exception org.apache.pig.backend.executionengine.ExecException
Create a new ExecException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
ExecJob - Interface in org.apache.pig.backend.executionengine
Abstraction on a job that the execution engine runs.
ExecJob.JOB_STATUS - Enum in org.apache.pig.backend.executionengine
 
ExecPhysicalOperator - Interface in org.apache.pig.backend.executionengine
 
ExecPhysicalPlan - Interface in org.apache.pig.backend.executionengine
 
ExecScopedLogicalOperator - Interface in org.apache.pig.backend.executionengine
 
ExecTools - Class in org.apache.pig.backend.executionengine.util
A collection of static methods for use by the executionengine implementations.
ExecTools() - Constructor for class org.apache.pig.backend.executionengine.util.ExecTools
 
ExecType - Enum in org.apache.pig
The type of query execution
ExecutableManager - Class in org.apache.pig.impl.streaming
ExecutableManager manages an external executable which processes data in a Pig query.
ExecutableManager() - Constructor for class org.apache.pig.impl.streaming.ExecutableManager
Create a new ExecutableManager.
execute(PhysicalPlan, String) - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
Execute the physical plan in blocking mode.
execute(PhysicalPlan, String) - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
execute(LogicalRelationalOperator) - Method in class org.apache.pig.experimental.logical.optimizer.AllSameVisitor
Method to call on every node in the logical plan.
execute(String) - Method in class org.apache.pig.tools.grunt.Command
 
executeBatch() - Method in class org.apache.pig.PigServer
Submits a batch of Pig commands for execution.
ExecutionEngine - Interface in org.apache.pig.backend.executionengine
TODO: provide a manner to generate/collect logging information for DBG purposes TODO: add keys for properties/statistics
exists(FileSystem, Path) - Static method in class org.apache.hadoop.zebra.types.CGSchema
 
exists() - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
Checks whether the entity exists or not
exists() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
existsFile(String) - Method in class org.apache.pig.PigServer
 
exitCode - Variable in class org.apache.pig.impl.streaming.ExecutableManager
 
EXP - Class in org.apache.pig.piggybank.evaluation.math
math.EXP implements a binding to the Java function Math.exp(double).
EXP() - Constructor for class org.apache.pig.piggybank.evaluation.math.EXP
 
explain(OutputStream) - Method in interface org.apache.pig.backend.executionengine.ExecPhysicalPlan
To provide an "explanation" about how the physical plan has been constructed
explain(PhysicalPlan, PrintStream, String, boolean) - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
Explain executor specific information.
explain(PhysicalPlan, PrintStream, String, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
explain(PhysicalPlan, PigContext, PrintStream, String, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
Explain how a pig job will be executed on the underlying infrastructure.
explain(PhysicalPlan, PigContext, PrintStream, String, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
 
explain(OutputStream) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
Write a visual representation of the Physical Plan into the given output stream
explain(OutputStream, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
Write a visual representation of the Physical Plan into the given output stream
explain(PrintStream, String, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
Write a visual representation of the Physical Plan into the given printstream
explain(PrintStream, String, boolean) - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
 
explain(OutputStream, PrintStream) - Method in class org.apache.pig.impl.logicalLayer.LogicalPlan
 
explain(PrintStream, String, boolean) - Method in class org.apache.pig.impl.logicalLayer.LogicalPlan
 
explain(OutputStream, PrintStream) - Method in class org.apache.pig.impl.plan.OperatorPlan
 
explain(OutputStream, PrintStream) - Method in class org.apache.pig.impl.plan.optimizer.RulePlan
 
explain(String, PrintStream) - Method in class org.apache.pig.PigServer
Provide information on how a pig query will be executed.
explain(String, String, boolean, boolean, PrintStream, PrintStream, PrintStream) - Method in class org.apache.pig.PigServer
Provide information on how a pig query will be executed.
explainCurrentBatch() - Method in class org.apache.pig.tools.grunt.GruntParser
 
EXPM1 - Class in org.apache.pig.piggybank.evaluation.math
math.EXPM1 implements a binding to the Java function Math.expm1(double).
EXPM1() - Constructor for class org.apache.pig.piggybank.evaluation.math.EXPM1
 
expr - Variable in class org.apache.hadoop.zebra.pig.comparator.BagExpr
 
expr - Variable in class org.apache.hadoop.zebra.pig.comparator.NegateExpr
 
Expression - Class in org.apache.pig
A class to communicate Filter expressions to LoadFuncs
Expression() - Constructor for class org.apache.pig.Expression
 
Expression.BinaryExpression - Class in org.apache.pig
 
Expression.BinaryExpression(Expression, Expression, Expression.OpType) - Constructor for class org.apache.pig.Expression.BinaryExpression
 
Expression.Column - Class in org.apache.pig
 
Expression.Column(String) - Constructor for class org.apache.pig.Expression.Column
 
Expression.Const - Class in org.apache.pig
 
Expression.Const(Object) - Constructor for class org.apache.pig.Expression.Const
 
Expression.OpType - Enum in org.apache.pig
 
ExpressionOperator - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
A base class for all types of expressions.
ExpressionOperator(OperatorKey) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
 
ExpressionOperator(OperatorKey, int) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
 
ExpressionOperator - Class in org.apache.pig.impl.logicalLayer
 
ExpressionOperator(LogicalPlan, OperatorKey, int) - Constructor for class org.apache.pig.impl.logicalLayer.ExpressionOperator
 
ExpressionOperator(LogicalPlan, OperatorKey) - Constructor for class org.apache.pig.impl.logicalLayer.ExpressionOperator
 
exprOpsMap - Variable in class org.apache.pig.experimental.logical.LogicalPlanMigrationVistor.LogicalExpPlanMigrationVistor
 
exprPlan - Variable in class org.apache.pig.experimental.logical.LogicalPlanMigrationVistor.LogicalExpPlanMigrationVistor
 
exprs - Variable in class org.apache.hadoop.zebra.pig.comparator.TupleExpr
 
exprToString(ComparatorExpr) - Static method in class org.apache.hadoop.zebra.pig.comparator.ExprUtils
Converting an expression to a string.
ExprUtils - Class in org.apache.hadoop.zebra.pig.comparator
 
ExprUtils() - Constructor for class org.apache.hadoop.zebra.pig.comparator.ExprUtils
 
exprVisitor - Variable in class org.apache.pig.experimental.logical.optimizer.AllExpressionVisitor
 
ExpToPhyTranslationVisitor - Class in org.apache.pig.experimental.logical.expression
 
ExpToPhyTranslationVisitor(OperatorPlan, LogicalRelationalOperator, PhysicalPlan, Map<Operator, PhysicalOperator>) - Constructor for class org.apache.pig.experimental.logical.expression.ExpToPhyTranslationVisitor
 
ExpToPhyTranslationVisitor(OperatorPlan, PlanWalker, LogicalRelationalOperator, PhysicalPlan, Map<Operator, PhysicalOperator>) - Constructor for class org.apache.pig.experimental.logical.expression.ExpToPhyTranslationVisitor
 
extractDayDate(String) - Static method in class org.apache.pig.piggybank.storage.hiverc.HiveRCSchemaUtil
Extract the date from the hive file names e.g /user/hive/warehouse/table/daydate=2009-10-01/upload001/0002.dat
This method will extract the 2009-10-01 from this name.
extractPigTypeFromHiveType(Object) - Static method in class org.apache.pig.piggybank.storage.hiverc.HiveRCSchemaUtil
Converts from a hive type to a pig type
extraJars - Variable in class org.apache.pig.impl.PigContext
 

F

failedStores - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
 
falseRef - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
 
fieldNames() - Method in class org.apache.pig.ResourceSchema
 
fields - Variable in class org.apache.pig.ResourceStatistics
 
FILE_SYSTEM_NAME - Static variable in class org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil
 
fileExists(String, PigContext) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
fileExists(String, DataStorage) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
FileInputHandler - Class in org.apache.pig.impl.streaming
FileInputHandler handles the input for the Pig-Streaming executable in an asynchronous manner by feeding it input via an external file specified by the user.
FileInputHandler(StreamingCommand.HandleSpec) - Constructor for class org.apache.pig.impl.streaming.FileInputHandler
 
FileInputLoadFunc - Class in org.apache.pig
This class provides an implementation of OrderedLoadFunc interface which can be optionally re-used by LoadFuncs that use FileInputFormat, by having this as a super class
FileInputLoadFunc() - Constructor for class org.apache.pig.FileInputLoadFunc
 
FileLocalizer - Class in org.apache.pig.impl.io
 
FileLocalizer() - Constructor for class org.apache.pig.impl.io.FileLocalizer
 
FileLocalizer.DataStorageInputStreamIterator - Class in org.apache.pig.impl.io
 
FileLocalizer.DataStorageInputStreamIterator(ElementDescriptor[]) - Constructor for class org.apache.pig.impl.io.FileLocalizer.DataStorageInputStreamIterator
 
filename - Variable in class org.apache.pig.FileSplitComparable
 
FileOutputHandler - Class in org.apache.pig.impl.streaming
FileOutputHandler handles the output from the Pig-Streaming executable in an asynchronous manner by reading it from an external file specified by the user.
FileOutputHandler(StreamingCommand.HandleSpec) - Constructor for class org.apache.pig.impl.streaming.FileOutputHandler
 
fileSize(String) - Method in class org.apache.pig.PigServer
Returns the length of a file in bytes which exists in the HDFS (accounts for replication).
FileSpec - Class in org.apache.pig.impl.io
A simple class that specifies a file name and storage function which is used to read/write it
FileSpec(String, FuncSpec) - Constructor for class org.apache.pig.impl.io.FileSpec
 
FileSplitComparable - Class in org.apache.pig
This class can be used to represent a relative position in a file.
FileSplitComparable() - Constructor for class org.apache.pig.FileSplitComparable
 
FileSplitComparable(String, long) - Constructor for class org.apache.pig.FileSplitComparable
 
FilterAboveForeach - Class in org.apache.pig.experimental.logical.rules
This Rule moves Filter Above Foreach.
FilterAboveForeach(String) - Constructor for class org.apache.pig.experimental.logical.rules.FilterAboveForeach
 
FilterAboveForeach.FilterAboveForEachTransformer - Class in org.apache.pig.experimental.logical.rules
 
FilterAboveForeach.FilterAboveForEachTransformer() - Constructor for class org.apache.pig.experimental.logical.rules.FilterAboveForeach.FilterAboveForEachTransformer
 
FilterFunc - Class in org.apache.pig
 
FilterFunc() - Constructor for class org.apache.pig.FilterFunc
 
FINAL - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
finalize() - Method in class org.apache.pig.data.DefaultAbstractBag
Need to override finalize to clean out the mSpillFiles array.
finalize() - Method in class org.apache.pig.data.InternalCachedBag
 
findContainingJar(Class) - Static method in class org.apache.pig.impl.util.JarManager
Find a jar that contains a class of the same name, if any.
findField(long) - Method in class org.apache.pig.experimental.logical.relational.LogicalSchema
Look for the index of the field that contains the specified uid
findMetaFile(String, String, Configuration) - Method in class org.apache.pig.piggybank.storage.JsonMetadata
.
findPigDataType(String) - Static method in class org.apache.pig.piggybank.storage.hiverc.HiveRCSchemaUtil
Returns the pig DataType for the hive type
FindQuantiles - Class in org.apache.pig.impl.builtin
 
FindQuantiles() - Constructor for class org.apache.pig.impl.builtin.FindQuantiles
 
FindQuantiles(String[]) - Constructor for class org.apache.pig.impl.builtin.FindQuantiles
 
findReferent(LogicalRelationalOperator) - Method in class org.apache.pig.experimental.logical.expression.ProjectExpression
Find the LogicalRelationalOperator that this projection refers to.
findType(Object) - Static method in class org.apache.pig.data.DataType
Determine the datatype of an object.
findType(Type) - Static method in class org.apache.pig.data.DataType
Given a Type object determine the data type it represents.
findTypeName(ColumnType) - Static method in enum org.apache.hadoop.zebra.schema.ColumnType
Get the Zebra type name for the passed in Zebra column type
findTypeName(Object) - Static method in class org.apache.pig.data.DataType
Get the type name.
findTypeName(byte) - Static method in class org.apache.pig.data.DataType
Get the type name from the type byte code
finish() - Method in class org.apache.hadoop.zebra.io.BasicTable.Writer
Release resources used by the object.
finish() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
finish() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
finish() - Method in class org.apache.pig.EvalFunc
Placeholder for cleanup to be performed at the end.
finish() - Method in class org.apache.pig.FilterFunc
Placeholder for cleanup to be performed at the end.
first - Variable in class org.apache.pig.impl.util.Pair
 
FixedLengthPrimitive - Class in org.apache.hadoop.zebra.pig.comparator
Helper class for fixed length primitives
FixedLengthPrimitive(int, int) - Constructor for class org.apache.hadoop.zebra.pig.comparator.FixedLengthPrimitive
Constructor
fixUpContainedPlans(LogicalOperator, LogicalOperator, LogicalOperator, Map<Integer, Integer>) - Method in class org.apache.pig.impl.logicalLayer.optimizer.LogicalTransformer
Once a node has been inserted, inner plans associated with other nodes may have references to the node that has been replaced or moved.
FLOAT - Static variable in class org.apache.pig.data.DataType
 
FloatAbs - Class in org.apache.pig.piggybank.evaluation.math
math.ABS implements a binding to the Java function Math.abs(float) for computing the absolute value of the argument.
FloatAbs() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatAbs
 
FloatAvg - Class in org.apache.pig.builtin
Generates the average of the values of the first field of a tuple.
FloatAvg() - Constructor for class org.apache.pig.builtin.FloatAvg
 
FloatAvg.Final - Class in org.apache.pig.builtin
 
FloatAvg.Final() - Constructor for class org.apache.pig.builtin.FloatAvg.Final
 
FloatAvg.Initial - Class in org.apache.pig.builtin
 
FloatAvg.Initial() - Constructor for class org.apache.pig.builtin.FloatAvg.Initial
 
FloatAvg.Intermediate - Class in org.apache.pig.builtin
 
FloatAvg.Intermediate() - Constructor for class org.apache.pig.builtin.FloatAvg.Intermediate
 
FloatCopySign - Class in org.apache.pig.piggybank.evaluation.math
math.copySign implements a binding to the Java function Math.copySign(float,float).
FloatCopySign() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatCopySign
 
FloatExpr - Class in org.apache.hadoop.zebra.pig.comparator
 
FloatExpr(int) - Constructor for class org.apache.hadoop.zebra.pig.comparator.FloatExpr
 
FloatGetExponent - Class in org.apache.pig.piggybank.evaluation.math
math.getExponent implements a binding to the Java function Math.getExponent(double).
FloatGetExponent() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatGetExponent
 
FloatMax - Class in org.apache.pig.builtin
Generates the max of the values of the first field of a tuple.
FloatMax() - Constructor for class org.apache.pig.builtin.FloatMax
 
FloatMax - Class in org.apache.pig.piggybank.evaluation.math
math.max implements a binding to the Java function Math.max(int,int) for computing the the max value of the arguments.
FloatMax() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatMax
 
FloatMax.Final - Class in org.apache.pig.builtin
 
FloatMax.Final() - Constructor for class org.apache.pig.builtin.FloatMax.Final
 
FloatMax.Initial - Class in org.apache.pig.builtin
 
FloatMax.Initial() - Constructor for class org.apache.pig.builtin.FloatMax.Initial
 
FloatMax.Intermediate - Class in org.apache.pig.builtin
 
FloatMax.Intermediate() - Constructor for class org.apache.pig.builtin.FloatMax.Intermediate
 
FloatMin - Class in org.apache.pig.builtin
Generates the min of the Float values in the first field of a tuple.
FloatMin() - Constructor for class org.apache.pig.builtin.FloatMin
 
FloatMin - Class in org.apache.pig.piggybank.evaluation.math
math.min implements a binding to the Java function Math.min(int,int) for computing the the min value of the arguments.
FloatMin() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatMin
 
FloatMin.Final - Class in org.apache.pig.builtin
 
FloatMin.Final() - Constructor for class org.apache.pig.builtin.FloatMin.Final
 
FloatMin.Initial - Class in org.apache.pig.builtin
 
FloatMin.Initial() - Constructor for class org.apache.pig.builtin.FloatMin.Initial
 
FloatMin.Intermediate - Class in org.apache.pig.builtin
 
FloatMin.Intermediate() - Constructor for class org.apache.pig.builtin.FloatMin.Intermediate
 
FloatNextAfter - Class in org.apache.pig.piggybank.evaluation.math
math.nextAfter implements a binding to the Java function Math.nextAfter(double,double).
FloatNextAfter() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatNextAfter
 
FloatNextup - Class in org.apache.pig.piggybank.evaluation.math
math.NEXTUP implements a binding to the Java function Math.nextUp(double).
FloatNextup() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatNextup
 
FloatRound - Class in org.apache.pig.piggybank.evaluation.math
math.ROUND implements a binding to the Java function Math.round(float).
FloatRound() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatRound
 
FloatSignum - Class in org.apache.pig.piggybank.evaluation.math
math.SIGNUM implements a binding to the Java function Math.signum(float).
FloatSignum() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatSignum
 
FloatSum - Class in org.apache.pig.builtin
Generates the sum of the Float values in the first field of a tuple.
FloatSum() - Constructor for class org.apache.pig.builtin.FloatSum
 
FloatSum.Final - Class in org.apache.pig.builtin
 
FloatSum.Final() - Constructor for class org.apache.pig.builtin.FloatSum.Final
 
FloatSum.Initial - Class in org.apache.pig.builtin
 
FloatSum.Initial() - Constructor for class org.apache.pig.builtin.FloatSum.Initial
 
FloatSum.Intermediate - Class in org.apache.pig.builtin
 
FloatSum.Intermediate() - Constructor for class org.apache.pig.builtin.FloatSum.Intermediate
 
FloatUlp - Class in org.apache.pig.piggybank.evaluation.math
math.ULP implements a binding to the Java function Math.ulp(float).
FloatUlp() - Constructor for class org.apache.pig.piggybank.evaluation.math.FloatUlp
 
FLOOR - Class in org.apache.pig.piggybank.evaluation.math
math.FLOOR implements a binding to the Java function Math.floor(double).
FLOOR() - Constructor for class org.apache.pig.piggybank.evaluation.math.FLOOR
 
forceSchema(Schema) - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
Directly force the schema without reconcilation Please use with great care
format(DataBag) - Static method in class org.apache.pig.impl.util.BagFormat
 
format(Tuple) - Static method in class org.apache.pig.impl.util.TupleFormat
Default implementation of format of tuple (each filed is delimited by tab)
formatTuple(Tuple, int) - Static method in class org.apache.hadoop.zebra.types.TypesUtils
Checking and formatting an input tuple to conform to the input schema.
The current implementation always create a new tuple because PIG expects Slice.next(tuple) always returning a brand new tuple.
foundAnyCast() - Method in class org.apache.pig.impl.logicalLayer.CastFinder
 
foundAnyUDF() - Method in class org.apache.pig.impl.logicalLayer.UDFFinder
 
fromEdges - Variable in class org.apache.pig.experimental.plan.BaseOperatorPlan
 
FrontendException - Exception in org.apache.pig.impl.logicalLayer
 
FrontendException() - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with null as the error message.
FrontendException(String) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified cause.
FrontendException(String, Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int, Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int, byte) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int, byte, Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int, boolean) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int, byte, boolean) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(String, int, byte, boolean, String) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
FrontendException(String, int, byte, boolean, String, Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message, error code, error source, retriable or not, detalied message for the developer and cause.
fs - Variable in class org.apache.pig.backend.hadoop.datastorage.HPath
 
fullPath(String, DataStorage) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
fullPath(String, PigContext) - Static method in class org.apache.pig.impl.io.FileLocalizer
 
FuncSpec - Class in org.apache.pig
Class to represent a UDF specification - essentially encapsulates the class name and the arguments to the constructor
FuncSpec(String, String) - Constructor for class org.apache.pig.FuncSpec
 
FuncSpec(String, String[]) - Constructor for class org.apache.pig.FuncSpec
 
FuncSpec(String, String[], Schema) - Constructor for class org.apache.pig.FuncSpec
 
FuncSpec(String) - Constructor for class org.apache.pig.FuncSpec
 
FuncSpec(String, Schema) - Constructor for class org.apache.pig.FuncSpec
 
FunctionalLogicalOptimizer - Class in org.apache.pig.pen.util
 
FunctionalLogicalOptimizer(LogicalPlan) - Constructor for class org.apache.pig.pen.util.FunctionalLogicalOptimizer
 
FunctionInstantiator - Interface in org.apache.pig.impl
 

G

genAllTypes() - Static method in class org.apache.pig.data.DataType
 
generateDefaultCGSchema(String, String, String, String, String, short, int, String) - Method in class org.apache.hadoop.zebra.types.Partition
 
generateDefaultCGSchema(String, String, String, String, String, short, int, String) - Method in class org.apache.hadoop.zebra.types.Partition.PartitionInfo
 
generateKey(Tuple) - Method in class org.apache.hadoop.zebra.pig.comparator.KeyGenerator
Generate the binary key for the input tuple
generateNestedSchema(byte, byte...) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
GENERIC_WRITABLECOMPARABLE - Static variable in class org.apache.pig.data.DataType
 
genNameToTypeMap() - Static method in class org.apache.pig.data.DataType
 
genOpKey(String) - Static method in class org.apache.pig.impl.plan.OperatorKey
Utility function for creating operator keys.
genSubstitutedFile(BufferedReader, Writer, String[], String[]) - Method in class org.apache.pig.tools.parameters.ParameterSubstitutionPreprocessor
This is the main API that takes script template and produces pig script
genTypeToNameMap() - Static method in class org.apache.pig.data.DataType
 
get(BytesWritable, BytesWritable) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Copy the key and value in one shot into BytesWritables.
get(DataInputStream, Tuple) - Method in class org.apache.hadoop.zebra.types.TypesUtils.TupleReader
Read a tuple from the stream, and perform projection.
get() - Method in class org.apache.pig.backend.hadoop.DoubleWritable
 
get() - Method in class org.apache.pig.data.DataByteArray
Get the underlying byte array.
get(int) - Method in class org.apache.pig.data.DefaultTuple
Get the value in a given field.
get(int) - Method in class org.apache.pig.data.TargetedTuple
 
get(int) - Method in interface org.apache.pig.data.Tuple
Get the value in a given field.
get(int) - Method in class org.apache.pig.impl.plan.CompilationMessageCollector
 
get(K) - Method in class org.apache.pig.impl.util.MultiMap
Get the collection of values associated with a given key.
get(int) - Method in class org.apache.pig.pen.util.ExampleTuple
 
getAbsolutePath(String, Path) - Static method in class org.apache.pig.LoadFunc
Construct the absolute path from the file location and the current directory.
getActiveContainer() - Method in interface org.apache.pig.backend.datastorage.DataStorage
 
getActiveContainer() - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
getActiveSplit() - Static method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat
 
getAddedFields() - Method in class org.apache.pig.impl.plan.ProjectionMap
 
getAggregate() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigHadoopLogger
 
getAlias() - Method in interface org.apache.pig.backend.executionengine.ExecJob
Returns the alias of relation generated by this job
getAlias() - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
getAlias() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getAlias() - Method in class org.apache.pig.experimental.logical.relational.LogicalRelationalOperator
Get the alias of this operator.
getAlias() - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
 
getAlias() - Method in class org.apache.pig.LoadPushDown.RequiredField
 
getAliases() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
getAliases() - Method in class org.apache.pig.PigServer
 
getAliasKeySet() - Method in class org.apache.pig.PigServer
 
getAll() - Method in class org.apache.pig.data.DefaultTuple
Get all of the fields in the tuple as a list.
getAll() - Method in class org.apache.pig.data.TargetedTuple
 
getAll() - Method in interface org.apache.pig.data.Tuple
Get all of the fields in the tuple as a list.
getAll() - Method in class org.apache.pig.pen.util.ExampleTuple
 
getAllFileRecursively(List<FileStatus>, Configuration) - Static method in class org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil
Get all files recursively from the given list of files
getAllMatches() - Method in class org.apache.pig.impl.plan.optimizer.RuleMatcher
 
getAmendKey() - Method in class org.apache.pig.data.AmendableTuple
 
getAnnotation(String) - Method in class org.apache.pig.experimental.plan.Operator
Look to see if a node is annotated.
getArgStringFromSpec(String) - Static method in class org.apache.pig.FuncSpec
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.AVG
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.CONCAT
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MAX
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MIN
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SIZE
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SUM
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.TOKENIZE
 
getArgToFuncMapping() - Method in class org.apache.pig.EvalFunc
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.convert.CustomFormatToISO
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.convert.ISOToUnix
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.convert.UnixToISO
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISODaysBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOHoursBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOMinutesBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOMonthsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOSecondsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.diff.ISOYearsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.DiffDate
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToDay
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToHour
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMinute
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToMonth
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToSecond
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToWeek
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOToYear
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.ABS
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.copySign
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.DoubleBase
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.DoubleDoubleBase
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.getExponent
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.MAX
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.MIN
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.nextAfter
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.NEXTUP
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.ROUND
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.SCALB
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.SIGNUM
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.math.ULP
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.string.HashFNV
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.string.LOWER
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.string.RegexExtract
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.string.RegexExtractAll
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.string.RegexMatch
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.string.UPPER
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.DateExtractor
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.HostExtractor
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.SearchEngineExtractor
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.util.apachelogparser.SearchTermExtractor
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.util.SearchQuery
 
getArgToFuncMapping() - Method in class org.apache.pig.piggybank.evaluation.util.Top
 
getArguments() - Method in class org.apache.pig.experimental.logical.expression.UserFuncExpression
 
getArguments() - Method in class org.apache.pig.impl.logicalLayer.LOUserFunc
 
getAscendingCols() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getAscs() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.SortKeyInfo
 
getAtomicGroupByType() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
This can be used to get the merged type of output group col only when the group col is of atomic type TODO: This doesn't work with group by complex type
getAtomicGroupByType(LOCogroup) - Method in class org.apache.pig.impl.logicalLayer.validators.TypeCheckingVisitor
This can be used to get the merged type of output group col only when the group col is of atomic type TODO: This doesn't work with group by complex type
getAtomicJoinColType() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
This can be used to get the merged type of output join col only when the join col is of atomic type
getAttributes(MapReduceOper) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter
 
getAttributes(PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.DotPOPrinter
 
getAttributes(LogicalOperator) - Method in class org.apache.pig.impl.logicalLayer.DotLOPrinter
 
getAttributes(E) - Method in class org.apache.pig.impl.plan.DotPlanDumper
Used to generate the the attributes of a node
getAvgRecordSize() - Method in class org.apache.pig.ResourceStatistics
 
getBagColNum() - Method in class org.apache.pig.experimental.logical.expression.BagDereferenceExpression
Column number in the bag at column col this Dereference References.
getBagColumns() - Method in class org.apache.pig.experimental.logical.expression.BagDereferenceExpression
 
getBasePlan() - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
getBeginKey() - Method in class org.apache.hadoop.zebra.io.BasicTableStatus
Get the begin key.
getBinaryInputQueue() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
getBinaryOutputQueue() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
getBlockDistribution(BasicTable.Reader.RangeSplit) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Given a split range, calculate how the file data that fall into the range are distributed among hosts.
getBlockDistribution(BasicTable.Reader.RowSplit) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Given a row-based split, calculate how the file data that fall into the split are distributed among hosts.
getBlockDistribution(RawComparable) - Method in class org.apache.hadoop.zebra.io.KeyDistribution
 
getBuffer() - Method in class org.apache.hadoop.zebra.tfile.BoundedByteArrayOutputStream
Returns the underlying buffer.
getBytesWritten() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getCacheSpecs() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the list of files which need to be cached on the execute nodes.
getCanonicalMap() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
 
getCast() - Method in class org.apache.pig.impl.plan.ProjectionMap.Column
Check if the column is cast
getCastList() - Method in class org.apache.pig.impl.logicalLayer.CastFinder
 
getCastSet() - Method in class org.apache.pig.impl.logicalLayer.CastFinder
 
getCastType() - Method in class org.apache.pig.impl.plan.ProjectionMap.Column
Get the data type of the cast
getCGSchema(int) - Method in class org.apache.hadoop.zebra.types.Partition
 
getCGSchemas() - Method in class org.apache.hadoop.zebra.types.Partition
 
getChanges() - Method in class org.apache.pig.impl.plan.ProjectionMap
 
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator
Get the child expressions of this expression
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
Get the child expressions of this expression
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
Get the sub-expressions of this expression.
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
Get child expressions of this expression
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
Get child expression of this expression
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
Get child expressions of this expression
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
Get child expression of this expression
getChildExpressions() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.UnaryExpressionOperator
Get child expression of this expression
getClassForAlias(String) - Method in class org.apache.pig.impl.PigContext
 
getClassName() - Method in class org.apache.pig.FuncSpec
 
getClassNameFromSpec(String) - Static method in class org.apache.pig.FuncSpec
 
getClientSystemProps() - Method in class org.apache.pig.impl.util.UDFContext
Get the System Properties (Read only) as on the client machine from where Pig was launched.
getClonedPlan() - Method in class org.apache.pig.impl.logicalLayer.LogicalPlanCloneHelper
 
getClonedPlan() - Method in class org.apache.pig.impl.logicalLayer.LogicalPlanCloner
 
getCol() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getColIndex() - Method in class org.apache.pig.SortColInfo
 
getColMap() - Method in class org.apache.hadoop.zebra.types.Partition.PartitionInfo
 
getColName() - Method in class org.apache.pig.SortColInfo
 
getColNum() - Method in class org.apache.pig.experimental.logical.expression.ProjectExpression
Column number this project references.
getColNum() - Method in class org.apache.pig.experimental.logical.relational.LOInnerLoad
 
getColumn(String) - Method in class org.apache.hadoop.zebra.schema.Schema
get a column by name
getColumn(int) - Method in class org.apache.hadoop.zebra.schema.Schema
Get a particular column's schema
getColumn() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getColumnChains() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.SortKeyInfo
 
getColumnIndex(String) - Method in class org.apache.hadoop.zebra.schema.Schema
Get the index of the column for the input column name.
getColumnIndex(String, String) - Static method in class org.apache.hadoop.zebra.types.Projection
Get a column's index in a projection.
getColumnInfo(int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnChainInfo
 
getColumnInfos() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnChainInfo
 
getColumnName(int) - Method in class org.apache.hadoop.zebra.schema.Schema
 
getColumns() - Method in class org.apache.hadoop.zebra.schema.Schema
Get the names of the individual columns.
getColumns() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getColumns(LogicalSchema, Set<Long>) - Method in class org.apache.pig.experimental.logical.rules.ColumnPruneHelper
 
getColumnSchema(String) - Method in class org.apache.hadoop.zebra.schema.Schema
Get a column's schema
getColumnSchema(Schema.ParsedName) - Method in class org.apache.hadoop.zebra.schema.Schema
find the most fitting subcolumn containing the name: the parsed name is set after the field name plus any possible separator of '.' or '#'.
getColumnSchema(int) - Method in class org.apache.hadoop.zebra.types.Projection
Get a particular projected column's schema
getColumnSchemaOnParsedName(Schema.ParsedName) - Method in class org.apache.hadoop.zebra.schema.Schema
Get a subcolumn's schema and move the name just parsed into the next subtype
getCommand() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
Get the StreamingCommand for this StreamSpec.
getCommandArgs() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the parsed command arguments.
getCommandForAlias(String) - Method in class org.apache.pig.impl.PigContext
Get the StreamingCommand for the given alias.
getCommonNodes() - Method in class org.apache.pig.impl.plan.optimizer.CommonNodeFinder
 
getComparator() - Method in class org.apache.hadoop.zebra.mapred.ZebraSortInfo
 
getComparator() - Method in class org.apache.hadoop.zebra.mapreduce.ZebraSortInfo
 
getComparator() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get an instance of the RawComparator that is constructed based on the string comparator representation.
getComparator() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getComparator() - Method in class org.apache.hadoop.zebra.types.Partition
 
getComparator() - Method in class org.apache.hadoop.zebra.types.SortInfo
Get the comparator name
getComparator() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getComparatorName() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get the string representation of the comparator.
getComparisonPlan() - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
getCompleteness(LogicalOperator, Map<LogicalOperator, DataBag>, Map<LogicalOperator, Collection<IdentityHashSet<Tuple>>>, boolean) - Static method in class org.apache.pig.pen.util.MetricEvaluation
 
getCompressor() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getConciseness(LogicalOperator, Map<LogicalOperator, DataBag>, Map<LogicalOperator, Collection<IdentityHashSet<Tuple>>>, boolean) - Static method in class org.apache.pig.pen.util.MetricEvaluation
 
getCond() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
Get condition
getCond() - Method in class org.apache.pig.impl.logicalLayer.LOBinCond
 
getCondition() - Method in class org.apache.pig.experimental.logical.expression.BinCondExpression
Returns the operator which handles this condition
getConditionPlan() - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
getConf() - Method in class org.apache.hadoop.zebra.mapred.ZebraOutputPartition
 
getConf() - Method in class org.apache.hadoop.zebra.mapreduce.ZebraOutputPartition
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SecondaryKeyPartitioner
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SkewedPartitioner
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBytesRawComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigDoubleRawComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigFloatRawComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigIntRawComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigLongRawComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSecondaryKeyComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextRawComparator
 
getConf() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTupleRawComparator
 
getConf() - Method in class org.apache.pig.impl.PigContext
Deprecated. use PigContext.getProperties() instead
getConfiguration() - Method in interface org.apache.pig.backend.datastorage.DataStorage
Provides configuration information about the storage itself.
getConfiguration() - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
Retrieve configuration information for entity
getConfiguration() - Method in interface org.apache.pig.backend.executionengine.ExecJob
Get configuration information
getConfiguration() - Method in interface org.apache.pig.backend.executionengine.ExecPhysicalPlan
A job may have properties, like a priority, degree of parallelism...
getConfiguration() - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
Provides configuration information about the execution engine itself.
getConfiguration() - Method in class org.apache.pig.backend.hadoop.datastorage.HConfiguration
 
getConfiguration() - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
getConfiguration() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
getConfiguration() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
getConfiguration() - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
getConfiguration() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getCount() - Method in class org.apache.pig.impl.plan.optimizer.CommonNodeFinder
 
getCount() - Method in class org.apache.pig.pen.physicalOperators.POCounter
 
getCounts() - Method in class org.apache.pig.impl.util.LineageTracer
 
getCounts() - Method in class org.apache.pig.pen.util.LineageTracer
 
getCtorArgs() - Method in class org.apache.pig.FuncSpec
 
getCurrentKey() - Method in class org.apache.hadoop.zebra.mapreduce.TableRecordReader
 
getCurrentKey() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader
 
getCurrentKey() - Method in class org.apache.pig.impl.io.BinStorageRecordReader
 
getCurrentKey() - Method in class org.apache.pig.piggybank.storage.hiverc.HiveRCRecordReader
 
getCurrentKey() - Method in class org.apache.pig.piggybank.storage.XMLLoader.XMLFileRecordReader
 
getCurrentValue() - Method in class org.apache.hadoop.zebra.mapreduce.TableRecordReader
 
getCurrentValue() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader
 
getCurrentValue() - Method in class org.apache.pig.impl.io.BinStorageRecordReader
 
getCurrentValue() - Method in class org.apache.pig.piggybank.storage.hiverc.HiveRCRecordReader
 
getCurrentValue() - Method in class org.apache.pig.piggybank.storage.XMLLoader.XMLFileRecordReader
 
getDataStorage() - Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
 
getDataStorage() - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
 
getDataStorage() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
getDataStorage() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
getDefaultLogLevel() - Method in class org.apache.pig.impl.PigContext
 
getDeletedCGs() - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
 
getDescription() - Method in class org.apache.pig.ResourceSchema.ResourceFieldSchema
 
getDetailedMessage() - Method in exception org.apache.pig.PigException
Returns the detailed message used by developers for debugging
getDeterminedSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getDfs() - Method in class org.apache.pig.impl.PigContext
 
getDistinct(Tuple) - Method in class org.apache.pig.builtin.Distinct
 
getDistinctChanged() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.SecondaryKeyOptimizer
 
getDT() - Method in class org.apache.hadoop.zebra.schema.Schema.ParsedName
Get the column type
getEndKey() - Method in class org.apache.hadoop.zebra.io.BasicTableStatus
Get the end key.
getEnforcedSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getEntryComparator() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get a Comparator object to compare Entries.
getEntryCount() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get the number of key-value pair entries in TFile.
getEquivalenceClasses(LogicalOperator, Map<LogicalOperator, DataBag>) - Static method in class org.apache.pig.pen.EquivalenceClasses
 
getError(FileSpec) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
Get the exception that caused a failure on the backend for a store location (if any).
getErrorCode() - Method in exception org.apache.pig.PigException
Returns the error code of the exception
getErrorMessages(TaskReport[], String, boolean, PigContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
 
getErrorSource() - Method in class org.apache.pig.impl.PigContext
Check the execution mode and return the appropriate error source
getErrorSource() - Method in exception org.apache.pig.PigException
Returns the error source of the exception.
getExamples() - Method in class org.apache.pig.pen.ExampleGenerator
 
getExamples(String) - Method in class org.apache.pig.PigServer
 
getException() - Method in interface org.apache.pig.backend.executionengine.ExecJob
Get exceptions that happened during execution
getException() - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
getExecType() - Method in class org.apache.pig.impl.PigContext
Returns the type of execution currently in effect.
getExecutable() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the command to be executed.
getExecutableManager() - Method in class org.apache.pig.impl.logicalLayer.LOStream
 
getExecutionEngine() - Method in class org.apache.pig.impl.PigContext
 
getExponent - Class in org.apache.pig.piggybank.evaluation.math
math.getExponent implements a binding to the Java function Math.getExponent(double).
getExponent() - Constructor for class org.apache.pig.piggybank.evaluation.math.getExponent
 
getExpr() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.UnaryExpressionOperator
Get the contained expression.
getExpression() - Method in class org.apache.pig.experimental.logical.expression.UnaryExpression
Get the expression that this unary expression operators on.
getExpression() - Method in class org.apache.pig.impl.logicalLayer.LOCast
 
getExpression() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getExpression(ExpressionOperator) - Static method in class org.apache.pig.impl.logicalLayer.PColFilterExtractor
 
getExpressionPlans() - Method in class org.apache.pig.experimental.logical.relational.LOCogroup
 
getExpressionPlans() - Method in class org.apache.pig.experimental.logical.relational.LOJoin
Get all of the expressions plans that are in this join.
getFailedFiles() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
 
getFeatures() - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
getFeatures() - Method in class org.apache.pig.builtin.PigStorage
 
getFeatures() - Method in interface org.apache.pig.LoadPushDown
Determine the operators that can be pushed to the loader.
getFeatures() - Method in class org.apache.pig.piggybank.storage.HiveColumnarLoader
 
getField(String) - Method in class org.apache.pig.experimental.logical.relational.LogicalSchema
Fetch a field by alias
getField(int) - Method in class org.apache.pig.experimental.logical.relational.LogicalSchema
Fetch a field by field number
getField(String) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
Given an alias name, find the associated FieldSchema.
getField(int) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
Given a field number, find the associated FieldSchema.
getField(int) - Method in class org.apache.pig.impl.plan.RequiredFields
 
getFields() - Method in class org.apache.pig.experimental.logical.relational.LogicalSchema
Get all fields
getFields() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
getFields() - Method in class org.apache.pig.impl.plan.RequiredFields
 
getFields() - Method in class org.apache.pig.LoadPushDown.RequiredFieldList
 
getFields() - Method in class org.apache.pig.ResourceSchema
 
getFields() - Method in class org.apache.pig.ResourceStatistics
 
getFieldSchema() - Method in class org.apache.pig.experimental.logical.expression.MapLookupExpression
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.ExpressionOperator
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOAdd
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOAnd
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOBinCond
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOCast
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOConst
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LODivide
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOEqual
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOGreaterThan
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOGreaterThanEqual
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOIsNull
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLesserThan
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLesserThanEqual
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOMapLookup
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOMod
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOMultiply
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LONegative
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LONot
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LONotEqual
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOOr
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LORegexp
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOSubtract
 
getFieldSchema() - Method in class org.apache.pig.impl.logicalLayer.LOUserFunc
 
getFileName() - Method in class org.apache.pig.impl.io.FileSpec
 
getFileSpec() - Method in class org.apache.pig.experimental.logical.relational.LOLoad
 
getFilterPlan() - Method in class org.apache.pig.experimental.logical.relational.LOFilter
 
getFilterPlan() - Method in class org.apache.pig.experimental.logical.relational.LOSplitOutput
 
getFinal() - Method in interface org.apache.pig.Algebraic
 
getFinal() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getFinal() - Method in class org.apache.pig.builtin.AVG
 
getFinal() - Method in class org.apache.pig.builtin.COUNT
 
getFinal() - Method in class org.apache.pig.builtin.COUNT_STAR
 
getFinal() - Method in class org.apache.pig.builtin.Distinct
 
getFinal() - Method in class org.apache.pig.builtin.DoubleAvg
 
getFinal() - Method in class org.apache.pig.builtin.DoubleMax
 
getFinal() - Method in class org.apache.pig.builtin.DoubleMin
 
getFinal() - Method in class org.apache.pig.builtin.DoubleSum
 
getFinal() - Method in class org.apache.pig.builtin.FloatAvg
 
getFinal() - Method in class org.apache.pig.builtin.FloatMax
 
getFinal() - Method in class org.apache.pig.builtin.FloatMin
 
getFinal() - Method in class org.apache.pig.builtin.FloatSum
 
getFinal() - Method in class org.apache.pig.builtin.IntAvg
 
getFinal() - Method in class org.apache.pig.builtin.IntMax
 
getFinal() - Method in class org.apache.pig.builtin.IntMin
 
getFinal() - Method in class org.apache.pig.builtin.IntSum
 
getFinal() - Method in class org.apache.pig.builtin.LongAvg
 
getFinal() - Method in class org.apache.pig.builtin.LongMax
 
getFinal() - Method in class org.apache.pig.builtin.LongMin
 
getFinal() - Method in class org.apache.pig.builtin.LongSum
 
getFinal() - Method in class org.apache.pig.builtin.MAX
 
getFinal() - Method in class org.apache.pig.builtin.MIN
 
getFinal() - Method in class org.apache.pig.builtin.StringMax
 
getFinal() - Method in class org.apache.pig.builtin.StringMin
 
getFinal() - Method in class org.apache.pig.builtin.SUM
 
getFinal() - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField
 
getFinal() - Method in class org.apache.pig.piggybank.evaluation.stats.COR
 
getFinal() - Method in class org.apache.pig.piggybank.evaluation.stats.COV
 
getFinal() - Method in class org.apache.pig.piggybank.evaluation.util.Top
 
getFirstKey() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get the first key in the TFile.
getFirstLineFromMessage(String) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher
 
getFlatten() - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getFlatten() - Method in class org.apache.pig.impl.logicalLayer.LOGenerate
 
getFlattenedColumnMap() - Method in class org.apache.pig.impl.logicalLayer.optimizer.PushDownForeachFlatten
 
getFlattenFlags() - Method in class org.apache.pig.experimental.logical.relational.LOGenerate
 
getForEach() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POJoinPackage
 
getForEachPlans() - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getFormatMinSplitSize() - Method in class org.apache.pig.piggybank.storage.hiverc.HiveRCInputFormat
The input split size should never be smaller than the RCFile.SYNC_INTERVAL
getFragment() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
getFs() - Method in class org.apache.pig.impl.PigContext
 
getFuncName() - Method in class org.apache.pig.impl.io.FileSpec
 
getFuncSpec() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getFuncSpec() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getFuncSpec() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getFuncSpec() - Method in class org.apache.pig.experimental.logical.expression.CastExpression
Get the FuncSpec that performs the casting functionality
getFuncSpec() - Method in class org.apache.pig.experimental.logical.expression.UserFuncExpression
 
getFuncSpec() - Method in class org.apache.pig.impl.io.FileSpec
 
getFuncSpec() - Method in class org.apache.pig.impl.logicalLayer.LOUserFunc
 
getFuncSpecFromAlias(String) - Method in class org.apache.pig.impl.PigContext
 
getGeneratedInputUids() - Method in class org.apache.pig.experimental.logical.relational.LOCogroup
Returns an Unmodifiable Map of Input Number to Uid
getGeneratePlans() - Method in class org.apache.pig.impl.logicalLayer.LOGenerate
 
getGenerator() - Static method in class org.apache.pig.impl.plan.NodeIdGenerator
 
getGroup() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getGroupByPlans() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getGroupType() - Method in class org.apache.pig.experimental.logical.relational.LOCogroup
 
getGroupType() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getHandleSpecs(StreamingCommand.Handle) - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get specifications for the given Handle.
getHFS() - Method in class org.apache.pig.backend.hadoop.datastorage.HDataStorage
 
getHFS() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
getHosts(int) - Method in class org.apache.hadoop.zebra.io.BlockDistribution
Get up to n hosts that own the most bytes.
getId() - Method in interface org.apache.pig.backend.executionengine.ExecPhysicalOperator
 
getId() - Method in interface org.apache.pig.backend.executionengine.ExecScopedLogicalOperator
 
getId() - Method in class org.apache.pig.impl.plan.OperatorKey
 
getIndex() - Method in class org.apache.hadoop.zebra.schema.Schema.ColumnSchema
access function to get the column name
getIndex() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
getIndex() - Method in class org.apache.pig.impl.io.NullablePartitionWritable
 
getIndex() - Method in class org.apache.pig.impl.io.PigNullableWritable
 
getIndex(E) - Method in class org.apache.pig.impl.plan.OperatorPlan.IndexHelper
 
getIndex() - Method in class org.apache.pig.LoadPushDown.RequiredField
 
getIndexFile() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin
 
getInitial() - Method in interface org.apache.pig.Algebraic
 
getInitial() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getInitial() - Method in class org.apache.pig.builtin.AVG
 
getInitial() - Method in class org.apache.pig.builtin.COUNT
 
getInitial() - Method in class org.apache.pig.builtin.COUNT_STAR
 
getInitial() - Method in class org.apache.pig.builtin.Distinct
 
getInitial() - Method in class org.apache.pig.builtin.DoubleAvg
 
getInitial() - Method in class org.apache.pig.builtin.DoubleMax
 
getInitial() - Method in class org.apache.pig.builtin.DoubleMin
 
getInitial() - Method in class org.apache.pig.builtin.DoubleSum
 
getInitial() - Method in class org.apache.pig.builtin.FloatAvg
 
getInitial() - Method in class org.apache.pig.builtin.FloatMax
 
getInitial() - Method in class org.apache.pig.builtin.FloatMin
 
getInitial() - Method in class org.apache.pig.builtin.FloatSum
 
getInitial() - Method in class org.apache.pig.builtin.IntAvg
 
getInitial() - Method in class org.apache.pig.builtin.IntMax
 
getInitial() - Method in class org.apache.pig.builtin.IntMin
 
getInitial() - Method in class org.apache.pig.builtin.IntSum
 
getInitial() - Method in class org.apache.pig.builtin.LongAvg
 
getInitial() - Method in class org.apache.pig.builtin.LongMax
 
getInitial() - Method in class org.apache.pig.builtin.LongMin
 
getInitial() - Method in class org.apache.pig.builtin.LongSum
 
getInitial() - Method in class org.apache.pig.builtin.MAX
 
getInitial() - Method in class org.apache.pig.builtin.MIN
 
getInitial() - Method in class org.apache.pig.builtin.StringMax
 
getInitial() - Method in class org.apache.pig.builtin.StringMin
 
getInitial() - Method in class org.apache.pig.builtin.SUM
 
getInitial() - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField
 
getInitial() - Method in class org.apache.pig.piggybank.evaluation.stats.COR
 
getInitial() - Method in class org.apache.pig.piggybank.evaluation.stats.COV
 
getInitial() - Method in class org.apache.pig.piggybank.evaluation.util.Top
 
getInner() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
 
getInner() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
 
getInner() - Method in class org.apache.pig.experimental.logical.relational.LOCogroup
 
getInner() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getInnerFlags() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSkewedJoin
 
getInnerFlags() - Method in class org.apache.pig.experimental.logical.relational.LOJoin
 
getInnerFlags() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getInnerPlan() - Method in class org.apache.pig.experimental.logical.relational.LOForEach
 
getInnerPlansOf(int) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin
 
getInput() - Method in class org.apache.pig.impl.logicalLayer.LODistinct
 
getInput() - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
getInput() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
getInput() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getInputArgsSchema() - Method in class org.apache.pig.FuncSpec
 
getInputColumn() - Method in class org.apache.pig.impl.plan.ProjectionMap.Column
Get the mapped column details
getInputFile() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getInputFormat() - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
getInputFormat() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MergeJoinIndexer
 
getInputFormat() - Method in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
 
getInputFormat() - Method in class org.apache.pig.builtin.BinStorage
 
getInputFormat() - Method in class org.apache.pig.builtin.PigStorage
 
getInputFormat() - Method in class org.apache.pig.builtin.TextLoader
 
getInputFormat() - Method in class org.apache.pig.impl.builtin.DefaultIndexableLoader
 
getInputFormat() - Method in class org.apache.pig.impl.builtin.SampleLoader
 
getInputFormat() - Method in class org.apache.pig.impl.io.ReadToEndLoader
 
getInputFormat() - Method in class org.apache.pig.LoadFunc
This will be called during planning on the front end.
getInputFormat() - Method in class org.apache.pig.piggybank.storage.HiveColumnarLoader
 
getInputFormat() - Method in class org.apache.pig.piggybank.storage.RegExLoader
 
getInputFormat() - Method in class org.apache.pig.piggybank.storage.SequenceFileLoader
 
getInputFormat() - Method in class org.apache.pig.piggybank.storage.XMLLoader
 
getInputNum() - Method in class org.apache.pig.experimental.logical.expression.ProjectExpression
Input number this project references.
getInputPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
getInputPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POJoinPackage
 
getInputs() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getInputs() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getInputs() - Method in class org.apache.pig.impl.logicalLayer.LOCross
 
getInputs() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getInputs() - Method in class org.apache.pig.impl.logicalLayer.LOUnion
 
getInputSpec() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
 
getInputSpec() - Method in class org.apache.pig.impl.logicalLayer.LOStore
 
getInputSpec() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the input specification of the StreamingCommand.
getInputType() - Method in class org.apache.pig.impl.streaming.DefaultInputHandler
 
getInputType() - Method in class org.apache.pig.impl.streaming.FileInputHandler
 
getInputType() - Method in class org.apache.pig.impl.streaming.InputHandler
Get the handled InputType
getInsertBetween() - Method in class org.apache.pig.impl.logicalLayer.optimizer.PushDownForeachFlatten
 
getInserter(String, boolean) - Method in class org.apache.hadoop.zebra.io.BasicTable.Writer
Get a inserter with a given name.
getInstance() - Static method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigHadoopLogger
 
getInstance() - Static method in class org.apache.pig.data.BagFactory
Get a reference to the singleton factory.
getInstance() - Static method in class org.apache.pig.data.TupleFactory
Get a reference to the singleton factory.
getIntermed() - Method in interface org.apache.pig.Algebraic
 
getIntermed() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getIntermed() - Method in class org.apache.pig.builtin.AVG
 
getIntermed() - Method in class org.apache.pig.builtin.COUNT
 
getIntermed() - Method in class org.apache.pig.builtin.COUNT_STAR
 
getIntermed() - Method in class org.apache.pig.builtin.Distinct
 
getIntermed() - Method in class org.apache.pig.builtin.DoubleAvg
 
getIntermed() - Method in class org.apache.pig.builtin.DoubleMax
 
getIntermed() - Method in class org.apache.pig.builtin.DoubleMin
 
getIntermed() - Method in class org.apache.pig.builtin.DoubleSum
 
getIntermed() - Method in class org.apache.pig.builtin.FloatAvg
 
getIntermed() - Method in class org.apache.pig.builtin.FloatMax
 
getIntermed() - Method in class org.apache.pig.builtin.FloatMin
 
getIntermed() - Method in class org.apache.pig.builtin.FloatSum
 
getIntermed() - Method in class org.apache.pig.builtin.IntAvg
 
getIntermed() - Method in class org.apache.pig.builtin.IntMax
 
getIntermed() - Method in class org.apache.pig.builtin.IntMin
 
getIntermed() - Method in class org.apache.pig.builtin.IntSum
 
getIntermed() - Method in class org.apache.pig.builtin.LongAvg
 
getIntermed() - Method in class org.apache.pig.builtin.LongMax
 
getIntermed() - Method in class org.apache.pig.builtin.LongMin
 
getIntermed() - Method in class org.apache.pig.builtin.LongSum
 
getIntermed() - Method in class org.apache.pig.builtin.MAX
 
getIntermed() - Method in class org.apache.pig.builtin.MIN
 
getIntermed() - Method in class org.apache.pig.builtin.StringMax
 
getIntermed() - Method in class org.apache.pig.builtin.StringMin
 
getIntermed() - Method in class org.apache.pig.builtin.SUM
 
getIntermed() - Method in class org.apache.pig.piggybank.evaluation.MaxTupleBy1stField
 
getIntermed() - Method in class org.apache.pig.piggybank.evaluation.stats.COR
 
getIntermed() - Method in class org.apache.pig.piggybank.evaluation.stats.COV
 
getIntermed() - Method in class org.apache.pig.piggybank.evaluation.util.Top
 
getIsKeyWrappedList() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
Returns the list of booleans that indicates if the key needs to unwrapped for the corresponding plan.
getJobConf() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
getJobConf() - Method in class org.apache.pig.impl.util.UDFContext
Get the JobConf.
getJoinPlan(int) - Method in class org.apache.pig.experimental.logical.relational.LOJoin
 
getJoinPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
getJoinPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSkewedJoin
 
getJoinPlans() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getJoinType() - Method in class org.apache.pig.experimental.logical.relational.LOJoin
 
getJoinType() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
Returns the type of join.
getKey(BytesWritable) - Method in interface org.apache.hadoop.zebra.io.TableScanner
Get the row key.
getKey(BytesWritable) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Copy the key into BytesWritable.
getKey(byte[]) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Copy the key into user supplied buffer.
getKey(byte[], int) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Copy the key into user supplied buffer.
getKey() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
 
getKey() - Method in class org.apache.pig.impl.io.NullablePartitionWritable
 
getKeyAsTuple() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
 
getKeyDistribution(int, int, BlockDistribution) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Collect some key samples and use them to partition the table.
getKeyFromResult(List<Result>, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
getKeyInfo() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
 
getKeyLength() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Get the length of the key.
getKeyNear(long) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get a sample key that is within a block whose starting offset is greater than or equal to the specified offset.
getKeyPositionsInTuple() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCombinerPackage
 
getKeyPositionsInTuple() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
Get the field positions of key in the output tuples.
getKeys() - Method in class org.apache.hadoop.zebra.io.KeyDistribution
Get the list of sampling keys
getKeys() - Method in class org.apache.pig.impl.plan.MapKeysInfo
 
getKeys() - Method in class org.apache.pig.impl.plan.OperatorPlan
Get the map of operator key and associated operators
getKeyStream() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner.Entry
Streaming access to the key.
getKeyTuple() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
 
getKeyType() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigCombiner.Combine
 
getKeyType() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase
 
getKeyType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup
 
getKeyType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
getKeyType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
 
getKeyType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange
 
getKind() - Method in class org.apache.pig.impl.plan.CompilationMessageCollector.Message
 
getKindAggregate(CompilationMessageCollector.MessageType) - Method in class org.apache.pig.impl.plan.CompilationMessageCollector
 
getLastAlias() - Method in class org.apache.pig.impl.PigContext
 
getLastDataOffset() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
 
getLastKey() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get the last key in the TFile.
getLeaves() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
getLeaves() - Method in class org.apache.pig.impl.plan.OperatorPlan
Get a list of all nodes in the graph that are leaves.
getLength() - Method in class org.apache.hadoop.zebra.io.BlockDistribution
Get the total number of bytes of all the blocks.
getLength() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit
 
getLFile() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLoad
 
getLfs() - Method in class org.apache.pig.impl.PigContext
 
getLhs() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator
 
getLhs() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
Get left expression
getLhs() - Method in class org.apache.pig.experimental.logical.expression.BinaryExpression
Get the left hand side of this binary expression.
getLhs() - Method in class org.apache.pig.experimental.logical.expression.BinCondExpression
Get the left hand side of this expression.
getLhs() - Method in class org.apache.pig.Expression.BinaryExpression
 
getLhsOp() - Method in class org.apache.pig.impl.logicalLayer.LOBinCond
 
getLhsOperand() - Method in class org.apache.pig.impl.logicalLayer.BinaryExpressionOperator
 
getLimit() - Method in class org.apache.hadoop.zebra.tfile.BoundedByteArrayOutputStream
Return the current limit
getLimit() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLimit
 
getLimit() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort
 
getLimit() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
getLimit() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getLineNumber() - Method in class org.apache.pig.experimental.logical.relational.LogicalRelationalOperator
Get the line number in the submitted Pig Latin script where this operator occurred.
getLoadCaster() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MergeJoinIndexer
 
getLoadCaster() - Method in class org.apache.pig.builtin.BinStorage
 
getLoadCaster() - Method in class org.apache.pig.builtin.PigStreaming
 
getLoadCaster() - Method in class org.apache.pig.builtin.TextLoader
 
getLoadCaster() - Method in class org.apache.pig.impl.builtin.DefaultIndexableLoader
 
getLoadCaster() - Method in class org.apache.pig.impl.builtin.SampleLoader
 
getLoadCaster() - Method in class org.apache.pig.impl.io.ReadToEndLoader
 
getLoadCaster() - Method in class org.apache.pig.LoadFunc
This will be called on the front end during planning and not on the back end during execution.
getLoadCaster() - Method in interface org.apache.pig.StreamToPig
This will be called on the front end during planning and not on the back end during execution.
getLoadFunc() - Method in class org.apache.pig.experimental.logical.relational.LOLoad
 
getLoadFunc() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getLoadFuncSpec() - Method in class org.apache.pig.impl.logicalLayer.LOCast
 
getLoads(PhysicalPlan) - Static method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.util.PlanHelper
Get all the load operators in the plan in the right dependency order
getLocations() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit
 
getLOForEach() - Method in class org.apache.pig.experimental.logical.relational.LOInnerLoad
Get the LOForEach operator that contains this operator as part of inner plan
getLog4jProperties() - Method in class org.apache.pig.impl.PigContext
 
getLogDir() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the directory where the log-files of the command are persisted.
getLogFilesLimit() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the maximum number of tasks whose stderr logs files are persisted.
getLogger() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getLogger() - Method in class org.apache.pig.EvalFunc
 
getLogs(OutputStream) - Method in interface org.apache.pig.backend.executionengine.ExecJob
Collecting various forms of outputs
getLogs(OutputStream) - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
getLogToPhyMap() - Method in class org.apache.pig.pen.LocalLogToPhyTranslationVisitor
 
getLookUpKey() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getLookupKey() - Method in class org.apache.pig.experimental.logical.expression.MapLookupExpression
 
getLookUpKey() - Method in class org.apache.pig.impl.logicalLayer.LOMapLookup
 
getMajor() - Method in class org.apache.hadoop.zebra.tfile.Utils.Version
Get the major version.
getMap() - Method in class org.apache.pig.experimental.logical.expression.MapLookupExpression
 
getMap() - Method in class org.apache.pig.impl.logicalLayer.LOMapLookup
 
getMapKeysInfo(int) - Method in class org.apache.pig.impl.plan.RequiredFields
Get the ith MapKeysInfo structure
getMappedFields() - Method in class org.apache.pig.impl.plan.ProjectionMap
 
getMAscCols() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort
 
getMaterializedResults() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
getmBytes() - Method in class org.apache.pig.ResourceStatistics
 
getMembers(Tuple) - Method in class org.apache.pig.impl.util.LineageTracer
 
getMembers(Tuple) - Method in class org.apache.pig.pen.util.LineageTracer
 
getMembershipMap() - Method in class org.apache.pig.impl.util.LineageTracer
 
getMembershipMap() - Method in class org.apache.pig.pen.util.LineageTracer
 
GetMemNumRows - Class in org.apache.pig.impl.builtin
UDF to get memory size of a tuple and extracts number of rows value from special tuple created by PoissonSampleLoader It is used by skewed join.
GetMemNumRows() - Constructor for class org.apache.pig.impl.builtin.GetMemNumRows
 
getMemorySize() - Method in class org.apache.pig.data.AccumulativeBag
 
getMemorySize() - Method in class org.apache.pig.data.DefaultAbstractBag
Return the size of memory usage.
getMemorySize() - Method in class org.apache.pig.data.DefaultTuple
Determine the size of tuple in memory.
getMemorySize() - Method in class org.apache.pig.data.NonSpillableDataBag
 
getMemorySize() - Method in class org.apache.pig.data.ReadOnceBag
 
getMemorySize() - Method in class org.apache.pig.data.SingleTupleBag
 
getMemorySize() - Method in class org.apache.pig.data.TargetedTuple
 
getMemorySize() - Method in interface org.apache.pig.data.Tuple
Determine the size of tuple in memory.
getMemorySize() - Method in interface org.apache.pig.impl.util.Spillable
Requests that an object return an estimate of its in memory size.
getMemorySize() - Method in class org.apache.pig.pen.util.ExampleTuple
 
getMessage() - Method in class org.apache.pig.impl.plan.CompilationMessageCollector.Message
 
getMessageCollector() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer
 
getMessageCollector() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
getMessageType() - Method in class org.apache.pig.impl.plan.CompilationMessageCollector.Message
 
getMetaBlock(String) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Obtain an input stream for reading a meta block.
getMetaBlock(String) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Stream access to a meta block.``
getMinor() - Method in class org.apache.hadoop.zebra.tfile.Utils.Version
Get the minor version.
getMinStepSize() - Method in class org.apache.hadoop.zebra.io.KeyDistribution
Get the minimum split step size from all tables in union
getMostCommonValues() - Method in class org.apache.pig.ResourceStatistics.ResourceFieldStatistics
 
getMostCommonValuesFreq() - Method in class org.apache.pig.ResourceStatistics.ResourceFieldStatistics
 
getMRPlan() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
Used to get the compiled plan
getMRPlan() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getMSortFunc() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort
 
getMultiInputNestedPlans(LogicalOperator) - Method in class org.apache.pig.impl.logicalLayer.DotLOPrinter
 
getMultiInputNestedPlans(E) - Method in class org.apache.pig.impl.plan.PlanDumper
Used to determine if an operator has nested plans, which are connected to specific input operators.
getMultiOutputNestedPlans(PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.DotPOPrinter
 
getMultiOutputNestedPlans(E) - Method in class org.apache.pig.impl.plan.PlanDumper
Used to determine if an operator has nested output plans
getName(int) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
 
getName() - Method in enum org.apache.hadoop.zebra.schema.ColumnType
Get the Zebra type name for this Zebra column type
getName() - Method in class org.apache.hadoop.zebra.schema.Schema.ColumnSchema
access function to get the column name
getName() - Method in class org.apache.hadoop.zebra.schema.Schema.ParsedName
Get the column name
getName() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getName(MapReduceOper) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter
 
getName(PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.DotPOPrinter
 
getName() - Method in class org.apache.pig.experimental.plan.Operator
 
getName() - Method in class org.apache.pig.experimental.plan.optimizer.Rule
 
getName() - Method in class org.apache.pig.Expression.Column
 
getName(LogicalOperator) - Method in class org.apache.pig.impl.logicalLayer.DotLOPrinter
 
getName(E) - Method in class org.apache.pig.impl.plan.DotPlanDumper
Used to generate the label for an operator.
getName() - Method in class org.apache.pig.impl.streaming.StreamingCommand.HandleSpec
Get the name of the HandleSpec.
getName() - Method in class org.apache.pig.ResourceSchema.ResourceFieldSchema
 
getNeedAllFields() - Method in class org.apache.pig.impl.plan.RequiredFields
 
getNeedNoFields() - Method in class org.apache.pig.impl.plan.RequiredFields
 
getNestedPlans(MapReduceOper) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter
 
getNestedPlans(PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.DotPOPrinter
 
getNestedPlans(LogicalOperator) - Method in class org.apache.pig.impl.logicalLayer.DotLOPrinter
 
getNestedPlans(E) - Method in class org.apache.pig.impl.plan.PlanDumper
Used to determine if an operator has nested plans (without connections to in- or output operators.
getNewBaseData() - Method in class org.apache.pig.pen.AugmentBaseDataVisitor
 
getNewLogicalPlan() - Method in class org.apache.pig.experimental.logical.LogicalPlanMigrationVistor
 
getNewName() - Static method in class org.apache.pig.impl.logicalLayer.CanonicalNamer
 
getNewTransformer() - Method in class org.apache.pig.experimental.logical.rules.AddForEach
 
getNewTransformer() - Method in class org.apache.pig.experimental.logical.rules.ColumnMapKeyPrune
 
getNewTransformer() - Method in class org.apache.pig.experimental.logical.rules.FilterAboveForeach
 
getNewTransformer() - Method in class org.apache.pig.experimental.logical.rules.MergeFilter
 
getNewTransformer() - Method in class org.apache.pig.experimental.logical.rules.PushUpFilter
 
getNewTransformer() - Method in class org.apache.pig.experimental.logical.rules.SplitFilter
 
getNewTransformer() - Method in class org.apache.pig.experimental.plan.optimizer.Rule
Get the transformer for this rule.
getNext() - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
getNext() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MergeJoinIndexer
 
getNext() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.DiscreteProbabilitySampleGenerator
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
getNext(Integer) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(Long) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(Double) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(Float) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(String) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(DataByteArray) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(Map) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(Boolean) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(Tuple) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(DataBag) - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.EqualToExpr
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.GreaterThanExpr
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.GTOrEqualToExpr
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LessThanExpr
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LTOrEqualToExpr
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Mod
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Mod
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.NotEqualToExpr
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POAnd
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POIsNull
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONegative
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONegative
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONegative
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONegative
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONot
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POOr
 
getNext() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
Fetches the input tuple and returns the requested column
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
Asked for Tuples.
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORelationToExprProject
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract
 
getNext(Integer) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Double) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Float) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(String) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(DataByteArray) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Map) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCombinerPackage
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODemux
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter
Attaches the proccesed input tuple to the expression plan and checks if comparison operator returns a true.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POGlobalRearrange
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POJoinPackage
Calls getNext to get next ForEach result.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLimit
Counts the number of tuples processed into static variable soFar, if the number of tuples processed reach the limit, return EOP; Otherwise, return the tuple
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLoad
The main method used by this operator's successor to read tuples from the specified file using the specified load function.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
Calls getNext on the generate operator inside the nested physical plan.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
Constructs the output tuple from the inputs.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POOptimizedForEach
Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
From the inputs, constructs the output tuple for this co-group in the required format which is (key, {bag of tuples from input 1}, {bag of tuples from input 2}, ...)
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite
Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPartitionRearrange
Calls getNext on the generate operator inside the nested physical plan.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange
Calls getNext on the generate operator inside the nested physical plan.
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PORead
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSortedDistinct
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSplit
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
getNext(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POUnion
The code below, tries to follow our single threaded shared execution model with execution being passed around each non-drained input
getNext() - Method in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
 
getNext() - Method in class org.apache.pig.builtin.BinStorage
 
getNext() - Method in class org.apache.pig.builtin.PigStorage
 
getNext() - Method in class org.apache.pig.builtin.TextLoader
 
getNext() - Method in class org.apache.pig.impl.builtin.DefaultIndexableLoader
 
getNext() - Method in class org.apache.pig.impl.builtin.PoissonSampleLoader
 
getNext() - Method in class org.apache.pig.impl.builtin.RandomSampleLoader
Allocate a buffer for numSamples elements, populate it with the first numSamples tuples, and continue scanning rest of the input.
getNext() - Method in class org.apache.pig.impl.io.ReadToEndLoader
 
getNext() - Method in class org.apache.pig.impl.streaming.OutputHandler
Get the next output Tuple of the managed process.
getNext() - Method in class org.apache.pig.LoadFunc
Retrieves the next tuple to be processed.
getNext(Tuple) - Method in class org.apache.pig.pen.physicalOperators.POCogroup
 
getNext(Tuple) - Method in class org.apache.pig.pen.physicalOperators.POCounter
 
getNext(Tuple) - Method in class org.apache.pig.pen.physicalOperators.POCross
 
getNext(Tuple) - Method in class org.apache.pig.pen.physicalOperators.POSplit
 
getNext(Tuple) - Method in class org.apache.pig.pen.physicalOperators.POSplitOutput
 
getNext(Tuple) - Method in class org.apache.pig.pen.physicalOperators.POStreamLocal
This is different from the Map-Reduce implementation of the POStream since there is no push model here.
getNext() - Method in class org.apache.pig.piggybank.storage.HiveColumnarLoader
 
getNext() - Method in class org.apache.pig.piggybank.storage.RegExLoader
 
getNext() - Method in class org.apache.pig.piggybank.storage.SequenceFileLoader
 
getNext() - Method in class org.apache.pig.piggybank.storage.XMLLoader
Retrieves the next tuple to be processed.
getNextHelper(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
getNextNodeId(String) - Method in class org.apache.pig.impl.plan.NodeIdGenerator
 
getNextOpt() - Method in class org.apache.pig.tools.cmdline.CmdLineParser
Get the next option.
getNextUid() - Static method in class org.apache.pig.experimental.logical.expression.LogicalExpression
 
getNodeClass() - Method in class org.apache.pig.impl.plan.optimizer.RuleOperator
Get the node class of this operator.
getNodeType() - Method in class org.apache.pig.impl.plan.optimizer.RuleOperator
Get the node type of this operator.
getNumColumns() - Method in class org.apache.hadoop.zebra.schema.Schema
Get the number of columns as defined in the schema.
getNumColumns() - Method in class org.apache.hadoop.zebra.types.Projection
Get number of columns in the projection
getNumColumns(String) - Static method in class org.apache.hadoop.zebra.types.Projection
Get number of columns from a projection string
getNumDistinctValues() - Method in class org.apache.pig.ResourceStatistics.ResourceFieldStatistics
 
getNumInps() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
 
getNumMRUseSecondaryKey() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.SecondaryKeyOptimizer
 
getNumRecords() - Method in class org.apache.pig.ResourceStatistics
 
getNumSamples() - Method in class org.apache.pig.impl.builtin.SampleLoader
 
getNumSortRemoved() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.SecondaryKeyOptimizer
 
getOffsetForKey(RawComparable) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
 
getOperand() - Method in class org.apache.pig.impl.logicalLayer.LORegexp
 
getOperand() - Method in class org.apache.pig.impl.logicalLayer.UnaryExpressionOperator
 
getOperandType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
 
getOperandType() - Method in interface org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ComparisonOperator
Determine the type of the operand(s) of this comparator.
getOperandType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.UnaryComparisonOperator
 
getOperator(OperatorKey) - Method in class org.apache.pig.impl.plan.OperatorPlan
Given an OperatorKey, find the associated operator.
getOperatorKey() - Method in interface org.apache.pig.backend.executionengine.ExecScopedLogicalOperator
 
getOperatorKey() - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
Get the operator key for this operator.
getOperatorKey() - Method in class org.apache.pig.impl.plan.Operator
Get the operator key for this operator.
getOperatorKey(E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Given an operator, find its OperatorKey.
getOperators() - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
 
getOperators() - Method in interface org.apache.pig.experimental.plan.OperatorPlan
Get an iterator of all operators in this plan
getOperators() - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
getOpsToBeReset() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
getOpTable() - Method in interface org.apache.pig.backend.executionengine.ExecPhysicalPlan
 
getOpType() - Method in class org.apache.pig.Expression
 
getOutputCommitter(TaskAttemptContext) - Method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
 
getOutputCommitter(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat
 
getOutputFile() - Method in class org.apache.pig.impl.logicalLayer.LOStore
 
getOutputFormat() - Method in class org.apache.hadoop.zebra.pig.TableStorer
 
getOutputFormat() - Method in class org.apache.pig.builtin.BinStorage
 
getOutputFormat() - Method in class org.apache.pig.builtin.PigStorage
 
getOutputFormat() - Method in class org.apache.pig.piggybank.storage.MultiStorage
 
getOutputFormat() - Method in class org.apache.pig.StoreFunc
Return the OutputFormat associated with StoreFunc.
getOutputFormat() - Method in interface org.apache.pig.StoreFuncInterface
Return the OutputFormat associated with StoreFuncInterface.
getOutputPartition(BytesWritable, Tuple) - Method in class org.apache.hadoop.zebra.mapred.ZebraOutputPartition
 
getOutputPartition(BytesWritable, Tuple) - Method in class org.apache.hadoop.zebra.mapreduce.ZebraOutputPartition
 
getOutputPath(JobConf) - Static method in class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated. Get the output path of the BasicTable from JobConf
getOutputPath(JobContext) - Static method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
Get the output path of the BasicTable from JobContext
getOutputPaths(JobConf) - Static method in class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated. Set the multiple output paths of the BasicTable in JobConf
getOutputPaths(JobContext) - Static method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
Set the multiple output paths of the BasicTable in JobContext
getOutputPlans() - Method in class org.apache.pig.experimental.logical.relational.LOGenerate
 
getOutputs() - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
getOutputSpec() - Method in class org.apache.pig.experimental.logical.relational.LOStore
 
getOutputSpec() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the specification of the primary output of the StreamingCommand.
getOutputType() - Method in class org.apache.pig.impl.streaming.DefaultOutputHandler
 
getOutputType() - Method in class org.apache.pig.impl.streaming.FileOutputHandler
 
getOutputType() - Method in class org.apache.pig.impl.streaming.OutputHandler
Get the handled OutputType.
getOverloaded() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getOwner() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getPackageImportList() - Static method in class org.apache.pig.impl.PigContext
 
getPackages() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
Returns the list of packages.
getPartition(PigNullableWritable, Writable, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SecondaryKeyPartitioner
 
getPartition(PigNullableWritable, Writable, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.SkewedPartitioner
 
getPartition(PigNullableWritable, Writable, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner
 
getPartition() - Method in class org.apache.pig.impl.io.NullablePartitionWritable
 
getPartitionInfo() - Method in class org.apache.hadoop.zebra.types.Partition
 
getPartitionKeys(String, Job) - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
getPartitionKeys(String, Job) - Method in class org.apache.pig.builtin.BinStorage
 
getPartitionKeys(String, Job) - Method in interface org.apache.pig.LoadMetadata
Find what columns are partition keys for this input.
getPartitionKeys(String, Job) - Method in class org.apache.pig.piggybank.storage.HiveColumnarLoader
 
getPartitionKeys(String, Job) - Method in class org.apache.pig.piggybank.storage.JsonMetadata
 
getPartitionKeys(String, Job) - Method in class org.apache.pig.piggybank.storage.PigStorageSchema
 
getPath() - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get the path to the table.
getPath() - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
getPathFilter(Configuration) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get the path filter used by the table.
getPathsToSkip() - Method in class org.apache.pig.impl.PigContext
Get paths which are to skipped while automatically shipping binaries for streaming.
getPathStrings(String) - Static method in class org.apache.pig.LoadFunc
Parse comma separated path strings into a string array.
getPattern() - Method in class org.apache.pig.experimental.plan.optimizer.Rule
Return the pattern to be matched for this rule
getPattern() - Method in class org.apache.pig.piggybank.storage.apachelog.CombinedLogLoader
 
getPattern() - Method in class org.apache.pig.piggybank.storage.apachelog.CommonLogLoader
 
getPattern() - Method in class org.apache.pig.piggybank.storage.MyRegExLoader
 
getPattern() - Method in class org.apache.pig.piggybank.storage.RegExLoader
 
getPc() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLoad
 
getPColCondition() - Method in class org.apache.pig.impl.logicalLayer.PColFilterExtractor
 
getPerfTimerFactory() - Static method in class org.apache.pig.tools.timer.PerformanceTimerFactory
Get the timer factory.
getPerm() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getPermissionException(Exception) - Static method in class org.apache.pig.impl.util.LogUtils
 
getPersistStderr() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Should the stderr of the managed process be persisted?
getPhysicalOpTable() - Method in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
getPhysicalPlan() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.LogToPhyTranslationVisitor
 
getPhysicalPlan() - Method in class org.apache.pig.experimental.logical.expression.ExpToPhyTranslationVisitor
 
getPhysicalPlan() - Method in class org.apache.pig.experimental.logical.relational.LogToPhyTranslationVisitor
 
getPhysicalPlan() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getPigContext() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPartitionRearrange
 
getPigContext() - Method in class org.apache.pig.PigServer
 
getPigException(Throwable) - Static method in class org.apache.pig.impl.util.LogUtils
 
getPigLogger() - Static method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getPigLogger() - Method in class org.apache.pig.EvalFunc
 
getPigSchema(ResourceSchema) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
getPigStats() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getPlainForEachOP() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
getPlan() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
Used to get the plan that was compiled
getPlan() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter.InnerOperator
 
getPlan() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter
 
getPlan() - Method in class org.apache.pig.experimental.plan.Operator
Get the plan associated with this operator.
getPlan() - Method in class org.apache.pig.experimental.plan.PlanVisitor
 
getPlan() - Method in class org.apache.pig.experimental.plan.PlanWalker
 
getPlan() - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
 
getPlan() - Method in class org.apache.pig.impl.plan.optimizer.Rule
 
getPlan() - Method in class org.apache.pig.impl.plan.optimizer.Transformer
 
getPlan() - Method in class org.apache.pig.impl.plan.PlanVisitor
 
getPlan() - Method in class org.apache.pig.impl.plan.PlanWalker
 
getPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup
 
getPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODemux
Returns the list of inner plans.
getPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
getPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange
 
getPlans() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSplit
Returns the list of nested plans.
getPos() - Method in class org.apache.hadoop.zebra.mapred.TableRecordReader
Deprecated.  
getPos() - Method in class org.apache.hadoop.zebra.mapreduce.TableRecordReader
 
getPosition() - Method in class org.apache.pig.impl.io.BufferedPositionedInputStream
Returns the current position in the tracked InputStream.
getPosition(String) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
Given an alias, find the associated position of the field schema.
getPOStore() - Method in interface org.apache.pig.backend.executionengine.ExecJob
 
getPOStore() - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
getPredecessors(Operator) - Method in class org.apache.pig.experimental.plan.BaseOperatorPlan
For a given operator, get all operators immediately before it in the plan.
getPredecessors(Operator) - Method in interface org.apache.pig.experimental.plan.OperatorPlan
For a given operator, get all operators immediately before it in the plan.
getPredecessors(Operator) - Method in class org.apache.pig.experimental.plan.OperatorSubPlan
 
getPredecessors(E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Find all of the nodes that have edges to the indicated node from themselves.
getPrefix() - Method in class org.apache.pig.experimental.logical.optimizer.PlanPrinter.DepthFirstMemoryWalker
 
getProactiveSpillCount() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getProgress() - Method in class org.apache.hadoop.zebra.mapred.TableRecordReader
Deprecated.  
getProgress() - Method in class org.apache.hadoop.zebra.mapreduce.TableRecordReader
 
getProgress() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader
 
getProgress() - Method in class org.apache.pig.impl.io.BinStorageRecordReader
Get the progress within the split
getProgress() - Method in class org.apache.pig.piggybank.storage.hiverc.HiveRCRecordReader
 
getProgress() - Method in class org.apache.pig.piggybank.storage.XMLLoader.XMLFileRecordReader
 
getprojction() - Method in class org.apache.hadoop.zebra.types.TypesUtils.TupleReader
 
getProjectedColsMap() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
getProjectExpression() - Method in class org.apache.pig.experimental.logical.expression.BagDereferenceExpression
 
getProjection() - Method in interface org.apache.hadoop.zebra.io.TableScanner
 
getProjection(JobConf) - Static method in class org.apache.hadoop.zebra.mapred.TableInputFormat
Deprecated. Get the projection from the JobConf
getProjection(JobContext) - Static method in class org.apache.hadoop.zebra.mapreduce.TableInputFormat
Get the projection from the JobContext
getProjection(int) - Method in class org.apache.hadoop.zebra.types.Partition
returns projection schema for a particular column group
getProjection() - Method in class org.apache.hadoop.zebra.types.Partition
returns table projection
getProjection() - Method in class org.apache.pig.experimental.logical.relational.LOInnerLoad
 
getProjection() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOCross
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LODistinct
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOStore
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOStream
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.LOUnion
 
getProjectionMap() - Method in class org.apache.pig.impl.logicalLayer.RelationalOperator
Produce a map describing how this operator modifies its projection.
getProjectionMap() - Method in class org.apache.pig.impl.plan.Operator
Produce a map describing how this operator modifies its projection.
getProjectionSchema(String[], HashMap<Schema.ColumnSchema, HashSet<String>>) - Method in class org.apache.hadoop.zebra.schema.Schema
Get a projection's schema
getProjectionSchema() - Method in class org.apache.hadoop.zebra.types.Projection
 
getProjectionStr(String[]) - Static method in class org.apache.hadoop.zebra.types.Projection
Get a projection string from a series of column names
getProjectList() - Method in class org.apache.pig.impl.logicalLayer.TopLevelProjectFinder
 
getProjectSet() - Method in class org.apache.pig.impl.logicalLayer.TopLevelProjectFinder
 
getProjectStarSet() - Method in class org.apache.pig.impl.logicalLayer.TopLevelProjectFinder
 
getProperties() - Method in class org.apache.pig.impl.PigContext
Provides configuration information.
getPushBefore() - Method in class org.apache.pig.impl.logicalLayer.optimizer.PushUpFilter
 
getPushBeforeInput() - Method in class org.apache.pig.impl.logicalLayer.optimizer.PushUpFilter
 
getQuantFile() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
 
getQuantileJob(POSort, MapReduceOper, FileSpec, FileSpec, int, Pair<Integer, Byte>[]) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
getR() - Static method in class org.apache.pig.impl.io.FileLocalizer
 
getReadFrom() - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
getRealness(LogicalOperator, Map<LogicalOperator, DataBag>, boolean) - Static method in class org.apache.pig.pen.util.MetricEvaluation
 
getRecordNum() - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
Get the RecordNum corresponding to the entry pointed by the cursor.
getRecordNumNear(long) - Method in class org.apache.hadoop.zebra.tfile.TFile.Reader
Get the RecordNum for the first key-value pair in a compressed block whose byte offset in the TFile is greater than or equal to the specified offset.
getRecordReader(InputSplit, JobConf, Reporter) - Method in class org.apache.hadoop.zebra.mapred.TableInputFormat
Deprecated.  
getRecordsWritten() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getRecordWriter(FileSystem, JobConf, String, Progressable) - Method in class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated.  
getRecordWriter(TaskAttemptContext) - Method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
 
getRecordWriter(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat
 
getRecordWriter(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextOutputFormat
 
getRecordWriter(TaskAttemptContext) - Method in class org.apache.pig.impl.io.BinStorageOutputFormat
 
getRecordWriter(TaskAttemptContext) - Method in class org.apache.pig.piggybank.storage.MultiStorage.MultiStorageOutputFormat
 
getRegexp() - Method in class org.apache.pig.impl.logicalLayer.LORegexp
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOCross
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LODistinct
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOStore
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOStream
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.LOUnion
 
getRelevantInputs(int, int) - Method in class org.apache.pig.impl.logicalLayer.RelationalOperator
Get relevant input columns of a particular output column.
getRelevantPlan(int) - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getRemainingArgs() - Method in class org.apache.pig.tools.cmdline.CmdLineParser
Get any remaining arguments.
getRemovedFields() - Method in class org.apache.pig.impl.plan.ProjectionMap
 
getReplFiles() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
getReporter() - Method in class org.apache.pig.EvalFunc
 
getRepresentative(Tuple) - Method in class org.apache.pig.impl.util.LineageTracer
 
getRepresentative(Tuple) - Method in class org.apache.pig.pen.util.LineageTracer
 
getRequestedParallelisam() - Method in class org.apache.pig.experimental.logical.relational.LogicalRelationalOperator
Get the requestedParallelism for this operator.
getRequestedParallelism() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
 
getRequestedParallelism() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getRequestedParallelism() - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
 
getRequiredFieldList() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getRequiredFieldResponse() - Method in class org.apache.pig.LoadPushDown.RequiredFieldResponse
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOCross
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LODistinct
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOStore
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOStream
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.LOUnion
 
getRequiredFields() - Method in class org.apache.pig.impl.logicalLayer.RelationalOperator
Get a list of fields that this operator requires.
getResults() - Method in interface org.apache.pig.backend.executionengine.ExecJob
if query has executed successfully we want to retrieve the results via iterating over them.
getResults() - Method in class org.apache.pig.backend.hadoop.executionengine.HJob
 
getResultType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
getReturnType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc
 
getReturnType() - Method in class org.apache.pig.EvalFunc
 
getReturnType() - Method in class org.apache.pig.impl.builtin.GetMemNumRows
 
getReverseCanonicalMap() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
 
getRhs() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator
 
getRhs() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
Get right expression
getRhs() - Method in class org.apache.pig.experimental.logical.expression.BinaryExpression
Get the right hand side of this binary expression.
getRhs() - Method in class org.apache.pig.experimental.logical.expression.BinCondExpression
Get the right hand side of this expression.
getRhs() - Method in class org.apache.pig.Expression.BinaryExpression
 
getRhsOp() - Method in class org.apache.pig.impl.logicalLayer.LOBinCond
 
getRhsOperand() - Method in class org.apache.pig.impl.logicalLayer.BinaryExpressionOperator
 
getRoot() - Method in interface org.apache.pig.backend.executionengine.ExecPhysicalPlan
 
getRootJobIDs() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getRoots() - Method in class org.apache.pig.impl.plan.OperatorPlan
Get a list of all nodes in the graph that are roots.
getRows() - Method in class org.apache.hadoop.zebra.io.BasicTableStatus
Get the # of rows of the BasicTable.
getRowSplitCGIndex() - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get index of the column group that will be used for row-based split.
getRuleName() - Method in class org.apache.pig.impl.plan.optimizer.Rule
 
getSamplingJob(POSort, MapReduceOper, List<PhysicalPlan>, FileSpec, FileSpec, int, List<PhysicalPlan>, String, String[], String) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
Create a sampling job to collect statistics by sampling an input file.
getScanner(BytesWritable, BytesWritable, boolean) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get a scanner that reads all rows whose row keys fall in a specific range.
getScanner(BasicTable.Reader.RangeSplit, boolean) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get a scanner that reads a consecutive number of rows as defined in the BasicTable.Reader.RangeSplit object, which should be obtained from previous calls of BasicTable.Reader.rangeSplit(int).
getScanner(boolean, BasicTable.Reader.RowSplit) - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get a scanner that reads a consecutive number of rows as defined in the BasicTable.Reader.RowSplit object.
getSchema() - Method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get the schema of the table.
getSchema(Path, Configuration) - Static method in class org.apache.hadoop.zebra.io.BasicTable.Reader
Get the BasicTable schema without loading the full table index.
getSchema() - Method in class org.apache.hadoop.zebra.io.BasicTable.Writer
Get the schema of the table.
getSchema() - Method in interface org.apache.hadoop.zebra.io.TableInserter
Get the schema of the underlying table we are writing to.
getSchema() - Method in interface org.apache.hadoop.zebra.io.TableScanner
Get the projection's schema
getSchema(JobConf) - Static method in class org.apache.hadoop.zebra.mapred.BasicTableOutputFormat
Deprecated. Get the table schema in JobConf.
getSchema(JobConf) - Static method in class org.apache.hadoop.zebra.mapred.TableInputFormat
Deprecated. Get the schema of a table expr
getSchema(JobContext) - Static method in class org.apache.hadoop.zebra.mapreduce.BasicTableOutputFormat
Get the table schema in JobContext.
getSchema(JobContext) - Static method in class org.apache.hadoop.zebra.mapreduce.TableInputFormat
Get the schema of a table expr
getSchema(String, Job) - Method in class org.apache.hadoop.zebra.pig.TableLoader
 
getSchema() - Method in class org.apache.hadoop.zebra.schema.Schema.ColumnSchema
 
getSchema() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getSchema() - Method in class org.apache.hadoop.zebra.types.Partition
returns table schema
getSchema() - Method in class org.apache.hadoop.zebra.types.Projection
accessor to the projected schema including invalid columns
getSchema() - Method in class org.apache.hadoop.zebra.types.TypesUtils.TupleReader
 
getSchema(int) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSkewedJoin
 
getSchema() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
 
getSchema(String, Job) - Method in class org.apache.pig.builtin.BinStorage
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOCogroup
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOFilter
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOForEach
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOGenerate
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LogicalRelationalOperator
Get the schema for the output of this relational operator.
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOInnerLoad
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOJoin
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOLoad
Get the schema for this load.
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOSplit
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOSplitOutput
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOStore
 
getSchema() - Method in class org.apache.pig.experimental.logical.relational.LOUnion
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.ExpressionOperator
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOAdd
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOAnd
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOBinCond
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOCast
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOCogroup
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOConst
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOCross
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LODefine
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LODistinct
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LODivide
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOEqual
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOFilter
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOForEach
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOGenerate
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LogicalOperator
Get a copy of the schema for the output of this operator.
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOGreaterThan
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOGreaterThanEqual
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOIsNull
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOJoin
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLesserThan
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLesserThanEqual
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLimit
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOMapLookup
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOMod
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOMultiply
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LONegative
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LONot
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LONotEqual
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOOr
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LORegexp
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOSort
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOSplit
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOSplitOutput
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOStore
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOStream
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOSubtract
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOUnion
 
getSchema() - Method in class org.apache.pig.impl.logicalLayer.LOUserFunc
 
getSchema(String, Job) - Method in interface org.apache.pig.LoadMetadata
Get a schema for the data to be loaded.
getSchema(String, Job) - Method in class org.apache.pig.piggybank.storage.HiveColumnarLoader
 
getSchema(String, Job) - Method in class org.apache.pig.piggybank.storage.JsonMetadata
For JsonMetadata schema is considered optional This method suppresses (and logs) errors if they are encountered.
getSchema(String, Job) - Method in class org.apache.pig.piggybank.storage.PigStorageSchema
 
getSchema() - Method in class org.apache.pig.ResourceSchema.ResourceFieldSchema
 
getSchemaFile() - Method in class org.apache.pig.impl.logicalLayer.LOLoad
 
getSchemaFromString(String) - Static method in class org.apache.pig.impl.util.Utils
 
getSchemaFromString(String, byte) - Static method in class org.apache.pig.impl.util.Utils
 
getSchemaName(String, Schema) - Method in class org.apache.pig.EvalFunc
 
getScope() - Method in interface org.apache.pig.backend.executionengine.ExecPhysicalOperator
 
getScope() - Method in interface org.apache.pig.backend.executionengine.ExecScopedLogicalOperator
 
getScope() - Method in class org.apache.pig.impl.plan.OperatorKey
 
getSecondaryProjectedColsMap() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
getSecondarySortOrder() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
 
getSentinel() - Method in class org.apache.pig.impl.logicalLayer.LOProject
 
getSerializer() - Method in class org.apache.hadoop.zebra.types.CGSchema
 
getSFile() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
 
getShipCacheProperties() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream
 
getShipFiles() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get whether files for this command should be shipped or not.
getShipSpecs() - Method in class org.apache.pig.impl.streaming.StreamingCommand
Get the list of files which need to be shipped to the cluster.
getSignature() - Method in class org.apache.pig.backend.ha