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

A

abortJob(JobContext, JobStatus.State) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
abortJob(JobContext, JobStatus.State) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigOutputFormatTez.PigOutputCommitterTez
 
abortTask(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
ABS - Class in org.apache.pig.builtin
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.builtin.ABS
 
AbstractAccumuloStorage - Class in org.apache.pig.backend.hadoop.accumulo
A LoadStoreFunc for retrieving data from and storing data to Accumulo A Key/Val pair will be returned as tuples: (key, colfam, colqual, colvis, timestamp, value).
AbstractAccumuloStorage(String, String) - Constructor for class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
AbstractTuple - Class in org.apache.pig.data
This class provides a convenient base for Tuple implementations.
AbstractTuple() - Constructor for class org.apache.pig.data.AbstractTuple
 
accept(PlanVisitor) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PatternNode
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.AddExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.AndExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.BinCondExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.CastExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.ConstantExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.DereferenceExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.DivideExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.EqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.GreaterThanEqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.GreaterThanExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.IsNullExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.LessThanEqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.LessThanExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.MapLookupExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.ModExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.MultiplyExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.NegativeExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.NotEqualExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.NotExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.OrExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.ProjectExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.RegexExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.ScalarExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.SubtractExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.expression.UserFuncExpression
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOCogroup
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOCross
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOCube
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LODistinct
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOFilter
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOForEach
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOGenerate
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOInnerLoad
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOJoin
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOLimit
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOLoad
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LONative
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LORank
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOSort
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOSplit
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOSplitOutput
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOStore
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOStream
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.logical.relational.LOUnion
 
accept(PlanVisitor) - Method in class org.apache.pig.newplan.Operator
Accept a visitor at this node in the graph.
accept(PlanVisitor) - Method in class org.apache.pig.tools.pigstats.JobStats
 
accept(PlanVisitor) - Method in class org.apache.pig.tools.pigstats.mapreduce.MRJobStats
 
accept(PlanVisitor) - Method in class org.apache.pig.tools.pigstats.tez.TezTaskStats
 
accepts(Properties) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.LocalExecType
 
accepts(Properties) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRExecType
 
accepts(Properties) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezExecType
 
accepts(Properties) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezLocalExecType
 
accepts(Properties) - Method in interface org.apache.pig.ExecType
An ExecType is selected based off the Properties for the given script.
accepts(String, String) - Method in enum org.apache.pig.scripting.ScriptEngine.SupportedScriptLang
If other discovery mechanisms come up they can also override accepts()
accumChild(List<ExpressionOperator>, byte) - 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.AccumulatorEvalFunc
 
accumulate(Tuple) - Method in class org.apache.pig.AlgebraicEvalFunc
This is the free accumulate implementation based on the static classes provided by the Algebraic static classes.
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigDecimalMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigIntegerMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicDoubleMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicFloatMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicIntMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AlgebraicLongMathBase
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.AVG
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.BigDecimalAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.BigIntegerAvg
 
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.DateTimeMax
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.DateTimeMin
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.DoubleAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.FloatAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.IntAvg
 
accumulate(Tuple) - Method in class org.apache.pig.builtin.LongAvg
 
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.IteratingAccumulatorEvalFunc
 
accumulate(Tuple) - Method in class org.apache.pig.scripting.groovy.GroovyAccumulatorEvalFunc
 
accumulate(Tuple) - Method in class org.apache.pig.scripting.jruby.JrubyAccumulatorEvalFunc
This uses the "exec" method required of AccumulatorPigUdf Ruby classes.
accumulateStats(JobControl) - Static method in class org.apache.pig.tools.pigstats.mapreduce.MRPigStatsUtil
Updates the statistics after a patch of jobs is done
accumulateStats(TezJob) - Method in class org.apache.pig.tools.pigstats.tez.TezStats
Updates the statistics after DAG is finished.
ACCUMULATIVE_BATCHSIZE - Static variable in class org.apache.pig.PigConfiguration
 
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
An interface that allows UDFs that take a bag to accumulate tuples in chunks rather than take the whole set at once.
AccumulatorAccumulate - Annotation Type in org.apache.pig.scripting.groovy
This annotation is to be used on a Groovy method which is part of an Accumulator UDF to indicate that it will act as the 'accumulate' method of the UDF.
AccumulatorCleanup - Annotation Type in org.apache.pig.scripting.groovy
This annotation is to be used on a Groovy method which is part of an Accumulator UDF to indicate that it will act as the 'cleanup' method of the UDF.
AccumulatorEvalFunc<T> - Class in org.apache.pig
This class is used to provide a free implementation of the EvalFunc exec function given implementation of the Accumulator interface.
AccumulatorEvalFunc() - Constructor for class org.apache.pig.AccumulatorEvalFunc
 
AccumulatorGetValue - Annotation Type in org.apache.pig.scripting.groovy
This annotation is to be used on a Groovy method which is part of an Accumulator UDF to indicate that it will act as the 'getValue' method of the UDF.
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
 
AccumulatorOptimizer - Class in org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer
A visitor to optimize plans that determines if a vertex plan can run in accumulative mode.
AccumulatorOptimizer(TezOperPlan) - Constructor for class org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.AccumulatorOptimizer
 
AccumulatorOptimizerUtil - Class in org.apache.pig.backend.hadoop.executionengine.util
 
AccumulatorOptimizerUtil() - Constructor for class org.apache.pig.backend.hadoop.executionengine.util.AccumulatorOptimizerUtil
 
AccumuloBinaryConverter - Class in org.apache.pig.backend.hadoop.accumulo
A LoadStoreCaster implementation which stores most type implementations as bytes generated from the toString representation with a UTF8 Charset.
AccumuloBinaryConverter() - Constructor for class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
AccumuloStorage - Class in org.apache.pig.backend.hadoop.accumulo
Basic PigStorage implementation that uses Accumulo as the backing store.
AccumuloStorage() - Constructor for class org.apache.pig.backend.hadoop.accumulo.AccumuloStorage
Creates an AccumuloStorage which writes all values in a Tuple with an empty column family and doesn't group column families together on read (creates on Map for all columns)
AccumuloStorage(String) - Constructor for class org.apache.pig.backend.hadoop.accumulo.AccumuloStorage
Create an AccumuloStorage with a CSV of columns-families to use on write and whether columns in a row should be grouped by family on read.
AccumuloStorage(String, String) - Constructor for class org.apache.pig.backend.hadoop.accumulo.AccumuloStorage
 
AccumuloStorageOptions - Class in org.apache.pig.backend.hadoop.accumulo
 
AccumuloStorageOptions() - Constructor for class org.apache.pig.backend.hadoop.accumulo.AccumuloStorageOptions
 
ACOS - Class in org.apache.pig.builtin
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.builtin.ACOS
 
actionPerformed(ActionEvent) - Method in class org.apache.pig.tools.streams.StreamGenerator
 
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(Number, Number, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
add(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin.TuplesToSchemaTupleList
 
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(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(Tuple) - Method in class org.apache.pig.impl.util.avro.AvroBagWrapper
 
add(E) - Method in class org.apache.pig.impl.util.IdentityHashSet
 
add(LoadPushDown.RequiredField) - Method in class org.apache.pig.LoadPushDown.RequiredFieldList
Add a field to the list of required fields.
add(Operator) - Method in class org.apache.pig.newplan.BaseOperatorPlan
Add a new operator to the plan.
add(Operator) - Method in interface org.apache.pig.newplan.OperatorPlan
Add a new operator to the plan.
add(Operator) - Method in class org.apache.pig.newplan.OperatorSubPlan
 
add(ThreadContext, IRubyObject[]) - Method in class org.apache.pig.scripting.jruby.RubyDataBag
The add method accepts a varargs argument; each argument can be either a random object, a DataBag, or a RubyArray.
add(ThreadContext, IRubyObject[]) - Method in class org.apache.pig.scripting.jruby.RubySchema
This method provides addition semantics, without modifying the original Schema.
addAccumulator(PhysicalPlan) - Static method in class org.apache.pig.backend.hadoop.executionengine.util.AccumulatorOptimizerUtil
 
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
 
addAll(Collection<Tuple>) - Method in class org.apache.pig.data.DefaultAbstractBag
 
addAll(Iterable<Tuple>) - Method in class org.apache.pig.data.DefaultAbstractBag
Add contents of an iterable (a collection or a DataBag)
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(DataBag) - Method in class org.apache.pig.impl.util.avro.AvroBagWrapper
 
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
addColsToTuple(DataInput, Tuple) - Method in class org.apache.pig.data.BinInterSedes
 
addColsToTuple(DataInput, Tuple) - Method in interface org.apache.pig.data.InterSedes
The type of next object has been determined to be of type Tuple, add the columns that belong to the tuple to given tuple argument t
addColumn(Mutation, String, String, Value) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorage
Adds the given column family, column qualifier and value to the given mutation
addCombiner(PhysicalPlan, PhysicalPlan, PhysicalPlan, CompilationMessageCollector, boolean) - Static method in class org.apache.pig.backend.hadoop.executionengine.util.CombinerOptimizerUtil
Algebraic functions and distinct in nested plan of a foreach are partially computed in the map and combine phase.
addCounterValue(Result) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCounter
Add current task id and local counter value.
addData(Tuple) - Method in class org.apache.pig.pen.Illustrator
 
addDependencyJars(Configuration, Class<?>...) - Static method in class org.apache.pig.backend.hadoop.accumulo.Utils
 
addDependencyJars(Job, Class<?>...) - Static method in class org.apache.pig.impl.util.JarManager
Add the jars containing the given classes to the job's configuration such that JobClient will ship them to the cluster and add them to the DistributedCache
AddDuration - Class in org.apache.pig.builtin
AddDuration returns the result of a DateTime object plus a Duration object
AddDuration() - Constructor for class org.apache.pig.builtin.AddDuration
 
addEmptyBagOuterJoin(PhysicalPlan, Schema) - Static method in class org.apache.pig.impl.util.CompilerUtils
 
AddExpression - Class in org.apache.pig.newplan.logical.expression
Add Operator
AddExpression(OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.newplan.logical.expression.AddExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
addExtraResource(URL) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperPlan
 
addExtraResource(String, Path) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperPlan
 
addField(LogicalSchema.LogicalFieldSchema) - Method in class org.apache.pig.newplan.logical.relational.LogicalSchema
Add a field to this schema.
AddForEach - Class in org.apache.pig.newplan.logical.rules
 
AddForEach(String) - Constructor for class org.apache.pig.newplan.logical.rules.AddForEach
 
AddForEach.AddForEachTransformer - Class in org.apache.pig.newplan.logical.rules
 
AddForEach.AddForEachTransformer() - Constructor for class org.apache.pig.newplan.logical.rules.AddForEach.AddForEachTransformer
 
addForEachAfter(LogicalPlan, LogicalRelationalOperator, int, Set<Integer>) - Static method in class org.apache.pig.newplan.logical.Util
 
addHandleSpec(StreamingCommand.Handle, StreamingCommand.HandleSpec) - Method in class org.apache.pig.impl.streaming.StreamingCommand
addInPlace(ThreadContext, IRubyObject[]) - Method in class org.apache.pig.scripting.jruby.RubySchema
This method provides addition semantics, modifying the original Schema in place.
addInput(OperatorKey) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator.VertexGroupInfo
 
addInputKey(String) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POShuffledValueInputTez
 
addInputKey(String) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POShuffleTezLoad
 
addInputPlan(PhysicalPlan, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
addInputs(IdentityHashSet<Tuple>) - Method in class org.apache.pig.pen.Illustrator
 
addInputStatistics(Map<String, Map<String, Long>>) - Method in class org.apache.pig.tools.pigstats.tez.TezTaskStats
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POCounterStatsTez
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POFRJoinTez
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POIdentityInOutTez
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.PORankTez
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POShuffledValueInputTez
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POShuffleTezLoad
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POSimpleTezLoad
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POValueInputTez
 
addInputsToSkip(Set<String>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.ReadScalarsTez
 
addInputsToSkip(Set<String>) - Method in interface org.apache.pig.backend.hadoop.executionengine.tez.runtime.TezInput
Add to the list of inputs to skip download if already available in vertex cache
addIsKeyWrappedList(List<Boolean>) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.MultiQueryPackager
Adds a list of IsKeyWrapped boolean values
addJar(String) - Method in class org.apache.pig.impl.PigContext
 
addJar(URL, String) - 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.
addJobConfToEnvironment(Configuration, Map<String, String>) - Static method in class org.apache.pig.impl.streaming.StreamingUtil
 
addJobStats(Job) - Static method in class org.apache.pig.tools.pigstats.mapreduce.MRPigStatsUtil
Add stats for a new Job, which doesn't yet need to be completed.
addNativeJobStats(PigStats, NativeMapReduceOper, boolean) - Static method in class org.apache.pig.tools.pigstats.mapreduce.MRPigStatsUtil
 
addNativeJobStats(PigStats, NativeMapReduceOper, boolean, Exception) - Static method in class org.apache.pig.tools.pigstats.mapreduce.MRPigStatsUtil
 
addNewObjSize(long) - Method in class org.apache.pig.data.SelfSpillBag.MemoryLimits
Submit information about size of another object
addOriginalLocation(String, SourceLocation) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
addOriginalLocation(String, List<PhysicalOperator.OriginalLocation>) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
addOutputKey(String) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POValueOutputTez
 
addOutputStatistics(Map<String, Map<String, Long>>) - Method in class org.apache.pig.tools.pigstats.tez.TezTaskStats
 
addPackager(Packager) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.MultiQueryPackager
Appends the specified package object to the end of the package list.
addPackager(Packager, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.MultiQueryPackager
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.newplan.optimizer.PlanOptimizer
Adds a listener to the optimization.
addRank(Result) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PORank
Reads the output tuple from POCounter and the cumulative sum previously calculated.
addRequiredItems(LOLoad, Pair<Map<Integer, Set<String>>, Set<Integer>>) - Method in class org.apache.pig.newplan.logical.rules.ColumnPruneVisitor
 
addSchema(Schema) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSkewedJoin
 
addScriptFile(String) - Method in class org.apache.pig.impl.PigContext
calls: addScriptFile(path, new File(path)), ensuring that a given path is added to the jar at most once.
addScriptFile(String, String) - Method in class org.apache.pig.impl.PigContext
this method adds script files that must be added to the shipped jar named differently from their local fs path.
addScriptJar(String) - Method in class org.apache.pig.impl.PigContext
 
addSettingsToConf(MapReduceOper, Configuration) - Method in class org.apache.pig.tools.pigstats.mapreduce.MRScriptState
 
addSettingsToConf(TezOperator, Configuration) - Method in class org.apache.pig.tools.pigstats.tez.TezScriptState
 
addSubPlanPropertiesToParent(TezOperator, TezOperator) - Static method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.MultiQueryOptimizerTez
 
addTezJobStatsForNative(NativeTezOper, boolean) - Method in class org.apache.pig.tools.pigstats.tez.TezStats
 
addTezResource(URI) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezResourceManager
 
addTezResource(String, Path) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezResourceManager
 
addTezResources(Set<URI>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezResourceManager
 
addToClassPath(String) - Method in class org.apache.pig.impl.util.JavaCompilerHelper
 
addToFilterPlan(LogicalExpression) - Method in class org.apache.pig.newplan.FilterExtractor
 
addToLocalCounter(Long) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCounter
 
addUnionPredecessor(OperatorKey) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator
 
addVertexGroupStore(OperatorKey, OperatorKey) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator
 
addWorkflowAdjacenciesToConf(MROperPlan, Configuration) - Method in class org.apache.pig.tools.pigstats.mapreduce.MRScriptState
 
addWorkflowAdjacenciesToConf(TezOperPlan, Configuration) - Method in class org.apache.pig.tools.pigstats.tez.TezScriptState
 
adjust() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.LimitAdjuster
 
adjustNumReducers(MROperPlan, MapReduceOper, Job) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler
Adjust the number of reducers based on the default_parallel, requested parallel and estimated parallel.
aggregateScalarsFiles() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
Algebraic - Interface in org.apache.pig
An interface to declare that an EvalFunc's calculation can be decomposed into intitial, intermediate, and final steps.
AlgebraicBigDecimalMathBase - Class in org.apache.pig.builtin
Core logic for applying an SUM function to a bag of BigDecimals.
AlgebraicBigDecimalMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicBigDecimalMathBase
 
AlgebraicBigDecimalMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicBigDecimalMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicBigDecimalMathBase.Final
 
AlgebraicBigDecimalMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicBigDecimalMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicBigDecimalMathBase.Intermediate
 
AlgebraicBigIntegerMathBase - Class in org.apache.pig.builtin
Core logic for applying an SUM function to a bag of BigIntegers.
AlgebraicBigIntegerMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicBigIntegerMathBase
 
AlgebraicBigIntegerMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicBigIntegerMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicBigIntegerMathBase.Final
 
AlgebraicBigIntegerMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicBigIntegerMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicBigIntegerMathBase.Intermediate
 
AlgebraicByteArrayMathBase - Class in org.apache.pig.builtin
Core logic for applying an accumulative/algebraic math function to a bag of doubles.
AlgebraicByteArrayMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicByteArrayMathBase
 
AlgebraicByteArrayMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicByteArrayMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicByteArrayMathBase.Final
 
AlgebraicByteArrayMathBase.Initial - Class in org.apache.pig.builtin
 
AlgebraicByteArrayMathBase.Initial() - Constructor for class org.apache.pig.builtin.AlgebraicByteArrayMathBase.Initial
 
AlgebraicByteArrayMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicByteArrayMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicByteArrayMathBase.Intermediate
 
AlgebraicDoubleMathBase - Class in org.apache.pig.builtin
Core logic for applying an accumulative/algebraic math function to a bag of doubles.
AlgebraicDoubleMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicDoubleMathBase
 
AlgebraicDoubleMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicDoubleMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicDoubleMathBase.Final
 
AlgebraicDoubleMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicDoubleMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicDoubleMathBase.Intermediate
 
AlgebraicEvalFunc<T> - Class in org.apache.pig
This class is used to provide a free implementation of the Accumulator interface and EvalFunc class in the case of an Algebraic function.
AlgebraicEvalFunc(String...) - Constructor for class org.apache.pig.AlgebraicEvalFunc
It is key that if a subclass has a constructor, that it calls super(args...) or else this class will not instantiate properly.
AlgebraicFinal - Annotation Type in org.apache.pig.scripting.groovy
This annotation is to be used on a Groovy method which is part of an Algebraic UDF to indicate that it will act as the exec method of the 'Final' class of the UDF.
AlgebraicFloatMathBase - Class in org.apache.pig.builtin
Core logic for applying an accumulative/algebraic math function to a bag of Floats.
AlgebraicFloatMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicFloatMathBase
 
AlgebraicFloatMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicFloatMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicFloatMathBase.Final
 
AlgebraicFloatMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicFloatMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicFloatMathBase.Intermediate
 
AlgebraicInitial - Annotation Type in org.apache.pig.scripting.groovy
This annotation is to be used on a Groovy method which is part of an Algebraic UDF to indicate that it will act as the exec method of the 'Initial' class of the UDF.
AlgebraicIntermed - Annotation Type in org.apache.pig.scripting.groovy
This annotation is to be used on a Groovy method which is part of an Algebraic UDF to indicate that it will act as the exec method of the 'Intermed' class of the UDF.
AlgebraicIntMathBase - Class in org.apache.pig.builtin
Core logic for applying an accumulative/algebraic math function to a bag of doubles.
AlgebraicIntMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicIntMathBase
 
AlgebraicIntMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicIntMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicIntMathBase.Final
 
AlgebraicIntMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicIntMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicIntMathBase.Intermediate
 
AlgebraicLongMathBase - Class in org.apache.pig.builtin
Core logic for applying an accumulative/algebraic math function to a bag of Longs.
AlgebraicLongMathBase() - Constructor for class org.apache.pig.builtin.AlgebraicLongMathBase
 
AlgebraicLongMathBase.Final - Class in org.apache.pig.builtin
 
AlgebraicLongMathBase.Final() - Constructor for class org.apache.pig.builtin.AlgebraicLongMathBase.Final
 
AlgebraicLongMathBase.Intermediate - Class in org.apache.pig.builtin
 
AlgebraicLongMathBase.Intermediate() - Constructor for class org.apache.pig.builtin.AlgebraicLongMathBase.Intermediate
 
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.impl.logicalLayer.schema.Schema.FieldSchema
Alias for this field.
alias - Variable in class org.apache.pig.newplan.logical.relational.LogicalRelationalOperator
 
alias - Variable in class org.apache.pig.newplan.logical.relational.LogicalSchema.LogicalFieldSchema
 
ALIAS - Static variable in class org.apache.pig.tools.pigstats.JobStats
 
ALIAS_LOCATION - Static variable in class org.apache.pig.tools.pigstats.JobStats
 
aliasOuputMap - Variable in class org.apache.pig.tools.pigstats.PigStats
 
AllExpressionVisitor - Class in org.apache.pig.newplan.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.newplan.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
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ABS
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.AddDuration
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ARITY
Deprecated.
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.Assert
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.BagSize
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.BagToString
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.BagToTuple
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.Base
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.BigDecimalAbs
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.BigIntegerAbs
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.CONCAT
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ConstantSize
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.CubeDimensions
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.CurrentTime
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.DaysBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.DIFF
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.DoubleRound
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.DoubleRoundTo
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ENDSWITH
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.EqualsIgnoreCase
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.FloatAbs
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.FloatRound
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.FloatRoundTo
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetDay
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetHour
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetMilliSecond
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetMinute
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetMonth
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetSecond
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetWeek
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetWeekYear
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.GetYear
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.HoursBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.INDEXOF
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.IntAbs
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.INVERSEMAP
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.IsEmpty
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.KEYSET
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.LAST_INDEX_OF
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.LCFIRST
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.LongAbs
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.LOWER
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.LTRIM
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.MapSize
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.MilliSecondsBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.MinutesBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.MonthsBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.PluckTuple
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.REGEX_EXTRACT
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.REGEX_EXTRACT_ALL
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.REPLACE
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.RollupDimensions
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ROUND
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ROUND_TO
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.RTRIM
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.SecondsBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.SIZE
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.SPRINTF
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.STARTSWITH
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.StringConcat
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.StringSize
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.STRSPLIT
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.STRSPLITTOBAG
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.SUBSTRING
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.SUBTRACT
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.SubtractDuration
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.TOBAG
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToDate
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToDate2ARGS
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToDate3ARGS
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToDateISO
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.TOKENIZE
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.TOMAP
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToMilliSeconds
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToString
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.TOTUPLE
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.ToUnixTime
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.TRIM
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.TupleSize
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.UCFIRST
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.UPPER
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.VALUELIST
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.VALUESET
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.WeeksBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.builtin.YearsBetween
 
allowCompileTimeCalculation() - Method in class org.apache.pig.EvalFunc
Whether the UDF should be evaluated at compile time if all inputs are constant.
allowRecursive - Variable in class org.apache.pig.builtin.AvroStorage
 
AllSameExpressionVisitor - Class in org.apache.pig.newplan.logical.expression
 
AllSameExpressionVisitor(OperatorPlan, PlanWalker) - Constructor for class org.apache.pig.newplan.logical.expression.AllSameExpressionVisitor
 
AllSameRalationalNodesVisitor - Class in org.apache.pig.newplan.logical.optimizer
A visitor that walks the logical plan and calls the same method on every type of node.
AllSameRalationalNodesVisitor(OperatorPlan, PlanWalker) - Constructor for class org.apache.pig.newplan.logical.optimizer.AllSameRalationalNodesVisitor
 
alreadyClosed - Variable in class org.apache.pig.impl.streaming.InputHandler
 
alreadyClosed - Variable in class org.apache.pig.impl.streaming.OutputHandler
 
ALTERNATIVE_FILE_SYSTEM_LOCATION - Static variable in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
AmendableTuple - Class in org.apache.pig.data
 
AmendableTuple(int, Object) - Constructor for class org.apache.pig.data.AmendableTuple
 
AndExpression - Class in org.apache.pig.newplan.logical.expression
Boolean and expression.
AndExpression(OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.newplan.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.newplan.Operator
Add an annotation to a node in the plan.
annotations - Variable in class org.apache.pig.newplan.Operator
 
append(Object) - Method in class org.apache.pig.data.AppendableSchemaTuple
 
append(DataByteArray) - Method in class org.apache.pig.data.DataByteArray
Append given byte array to the internal byte array.
append(byte[]) - Method in class org.apache.pig.data.DataByteArray
 
append(byte[], int, int) - Method in class org.apache.pig.data.DataByteArray
 
append(String) - Method in class org.apache.pig.data.DataByteArray
 
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.SchemaTuple
 
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.impl.util.avro.AvroTupleWrapper
 
append(Object) - Method in class org.apache.pig.pen.util.ExampleTuple
 
append(ThreadContext, IRubyObject) - Method in class org.apache.pig.scripting.jruby.RubyDataByteArray
This calls to the append function of the underlying DataByteArray.
AppendableSchemaTuple<T extends AppendableSchemaTuple<T>> - Class in org.apache.pig.data
 
AppendableSchemaTuple() - Constructor for class org.apache.pig.data.AppendableSchemaTuple
 
appendedFieldsSize() - Method in class org.apache.pig.data.AppendableSchemaTuple
 
apply(S) - Method in interface org.apache.pig.ExceptionalFunction
Performs a unit of work on item, possibly throwing E in the process.
apply(S) - Method in interface org.apache.pig.Function
 
applySecondaryKeySort(PhysicalPlan, PhysicalPlan) - Static method in class org.apache.pig.backend.hadoop.executionengine.util.SecondaryKeyOptimizerUtil
 
ARITY - Class in org.apache.pig.builtin
Deprecated.
Use SIZE instead.
ARITY() - Constructor for class org.apache.pig.builtin.ARITY
Deprecated.
 
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.builtin
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.builtin.ASIN
 
Assert - Class in org.apache.pig.builtin
 
Assert() - Constructor for class org.apache.pig.builtin.Assert
 
ASTERISK - Static variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
ATAN - Class in org.apache.pig.builtin
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.builtin.ATAN
 
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(Object, DataBag[], boolean[]) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.JoinPackager
 
attachInput(Object, DataBag[], boolean[]) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager
 
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.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.
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POCounterStatsTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POFRJoinTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POIdentityInOutTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.PORankTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POShuffledValueInputTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POShuffleTezLoad
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POSimpleTezLoad
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POValueInputTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.ReadScalarsTez
 
attachInputs(Map<String, LogicalInput>, Configuration) - Method in interface org.apache.pig.backend.hadoop.executionengine.tez.runtime.TezInput
 
attachInputToPlans(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POCounterStatsTez
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POCounterTez
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POIdentityInOutTez
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTez
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POStoreTez
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POValueOutputTez
 
attachOutputs(Map<String, LogicalOutput>, Configuration) - Method in interface org.apache.pig.backend.hadoop.executionengine.tez.runtime.TezOutput
 
attachStorePlan(String, LogicalPlan, String, String, Operator, String, PigContext) - Static method in class org.apache.pig.parser.QueryParserUtils
 
AugmentBaseDataVisitor - Class in org.apache.pig.pen
 
AugmentBaseDataVisitor(OperatorPlan, Map<Operator, PhysicalOperator>, Map<LOLoad, DataBag>, Map<Operator, DataBag>) - Constructor for class org.apache.pig.pen.AugmentBaseDataVisitor
 
authorizations - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
AUTHORIZATIONS_OPTION - Static variable in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorageOptions
 
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 a set of values.
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
 
AvroArrayReader - Class in org.apache.pig.impl.util.avro
RecordReader for Avro files
AvroArrayReader(Schema) - Constructor for class org.apache.pig.impl.util.avro.AvroArrayReader
Creates new instance of AvroRecordReader.
AvroBagWrapper<T> - Class in org.apache.pig.impl.util.avro
Class that implements the Pig bag interface, wrapping an Avro array.
AvroBagWrapper(GenericArray<T>) - Constructor for class org.apache.pig.impl.util.avro.AvroBagWrapper
Create new AvroBagWrapper instance.
AvroMapWrapper - Class in org.apache.pig.impl.util.avro
Wrapper for map objects, so we can translate UTF8 objects to Strings if we encounter them.
AvroMapWrapper(Map<CharSequence, Object>) - Constructor for class org.apache.pig.impl.util.avro.AvroMapWrapper
Creates a new AvroMapWrapper object from the map object .
AvroRecordReader - Class in org.apache.pig.impl.util.avro
RecordReader for Avro files
AvroRecordReader(Schema) - Constructor for class org.apache.pig.impl.util.avro.AvroRecordReader
Creates new instance of AvroRecordReader.
AvroRecordWriter - Class in org.apache.pig.impl.util.avro
RecordWriter for Avro objects.
AvroRecordWriter(Path, Configuration) - Constructor for class org.apache.pig.impl.util.avro.AvroRecordWriter
Creates new AvroRecordWriter.
avroSchemaToResourceSchema(Schema, Boolean) - Static method in class org.apache.pig.impl.util.avro.AvroStorageSchemaConversionUtilities
Translates an Avro schema to a Resource Schema (for Pig).
AvroStorage - Class in org.apache.pig.builtin
Pig UDF for reading and writing Avro data.
AvroStorage() - Constructor for class org.apache.pig.builtin.AvroStorage
Creates new instance of Pig Storage function, without specifying the schema.
AvroStorage(String) - Constructor for class org.apache.pig.builtin.AvroStorage
Creates new instance of Pig Storage function.
AvroStorage(String, String) - Constructor for class org.apache.pig.builtin.AvroStorage
Creates new instance of AvroStorage function, specifying output schema properties.
AvroStorageDataConversionUtilities - Class in org.apache.pig.impl.util.avro
Utility classes for AvroStorage; contains static methods for converting between Avro and Pig objects.
AvroStorageDataConversionUtilities() - Constructor for class org.apache.pig.impl.util.avro.AvroStorageDataConversionUtilities
 
AvroStorageSchemaConversionUtilities - Class in org.apache.pig.impl.util.avro
Static methods for converting from Avro Schema object to Pig Schema objects, and vice versa.
AvroStorageSchemaConversionUtilities() - Constructor for class org.apache.pig.impl.util.avro.AvroStorageSchemaConversionUtilities
 
AvroTupleWrapper<T extends org.apache.avro.generic.IndexedRecord> - Class in org.apache.pig.impl.util.avro
Object that wraps an Avro object in a tuple.
AvroTupleWrapper(T) - Constructor for class org.apache.pig.impl.util.avro.AvroTupleWrapper
Creates a new AvroTupleWrapper object.

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(Tuple...) - Static method in class org.apache.pig.builtin.mock.Storage
 
BAG - Static variable in class org.apache.pig.data.BinInterSedes
 
BAG - Static variable in class org.apache.pig.data.DataType
 
bag(ThreadContext, IRubyObject, IRubyObject, IRubyObject) - Static method in class org.apache.pig.scripting.jruby.RubySchema
This is a ruby method which takes a name and an array of arguments and constructs a Bag schema from them.
bag(ThreadContext, IRubyObject, IRubyObject) - Static method in class org.apache.pig.scripting.jruby.RubySchema
This is a ruby method which takes an array of arguments and constructs a Bag schema from them.
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
Construct a new 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.Packager
 
bags - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
BagSize - Class in org.apache.pig.builtin
This method should never be used directly, use SIZE.
BagSize() - Constructor for class org.apache.pig.builtin.BagSize
 
BagToString - Class in org.apache.pig.builtin
Flatten a bag into a string.
BagToString() - Constructor for class org.apache.pig.builtin.BagToString
 
BagToTuple - Class in org.apache.pig.builtin
Flatten a bag into a tuple.
BagToTuple() - Constructor for class org.apache.pig.builtin.BagToTuple
 
Base - Class in org.apache.pig.builtin
base class for math udfs
Base() - Constructor for class org.apache.pig.builtin.Base
 
BaseOperatorPlan - Class in org.apache.pig.newplan
 
BaseOperatorPlan() - Constructor for class org.apache.pig.newplan.BaseOperatorPlan
 
BaseOperatorPlan(BaseOperatorPlan) - Constructor for class org.apache.pig.newplan.BaseOperatorPlan
 
BIG_JOB_LOG_MSG - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler
 
BIGCHARARRAY - Static variable in class org.apache.pig.data.DataType
Internal use only.
BIGDECIMAL - Static variable in class org.apache.pig.data.BinInterSedes
 
BIGDECIMAL - Static variable in class org.apache.pig.data.DataType
 
BigDecimalAbs - Class in org.apache.pig.builtin
 
BigDecimalAbs() - Constructor for class org.apache.pig.builtin.BigDecimalAbs
 
BigDecimalAvg - Class in org.apache.pig.builtin
This method should never be used directly, use AVG.
BigDecimalAvg() - Constructor for class org.apache.pig.builtin.BigDecimalAvg
 
BigDecimalAvg.Final - Class in org.apache.pig.builtin
 
BigDecimalAvg.Final() - Constructor for class org.apache.pig.builtin.BigDecimalAvg.Final
 
BigDecimalAvg.Initial - Class in org.apache.pig.builtin
 
BigDecimalAvg.Initial() - Constructor for class org.apache.pig.builtin.BigDecimalAvg.Initial
 
BigDecimalAvg.Intermediate - Class in org.apache.pig.builtin
 
BigDecimalAvg.Intermediate() - Constructor for class org.apache.pig.builtin.BigDecimalAvg.Intermediate
 
BigDecimalMax - Class in org.apache.pig.builtin
This method should never be used directly, use MAX.
BigDecimalMax() - Constructor for class org.apache.pig.builtin.BigDecimalMax
 
BigDecimalMax.Final - Class in org.apache.pig.builtin
 
BigDecimalMax.Final() - Constructor for class org.apache.pig.builtin.BigDecimalMax.Final
 
BigDecimalMax.Intermediate - Class in org.apache.pig.builtin
 
BigDecimalMax.Intermediate() - Constructor for class org.apache.pig.builtin.BigDecimalMax.Intermediate
 
BigDecimalMin - Class in org.apache.pig.builtin
This method should never be used directly, use MIN.
BigDecimalMin() - Constructor for class org.apache.pig.builtin.BigDecimalMin
 
BigDecimalMin.Final - Class in org.apache.pig.builtin
 
BigDecimalMin.Final() - Constructor for class org.apache.pig.builtin.BigDecimalMin.Final
 
BigDecimalMin.Intermediate - Class in org.apache.pig.builtin
 
BigDecimalMin.Intermediate() - Constructor for class org.apache.pig.builtin.BigDecimalMin.Intermediate
 
BigDecimalSum - Class in org.apache.pig.builtin
This method should never be used directly, use SUM.
BigDecimalSum() - Constructor for class org.apache.pig.builtin.BigDecimalSum
 
BigDecimalSum.Final - Class in org.apache.pig.builtin
 
BigDecimalSum.Final() - Constructor for class org.apache.pig.builtin.BigDecimalSum.Final
 
BigDecimalSum.Intermediate - Class in org.apache.pig.builtin
 
BigDecimalSum.Intermediate() - Constructor for class org.apache.pig.builtin.BigDecimalSum.Intermediate
 
BigDecimalWrapper - Class in org.apache.pig.builtin
Max and min seeds cannot be defined to BigDecimal as the value could go as large as The computer allows.
BigDecimalWrapper(BigInteger) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(BigInteger, int) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(BigInteger, int, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(BigInteger, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(char[]) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(char[], int, int) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(char[], int, int, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(char[], MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(double) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(double, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(int) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(int, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(long) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(long, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(String) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWrapper(String, MathContext) - Constructor for class org.apache.pig.builtin.BigDecimalWrapper
 
BigDecimalWritable - Class in org.apache.pig.backend.hadoop
 
BigDecimalWritable() - Constructor for class org.apache.pig.backend.hadoop.BigDecimalWritable
 
BigDecimalWritable(BigDecimal) - Constructor for class org.apache.pig.backend.hadoop.BigDecimalWritable
 
BigDecimalWritable.Comparator - Class in org.apache.pig.backend.hadoop
A Comparator optimized for BigDecimalWritable.
BigDecimalWritable.Comparator() - Constructor for class org.apache.pig.backend.hadoop.BigDecimalWritable.Comparator
 
BIGINTEGER - Static variable in class org.apache.pig.data.BinInterSedes
 
BIGINTEGER - Static variable in class org.apache.pig.data.DataType
 
BigIntegerAbs - Class in org.apache.pig.builtin
 
BigIntegerAbs() - Constructor for class org.apache.pig.builtin.BigIntegerAbs
 
BigIntegerAvg - Class in org.apache.pig.builtin
This method should never be used directly, use AVG.
BigIntegerAvg() - Constructor for class org.apache.pig.builtin.BigIntegerAvg
 
BigIntegerAvg.Final - Class in org.apache.pig.builtin
 
BigIntegerAvg.Final() - Constructor for class org.apache.pig.builtin.BigIntegerAvg.Final
 
BigIntegerAvg.Initial - Class in org.apache.pig.builtin
 
BigIntegerAvg.Initial() - Constructor for class org.apache.pig.builtin.BigIntegerAvg.Initial
 
BigIntegerAvg.Intermediate - Class in org.apache.pig.builtin
 
BigIntegerAvg.Intermediate() - Constructor for class org.apache.pig.builtin.BigIntegerAvg.Intermediate
 
BigIntegerMax - Class in org.apache.pig.builtin
This method should never be used directly, use MAX.
BigIntegerMax() - Constructor for class org.apache.pig.builtin.BigIntegerMax
 
BigIntegerMax.Final - Class in org.apache.pig.builtin
 
BigIntegerMax.Final() - Constructor for class org.apache.pig.builtin.BigIntegerMax.Final
 
BigIntegerMax.Intermediate - Class in org.apache.pig.builtin
 
BigIntegerMax.Intermediate() - Constructor for class org.apache.pig.builtin.BigIntegerMax.Intermediate
 
BigIntegerMin - Class in org.apache.pig.builtin
This method should never be used directly, use MIN.
BigIntegerMin() - Constructor for class org.apache.pig.builtin.BigIntegerMin
 
BigIntegerMin.Final - Class in org.apache.pig.builtin
 
BigIntegerMin.Final() - Constructor for class org.apache.pig.builtin.BigIntegerMin.Final
 
BigIntegerMin.Intermediate - Class in org.apache.pig.builtin
 
BigIntegerMin.Intermediate() - Constructor for class org.apache.pig.builtin.BigIntegerMin.Intermediate
 
BigIntegerSum - Class in org.apache.pig.builtin
This method should never be used directly, use SUM.
BigIntegerSum() - Constructor for class org.apache.pig.builtin.BigIntegerSum
 
BigIntegerSum.Final - Class in org.apache.pig.builtin
 
BigIntegerSum.Final() - Constructor for class org.apache.pig.builtin.BigIntegerSum.Final
 
BigIntegerSum.Intermediate - Class in org.apache.pig.builtin
 
BigIntegerSum.Intermediate() - Constructor for class org.apache.pig.builtin.BigIntegerSum.Intermediate
 
BigIntegerWrapper - Class in org.apache.pig.builtin
Max and min seeds cannot be defined to BigInteger as the value could go as large as The computer allows.
BigIntegerWrapper(byte[]) - Constructor for class org.apache.pig.builtin.BigIntegerWrapper
 
BigIntegerWrapper(int, byte[]) - Constructor for class org.apache.pig.builtin.BigIntegerWrapper
 
BigIntegerWrapper(int, int, Random) - Constructor for class org.apache.pig.builtin.BigIntegerWrapper
 
BigIntegerWrapper(int, Random) - Constructor for class org.apache.pig.builtin.BigIntegerWrapper
 
BigIntegerWrapper(String) - Constructor for class org.apache.pig.builtin.BigIntegerWrapper
 
BigIntegerWrapper(String, int) - Constructor for class org.apache.pig.builtin.BigIntegerWrapper
 
BigIntegerWritable - Class in org.apache.pig.backend.hadoop
 
BigIntegerWritable() - Constructor for class org.apache.pig.backend.hadoop.BigIntegerWritable
 
BigIntegerWritable(BigInteger) - Constructor for class org.apache.pig.backend.hadoop.BigIntegerWritable
 
BigIntegerWritable.Comparator - Class in org.apache.pig.backend.hadoop
A Comparator optimized for BigIntegerWritable.
BigIntegerWritable.Comparator() - Constructor for class org.apache.pig.backend.hadoop.BigIntegerWritable.Comparator
 
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.newplan.logical.expression
Superclass for all binary expressions
BinaryExpression(String, OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.newplan.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
 
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
 
BinCondExpression - Class in org.apache.pig.newplan.logical.expression
 
BinCondExpression(OperatorPlan, LogicalExpression, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.newplan.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
bind(Object) - Method in class org.apache.pig.scripting.js.JSPig
javascript helper for binding parameters.
bind() - Method in class org.apache.pig.scripting.js.JSPig
bind(Map<String, Object>) - Method in class org.apache.pig.scripting.Pig
Bind this to a set of variables.
bind(List<Map<String, Object>>) - Method in class org.apache.pig.scripting.Pig
Bind this to multiple sets of variables.
bind() - Method in class org.apache.pig.scripting.Pig
Bind a Pig object to variables in the host language (optional operation).
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.
BinInterSedes - Class in org.apache.pig.data
A class to handle reading and writing of intermediate results of data types.
BinInterSedes() - Constructor for class org.apache.pig.data.BinInterSedes
 
BinInterSedes.BinInterSedesTupleRawComparator - Class in org.apache.pig.data
 
BinInterSedes.BinInterSedesTupleRawComparator() - Constructor for class org.apache.pig.data.BinInterSedes.BinInterSedesTupleRawComparator
 
BinSedesTuple - Class in org.apache.pig.data
This tuple has a faster (de)serialization mechanism.
BinSedesTupleFactory - Class in org.apache.pig.data
Default implementation of TupleFactory.
BinSedesTupleFactory() - Constructor for class org.apache.pig.data.BinSedesTupleFactory
 
BinStorage - Class in org.apache.pig.builtin
Load and store data in a binary format.
BinStorage() - Constructor for class org.apache.pig.builtin.BinStorage
 
BinStorage(String) - Constructor for class org.apache.pig.builtin.BinStorage
 
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
 
bitSetToLong(BitSet) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
BlackAndWhitelistFilter - Class in org.apache.pig.validator
This Filter handles black and whitelisting of Pig commands.
BlackAndWhitelistFilter(PigServer) - Constructor for class org.apache.pig.validator.BlackAndWhitelistFilter
 
BlackAndWhitelistFilter(PigContext) - Constructor for class org.apache.pig.validator.BlackAndWhitelistFilter
 
BlackAndWhitelistValidator - Class in org.apache.pig.validator
This validator walks through the list of operators defined in PigConfiguration.PIG_BLACKLIST and PigConfiguration.PIG_WHITELIST and checks whether the operation is permitted.
BlackAndWhitelistValidator(PigContext, OperatorPlan) - Constructor for class org.apache.pig.validator.BlackAndWhitelistValidator
 
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.
Bloom - Class in org.apache.pig.builtin
Use a Bloom filter build previously by BuildBloom.
Bloom(String) - Constructor for class org.apache.pig.builtin.Bloom
 
bloomIn(DataByteArray) - Method in class org.apache.pig.builtin.BuildBloomBase
 
bloomOr(Tuple) - Method in class org.apache.pig.builtin.BuildBloomBase
 
bloomOut() - Method in class org.apache.pig.builtin.BuildBloomBase
 
BOOLEAN - Static variable in class org.apache.pig.data.DataType
 
BOOLEAN_FALSE - Static variable in class org.apache.pig.data.BinInterSedes
 
BOOLEAN_TRUE - Static variable in class org.apache.pig.data.BinInterSedes
 
BoundScript - Class in org.apache.pig.scripting
This represents an instance of a bound pipeline.
box(DataBag) - Method in class org.apache.pig.data.SchemaTuple
 
box(Map<String, Object>) - Method in class org.apache.pig.data.SchemaTuple
 
box(byte[]) - Method in class org.apache.pig.data.SchemaTuple
 
box(String) - Method in class org.apache.pig.data.SchemaTuple
 
box(Tuple) - Method in class org.apache.pig.data.SchemaTuple
 
box(int) - Method in class org.apache.pig.data.SchemaTuple
 
box(long) - Method in class org.apache.pig.data.SchemaTuple
 
box(float) - Method in class org.apache.pig.data.SchemaTuple
 
box(double) - Method in class org.apache.pig.data.SchemaTuple
 
box(boolean) - Method in class org.apache.pig.data.SchemaTuple
 
box(DateTime) - Method in class org.apache.pig.data.SchemaTuple
 
box(BigDecimal) - Method in class org.apache.pig.data.SchemaTuple
 
box(BigInteger) - Method in class org.apache.pig.data.SchemaTuple
 
breadthFirst() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PlanPrinter
 
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
 
build() - Method in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat.HBaseTableIFBuilder
 
BuildBloom - Class in org.apache.pig.builtin
Build a bloom filter for use later in Bloom.
BuildBloom(String, String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom
Build a bloom filter of fixed size and number of hash functions.
BuildBloom(String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom
Construct a Bloom filter based on expected number of elements and desired accuracy.
BuildBloom.Final - Class in org.apache.pig.builtin
 
BuildBloom.Final() - Constructor for class org.apache.pig.builtin.BuildBloom.Final
 
BuildBloom.Final(String, String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom.Final
 
BuildBloom.Final(String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom.Final
 
BuildBloom.Initial - Class in org.apache.pig.builtin
 
BuildBloom.Initial() - Constructor for class org.apache.pig.builtin.BuildBloom.Initial
 
BuildBloom.Initial(String, String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom.Initial
 
BuildBloom.Initial(String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom.Initial
 
BuildBloom.Intermediate - Class in org.apache.pig.builtin
 
BuildBloom.Intermediate() - Constructor for class org.apache.pig.builtin.BuildBloom.Intermediate
 
BuildBloom.Intermediate(String, String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom.Intermediate
 
BuildBloom.Intermediate(String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloom.Intermediate
 
BuildBloomBase<T> - Class in org.apache.pig.builtin
A Base class for BuildBloom and its Algebraic implementations.
BuildBloomBase() - Constructor for class org.apache.pig.builtin.BuildBloomBase
 
BuildBloomBase(String, String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloomBase
 
BuildBloomBase(String, String, String) - Constructor for class org.apache.pig.builtin.BuildBloomBase
 
buildDAG(TezOperPlan, Map<String, LocalResource>) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezJobCompiler
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.FilterAboveForeach
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.FilterConstantCalculator
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.ForEachConstantCalculator
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.GroupByConstParallelSetter
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.LimitOptimizer
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.LoadTypeCastInserter
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.MergeFilter
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.MergeForEach
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.PartitionFilterOptimizer
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.PredicatePushdownOptimizer
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.PushDownForEachFlatten
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.PushUpFilter
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.SplitFilter
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.StreamTypeCastInserter
 
buildPattern() - Method in class org.apache.pig.newplan.logical.rules.WholePlanRule
 
buildPattern() - Method in class org.apache.pig.newplan.optimizer.Rule
Build the pattern that this rule will look for
buildRuleSets() - Method in class org.apache.pig.newplan.logical.optimizer.LogicalPlanOptimizer
 
buildSimpleFuncSpec(String, byte...) - Static method in class org.apache.pig.impl.util.Utils
 
BYTE - Static variable in class org.apache.pig.data.BinInterSedes
 
BYTE - Static variable in class org.apache.pig.data.DataType
 
BYTEARRAY - Static variable in class org.apache.pig.data.BinInterSedes
 
BYTEARRAY - Static variable in class org.apache.pig.data.DataType
 
BYTES_PER_REDUCER_PARAM - Static variable in interface org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigReducerEstimator
 
BytesHelper - Class in org.apache.pig.data.utils
 
BytesHelper() - Constructor for class org.apache.pig.data.utils.BytesHelper
 
bytesToBag(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
NOT IMPLEMENTED
bytesToBag(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
NOT IMPLEMENTED
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 bytearray to bag value.
bytesToBigCharArray(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToBigDecimal(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToBigDecimal(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
Not implemented!
bytesToBigDecimal(byte[]) - Method in class org.apache.pig.builtin.TextLoader
 
bytesToBigDecimal(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToBigDecimal(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytearray to BigDecimal value.
bytesToBigInteger(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToBigInteger(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
Not implemented!
bytesToBigInteger(byte[]) - Method in class org.apache.pig.builtin.TextLoader
 
bytesToBigInteger(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToBigInteger(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytearray to BigInteger value.
bytesToBoolean(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToBoolean(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
bytesToBoolean(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to Boolean
bytesToBoolean(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToBoolean(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytearray to boolean value.
bytesToCharArray(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToCharArray(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
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 bytearray to chararray value.
bytesToDateTime(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
NOT IMPLEMENTED
bytesToDateTime(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
NOT IMPLEMENTED
bytesToDateTime(byte[]) - Method in class org.apache.pig.builtin.TextLoader
TextLoader does not support conversion to DateTime
bytesToDateTime(byte[]) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToDateTime(byte[]) - Method in interface org.apache.pig.LoadCaster
Cast data from bytearray to datetime value.
bytesToDouble(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToDouble(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
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 bytearray to double value.
bytesToFloat(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToFloat(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
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 bytearray to float value.
bytesToInteger(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToInteger(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
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 bytearray to integer value.
bytesToInternalMap(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToLong(byte[]) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
 
bytesToLong(byte[]) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
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 bytearray to long value.
bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
NOT IMPLEMENTED
bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
 
bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.TextLoader
 
bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.builtin.Utf8StorageConverter
 
bytesToMap(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 
bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) - Method in interface org.apache.pig.LoadCaster
Cast data from bytearray to map value.
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloBinaryConverter
NOT IMPLEMENTED
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
NOT IMPLEMENTED
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[], int, int, byte) - Static method in class org.apache.pig.impl.util.StorageUtil
Transform bytes from a byte array up to the specified length to a Tuple
bytesToTuple(byte[], ResourceSchema.ResourceFieldSchema) - Method in interface org.apache.pig.LoadCaster
Cast data from bytearray to tuple value.
bytesToWritable(DataInput) - Static method in class org.apache.pig.data.DataReaderWriter
 

C

cache(String, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.ObjectCache
 
calcCastString() - Method in class org.apache.pig.ResourceSchema.ResourceFieldSchema
 
calculateMedianValue(List<Long>) - Method in class org.apache.pig.tools.pigstats.JobStats
Calculate the median value from the given array
calculateProgress(JobControl) - Method in class org.apache.pig.backend.hadoop.executionengine.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.
canPushDown() - Method in class org.apache.pig.newplan.FilterExtractor
 
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(byte, byte) - Static method in class org.apache.pig.data.DataType
Test if one type can cast to the other.
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
castable(LogicalSchema, LogicalSchema) - Static method in class org.apache.pig.newplan.logical.relational.LogicalSchema
Recursively compare two schemas to check if the input schema can be cast to the cast schema
castable(LogicalSchema.LogicalFieldSchema, LogicalSchema.LogicalFieldSchema) - Static method in class org.apache.pig.newplan.logical.relational.LogicalSchema.LogicalFieldSchema
Check if FieldSchema inFs is castable to outFs
caster - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
caster - Variable in class org.apache.pig.builtin.PigStorage
 
CASTER_OPTION - Static variable in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorageOptions
 
CastExpression - Class in org.apache.pig.newplan.logical.expression
 
CastExpression(OperatorPlan, LogicalExpression, LogicalSchema.LogicalFieldSchema) - Constructor for class org.apache.pig.newplan.logical.expression.CastExpression
 
CastLineageSetter - Class in org.apache.pig.newplan.logical.visitor
Find uid lineage information.
CastLineageSetter(LogicalPlan, CompilationMessageCollector) - Constructor for class org.apache.pig.newplan.logical.visitor.CastLineageSetter
 
CastUtils - Class in org.apache.pig.impl.util
 
CastUtils() - Constructor for class org.apache.pig.impl.util.CastUtils
 
CBRT - Class in org.apache.pig.builtin
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.builtin.CBRT
 
CEIL - Class in org.apache.pig.builtin
CEIL implements a binding to the Java function Math.ceil(double).
CEIL() - Constructor for class org.apache.pig.builtin.CEIL
 
ceilingCheck() - Method in class org.apache.pig.pen.Illustrator
 
changes() - Method in class org.apache.pig.impl.plan.ProjectionMap
 
CHARARRAY - Static variable in class org.apache.pig.data.BinInterSedes
 
CHARARRAY - Static variable in class org.apache.pig.data.DataType
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.AddForEach.AddForEachTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.ColumnMapKeyPrune.ColumnMapKeyPruneTransformer
 
check() - Method in class org.apache.pig.newplan.logical.rules.ColumnPruneHelper
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.ConstantCalculator.ConstantCalculatorTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.FilterAboveForeach.FilterAboveForEachTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.GroupByConstParallelSetter.GroupAllParallelSetterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.LimitOptimizer.OptimizeLimitTransformer
 
check() - Method in class org.apache.pig.newplan.logical.rules.MapKeysPruneHelper
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.MergeFilter.MergeFilterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.MergeForEach.MergeForEachTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.PartitionFilterOptimizer.PartitionFilterPushDownTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.PushUpFilter.PushUpFilterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.SplitFilter.SplitFilterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.logical.rules.TypeCastInserter.TypeCastInserterTransformer
 
check(OperatorPlan) - Method in class org.apache.pig.newplan.optimizer.Transformer
check if the transform should be done.
checkBagType() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager
 
checkEquality(LogicalRelationalOperator) - Method in class org.apache.pig.newplan.logical.relational.LogicalRelationalOperator
Do some basic equality checks on two relational operators.
checkExit(int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.RunJarSecurityManager
 
checkLeafIsStore(PhysicalPlan, PigContext) - Static method in class org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil
 
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(JobContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat
 
checkPermission(Permission) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.RunJarSecurityManager
 
checkPushDown(LogicalExpression) - Method in class org.apache.pig.newplan.FilterExtractor
 
checkPushDown(BinaryExpression) - Method in class org.apache.pig.newplan.FilterExtractor
 
checkPushDown(UnaryExpression) - Method in class org.apache.pig.newplan.FilterExtractor
 
checkPushDown(ProjectExpression) - Method in class org.apache.pig.newplan.FilterExtractor
 
checkPushDown(ProjectExpression) - Method in class org.apache.pig.newplan.PartitionFilterExtractor
 
checkPushDown(ProjectExpression) - Method in class org.apache.pig.newplan.PredicatePushDownFilterExtractor
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.AvroStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.BinStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.JsonStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.mock.Storage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.OrcStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.builtin.PigStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.impl.io.InterStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.impl.io.SequenceFileInterStorage
 
checkSchema(ResourceSchema) - Method in class org.apache.pig.impl.io.TFileStorage
 
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.
checkSchema(ResourceSchema) - Method in class org.apache.pig.StoreFuncWrapper
 
checkScript(String) - Method in class org.apache.pig.tools.grunt.Grunt
 
CHILD_JAVA_OPTS - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRConfiguration
 
cleanup() - Method in interface org.apache.pig.Accumulator
Called after getValue() to prepare processing for next key.
cleanup() - Method in class org.apache.pig.AccumulatorEvalFunc
 
cleanup() - Method in class org.apache.pig.AlgebraicEvalFunc
Per the Accumulator interface, this clears all of the variables used in the implementation.
cleanUp() - Method in class org.apache.pig.backend.hadoop.executionengine.fetch.FetchPOStoreImpl
 
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.PigGenericMapBase
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.PigGenericMapReduce.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.AlgebraicBigDecimalMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AlgebraicBigIntegerMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AlgebraicDoubleMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AlgebraicFloatMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AlgebraicIntMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AlgebraicLongMathBase
 
cleanup() - Method in class org.apache.pig.builtin.AVG
 
cleanup() - Method in class org.apache.pig.builtin.BigDecimalAvg
 
cleanup() - Method in class org.apache.pig.builtin.BigIntegerAvg
 
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.DateTimeMax
 
cleanup() - Method in class org.apache.pig.builtin.DateTimeMin
 
cleanup() - Method in class org.apache.pig.builtin.DoubleAvg
 
cleanup() - Method in class org.apache.pig.builtin.FloatAvg
 
cleanup() - Method in class org.apache.pig.builtin.IntAvg
 
cleanup() - Method in class org.apache.pig.builtin.LongAvg
 
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.IteratingAccumulatorEvalFunc
 
cleanup() - Method in class org.apache.pig.scripting.groovy.GroovyAccumulatorEvalFunc
 
cleanup() - Method in class org.apache.pig.scripting.jruby.JrubyAccumulatorEvalFunc
 
cleanupJob(JobContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.AvroStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.BinStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.mock.Storage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.OrcStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.builtin.PigStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.impl.io.InterStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.impl.io.SequenceFileInterStorage
 
cleanupOnFailure(String, Job) - Method in class org.apache.pig.impl.io.TFileStorage
 
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.
cleanupOnFailure(String, Job) - Method in class org.apache.pig.StoreFuncWrapper
 
cleanupOnFailureImpl(String, Job) - Static method in class org.apache.pig.StoreFunc
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.builtin.AvroStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.builtin.BinStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.builtin.mock.Storage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.builtin.OrcStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.builtin.PigStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.impl.io.InterStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.impl.io.SequenceFileInterStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.impl.io.TFileStorage
 
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.StoreFunc
This method will be called by Pig if the job which contains this store is successful, and some cleanup of intermediate resources is required.
cleanupOnSuccess(String, Job) - Method in interface org.apache.pig.StoreFuncInterface
This method will be called by Pig if the job which contains this store is successful, and some cleanup of intermediate resources is required.
cleanupOnSuccess(String, Job) - Method in class org.apache.pig.StoreFuncWrapper
 
cleanupOutput(POStore, Job) - Method in class org.apache.pig.builtin.PigStorage
 
cleanupOutput(POStore, Job) - Method in interface org.apache.pig.OverwritableStoreFunc
This method is called to cleanup the store/output location of this StoreFunc.
cleanupStaticData() - Static method in class org.apache.pig.impl.util.UDFContext
 
cleanupStaticData() - Method in class org.apache.pig.JVMReuseImpl
 
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.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage.POPackageTupleBuffer
 
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.avro.AvroBagWrapper
 
clear() - Method in class org.apache.pig.impl.util.avro.AvroMapWrapper
 
clear() - Method in class org.apache.pig.impl.util.IdentityHashSet
 
clear() - Method in class org.apache.pig.impl.util.MultiMap
 
clear() - Method in class org.apache.pig.scripting.jruby.RubyDataBag
This method deletes all of the entries in the underlying DataBag.
clearDone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POUnion
 
clearSpillables() - Method in class org.apache.pig.impl.util.SpillableMemoryManager
 
clearUnset(Configuration, Map<String, String>) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
Replaces the given entries in the configuration by clearing the Configuration and re-adding the elements that aren't in the Map of entries to unset
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnChainInfo
 
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnInfo
 
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.LitePackager
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager
 
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.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.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.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTez
Make a deep copy of this operator.
clone() - Method in class org.apache.pig.FuncSpec
 
clone() - Method in class org.apache.pig.impl.io.NullablePartitionWritable
 
clone() - Method in class org.apache.pig.impl.io.PigNullableWritable
 
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.plan.Operator
 
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.impl.util.UDFContext
Make a shallow copy of the context.
clone() - Method in class org.apache.pig.ResourceStatistics
 
clone(ThreadContext) - Method in class org.apache.pig.scripting.jruby.RubyDataBag
This method returns a copy of the encapsulated DataBag.
clone(ThreadContext) - Method in class org.apache.pig.scripting.jruby.RubySchema
 
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
 
cloneUid() - Method in class org.apache.pig.newplan.logical.relational.LogicalSchema.LogicalFieldSchema
 
close() - Method in interface org.apache.pig.backend.datastorage.DataStorage
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(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.executionengine.tez.runtime.PigProcessor
 
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() - Method in class org.apache.pig.impl.io.InterRecordReader
 
close(TaskAttemptContext) - Method in class org.apache.pig.impl.io.InterRecordWriter
 
close() - Method in class org.apache.pig.impl.io.TFileRecordReader
 
close(TaskAttemptContext) - Method in class org.apache.pig.impl.io.TFileRecordWriter
 
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 class org.apache.pig.impl.util.avro.AvroArrayReader
 
close() - Method in class org.apache.pig.impl.util.avro.AvroRecordReader
 
close(TaskAttemptContext) - Method in class org.apache.pig.impl.util.avro.AvroRecordWriter
 
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.pen.FakeRawKeyValueIterator
 
closePlan() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.XMLMRPrinter
 
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.PigGenericMapBase
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.Map
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.MapWithComparator
 
collect(Mapper<Text, Tuple, PigNullableWritable, Writable>.Context, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.MapWithPartitionIndex
 
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.PigMapReduceCounter.PigMapCounter
While tuples are collected, they are counted one by one by a global counter per task.
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 a 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.
COLON - Static variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
Column - Class in org.apache.pig.backend.hadoop.accumulo
Extracts necessary information from a user provide column "specification": colf[[*]:[colq[*]]] Removes any trailing asterisk on colfam or colqual, and appropriately sets the {#link Column.Type}
Column(String) - Constructor for class org.apache.pig.backend.hadoop.accumulo.Column
 
Column.Type - Enum in org.apache.pig.backend.hadoop.accumulo
 
COLUMN_IGNORE_WHITESPACE_OPTION - Static variable in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorageOptions
 
COLUMN_SEPARATOR_OPTION - Static variable in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorageOptions
 
ColumnAliasConversionVisitor - Class in org.apache.pig.newplan.logical.visitor
Logical plan visitor which will convert all column alias references to column indexes, using the underlying anonymous expression plan visitor.
ColumnAliasConversionVisitor(OperatorPlan) - Constructor for class org.apache.pig.newplan.logical.visitor.ColumnAliasConversionVisitor
 
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.newplan.logical.expression
Super class for all column expressions, including projection, constants, and deferences.
ColumnExpression(String, OperatorPlan) - Constructor for class org.apache.pig.newplan.logical.expression.ColumnExpression
 
ColumnInfo - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
 
ColumnInfo(List<Integer>, byte) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnInfo
 
ColumnInfo(int, byte) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.ColumnInfo
Constructor for range projection or project-star
ColumnMapKeyPrune - Class in org.apache.pig.newplan.logical.rules
This Rule prunes columns and map keys and set to loader.
ColumnMapKeyPrune(String) - Constructor for class org.apache.pig.newplan.logical.rules.ColumnMapKeyPrune
 
ColumnMapKeyPrune.ColumnMapKeyPruneTransformer - Class in org.apache.pig.newplan.logical.rules
 
ColumnMapKeyPrune.ColumnMapKeyPruneTransformer() - Constructor for class org.apache.pig.newplan.logical.rules.ColumnMapKeyPrune.ColumnMapKeyPruneTransformer
 
ColumnPruneHelper - Class in org.apache.pig.newplan.logical.rules
Helper class used by ColumnMapKeyPrune to figure out what columns can be pruned.
ColumnPruneHelper(OperatorPlan) - Constructor for class org.apache.pig.newplan.logical.rules.ColumnPruneHelper
 
ColumnPruneVisitor - Class in org.apache.pig.newplan.logical.rules
 
ColumnPruneVisitor(OperatorPlan, Map<LOLoad, Pair<Map<Integer, Set<String>>, Set<Integer>>>, boolean) - Constructor for class org.apache.pig.newplan.logical.rules.ColumnPruneVisitor
 
columns - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
columns - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject
 
columnSeparator - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
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.BigDecimalAvg
 
combine(DataBag) - Static method in class org.apache.pig.builtin.BigIntegerAvg
 
combine(DataBag) - Static method in class org.apache.pig.builtin.COR
combine results of different data chunk
combine(DataBag) - Static method in class org.apache.pig.builtin.COV
combine results of different data chunk
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_PLAN - Static variable in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigProcessor
 
combinePlan - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
 
combinePlan - Variable in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezEdgeDescriptor
 
CombinerOptimizer - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Optimize map reduce plans to use the combiner where possible.
CombinerOptimizer(MROperPlan, boolean) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer
 
CombinerOptimizer(MROperPlan, boolean, CompilationMessageCollector) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.CombinerOptimizer
 
CombinerOptimizer - Class in org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer
Optimize tez plans to use the combiner where possible.
CombinerOptimizer(TezOperPlan, boolean) - Constructor for class org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.CombinerOptimizer
 
CombinerOptimizer(TezOperPlan, boolean, CompilationMessageCollector) - Constructor for class org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.CombinerOptimizer
 
CombinerOptimizerUtil - Class in org.apache.pig.backend.hadoop.executionengine.util
 
CombinerPackager - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
The package operator that packages the globally rearranged tuples into output format after the combiner stage.
CombinerPackager(Packager, boolean[]) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.CombinerPackager
A new POPostCombinePackage will be constructed as a near clone of the provided POPackage.
combineSmallSplits() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
 
combineSmallSplits() - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator
 
COMMA - Static variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
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
 
commandLine - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
commandLine - Variable in class org.apache.pig.tools.pigstats.ScriptState
 
commitJob(JobContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
commitJob(JobContext) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigOutputFormatTez.PigOutputCommitterTez
 
commitTask(TaskAttemptContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputCommitter
 
comparator - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.BigDecimalWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.BigIntegerWritable.Comparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.DateTimeWritable.Comparator
 
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.PigBigDecimalRawComparator
Compare two NullableBigDecimalWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBigDecimalRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBigIntegerRawComparator
Compare two NullableBigIntegerWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBigIntegerRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBooleanRawComparator
Compare two NullableIntWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigBooleanRawComparator
 
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.PigDateTimeRawComparator
Compare two NullableIntWritables as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigDateTimeRawComparator
 
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(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.PigTupleDefaultRawComparator
Compare two NullableTuples as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTupleDefaultRawComparator
 
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTupleSortComparator
Compare two NullableTuples as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTupleSortComparator
 
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
Deprecated.
Compare two tuples.
compare(Tuple, Tuple) - Method in class org.apache.pig.ComparisonFunc
Deprecated.
This callback method must be implemented by all subclasses.
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.data.BinInterSedes.BinInterSedesTupleRawComparator
Compare two BinSedesTuples as raw bytes.
compare(WritableComparable, WritableComparable) - Method in class org.apache.pig.data.BinInterSedes.BinInterSedesTupleRawComparator
 
compare(byte[], byte[]) - Static method in class org.apache.pig.data.DataByteArray
 
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
Same as DataType.compare(Object, Object), but does not use reflection to determine the type of passed in objects, relying instead on the caller to provide the appropriate values, as determined by DataType.findType(Object).
compare(byte[], int, int, byte[], int, int) - Method in class org.apache.pig.data.DefaultTuple.DefaultTupleRawComparator
Compare two DefaultTuples as raw bytes.
compare(Object, Object) - Method in class org.apache.pig.data.DefaultTuple.DefaultTupleRawComparator
 
compare(boolean, int, boolean, int) - Method in class org.apache.pig.data.SchemaTuple
 
compare(int, int) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, long, boolean, long) - Method in class org.apache.pig.data.SchemaTuple
 
compare(long, long) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, float, boolean, float) - Method in class org.apache.pig.data.SchemaTuple
 
compare(float, float) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, double, boolean, double) - Method in class org.apache.pig.data.SchemaTuple
 
compare(double, double) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, boolean, boolean, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, byte[], boolean, byte[]) - Method in class org.apache.pig.data.SchemaTuple
 
compare(byte[], byte[]) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, DateTime, boolean, DateTime) - Method in class org.apache.pig.data.SchemaTuple
 
compare(DateTime, DateTime) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, BigDecimal, boolean, BigDecimal) - Method in class org.apache.pig.data.SchemaTuple
 
compare(BigDecimal, BigDecimal) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, BigInteger, boolean, BigInteger) - Method in class org.apache.pig.data.SchemaTuple
 
compare(BigInteger, BigInteger) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, String, boolean, String) - Method in class org.apache.pig.data.SchemaTuple
 
compare(String, String) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, DataBag, boolean, DataBag) - Method in class org.apache.pig.data.SchemaTuple
 
compare(DataBag, DataBag) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, Map<String, Object>, boolean, Map<String, Object>) - Method in class org.apache.pig.data.SchemaTuple
 
compare(Map<String, Object>, Map<String, Object>) - Method in class org.apache.pig.data.SchemaTuple
 
compare(boolean, SchemaTuple<?>, boolean, Object) - Method in class org.apache.pig.data.SchemaTuple
 
compare(ThreadContext, IRubyObject, IRubyObject, IRubyObject) - Static method in class org.apache.pig.scripting.jruby.RubyDataByteArray
This calls to the static method compare of DataByteArray.
compareElementAtPos(int, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareNull(boolean, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
compareNull(boolean, Tuple, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareSize(Tuple) - Method in class org.apache.pig.data.SchemaTuple
 
compareTo(BigDecimalWritable) - Method in class org.apache.pig.backend.hadoop.BigDecimalWritable
 
compareTo(BigIntegerWritable) - Method in class org.apache.pig.backend.hadoop.BigIntegerWritable
 
compareTo(ElementDescriptor) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
compareTo(Object) - Method in class org.apache.pig.backend.hadoop.DateTimeWritable
 
compareTo(Object) - Method in class org.apache.pig.backend.hadoop.DoubleWritable
 
compareTo(Object) - Method in class org.apache.pig.data.AccumulativeBag
 
compareTo(SchemaTuple<?>, boolean) - Method in class org.apache.pig.data.AppendableSchemaTuple
 
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.SchemaTuple
 
compareTo(Tuple) - Method in class org.apache.pig.data.SchemaTuple
 
compareTo(Tuple, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
compareTo(SchemaTuple<?>) - Method in class org.apache.pig.data.SchemaTuple
 
compareTo(SchemaTuple<?>, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
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.impl.util.avro.AvroBagWrapper
 
compareTo(Object) - Method in class org.apache.pig.impl.util.avro.AvroTupleWrapper
 
compareTo(Object) - Method in class org.apache.pig.pen.util.ExampleTuple
 
compareTo(ThreadContext, IRubyObject) - Method in class org.apache.pig.scripting.jruby.RubyDataByteArray
This calls the compareTo method of the encapsulated DataByteArray.
compareToSpecific(T) - Method in class org.apache.pig.data.AppendableSchemaTuple
 
compareToSpecific(T) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, int, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, long, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, float, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, double, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, boolean, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, byte[], SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, DateTime, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, BigDecimal, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, BigInteger, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, String, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, DataBag, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, Map<String, Object>, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
compareWithElementAtPos(boolean, SchemaTuple<?>, SchemaTuple<?>, int) - Method in class org.apache.pig.data.SchemaTuple
 
ComparisonFunc - Class in org.apache.pig
Deprecated.
ComparisonFunc() - Constructor for class org.apache.pig.ComparisonFunc
Deprecated.
 
ComparisonOperator - Interface in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
This is an interface for all comparison operators.
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
 
CompilationMessageCollector.Unknown - Enum in org.apache.pig.impl.plan
 
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(PhysicalPlan, PigContext) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
 
compile() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
The front-end method that the user calls to compile the plan.
compile() - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezCompiler
The front-end method that the user calls to compile the plan.
compile(TezOperPlan, String, TezPlanContainer) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezJobCompiler
 
compile(PhysicalPlan, PigContext) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezLauncher
 
compile(String, JavaCompilerHelper.JavaSourceFromString...) - Method in class org.apache.pig.impl.util.JavaCompilerHelper
 
compile(String) - Static method in class org.apache.pig.scripting.js.JSPig
Define a Pig pipeline.
compile(String, String) - Static method in class org.apache.pig.scripting.js.JSPig
Define a named portion of a Pig pipeline.
compile(String) - Static method in class org.apache.pig.scripting.Pig
Define a Pig pipeline.
compile(String, String) - Static method in class org.apache.pig.scripting.Pig
Define a named portion of a Pig pipeline.
CompiledAutomaton - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex
 
CompiledAutomaton(String) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex.CompiledAutomaton
 
CompiledRegex - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex
 
CompiledRegex(Pattern) - Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex.CompiledRegex
 
compileFromFile(String) - Static method in class org.apache.pig.scripting.js.JSPig
Define a Pig pipeline based on Pig Latin in a separate file.
compileFromFile(String, String) - Static method in class org.apache.pig.scripting.js.JSPig
Define a named Pig pipeline based on Pig Latin in a separate file.
compileFromFile(String) - Static method in class org.apache.pig.scripting.Pig
Define a Pig pipeline based on Pig Latin in a separate file.
compileFromFile(String, String) - Static method in class org.apache.pig.scripting.Pig
Define a named Pig pipeline based on Pig Latin in a separate file.
CompilerUtils - Class in org.apache.pig.impl.util
 
CompilerUtils() - Constructor for class org.apache.pig.impl.util.CompilerUtils
 
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
 
computeAll(DataBag, DataBag) - Static method in class org.apache.pig.builtin.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.builtin.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.SampleLoader
 
computeTimeSpent(Iterator<TaskReport>) - Method in class org.apache.pig.backend.hadoop.executionengine.Launcher
 
CONCAT - Class in org.apache.pig.builtin
Generates the concatenation of two or more arguments.
CONCAT() - Constructor for class org.apache.pig.builtin.CONCAT
 
conf - Variable in class org.apache.pig.tools.pigstats.JobStats
 
conf_ - Variable in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat.HBaseTableIFBuilder
 
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
 
configureCompression(Configuration) - Static method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler
 
configureInputFormat(Job) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
Method to allow specific implementations to add more elements to the Job for reading data from Accumulo.
configureInputFormat(Job) - Method in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorage
 
configureOutputFormat(Job) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
Method to allow specific implementations to add more elements to the Job for writing data to Accumulo.
configureValueOnlyTupleOutput(TezEdgeDescriptor, DataMovementType) - Static method in class org.apache.pig.backend.hadoop.executionengine.tez.util.TezCompilerUtil
 
connect(PhysicalOperator, PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
 
connect(TezOperPlan, TezOperator, TezOperator) - Static method in class org.apache.pig.backend.hadoop.executionengine.tez.util.TezCompilerUtil
 
connect(TezOperPlan, TezOperator, TezOperator, TezEdgeDescriptor) - Static method in class org.apache.pig.backend.hadoop.executionengine.tez.util.TezCompilerUtil
 
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.
connect(Operator, int, Operator, int) - Method in class org.apache.pig.newplan.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.newplan.BaseOperatorPlan
Connect two operators in the plan.
connect(Operator, int, Operator, int) - Method in interface org.apache.pig.newplan.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.newplan.OperatorPlan
Connect two operators in the plan.
connect(Operator, int, Operator, int) - Method in class org.apache.pig.newplan.OperatorSubPlan
 
connect(Operator, Operator) - Method in class org.apache.pig.newplan.OperatorSubPlan
 
connectedToPackage - Variable in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTez
 
connectSoftLink() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
ConstantCalculator - Class in org.apache.pig.newplan.logical.rules
 
ConstantCalculator(String, PigContext) - Constructor for class org.apache.pig.newplan.logical.rules.ConstantCalculator
 
ConstantCalculator.ConstantCalculatorTransformer - Class in org.apache.pig.newplan.logical.rules
 
ConstantCalculator.ConstantCalculatorTransformer(List<LogicalRelationalOperator>, PigContext) - Constructor for class org.apache.pig.newplan.logical.rules.ConstantCalculator.ConstantCalculatorTransformer
 
ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorExpressionVisitor - Class in org.apache.pig.newplan.logical.rules
 
ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorExpressionVisitor(OperatorPlan, LogicalRelationalOperator, PigContext) - Constructor for class org.apache.pig.newplan.logical.rules.ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorExpressionVisitor
 
ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorLogicalPlanVisitor - Class in org.apache.pig.newplan.logical.rules
 
ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorLogicalPlanVisitor(OperatorPlan, PigContext) - Constructor for class org.apache.pig.newplan.logical.rules.ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorLogicalPlanVisitor
 
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.newplan.logical.expression
A constant
ConstantExpression(OperatorPlan, Object) - Constructor for class org.apache.pig.newplan.logical.expression.ConstantExpression
Adds expression to the plan
ConstantSize - Class in org.apache.pig.builtin
This method should never be used directly, use SIZE.
ConstantSize() - Constructor for class org.apache.pig.builtin.ConstantSize
 
constExps - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
constructLROutput(List<Result>, List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
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
 
constructPROutput(List<Result>, Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POPartitionRearrangeTez
 
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
 
contains(String) - Static method in enum org.apache.pig.scripting.ScriptEngine.SupportedScriptLang
 
containsAll(Collection<?>) - Method in class org.apache.pig.impl.util.IdentityHashSet
 
containsKey(Object) - Method in class org.apache.pig.impl.util.avro.AvroMapWrapper
 
containsKey(K) - Method in class org.apache.pig.impl.util.MultiMap
 
containsOutputKey(String) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POValueOutputTez
 
containsPhysicalOperator(PhysicalPlan, Class<C>) - Static method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.util.PlanHelper
 
containsValue(Object) - Method in class org.apache.pig.impl.util.avro.AvroMapWrapper
 
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
 
context - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduceCounter.PigMapCounter
 
context - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduceCounter.PigReduceCounter
 
contextSignature - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
convert(Tuple, SchemaTupleFactory) - Static method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin.TuplesToSchemaTupleList
 
CONVERTED_TO_FETCH - Static variable in class org.apache.pig.impl.PigImplConstants
Used by pig to indicate that current job has been converted to run in fetch mode
CONVERTED_TO_LOCAL - Static variable in class org.apache.pig.impl.PigImplConstants
Used by pig to indicate that current job has been converted to run in local mode
convertNullToUnknown(Tuple) - Static method in class org.apache.pig.builtin.CubeDimensions
 
convertOrcToPig(Object, ObjectInspector, boolean[]) - Static method in class org.apache.pig.impl.util.orc.OrcUtils
 
convertToArray(DataBag) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.WeightedRangePartitioner
 
convertToType(LoadCaster, byte[], ResourceSchema.ResourceFieldSchema, byte) - Static method in class org.apache.pig.impl.util.CastUtils
 
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
 
copyAliasFrom(PhysicalOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
copyAllGeneratedToDistributedCache(PigContext, Configuration) - Static method in class org.apache.pig.data.SchemaTupleFrontend
This must be called when the code has been generated and the generated code needs to be shipped to the cluster, so that it may be used by the mappers and reducers.
copyTmpFileConfigurationValues(Configuration, Configuration) - Static method in class org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil
 
COR - Class in org.apache.pig.builtin
Computes the correlation between sets of data.
COR() - Constructor for class org.apache.pig.builtin.COR
 
COR(String...) - Constructor for class org.apache.pig.builtin.COR
 
COR.Final - Class in org.apache.pig.builtin
 
COR.Final() - Constructor for class org.apache.pig.builtin.COR.Final
 
COR.Final(String...) - Constructor for class org.apache.pig.builtin.COR.Final
 
COR.Initial - Class in org.apache.pig.builtin
 
COR.Initial() - Constructor for class org.apache.pig.builtin.COR.Initial
 
COR.Intermed - Class in org.apache.pig.builtin
 
COR.Intermed() - Constructor for class org.apache.pig.builtin.COR.Intermed
 
CORE_DEFAULT_SITE - Static variable in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
CORE_SITE - Static variable in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
COS - Class in org.apache.pig.builtin
COS implements a binding to the Java function Math.cos(double).
COS() - Constructor for class org.apache.pig.builtin.COS
 
COSH - Class in org.apache.pig.builtin
COSH implements a binding to the Java function Math.cosh(double).
COSH() - Constructor for class org.apache.pig.builtin.COSH
 
count(Tuple) - Static method in class org.apache.pig.builtin.AVG
 
count(Tuple) - Static method in class org.apache.pig.builtin.BigDecimalAvg
 
count(Tuple) - Static method in class org.apache.pig.builtin.BigIntegerAvg
 
COUNT - Class in org.apache.pig.builtin
Generates the count of the number of values in a bag.
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.builtin
Computes the covariance between sets of data.
COV() - Constructor for class org.apache.pig.builtin.COV
 
COV(String...) - Constructor for class org.apache.pig.builtin.COV
 
COV.Final - Class in org.apache.pig.builtin
 
COV.Final() - Constructor for class org.apache.pig.builtin.COV.Final
 
COV.Final(String...) - Constructor for class org.apache.pig.builtin.COV.Final
 
COV.Initial - Class in org.apache.pig.builtin
 
COV.Initial() - Constructor for class org.apache.pig.builtin.COV.Initial
 
COV.Intermed - Class in org.apache.pig.builtin
 
COV.Intermed() - Constructor for class org.apache.pig.builtin.COV.Intermed
 
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(Class<?>[]) - Static method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PatternPlan
This function can be used to create a new PatternPlan if the pattern nodes have at most one parent/child, and they are connected to each other.
create() - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTezFactory
 
create(POLocalRearrangeTezFactory.LocalRearrangeType) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTezFactory
 
create(int, POLocalRearrangeTezFactory.LocalRearrangeType) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTezFactory
 
create(int, POLocalRearrangeTezFactory.LocalRearrangeType, List<PhysicalPlan>, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POLocalRearrangeTezFactory
 
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
 
create(Token) - Method in class org.apache.pig.parser.PigParserNodeAdaptor
 
createCl(String) - Method in class org.apache.pig.impl.PigContext
Creates a Classloader based on the passed jarFile and any extra jar files.
createCopy(LOSort) - Static method in class org.apache.pig.newplan.logical.relational.LOSort
 
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.
createObjectInspector(TypeInfo) - Static method in class org.apache.pig.impl.util.orc.OrcUtils
 
createOutputHandler(StreamingCommand) - Static method in class org.apache.pig.impl.streaming.HandlerFactory
Create an OutputHandler for the given output specification of the StreamingCommand.
createPigScriptUDFJar(PigContext) - Static method in class org.apache.pig.impl.util.JarManager
 
createProcess(StreamingCommand) - Static method in class org.apache.pig.impl.streaming.StreamingUtil
Create an external process for StreamingCommand command.
createPut(Object, byte) - Method in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
Public method to initialize a Put.
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.impl.io.InterStorage.InterInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.pig.impl.io.TFileStorage.TFileInputFormat
 
createSoftLink(E, E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Create an soft edge between two nodes.
createSoftLink(Operator, Operator) - Method in class org.apache.pig.newplan.BaseOperatorPlan
Create an soft edge between two nodes.
createSoftLink(Operator, Operator) - Method in interface org.apache.pig.newplan.OperatorPlan
Create an soft edge between two nodes.
createSoftLink(Operator, Operator) - Method in class org.apache.pig.newplan.OperatorSubPlan
 
createStoreFunc(POStore) - Method in class org.apache.pig.backend.hadoop.executionengine.fetch.FetchPOStoreImpl
 
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
createTuple(Object[]) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
CubeDimensions - Class in org.apache.pig.builtin
Produces a DataBag with all combinations of the argument tuple members as in a data cube.
CubeDimensions() - Constructor for class org.apache.pig.builtin.CubeDimensions
 
CubeDimensions(String) - Constructor for class org.apache.pig.builtin.CubeDimensions
 
currentConf - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat
 
currentOp - Variable in class org.apache.pig.newplan.logical.expression.ExpToPhyTranslationVisitor
 
currentOp - Variable in class org.apache.pig.newplan.logical.optimizer.AllExpressionVisitor
 
currentPlan - Variable in class org.apache.pig.newplan.logical.expression.ExpToPhyTranslationVisitor
 
currentPlan - Variable in class org.apache.pig.newplan.logical.relational.LogToPhyTranslationVisitor
 
currentPlan - Variable in class org.apache.pig.newplan.optimizer.Rule
 
currentPlans - Variable in class org.apache.pig.newplan.logical.expression.ExpToPhyTranslationVisitor
 
currentPlans - Variable in class org.apache.pig.newplan.logical.relational.LogToPhyTranslationVisitor
 
CurrentTime - Class in org.apache.pig.builtin
 
CurrentTime() - Constructor for class org.apache.pig.builtin.CurrentTime
This is a default constructor for Pig reflection purposes.
currentWalker - Variable in class org.apache.pig.newplan.PlanVisitor
Guaranteed to always point to the walker currently being used.
customPartitioner - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct
 
customPartitioner - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POGlobalRearrange
 

D

DAG_COUNTER_GROUP - Static variable in class org.apache.pig.tools.pigstats.tez.TezStats
 
DanglingNestedNodeRemover - Class in org.apache.pig.newplan.logical.visitor
 
DanglingNestedNodeRemover(OperatorPlan) - Constructor for class org.apache.pig.newplan.logical.visitor.DanglingNestedNodeRemover
 
data - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCross
 
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.
dataMovementType - Variable in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezEdgeDescriptor
 
DataReaderWriter - Class in org.apache.pig.data
This class was used to handle reading and writing of intermediate results of data types.
DataReaderWriter() - Constructor for class org.apache.pig.data.DataReaderWriter
 
dataSourceType - Variable in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezEdgeDescriptor
 
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 functions for manipulating data objects.
DataType() - Constructor for class org.apache.pig.data.DataType
 
DATE_FORMAT - Static variable in class org.apache.pig.tools.pigstats.PigStats
 
DATETIME - Static variable in class org.apache.pig.data.BinInterSedes
 
DATETIME - Static variable in class org.apache.pig.data.DataType
 
DateTimeMax - Class in org.apache.pig.builtin
This method should never be used directly, use MAX.
DateTimeMax() - Constructor for class org.apache.pig.builtin.DateTimeMax
 
DateTimeMax.Final - Class in org.apache.pig.builtin
 
DateTimeMax.Final() - Constructor for class org.apache.pig.builtin.DateTimeMax.Final
 
DateTimeMax.Initial - Class in org.apache.pig.builtin
 
DateTimeMax.Initial() - Constructor for class org.apache.pig.builtin.DateTimeMax.Initial
 
DateTimeMax.Intermediate - Class in org.apache.pig.builtin
 
DateTimeMax.Intermediate() - Constructor for class org.apache.pig.builtin.DateTimeMax.Intermediate
 
DateTimeMin - Class in org.apache.pig.builtin
This method should never be used directly, use MAX.
DateTimeMin() - Constructor for class org.apache.pig.builtin.DateTimeMin
 
DateTimeMin.Final - Class in org.apache.pig.builtin
 
DateTimeMin.Final() - Constructor for class org.apache.pig.builtin.DateTimeMin.Final
 
DateTimeMin.Initial - Class in org.apache.pig.builtin
 
DateTimeMin.Initial() - Constructor for class org.apache.pig.builtin.DateTimeMin.Initial
 
DateTimeMin.Intermediate - Class in org.apache.pig.builtin
 
DateTimeMin.Intermediate() - Constructor for class org.apache.pig.builtin.DateTimeMin.Intermediate
 
DateTimeWritable - Class in org.apache.pig.backend.hadoop
Writable for Double values.
DateTimeWritable() - Constructor for class org.apache.pig.backend.hadoop.DateTimeWritable
 
DateTimeWritable(DateTime) - Constructor for class org.apache.pig.backend.hadoop.DateTimeWritable
 
DateTimeWritable.Comparator - Class in org.apache.pig.backend.hadoop
A Comparator optimized for DateTimeWritable.
DateTimeWritable.Comparator() - Constructor for class org.apache.pig.backend.hadoop.DateTimeWritable.Comparator
 
DaysBetween - Class in org.apache.pig.builtin
DaysBetween returns the number of days between two DateTime objects
DaysBetween() - Constructor for class org.apache.pig.builtin.DaysBetween
 
debugOff() - Method in class org.apache.pig.PigServer
Set the logging level to the default.
debugOn() - Method in class org.apache.pig.PigServer
Set the logging level to DEBUG.
decodeBytes(String) - Static method in class org.apache.pig.impl.util.ObjectSerializer
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.AddExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.AndExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.BinCondExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.CastExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.ConstantExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.DereferenceExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.DivideExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.EqualExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.GreaterThanEqualExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.GreaterThanExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.IsNullExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.LessThanEqualExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.LessThanExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.LogicalExpression
Create the deep copy of this expression and add that into the passed LogicalExpressionPlan Return the copy of this expression with updated logical expression plan.
deepCopy() - Method in class org.apache.pig.newplan.logical.expression.LogicalExpressionPlan
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.MapLookupExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.ModExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.MultiplyExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.NegativeExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.NotEqualExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.NotExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.OrExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.ProjectExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.RegexExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.ScalarExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.SubtractExpression
 
deepCopy(LogicalExpressionPlan) - Method in class org.apache.pig.newplan.logical.expression.UserFuncExpression
 
deepCopy() - Method in class org.apache.pig.newplan.logical.relational.LogicalSchema
 
deepCopy() - Method in class org.apache.pig.newplan.logical.relational.LogicalSchema.LogicalFieldSchema
 
deepCopyTo(POLocalRearrange) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange
 
DEFAULT_BYTES_PER_REDUCER - Static variable in interface org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigReducerEstimator
 
DEFAULT_CHUNK_SIZE - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.JoinPackager
 
DEFAULT_DELIMITERS - Static variable in class org.apache.pig.impl.util.StorageUtil
 
DEFAULT_MAX_REDUCER_COUNT_PARAM - Static variable in interface org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigReducerEstimator
 
DEFAULT_PERCENT_MEMUSAGE - Static variable in class org.apache.pig.impl.builtin.PartitionSkewedKeys
 
DEFAULT_SAMPLE_RATE - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPoissonSample
 
DEFAULT_SCOPE - Static variable in class org.apache.pig.newplan.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.
DefaultTuple.DefaultTupleRawComparator - Class in org.apache.pig.data
 
DefaultTuple.DefaultTupleRawComparator() - Constructor for class org.apache.pig.data.DefaultTuple.DefaultTupleRawComparator
 
DefaultTupleFactory - Class in org.apache.pig.data
Deprecated.
DefaultTupleFactory() - Constructor for class org.apache.pig.data.DefaultTupleFactory
Deprecated.
 
define(Ruby) - Static method in class org.apache.pig.scripting.jruby.RubyDataBag
This method registers the class with the given runtime.
define(Ruby) - Static method in class org.apache.pig.scripting.jruby.RubyDataByteArray
Registers the DataByteArray class with the Ruby runtime.
define(Ruby) - Static method in class org.apache.pig.scripting.jruby.RubySchema
This method registers the class with the given runtime.
define(String, String) - Static method in class org.apache.pig.scripting.js.JSPig
See Pig
define(String, String) - Static method in class org.apache.pig.scripting.Pig
Define an alias for a UDF or a streaming command.
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
 
deleteFile(String) - Method in class org.apache.pig.PigServer
Delete a file.
deleteTempFiles() - Static method in class org.apache.pig.impl.io.FileLocalizer
 
deleteTempResourceFiles() - Static method in class org.apache.pig.impl.io.FileLocalizer
 
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
 
DependencyOrderWalker - Class in org.apache.pig.newplan
A walker to walk graphs in dependency order.
DependencyOrderWalker(OperatorPlan) - Constructor for class org.apache.pig.newplan.DependencyOrderWalker
 
depthFirstLP() - Method in class org.apache.pig.newplan.logical.optimizer.LogicalPlanPrinter
 
depthFirstPP() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PlanPrinter
 
depthFirstPP(Element) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.XMLPhysicalPlanPrinter
 
depthFirstSearchForFile(FileStatus, FileSystem) - Static method in class org.apache.pig.impl.util.Utils
Finds a valid path for a file from a FileStatus object.
depthFirstSearchForFile(FileStatus[], FileSystem) - Static method in class org.apache.pig.impl.util.Utils
Finds a valid path for a file from an array of FileStatus objects.
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
 
DepthFirstWalker - Class in org.apache.pig.newplan
Do a depth first traversal of the graph.
DepthFirstWalker(OperatorPlan) - Constructor for class org.apache.pig.newplan.DepthFirstWalker
 
DereferenceExpression - Class in org.apache.pig.newplan.logical.expression
get one or elements out of a tuple or a bag in case of Tuple( a#2:int, b#3:bag{ b_a#4:int, b_b#5:float }, c#6:int ) # 1 (the number after # represents the uid) Dereference ( 0 ) --> a:int - dereference of single column in a tuple gives the field Dereference ( 0,2 ) --> Tuple(a#2:int, c#6:int) #7 - dereference of more than one column gives a tuple Dereference ( 1 ) --> Dereference ( 1 ) --> b:bag{b_b#5:float}#8 - dereference of a bag gives a bag
DereferenceExpression(OperatorPlan) - Constructor for class org.apache.pig.newplan.logical.expression.DereferenceExpression
 
DereferenceExpression(OperatorPlan, int) - Constructor for class org.apache.pig.newplan.logical.expression.DereferenceExpression
 
DereferenceExpression(OperatorPlan, List<Integer>) - Constructor for class org.apache.pig.newplan.logical.expression.DereferenceExpression
 
describe(String) - Method in class org.apache.pig.scripting.BoundScript
Describe the schema of an alias in this pipeline.
deserialize(byte[], int, int) - Method in class org.apache.pig.builtin.PigStreaming
 
deserialize(byte[], int, int) - Method in class org.apache.pig.impl.streaming.PigStreamingUDF
 
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 class org.apache.pig.PigStreamingBase
Deprecated.
deserialize(byte[], int, int) - Method in class org.apache.pig.PigStreamingBase
Given a byte array from a streaming executable, produce a tuple.
deserialize(byte[]) - Method in interface org.apache.pig.StreamToPig
Deprecated.
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.plans.PhysicalPlan
 
detachInput() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager
 
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
determineSchema(LogicalRelationalOperator) - Method in class org.apache.pig.newplan.logical.rules.LoadTypeCastInserter
if we are inserting casts in a load and if the loader implements determineSchema(), insert casts only where necessary Note that in this case, the data coming out of the loader is not a BYTEARRAY but is whatever determineSchema() says it is.
determineSchema(LogicalRelationalOperator) - Method in class org.apache.pig.newplan.logical.rules.StreamTypeCastInserter
 
determineSchema(LogicalRelationalOperator) - Method in class org.apache.pig.newplan.logical.rules.TypeCastInserter
 
didFetch - Variable in class org.apache.pig.impl.io.FileLocalizer.FetchFileRet
 
DIFF - Class in org.apache.pig.builtin
DIFF takes two bags as arguments and compares them.
DIFF() - Constructor for class org.apache.pig.builtin.DIFF
 
disableCounter() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigSplit
 
disableCounter() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
 
discardBatch() - Method in class org.apache.pig.PigServer
Discards a batch of Pig commands.
disconnect(TezOperator, TezOperator) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperPlan
 
disconnect(E, E) - Method in class org.apache.pig.impl.plan.OperatorPlan
Remove an edge from between two nodes.
disconnect(Operator, Operator) - Method in class org.apache.pig.newplan.BaseOperatorPlan
Disconnect two operators in the plan.
disconnect(Operator, Operator) - Method in interface org.apache.pig.newplan.OperatorPlan
Disconnect two operators in the plan.
disconnect(Operator, Operator) - Method in class org.apache.pig.newplan.OperatorSubPlan
 
DiscreteProbabilitySampleGenerator - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners
 
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
 
displayStatistics() - Static method in class org.apache.pig.tools.pigstats.mapreduce.MRPigStatsUtil
Logs the statistics in the Pig log file at INFO level
distinct - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.Packager
 
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
 
div(BigDecimal, BigDecimal) - Static method in class org.apache.pig.builtin.BigDecimalAvg
 
div(BigInteger, BigInteger) - Static method in class org.apache.pig.builtin.BigIntegerAvg
 
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
 
divide(Number, Number, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
DivideExpression - Class in org.apache.pig.newplan.logical.expression
Divide Operator
DivideExpression(OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.newplan.logical.expression.DivideExpression
Will add this operator to the plan and connect it to the left and right hand side operators.
doAllPredecessors(O, Set<O>, Collection<O>) - Method in class org.apache.pig.impl.plan.DependencyOrderWalker
 
doAllPredecessors(Operator, Set<Operator>, Collection<Operator>) - Method in class org.apache.pig.newplan.DependencyOrderWalker
 
doAllSuccessors(O, Set<O>, Collection<O>) - Method in class org.apache.pig.impl.plan.ReverseDependencyOrderWalker
 
doAllSuccessors(Operator, Set<Operator>, Collection<Operator>) - Method in class org.apache.pig.newplan.ReverseDependencyOrderWalker
 
doAllSuccessors(Operator, Collection<Operator>) - Method in class org.apache.pig.newplan.ReverseDependencyOrderWalkerWOSeenChk
 
doInsertBetween(E, E, E, boolean) - Method in class org.apache.pig.impl.plan.OperatorPlan
 
doParamSubstitution(InputStream, List<String>, List<String>) - Method in class org.apache.pig.impl.PigContext
 
doParamSubstitution(BufferedReader, List<String>, List<String>) - Method in class org.apache.pig.impl.PigContext
 
doParamSubstitution(BufferedReader) - Method in class org.apache.pig.impl.PigContext
 
doParamSubstitutionOutputToFile(BufferedReader, String, List<String>, List<String>) - Method in class org.apache.pig.impl.PigContext
 
doParamSubstitutionOutputToFile(BufferedReader, String) - Method in class org.apache.pig.impl.PigContext
 
DotLOPrinter - Class in org.apache.pig.newplan.logical
This class can print a logical plan in the DOT format.
DotLOPrinter(BaseOperatorPlan, PrintStream) - Constructor for class org.apache.pig.newplan.logical.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
 
DotPlanDumper - Class in org.apache.pig.newplan
This class puts everything that is needed to dump a plan in a format readable by graphviz's dot algorithm.
DotPlanDumper(BaseOperatorPlan, PrintStream) - Constructor for class org.apache.pig.newplan.DotPlanDumper
 
DotPlanDumper(BaseOperatorPlan, PrintStream, boolean, Set<Operator>, Set<Operator>, Set<Operator>) - Constructor for class org.apache.pig.newplan.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
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider) - Static method in class org.apache.pig.builtin.AlgebraicBigDecimalMathBase
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider) - Static method in class org.apache.pig.builtin.AlgebraicBigIntegerMathBase
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider, byte) - Static method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider) - Static method in class org.apache.pig.builtin.AlgebraicDoubleMathBase
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider) - Static method in class org.apache.pig.builtin.AlgebraicFloatMathBase
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider) - Static method in class org.apache.pig.builtin.AlgebraicIntMathBase
 
doTupleWork(Tuple, AlgebraicMathBase.KnownOpProvider) - Static method in class org.apache.pig.builtin.AlgebraicLongMathBase
 
DOUBLE - Static variable in class org.apache.pig.data.BinInterSedes
 
DOUBLE - Static variable in class org.apache.pig.data.DataType
 
DoubleAbs - Class in org.apache.pig.builtin
 
DoubleAbs() - Constructor for class org.apache.pig.builtin.DoubleAbs
 
DoubleAvg - Class in org.apache.pig.builtin
This method should never be used directly, use AVG.
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.builtin
base class for math udfs that return Double value
DoubleBase() - Constructor for class org.apache.pig.builtin.DoubleBase
 
doubleColonsToDoubleUnderscores - Variable in class org.apache.pig.builtin.AvroStorage
 
DoubleMax - Class in org.apache.pig.builtin
This method should never be used directly, use MAX.
DoubleMax() - Constructor for class org.apache.pig.builtin.DoubleMax
 
DoubleMax.Final - Class in org.apache.pig.builtin
 
DoubleMax.Final() - Constructor for class org.apache.pig.builtin.DoubleMax.Final
 
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
This method should never be used directly, use MIN.
DoubleMin() - Constructor for class org.apache.pig.builtin.DoubleMin
 
DoubleMin.Final - Class in org.apache.pig.builtin
 
DoubleMin.Final() - Constructor for class org.apache.pig.builtin.DoubleMin.Final
 
DoubleMin.Intermediate - Class in org.apache.pig.builtin
 
DoubleMin.Intermediate() - Constructor for class org.apache.pig.builtin.DoubleMin.Intermediate
 
DoubleRound - Class in org.apache.pig.builtin
Given a single data atom it Returns the closest long to the argument.
DoubleRound() - Constructor for class org.apache.pig.builtin.DoubleRound
 
DoubleRoundTo - Class in org.apache.pig.builtin
ROUND_TO safely rounds a number to a given precision by using an intermediate BigDecimal.
DoubleRoundTo() - Constructor for class org.apache.pig.builtin.DoubleRoundTo
 
DoubleSum - Class in org.apache.pig.builtin
This method should never be used directly, use SUM.
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.Intermediate - Class in org.apache.pig.builtin
 
DoubleSum.Intermediate() - Constructor for class org.apache.pig.builtin.DoubleSum.Intermediate
 
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
 
dryrun(String, PigContext) - Static method in class org.apache.pig.Main
 
DryRunGruntParser - Class in org.apache.pig.parser
 
DryRunGruntParser(Reader, String, PigContext) - Constructor for class org.apache.pig.parser.DryRunGruntParser
 
ds - Variable in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
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.
dump() - Method in class org.apache.pig.newplan.DotPlanDumper
 
dump() - Method in class org.apache.pig.newplan.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.
dumpEdge(Operator, Operator) - Method in class org.apache.pig.newplan.DotPlanDumper
 
dumpEdge(Operator, Operator) - Method in class org.apache.pig.newplan.PlanDumper
Will be called to dump the edges of the plan.
dumpInvisibleOperators(E) - Method in class org.apache.pig.impl.plan.DotPlanDumper
 
dumpInvisibleOperators(Operator) - Method in class org.apache.pig.newplan.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.
dumpMultiInputNestedOperator(Operator, MultiMap<Operator, BaseOperatorPlan>) - Method in class org.apache.pig.newplan.DotPlanDumper
 
dumpMultiInputNestedOperator(Operator, MultiMap<Operator, BaseOperatorPlan>) - Method in class org.apache.pig.newplan.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.
dumpMultiOutputNestedOperator(Operator, Collection<BaseOperatorPlan>) - Method in class org.apache.pig.newplan.DotPlanDumper
 
dumpMultiOutputNestedOperator(Operator, Collection<BaseOperatorPlan>) - Method in class org.apache.pig.newplan.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.
dumpNestedOperator(Operator, Collection<BaseOperatorPlan>) - Method in class org.apache.pig.newplan.DotPlanDumper
 
dumpNestedOperator(Operator, Collection<BaseOperatorPlan>) - Method in class org.apache.pig.newplan.PlanDumper
Will be called for nested operators.
dumpNestedSchema(String, String) - Method in class org.apache.pig.newplan.logical.relational.LOForEach
 
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
dumpOperator(Operator) - Method in class org.apache.pig.newplan.DotPlanDumper
 
dumpOperator(Operator) - Method in class org.apache.pig.newplan.PlanDumper
Will be called to dump a simple operator
dumpSchema(String) - Method in class org.apache.pig.PigServer
Write the schema for an alias to System.out.
dumpSchemaNested(String, String) - Method in class org.apache.pig.PigServer
Write the schema for a nestedAlias to System.out.
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
 
dumTup - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
duplicate() - Method in class org.apache.pig.PigServer.Graph
 
DuplicatedSchemaAliasException - Exception in org.apache.pig.parser
 
DuplicatedSchemaAliasException(IntStream, SourceLocation, String) - Constructor for exception org.apache.pig.parser.DuplicatedSchemaAliasException
 
DuplicateForEachColumnRewriteVisitor - Class in org.apache.pig.newplan.logical.visitor
 
DuplicateForEachColumnRewriteVisitor(OperatorPlan) - Constructor for class org.apache.pig.newplan.logical.visitor.DuplicateForEachColumnRewriteVisitor
 
dupNode() - Method in class org.apache.pig.parser.PigParserNode
 

E

each(ThreadContext, Block) - Method in class org.apache.pig.scripting.jruby.RubyDataBag
This is an implementation of the each method which opens up the Enumerable interface, and makes it very convenient to iterate over the elements of a DataBag.
earlyTermination - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
 
ElementDescriptor - Interface in org.apache.pig.backend.datastorage
DataStorageElementDescriptor provides methods necessary to manage an element in a DataStorage.
emitInitialPlanNotification(OperatorPlan<?>) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitJobFailedNotification(JobStats) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitjobFinishedNotification(JobStats) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitJobsSubmittedNotification(int) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitJobStartedNotification(String) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitLaunchCompletedNotification(int) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitLaunchStartedNotification(int) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitOutputCompletedNotification(OutputStats) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
emitProgressUpdatedNotification(int) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
empty - Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore
 
EMPTY_KEY - Static variable in class org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.POValueOutputTez
 
EmptyPigStats - Class in org.apache.pig.tools.pigstats
EmptyPigStats encapsulates dummy statistics of a fetch task, since during a fetch no MR jobs are executed
EmptyPigStats() - Constructor for class org.apache.pig.tools.pigstats.EmptyPigStats
 
EmptyPigStats(PigContext, POStore) - Constructor for class org.apache.pig.tools.pigstats.EmptyPigStats
 
encodeBytes(byte[]) - Static method in class org.apache.pig.impl.util.ObjectSerializer
 
end - Variable in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
 
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
 
END_OF_OUTPUT - Static variable in class org.apache.pig.impl.streaming.OutputHandler
 
END_ROW_OPTION - Static variable in class org.apache.pig.backend.hadoop.accumulo.AccumuloStorageOptions
 
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
 
EndOfAllInputSetter.EndOfAllInputChecker - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans
 
EndOfAllInputSetter.EndOfAllInputChecker(PhysicalPlan) - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.EndOfAllInputSetter.EndOfAllInputChecker
 
EndOfOpts - Static variable in class org.apache.pig.tools.cmdline.CmdLineParser
 
ENDSWITH - Class in org.apache.pig.builtin
Pig UDF to test input tuple.get(0) against tuple.get(1) to determine if the first argument ends with the string in the second.
ENDSWITH() - Constructor for class org.apache.pig.builtin.ENDSWITH
 
endTime - Variable in class org.apache.pig.tools.pigstats.PigStats
 
ensureAllKeyInstancesInSameSplit() - Method in interface org.apache.pig.CollectableLoadFunc
When this method is called, Pig is communicating to the Loader that it must load data such that all instances of a key are in same split.
entrySet() - Method in class org.apache.pig.impl.util.avro.AvroMapWrapper
 
enumeratorize(Ruby, IRubyObject, String) - Static method in class org.apache.pig.scripting.jruby.PigJrubyLibrary
This is a hack to get around the fact that in JRuby 1.6.7, the enumeratorize method isn't public.
equalByteArrays(byte[], byte[]) - Static method in class org.apache.pig.data.DataType
Test whether two byte arrays (Java byte arrays not Pig byte arrays) are equal.
EqualExpression - Class in org.apache.pig.newplan.logical.expression
Equality test expression.
EqualExpression(OperatorPlan, LogicalExpression, LogicalExpression) - Constructor for class org.apache.pig.newplan.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.pig.backend.hadoop.accumulo.Column
 
equals(Object) - Method in class org.apache.pig.backend.hadoop.BigDecimalWritable
 
equals(Object) - Method in class org.apache.pig.backend.hadoop.BigIntegerWritable
 
equals(Object) - Method in class org.apache.pig.backend.hadoop.datastorage.HPath
 
equals(Object) - Method in class org.apache.pig.backend.hadoop.DateTimeWritable
Returns true iff o is a DateTimeWritable with the same value.
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.backend.hadoop.executionengine.tez.plan.TezPlanContainerNode
 
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.AbstractTuple
 
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.NonSpillableDataBag
 
equals(Object) - Method in class org.apache.pig.data.ReadOnceBag
 
equals(Object) - Method in class org.apache.pig.data.SchemaTuple
 
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.data.utils.StructuresHelper.Pair
 
equals(Object) - Method in class org.apache.pig.data.utils.StructuresHelper.SchemaKey
 
equals(Object) - Method in class org.apache.pig.data.utils.StructuresHelper.Triple
 
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(LogicalSchema, LogicalSchema, boolean, boolean) - Static method in class org.apache.pig.newplan.logical.relational.LogicalSchema
Recursively compare two schemas for equality
equals(LogicalSchema.LogicalFieldSchema, LogicalSchema.LogicalFieldSchema, boolean, boolean) - Static method in class org.apache.pig.newplan.logical.relational.LogicalSchema.LogicalFieldSchema
Compare two field schema for equality
equals(ResourceSchema, ResourceSchema) - Static method in class org.apache.pig.ResourceSchema
Test whether two ResourceSchemas are the same.
equals(Object) - Method in class org.apache.pig.ResourceStatistics
 
equals(Object) - Method in class org.apache.pig.ResourceStatistics.ResourceFieldStatistics
 
equals(ThreadContext, IRubyObject) - Method in class org.apache.pig.scripting.jruby.RubyDataByteArray
Overrides equality leveraging DataByteArray's equality.
equals(Object) - Method in class org.apache.pig.SortColInfo
 
equals(Object) - Method in class org.apache.pig.SortInfo
 
EqualsIgnoreCase - Class in org.apache.pig.builtin
Compares two Strings ignoring case considerations.
EqualsIgnoreCase() - Constructor for class org.apache.pig.builtin.EqualsIgnoreCase
 
equalsZero(Number, byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
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
 
ERR_MSG_SCALAR - Static variable in class org.apache.pig.newplan.logical.visitor.ScalarVariableValidator
 
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
 
errorCode - Variable in class org.apache.pig.tools.pigstats.PigStats
 
errorInMap - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase
 
errorInReduce - Variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce.Reduce
 
errorMessage - Variable in class org.apache.pig.tools.pigstats.PigStats
 
errorSource - Variable in exception org.apache.pig.PigException
 
errorThrowable - Variable in class org.apache.pig.tools.pigstats.PigStats
 
ESTIMATE_PARALLELISM - Static variable in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigProcessor
 
ESTIMATED_NUM_PARALLELISM - Static variable in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigProcessor
 
estimateNumberOfReducers(Job, MapReduceOper) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.InputSizeReducerEstimator
Determines the number of reducers to be used.
estimateNumberOfReducers(Job, MapReduceOper) - Static method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler
Looks up the estimator from REDUCER_ESTIMATOR_KEY and invokes it to find the number of reducers to use.
estimateNumberOfReducers(Job, MapReduceOper) - Method in interface org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigReducerEstimator
Estimate the number of reducers for a given job based on the collection of load funcs passed.
estimateParallelism(TezOperPlan, TezOperator, Configuration) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.TezOperDependencyParallelismEstimator
 
estimateParallelism(TezOperPlan, TezOperator, Configuration) - Method in interface org.apache.pig.backend.hadoop.executionengine.tez.plan.optimizer.TezParallelismEstimator
 
eval(Tuple) - Method in interface org.apache.pig.builtin.InvokerFunction
 
eval(String) - Method in class org.apache.pig.scripting.js.JsScriptEngine
 
EvalFunc<T> - Class in org.apache.pig
The class is used to implement functions to be applied to fields in a dataset.
EvalFunc() - Constructor for class org.apache.pig.EvalFunc
 
EvalFunc.SchemaType - Enum in org.apache.pig
EvalFunc's schema type.
ExampleGenerator - Class in org.apache.pig.pen
This class is used to generate example tuples for the ILLUSTRATE purpose
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(Object) - Constructor for class org.apache.pig.pen.util.ExampleTuple
 
ExampleTuple(Tuple) - Constructor for class org.apache.pig.pen.util.ExampleTuple
 
ExceptionalFunction<S,T,E extends Exception> - Interface in org.apache.pig
An interface that captures a unit of work against an item where an exception might be thrown.
exec(Tuple) - Method in class org.apache.pig.AccumulatorEvalFunc
 
exec(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez
 
exec(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.PartitionSkewedKeysTez
 
exec(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.ReadScalarsTez
 
exec() - Method in class org.apache.pig.backend.hadoop.streaming.HadoopExecutableManager
 
exec(Tuple) - Method in class org.apache.pig.builtin.ABS
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.AddDuration
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigDecimalMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigDecimalMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigDecimalMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigIntegerMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigIntegerMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicBigIntegerMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicByteArrayMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicDoubleMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicDoubleMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicDoubleMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicFloatMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicFloatMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicFloatMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicIntMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicIntMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicIntMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicLongMathBase
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicLongMathBase.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.AlgebraicLongMathBase.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.ARITY
Deprecated.
 
exec(Tuple) - Method in class org.apache.pig.builtin.Assert
 
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.BagToString
 
exec(Tuple) - Method in class org.apache.pig.builtin.BagToTuple
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigDecimalAbs
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigDecimalAvg
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigDecimalAvg.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigDecimalAvg.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigDecimalAvg.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigIntegerAbs
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigIntegerAvg
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigIntegerAvg.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigIntegerAvg.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.BigIntegerAvg.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.Bloom
 
exec(Tuple) - Method in class org.apache.pig.builtin.BuildBloom
 
exec(Tuple) - Method in class org.apache.pig.builtin.BuildBloom.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.BuildBloom.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.BuildBloom.Intermediate
 
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.COR
Function to compute correlation between data sets.
exec(Tuple) - Method in class org.apache.pig.builtin.COR.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.COR.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.COR.Intermed
 
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.COV
Function to compute covariance between data sets.
exec(Tuple) - Method in class org.apache.pig.builtin.COV.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.COV.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.COV.Intermed
 
exec(Tuple) - Method in class org.apache.pig.builtin.CubeDimensions
 
exec(Tuple) - Method in class org.apache.pig.builtin.CurrentTime
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMax
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMax.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMax.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMax.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMin
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMin.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMin.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.DateTimeMin.Intermediate
 
exec(Tuple) - Method in class org.apache.pig.builtin.DaysBetween
 
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.DoubleBase
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleRound
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.DoubleRoundTo
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.ENDSWITH
 
exec(Tuple) - Method in class org.apache.pig.builtin.EqualsIgnoreCase
 
exec(Tuple) - Method in class org.apache.pig.builtin.FloatAbs
java level API
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.FloatRound
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.FloatRoundTo
java level API
exec(Object) - Method in class org.apache.pig.builtin.FunctionWrapperEvalFunc
 
exec(Tuple) - Method in class org.apache.pig.builtin.GenericInvoker
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetDay
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetHour
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetMilliSecond
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetMinute
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetMonth
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetSecond
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetWeek
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetWeekYear
 
exec(Tuple) - Method in class org.apache.pig.builtin.GetYear
 
exec(Tuple) - Method in class org.apache.pig.builtin.HoursBetween
 
exec(Tuple) - Method in class org.apache.pig.builtin.INDEXOF
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.builtin.IntAbs
java level API
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.INVERSEMAP
 
exec(Tuple) - Method in class org.apache.pig.builtin.InvokerGenerator
 
exec(Tuple) - Method in class org.apache.pig.builtin.IsEmpty
 
exec(Tuple) - Method in class org.apache.pig.builtin.KEYSET
 
exec(Tuple) - Method in class org.apache.pig.builtin.LAST_INDEX_OF
Finds the last location of a substring in a given string.
exec(Tuple) - Method in class org.apache.pig.builtin.LCFIRST
 
exec(Tuple) - Method in class org.apache.pig.builtin.LongAbs
java level API
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.LOWER
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.builtin.LTRIM
 
exec(Tuple) - Method in class org.apache.pig.builtin.MapSize
 
exec(Tuple) - Method in class org.apache.pig.builtin.MilliSecondsBetween
 
exec(Tuple) - Method in class org.apache.pig.builtin.MinutesBetween
 
exec(Tuple) - Method in class org.apache.pig.builtin.MonthsBetween
 
exec(Tuple) - Method in class org.apache.pig.builtin.PluckTuple
 
exec(Tuple) - Method in class org.apache.pig.builtin.RANDOM
 
exec(Tuple) - Method in class org.apache.pig.builtin.REGEX_EXTRACT
 
exec(Tuple) - Method in class org.apache.pig.builtin.REGEX_EXTRACT_ALL
 
exec(Tuple) - Method in class org.apache.pig.builtin.REPLACE
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.builtin.RollupDimensions
 
exec(Tuple) - Method in class org.apache.pig.builtin.ROUND
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.ROUND_TO
java level API
exec(Tuple) - Method in class org.apache.pig.builtin.RTRIM
 
exec(Tuple) - Method in class org.apache.pig.builtin.SecondsBetween
 
exec(Tuple) - Method in class org.apache.pig.builtin.SIZE
 
exec(Tuple) - Method in class org.apache.pig.builtin.SPRINTF
 
exec(Tuple) - Method in class org.apache.pig.builtin.STARTSWITH
 
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.STRSPLIT
Wrapper around Java's String.split
exec(Tuple) - Method in class org.apache.pig.builtin.STRSPLITTOBAG
Wrapper around Java's String.split
exec(Tuple) - Method in class org.apache.pig.builtin.SUBSTRING
Method invoked on every tuple during foreach evaluation
exec(Tuple) - Method in class org.apache.pig.builtin.SUBTRACT
Compares the two bag fields from input Tuple and returns a new bag composed of elements of first bag not in the second bag.
exec(Tuple) - Method in class org.apache.pig.builtin.SubtractDuration
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOBAG
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToDate
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToDate2ARGS
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToDate3ARGS
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToDateISO
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOKENIZE
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOMAP
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToMilliSeconds
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOP
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOP.Final
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOP.Initial
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOP.Intermed
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToString
 
exec(Tuple) - Method in class org.apache.pig.builtin.TOTUPLE
 
exec(Tuple) - Method in class org.apache.pig.builtin.ToUnixTime
 
exec(Tuple) - Method in class org.apache.pig.builtin.TRIM
 
exec(Tuple) - Method in class org.apache.pig.builtin.TupleSize
 
exec(Tuple) - Method in class org.apache.pig.builtin.UCFIRST
 
exec(Tuple) - Method in class org.apache.pig.builtin.UPPER
Upper-cases an input string.
exec(Tuple) - Method in class org.apache.pig.builtin.VALUELIST
 
exec(Tuple) - Method in class org.apache.pig.builtin.VALUESET
 
exec(Tuple) - Method in class org.apache.pig.builtin.WeeksBetween
 
exec(Tuple) - Method in class org.apache.pig.builtin.YearsBetween
 
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.IdentityColumn
 
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(Tuple) - Method in class org.apache.pig.impl.builtin.ReadScalars
Java level API
exec(Tuple) - Method in class org.apache.pig.impl.builtin.StreamingUDF
 
exec() - Method in class org.apache.pig.impl.streaming.ExecutableManager
Start execution of the external process.
exec(Iterator<Tuple>) - Method in class org.apache.pig.IteratingAccumulatorEvalFunc
 
exec(Tuple) - Method in class org.apache.pig.PrimitiveEvalFunc
 
exec(IN) - Method in class org.apache.pig.PrimitiveEvalFunc
 
exec(Tuple) - Method in class org.apache.pig.scripting.groovy.GroovyEvalFunc
 
exec(Tuple) - Method in class org.apache.pig.scripting.jruby.JrubyAlgebraicEvalFunc.AlgebraicFunctionWrapper
 
exec(Tuple) - Method in class org.apache.pig.scripting.jruby.JrubyAlgebraicEvalFunc.Final
 
exec(Tuple) - Method in class org.apache.pig.scripting.jruby.JrubyAlgebraicEvalFunc.Initial
 
exec(Tuple) - Method in class org.apache.pig.scripting.jruby.JrubyAlgebraicEvalFunc.Intermed
 
exec(Tuple) - Method in class org.apache.pig.scripting.jruby.JrubyEvalFunc
The exec method passes the tuple argument to the Ruby function, and converts the result back to Pig.
exec(Tuple) - Method in class org.apache.pig.scripting.js.JsFunction
 
exec(Tuple) - Method in class org.apache.pig.scripting.jython.JythonFunction
 
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
 
ExecType - Interface in org.apache.pig
The type of query execution.
ExecTypeProvider - Class in org.apache.pig
 
ExecTypeProvider() - Constructor for class org.apache.pig.ExecTypeProvider
 
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(LogicalExpression) - Method in class org.apache.pig.newplan.logical.expression.AllSameExpressionVisitor
Method to call on every node in the logical expression plan.
execute(LogicalRelationalOperator) - Method in class org.apache.pig.newplan.logical.optimizer.AllSameRalationalNodesVisitor
Method to call on every node in the logical plan.
execute(LogicalExpression) - Method in class org.apache.pig.newplan.logical.rules.ConstantCalculator.ConstantCalculatorTransformer.ConstantCalculatorExpressionVisitor
 
execute(LogicalRelationalOperator) - Method in class org.apache.pig.newplan.logical.visitor.ImplicitSplitInsertVisitor
 
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.
executeBatch(boolean) - Method in class org.apache.pig.PigServer
Submits a batch of Pig commands for execution.
ExecutionEngine - Interface in org.apache.pig.backend.executionengine
The main interface bridging the front end and back end of Pig.
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
Test whether a file exists.
exitCode - Variable in class org.apache.pig.impl.streaming.ExecutableManager
 
EXP - Class in org.apache.pig.builtin
Given a single data atom it returns the Euler's number e raised to the power of input
EXP() - Constructor for class org.apache.pig.builtin.EXP
 
explain(LogicalPlan, PigContext, PrintStream, String, boolean, File, String) - Method in interface org.apache.pig.backend.executionengine.ExecutionEngine
This method handles the backend processing of the Explain command.
explain(PhysicalPlan, PigContext, PrintStream, String) - Method in class org.apache.pig.backend.hadoop.executionengine.fetch.FetchLauncher
Creates an empty MR plan
explain(LogicalPlan, PigContext, PrintStream, String, boolean, File, String) - 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.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(PhysicalPlan, PigContext, PrintStream, String, boolean) - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezLauncher
 
explain(PrintStream, String, boolean) - Method in class org.apache.pig.newplan.BaseOperatorPlan
 
explain(PrintStream, String, boolean) - Method in class org.apache.pig.newplan.logical.expression.LogicalExpressionPlan
 
explain(PrintStream, String, boolean) - Method in class org.apache.pig.newplan.logical.relational.LogicalPlan
 
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, File, String) - Method in class org.apache.pig.PigServer
Provide information on how a pig query will be executed.
explain() - Method in class org.apache.pig.scripting.BoundScript
Explain this pipeline.
explainCurrentBatch() - Method in class org.apache.pig.tools.grunt.GruntParser
 
explainCurrentBatch(boolean) - Method in class org.apache.pig.tools.grunt.GruntParser
 
Expression - Class in org.apache.pig
A class to communicate Filter expressions to LoadFuncs.
Expression() - Constructor for class org.apache.pig.Expression
 
Expression.BetweenExpression - Class in org.apache.pig
 
Expression.BetweenExpression(Object, Object) - Constructor for class org.apache.pig.Expression.BetweenExpression
 
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.InExpression - Class in org.apache.pig
 
Expression.InExpression(List<Object>) - Constructor for class org.apache.pig.Expression.InExpression
 
Expression.OpType - Enum in org.apache.pig
 
Expression.UnaryExpression - Class in org.apache.pig
 
Expression.UnaryExpression(Expression, Expression.OpType) - Constructor for class org.apache.pig.Expression.UnaryExpression
 
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
 
ExpToPhyTranslationVisitor - Class in org.apache.pig.newplan.logical.expression
 
ExpToPhyTranslationVisitor(OperatorPlan, LogicalRelationalOperator, PhysicalPlan, Map<Operator, PhysicalOperator>) - Constructor for class org.apache.pig.newplan.logical.expression.ExpToPhyTranslationVisitor
 
ExpToPhyTranslationVisitor(OperatorPlan, PlanWalker, LogicalRelationalOperator, PhysicalPlan, Map<Operator, PhysicalOperator>) - Constructor for class org.apache.pig.newplan.logical.expression.ExpToPhyTranslationVisitor
 
extractArgs(CommandLine, AccumuloStorageOptions) - Method in class org.apache.pig.backend.hadoop.accumulo.AbstractAccumuloStorage
Extract arguments passed into the constructor to avoid the URI
extractDateTime(String) - Static method in class org.apache.pig.builtin.ToDate
 
extractDateTimeZone(String) - Static method in class org.apache.pig.builtin.ToDate
 
extraJars - Variable in class org.apache.pig.impl.PigContext
 

F

FAILURE - Static variable in class org.apache.pig.PigRunner.ReturnCode
 
FAILURE_HEADER - Static variable in class org.apache.pig.tools.pigstats.JobStats
 
FAILURE_HEADER - Static variable in class org.apache.pig.tools.pigstats.mapreduce.MRJobStats
 
failureMap - Variable in class org.apache.pig.backend.hadoop.executionengine.Launcher
 
FakeRawKeyValueIterator - Class in org.apache.pig.pen
 
FakeRawKeyValueIterator(boolean) - Constructor for class org.apache.pig.pen.FakeRawKeyValueIterator
 
fe - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
FEATURE - Static variable in class org.apache.pig.tools.pigstats.JobStats
 
featureLongToString(long) - Method in class org.apache.pig.tools.pigstats.ScriptState
 
FetchContext - Class in org.apache.pig.backend.hadoop.executionengine.fetch
A dummy counter handling context for fetch tasks
FetchContext() - Constructor for class org.apache.pig.backend.hadoop.executionengine.fetch.FetchContext
 
fetchFile(Properties, String) - Static method in class org.apache.pig.impl.io.FileLocalizer
Ensures that the passed path is on the local file system, fetching it to the java.io.tmpdir if necessary.
fetchFiles(Properties, String) - Static method in class org.apache.pig.impl.io.FileLocalizer
Ensures that the passed files pointed to by path are on the local file system, fetching them to the java.io.tmpdir if necessary.
FetchLauncher - Class in org.apache.pig.backend.hadoop.executionengine.fetch
This class is responsible for executing the fetch task, saving the result to disk and do the necessary cleanup afterwards.
FetchLauncher(PigContext) - Constructor for class org.apache.pig.backend.hadoop.executionengine.fetch.FetchLauncher
 
FetchOptimizer - Class in org.apache.pig.backend.hadoop.executionengine.fetch
FetchOptimizer determines whether the entire physical plan is fetchable, meaning that the task's result can be directly read (fetched) from the underlying storage rather than creating MR jobs.
FetchOptimizer() - Constructor for class org.apache.pig.backend.hadoop.executionengine.fetch.FetchOptimizer
 
FetchPOStoreImpl - Class in org.apache.pig.backend.hadoop.executionengine.fetch
This class is used to have a POStore write the output to the underlying storage via a output collector/record writer in case of a fetch task.
FetchPOStoreImpl(PigContext) - Constructor for class org.apache.pig.backend.hadoop.executionengine.fetch.FetchPOStoreImpl
 
FetchProgressableReporter - Class in org.apache.pig.backend.hadoop.executionengine.fetch
A dummy ProgressableReporter used for fetch tasks
FetchProgressableReporter() - Constructor for class org.apache.pig.backend.hadoop.executionengine.fetch.FetchProgressableReporter
 
fetchResource(String) - Static method in class org.apache.pig.impl.io.FileLocalizer
Ensures that the passed resource is available from the local file system, fetching it to a temporary directory.
FetchTaskContext - Class in org.apache.pig.backend.hadoop.executionengine.fetch
 
FetchTaskContext(FetchContext) - Constructor for class org.apache.pig.backend.hadoop.executionengine.fetch.FetchTaskContext
 
FieldIsNullException - Exception in org.apache.pig.data
 
FieldIsNullException() - Constructor for exception org.apache.pig.data.FieldIsNullException
 
FieldIsNullException(String) - Constructor for exception org.apache.pig.data.FieldIsNullException
 
fieldNames() - Method in class org.apache.pig.ResourceSchema
Get all field names.
fieldSchema - Variable in class org.apache.pig.newplan.logical.expression.LogicalExpression
 
file - Variable in class org.apache.pig.impl.io.FileLocalizer.FetchFileRet
 
file() - Method in class org.apache.pig.parser.SourceLocation
 
FILE_CONCATENATION_THRESHOLD - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompiler
 
FILE_CONCATENATION_THRESHOLD - Static variable in class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezCompiler
 
FILE_SYSTEM_LOCATION - Static variable in class org.apache.pig.backend.hadoop.executionengine.HExecutionEngine
 
FILE_SYSTEM_NAME - Static variable in class org.apache.pig.backend.hadoop.executionengine.util.MapRedUtil
 
FileBasedOutputSizeReader - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class that computes the size of output for file-based systems.
FileBasedOutputSizeReader() - Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.FileBasedOutputSizeReader
 
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
 
FileList - Class in org.apache.pig.data
This class extends ArrayList to add a finalize() that calls delete on the files .
FileList(int) - Constructor for class org.apache.pig.data.FileList
 
FileList() - Constructor for class org.apache.pig.data.FileList
 
FileList(LinkedList<File>) - Constructor for class org.apache.pig.data.FileList
 
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
 
FileLocalizer.FetchFileRet - Class in org.apache.pig.impl.io
 
FileLocalizer.FetchFileRet(File, boolean) - Constructor for class org.apache.pig.impl.io.FileLocalizer.FetchFileRet
 
filename - Variable in class org.apache.pig.FileSplitComparable
 
fileName - Variable in class org.apache.pig.tools.pigstats.ScriptState
 
FILEOUTPUTCOMMITTER_MARKSUCCESSFULJOBS - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRConfiguration
 
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 represents a relative position in a file.
FileSplitComparable() - Constructor for class org.apache.pig.FileSplitComparable
 
FileSplitComparable(String, long) - Constructor for class org.apache.pig.FileSplitComparable
 
filter - Variable in class org.apache.pig.builtin.Bloom
 
filter - Variable in class org.apache.pig.builtin.BuildBloomBase
 
FilterAboveForeach - Class in org.apache.pig.newplan.logical.rules
This Rule moves Filter Above Foreach.
FilterAboveForeach(String) - Constructor for class org.apache.pig.newplan.logical.rules.FilterAboveForeach
 
FilterAboveForeach.FilterAboveForEachTransformer - Class in org.apache.pig.newplan.logical.rules
 
FilterAboveForeach.FilterAboveForEachTransformer() - Constructor for class org.apache.pig.newplan.logical.rules.FilterAboveForeach.FilterAboveForEachTransformer
 
FilterConstantCalculator - Class in org.apache.pig.newplan.logical.rules
 
FilterConstantCalculator(String, PigContext) - Constructor for class org.apache.pig.newplan.logical.rules.FilterConstantCalculator
 
filteredPlan - Variable in class org.apache.pig.newplan.FilterExtractor
Plan that is created after all pushable filters are removed
filterExpr - Variable in class org.apache.pig.newplan.FilterExtractor
Final filterExpr after we are done
FilterExtractor - Class in org.apache.pig.newplan
Extracts filter predicates for interfaces implementing LoadPredicatePushdown
FilterExtractor(LogicalExpressionPlan) - Constructor for class org.apache.pig.newplan.FilterExtractor
 
FilterExtractor.KeyState - Class in org.apache.pig.newplan
 
FilterExtractor.KeyState() - Constructor for class org.apache.pig.newplan.FilterExtractor.KeyState
 
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.FileList
 
find(ThreadContext, IRubyObject) - Method in class org.apache.pig.scripting.jruby.RubySchema
Given a field name this string will search the RubySchema for a FieldSchema with that name and return it encapsulated in a Schema.
findByAlias(String) - Method in class org.apache.pig.newplan.logical.relational.LogicalPlan
 
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.newplan.logical.relational.LogicalSchema
Look for the index of the field that contains the specified uid
findFieldSchema(String) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema
Find a field schema instance in this FieldSchema hierarchy (including "this") that matches the given canonical name.
findFieldSchema(String) - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
Look for a FieldSchema instance in the schema hierarchy which has the given canonical name.
findGenerate(LOForEach) - Static method in class org.apache.pig.newplan.logical.rules.OptimizerUtils
Find generate op from the foreach operator.
findMetaFile(String, String, Configuration) - Method in class org.apache.pig.builtin.JsonMetadata
.
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
 
FindQuantilesTez - Class in org.apache.pig.backend.hadoop.executionengine.tez.plan.udf
 
FindQuantilesTez() - Constructor for class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez
 
FindQuantilesTez(String[]) - Constructor for class org.apache.pig.backend.hadoop.executionengine.tez.plan.udf.FindQuantilesTez
 
findReacheableInnerLoadFromBoundaryProject(ProjectExpression) - Static method in class org.apache.pig.newplan.logical.relational.LOForEach
 
findReferent() - Method in class org.apache.pig.newplan.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.
findTypeByName(String) - Static method in class org.apache.pig.data.DataType
Get the type code from the type name
findTypeClass(byte) - Static method in class org.apache.pig.data.DataType
 
findTypeFromNullableWritable(PigNullableWritable) - Static method in class org.apache.pig.backend.hadoop.HDataType
 
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.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.
finish() - Method in class org.apache.pig.tools.pigstats.tez.TezStats
 
first - Variable in class org.apache.pig.impl.util.Pair
 
fixDuplicateUids(List<LogicalSchema.LogicalFieldSchema>) - Static method in class org.apache.pig.newplan.logical.relational.LogicalRelationalOperator
In the case of an operation which manipualtes columns (such as a foreach or a join) it is possible for multiple columns to have been derived from the same column and thus have duplicate UID's.
FixedByteArrayOutputStream - Class in org.apache.pig.backend.hadoop.accumulo
Uses a fixed length array and will not grow in size dynamically like the ByteArrayOutputStream.
FixedByteArrayOutputStream(byte[]) - Constructor for class org.apache.pig.backend.hadoop.accumulo.FixedByteArrayOutputStream
 
fixSchema(ResourceSchema) - Method in class org.apache.pig.builtin.JsonStorage
 
fixSchemaAddTupleInBag(Schema) - Static method in class org.apache.pig.newplan.logical.Util
If schema argument has fields where a bag does not contain a tuple schema, it inserts a tuple schema.
flatten(ThreadContext, Block) - Method in class org.apache.pig.scripting.jruby.RubyDataBag
This is a convenience method which will run the given block on the first element of each tuple contained.
FLOAT - Static variable in class org.apache.pig.data.BinInterSedes
 
FLOAT - Static variable in class org.apache.pig.data.DataType
 
FloatAbs - Class in org.apache.pig.builtin
 
FloatAbs() - Constructor for class org.apache.pig.builtin.FloatAbs
 
FloatAvg - Class in org.apache.pig.builtin
This method should never be used directly, use AVG.
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
 
FloatMax - Class in org.apache.pig.builtin
This method should never be used directly, use MAX.
FloatMax() - Constructor for class org.apache.pig.builtin.FloatMax
 
FloatMax.Final - Class in org.apache.pig.builtin
 
FloatMax.Final() - Constructor for class org.apache.pig.builtin.FloatMax.Final
 
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
This method should never be used directly, use MIN.
FloatMin() - Constructor for class org.apache.pig.builtin.FloatMin
 
FloatMin.Final - Class in org.apache.pig.builtin
 
FloatMin.Final() - Constructor for class org.apache.pig.builtin.FloatMin.Final
 
FloatMin.Intermediate - Class in org.apache.pig.builtin
 
FloatMin.Intermediate() - Constructor for class org.apache.pig.builtin.FloatMin.Intermediate
 
FloatRound - Class in org.apache.pig.builtin
ROUND implements a binding to the Java function Math.round(float).
FloatRound() - Constructor for class org.apache.pig.builtin.FloatRound
 
FloatRoundTo - Class in org.apache.pig.builtin
ROUND_TO safely rounds a number to a given precision by using an intermediate BigDecimal.
FloatRoundTo() - Constructor for class org.apache.pig.builtin.FloatRoundTo
 
FloatSum - Class in org.apache.pig.builtin
This method should never be used directly, use SUM.
FloatSum() - Constructor for class org.apache.pig.builtin.FloatSum
 
FLOOR - Class in org.apache.pig.builtin
FLOOR implements a binding to the Java function Math.floor(double).
FLOOR() - Constructor for class org.apache.pig.builtin.FLOOR
 
ForEachConstantCalculator - Class in org.apache.pig.newplan.logical.rules
 
ForEachConstantCalculator(String, PigContext) - Constructor for class org.apache.pig.newplan.logical.rules.ForEachConstantCalculator
 
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)
found() - Method in class org.apache.pig.newplan.logical.visitor.ScalarVariableValidator.ProjectFinder
 
fragment - Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin
 
FRAMEWORK_NAME - Static variable in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRConfiguration
 
fromEdges - Variable in class org.apache.pig.newplan.BaseOperatorPlan
 
fromString(String) - Static method in class org.apache.pig.ExecTypeProvider
 
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, SourceLocation) - 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, byte, Throwable, SourceLocation) - 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.
FrontendException(Operator, String) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(Operator, String, int) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(Operator, String, int, byte) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(Operator, String, int, byte, Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(Operator, String, int, Throwable) - Constructor for exception org.apache.pig.impl.logicalLayer.FrontendException
Create a new FrontendException with the specified message and cause.
FrontendException(Operator, 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
 
fs(String) - Static method in class org.apache.pig.scripting.js.JSPig
See Pig
fs(String) - Static method in class org.apache.pig.scripting.Pig
Run a filesystem command.
FS_COUNTER_GROUP - Static variable in class org.apache.pig.tools.pigstats.mapreduce.MRPigStatsUtil
 
FS_COUNTER_GROUP - Static variable in class org.apache.pig.tools.pigstats.PigStatsUtil
Deprecated.
FS_COUNTER_GROUP - Static variable in class org.apache.pig.tools.pigstats.tez.TezStats
 
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.
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
 
Function<S,T> - Interface in org.apache.pig
A convenience typedef that ties into both google's Function and ExceptionalFunction.
FunctionWrapperEvalFunc - Class in org.apache.pig.builtin
EvalFunc that wraps an implementation of the Function interface, which is passed as a String in the constructor.
FunctionWrapperEvalFunc(String) - Constructor for class org.apache.pig.builtin.FunctionWrapperEvalFunc
Takes the class name of a Function, initializes it using the default constructor and passes it to FunctionWrapperEvalFunc(ExceptionalFunction function).
FunctionWrapperEvalFunc(Function) - Constructor for class org.apache.pig.builtin.FunctionWrapperEvalFunc
Determines the input and output types of the Function and initializes the superclass.
FunctionWrapperEvalFunc(ExceptionalFunction) - Constructor for class org.apache.pig.builtin.FunctionWrapperEvalFunc
Determines the input and output types of the Function and initializes the superclass.
FuncUtils - Class in org.apache.pig.builtin
 
FuncUtils() - Constructor for class org.apache.pig.builtin.FuncUtils
 

G

genAllTypes() - Static method in class org.apache.pig.data.DataType
Get an array of all type values.
GENERATED_CLASSES_KEY - Static variable in class org.apache.pig.PigConstants
This key is used in the job conf to let the various jobs know what code was generated.
generatedCodeCompareTo(SchemaTuple<?>, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeCompareToSpecific(T) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetBigDecimal(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetBigInteger(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetBoolean(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetBytes(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetDataBag(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetDateTime(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetDouble(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetField(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetFloat(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetInt(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetLong(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetMap(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetString(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeGetTuple(int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeHashCode() - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeNullsArray() - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeReadFields(DataInput, boolean[]) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSet(SchemaTuple<?>, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetBigDecimal(int, BigDecimal) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetBigInteger(int, BigInteger) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetBoolean(int, boolean) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetBytes(int, byte[]) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetDataBag(int, DataBag) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetDateTime(int, DateTime) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetDouble(int, double) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetField(int, Object) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetFloat(int, float) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetInt(int, int) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetIterator(Iterator<Object>) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetLong(int, long) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetMap(int, Map<String, Object>) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetSpecific(T) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetString(int, String) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSetTuple(int, Tuple) - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeSize() - Method in class org.apache.pig.data.SchemaTuple
 
generatedCodeWriteElements(DataOutput) - Method in class org.apache.pig.data.SchemaTuple
 
generateNestedSchema(byte, byte...) - Static method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
generateSchemaTuple(Schema, boolean, int, File, SchemaTupleClassGenerator.GenContext...) - Static method in class org.apache.pig.data.SchemaTupleClassGenerator
This class actually generates the code for a given Schema.
GENERIC_WRITABLECOMPARABLE - Static variable in class org.apache.pig.data.BinInterSedes
 
GENERIC_WRITABLECOMPARABLE - Static variable in class org.apache.pig.data.DataType
Internal use only; used to store WriteableComparable objects for creating ordered index in MergeJoin.
genericGetNext(byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add
 
genericGetNext(byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
 
genericGetNext(byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Mod
 
genericGetNext(byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply
 
genericGetNext(byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond
 
genericGetNext(byte) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract
 
GenericInvoker<T> - Class in org.apache.pig.builtin
The generic Invoker class does all the common grunt work of setting up an invoker.
GenericInvoker() - Constructor for class org.apache.pig.builtin.GenericInvoker
 
GenericInvoker(String) - Constructor for class org.apache.pig.builtin.GenericInvoker
 
GenericInvoker(String, String) - Constructor for class org.apache.pig.builtin.GenericInvoker
 
GenericInvoker(String, String, String) - Constructor for class org.apache.pig.builtin.GenericInvoker
 
genNameToTypeMap() - Static method in class org.apache.pig.data.DataType
Get a map of type names to type values.
genOpKey(String) - Static method in class org.apache.pig.impl.plan.OperatorKey
Utility function for creating operator keys.
genSubstitutedFile(BufferedReader, Writer) - Method in class org.apache.pig.tools.parameters.ParameterSubstitutionPreprocessor
This is the main API that takes script template and produces pig script
genSubstitutedFile(BufferedReader, Writer, String[], String[]) - Method in class org.apache.pig.tools.parameters.ParameterSubstitutionPreprocessor
 
genTypeToNameMap() - Static method in class org.apache.pig.data.DataType
Get a map of type values to type names.
get() - Method in class org.apache.pig.backend.hadoop.BigDecimalWritable
 
get() - Method in class org.apache.pig.backend.hadoop.BigIntegerWritable
 
get() - Method in class org.apache.pig.backend.hadoop.DateTimeWritable
 
get() - Method in class org.apache.pig.backend.hadoop.DoubleWritable
 
get() - Method in class org.apache.pig.backend.hadoop.executionengine.fetch.FetchTaskContext
 
get() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRTaskContext
 
get(Tuple) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin.TupleToMapKey
 
get(int) - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin.TuplesToSchemaTupleList
 
get() - Method in class org.apache.pig.backend.hadoop.executionengine.TaskContext
 
get() - Method in class org.apache.pig.backend.hadoop.executionengine.tez.runtime.TezTaskContext
 
get(String) - Method in class org.apache.pig.builtin.mock.Storage.Data
 
get(int) - Method in class org.apache.pig.data.AppendableSchemaTuple
 
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.SchemaTuple
 
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() - Method in class org.apache.pig.data.utils.StructuresHelper.SchemaKey
 
get(int) - Method in class org.apache.pig.impl.plan.CompilationMessageCollector
 
get(Object) - Method in class org.apache.pig.impl.util.avro.AvroMapWrapper
 
get(int) - Method in class org.apache.pig.impl.util.avro.AvroTupleWrapper
 
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
 
get(ThreadContext, IRubyObject) - Method in class org.apache.pig.scripting.jruby.RubySchema
This is the ruby method which allows people to access elements of the RubySchema object.
get(ThreadContext, IRubyObject, IRubyObject) - Method in class org.apache.pig.scripting.jruby.RubySchema
This is a version of [] which allows the range to be specified as such: [1,2].
get(ThreadContext) - Method in class org.apache.pig.scripting.jruby.RubySchema
This method allows access into the Schema nested in the encapsulated Schema.
get() - Static method in class org.apache.pig.scripting.ScriptPigContext
 
get() - Static method in class org.apache.pig.tools.pigstats.mapreduce.MRScriptState
 
get() - Static method in class org.apache.pig.tools.pigstats.PigStats
 
get() - Static method in class org.apache.pig.tools.pigstats.ScriptState
 
get() - Static method in class org.apache.pig.tools.pigstats.tez.TezScriptState
 
getAbsolutePath(String, Path) - Static method in class org.apache.pig.LoadFunc
Construct the absolute path from the file location and the current directory.
getAccumulativeBatchSize() - Static method in class org.apache.pig.backend.hadoop.executionengine.util.AccumulatorOptimizerUtil
 
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.backend.hadoop.executionengine.physicalLayer.PhysicalOperator.OriginalLocation
 
getAlias() - Method in class org.apache.pig.LoadPushDown.RequiredField
 
getAlias() - Method in class org.apache.pig.newplan.logical.relational.LogicalRelationalOperator
Get the alias of this operator.
getAlias() - Method in exception org.apache.pig.parser.DuplicatedSchemaAliasException
 
getAlias() - Method in exception org.apache.pig.parser.UndefinedAliasException
 
getAlias() - Method in class org.apache.pig.tools.pigstats.JobStats
 
getAlias() - Method in class org.apache.pig.tools.pigstats.mapreduce.MRJobStats
 
getAlias(MapReduceOper) - Method in class org.apache.pig.tools.pigstats.mapreduce.MRScriptState
 
getAlias() - Method in class org.apache.pig.tools.pigstats.OutputStats
 
getAlias(TezOperator) - Method in class org.apache.pig.tools.pigstats.tez.TezScriptState
 
getAliases() - Method in class org.apache.pig.impl.logicalLayer.schema.Schema
 
getAliases() - Method in class org.apache.pig.PigServer
Return a map containing the logical plan associated with each alias.
getAliasKeySet() - Method in class org.apache.pig.PigServer
Get the set of all current aliases.
getAliasLocation() - Method in class org.apache.pig.tools.pigstats.JobStats
 
getAliasLocation() - Method in class org.apache.pig.tools.pigstats.mapreduce.MRJobStats
 
getAliasLocation(MapReduceOper) - Method in class org.apache.pig.tools.pigstats.mapreduce.MRScriptState
 
getAliasLocation(TezOperator) - Method in class org.apache.pig.tools.pigstats.tez.TezScriptState
 
getAliasString() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
 
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.SchemaTuple
 
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.impl.util.avro.AvroTupleWrapper
 
getAll() - Method in class org.apache.pig.pen.util.ExampleTuple
 
getAllErrorMessages() - Method in class org.apache.pig.tools.pigstats.EmptyPigStats
 
getAllErrorMessages() - Method in class org.apache.pig.tools.pigstats.mapreduce.SimplePigStats
 
getAllErrorMessages() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getAllErrorMessages() - Method in class org.apache.pig.tools.pigstats.tez.TezStats
 
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
getAllListeners() - Method in class org.apache.pig.tools.pigstats.ScriptState
 
getAllStats() - Method in class org.apache.pig.tools.pigstats.EmptyPigStats
 
getAllStats() - Method in class org.apache.pig.tools.pigstats.mapreduce.SimplePigStats
 
getAllStats() - Method in class org.apache.pig.tools.pigstats.PigStats
 
getAllStats() - Method in class org.apache.pig.tools.pigstats.tez.TezStats
 
getAmendKey() - Method in class org.apache.pig.data.AmendableTuple
 
getAnnotation(String) - Method in class org.apache.pig.newplan.Operator
Look to see if a node is annotated.
getAnnotationCanonicalName() - Method in enum org.apache.pig.data.SchemaTupleClassGenerator.GenContext
 
getAppendedField(int) - Method in class org.apache.pig.data.AppendableSchemaTuple
 
getAppendedFields() - Method in class org.apache.pig.data.AppendableSchemaTuple
 
getApplicationId() - Method in class org.apache.pig.backend.hadoop.executionengine.tez.TezJob
 
getArgStringFromSpec(String) - Static method in class org.apache.pig.FuncSpec
Get the argument values passed to the func spec.
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ABS
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.AddDuration
 
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.COUNT
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.DaysBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.DoubleBase
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.DoubleRoundTo
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ENDSWITH
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.FloatRoundTo
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetDay
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetHour
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetMilliSecond
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetMinute
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetMonth
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetSecond
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetWeek
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetWeekYear
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.GetYear
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.HoursBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.LAST_INDEX_OF
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.LOWER
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.LTRIM
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MAX
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MilliSecondsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MIN
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MinutesBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.MonthsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.REGEX_EXTRACT
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.REGEX_EXTRACT_ALL
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.REPLACE
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ROUND
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ROUND_TO
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.RTRIM
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SecondsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SIZE
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.STARTSWITH
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.STRSPLIT
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.STRSPLITTOBAG
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SUBSTRING
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SubtractDuration
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.SUM
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ToDate
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.TOKENIZE
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ToMilliSeconds
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.TOP
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ToString
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.ToUnixTime
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.TRIM
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.UPPER
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.WeeksBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.builtin.YearsBetween
 
getArgToFuncMapping() - Method in class org.apache.pig.EvalFunc
Allow a UDF to specify type specific implementations of itself.
getArguments() - Method in class org.apache.pig.newplan.logical.expression.UserFuncExpression
 
getAscendingCol() - Method in class org.apache.pig.newplan.logical.relational.LORank
 
getAscendingCols() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PORank
 
getAscendingCols() - Method in class org.apache.pig.newplan.logical.relational.LOSort
 
getAscendingColumns() - Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCounter
 
getAscs() - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.SortKeyInfo
 
getAttachedLogicalOperator() - Method in class org.apache.pig.newplan.logical.expression.ScalarExpression
 
getAttachedRelationalOp() - Method in class org.apache.pig.newplan.logical.expression.ProjectExpression
 
getAttributes(MapReduceOper) - Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter