|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Math.abs(double)
for computing the
absolute value of the argument.ABS
Math.acos(double)
for computing the
arc cosine of value of the argument.ACOS
StreamingCommand.HandleSpec
to a given StreamingCommand.Handle
GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder)
to add a
value.
SIZE
instead.Math.asin(double)
for computing the
arc sine of value of the argument.ASIN
Math.atan(double)
for computing the
arc tangent of value of the argument.ATAN
Math.atan2(double,double)
.FSDataInputStream
to SeekableInput
.SIZE
.Base
OutputFormat
class for creating a
BasicTable.String Bin(arithmetic_expression, string1, ,..., stringN, sentinelN, default_string)
.
Logic:
if (arithmetic_expression<=sentinel1) return string1;
......- Bin() -
Constructor for class org.apache.pig.piggybank.evaluation.decode.Bin
-
- BinaryComparisonOperator - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
- This is a base class for all binary comparison operators.
- BinaryComparisonOperator(OperatorKey) -
Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
-
- BinaryComparisonOperator(OperatorKey, int) -
Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator
-
- BinaryExpression - Class in org.apache.pig.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
-
- BinCond - Class in org.apache.pig.piggybank.evaluation.decode
-
Syntax:
String BinCond(boolean_expression1, mapping_string1, ..., boolean_expressionN, mapping_stringN, other_string)
.
Logic:
if (boolean_expression1) return mapping_string1;
......- BinCond() -
Constructor for class org.apache.pig.piggybank.evaluation.decode.BinCond
-
- BinCondExpression - Class in org.apache.pig.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
- See:
Pig.bind()
- 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
-
- BLOCK_REPLICATION_KEY -
Static variable in interface org.apache.pig.backend.datastorage.ElementDescriptor
- Available from getConfiguration as a String and getStatistics as a Short.
- BLOCK_SIZE_KEY -
Static variable in interface org.apache.pig.backend.datastorage.ElementDescriptor
- Available from getConfiguration as a String and getStatistics as a Long.
- BlockDistribution - Class in org.apache.hadoop.zebra.io
- Class used to convey the information of how on-disk data that fall in a
specific split are distributed across hosts.
- BlockDistribution() -
Constructor for class org.apache.hadoop.zebra.io.BlockDistribution
-
- BOOLEAN -
Static variable in class org.apache.pig.data.DataType
-
- BOOLEAN_FALSE -
Static variable in class org.apache.pig.data.BinInterSedes
-
- BOOLEAN_TRUE -
Static variable in class org.apache.pig.data.BinInterSedes
-
- BooleanExpr - Class in org.apache.hadoop.zebra.pig.comparator
-
- BooleanExpr(int) -
Constructor for class org.apache.hadoop.zebra.pig.comparator.BooleanExpr
-
- BooleanSchema -
Static variable in class org.apache.pig.piggybank.storage.avro.AvroStorageUtils
-
- BoundedByteArrayOutputStream - Class in org.apache.hadoop.zebra.tfile
- A byte array backed output stream with a limit.
- BoundedByteArrayOutputStream(int) -
Constructor for class org.apache.hadoop.zebra.tfile.BoundedByteArrayOutputStream
- Create a BoundedByteArrayOutputStream with the specified
capacity
- BoundedByteArrayOutputStream(int, int) -
Constructor for class org.apache.hadoop.zebra.tfile.BoundedByteArrayOutputStream
- Create a BoundedByteArrayOutputStream with the specified
capacity and limit.
- BoundScript - Class in org.apache.pig.scripting
- This represents an instance of a bound pipeline.
- breadthFirst() -
Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PlanPrinter
-
- buffer() -
Method in class org.apache.hadoop.zebra.tfile.ByteArray
-
- buffer() -
Method in interface org.apache.hadoop.zebra.tfile.RawComparable
- Get the underlying byte array.
- buffer -
Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach
-
- BufferedPositionedInputStream - Class in org.apache.pig.impl.io
-
- BufferedPositionedInputStream(InputStream, long) -
Constructor for class org.apache.pig.impl.io.BufferedPositionedInputStream
-
- BufferedPositionedInputStream(InputStream) -
Constructor for class org.apache.pig.impl.io.BufferedPositionedInputStream
-
- BUG -
Static variable in exception org.apache.pig.PigException
-
- build() -
Method in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat.HBaseTableIFBuilder
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.DuplicateForEachColumnRewrite
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.FilterAboveForeach
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.GroupByConstParallelSetter
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.ImplicitSplitInserter
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.LimitOptimizer
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.LogicalExpressionSimplifier
-
- 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.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.TypeCastInserter
-
- 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 - Class in org.apache.hadoop.zebra.tfile
- Adaptor class to wrap byte-array backed objects (including java byte array)
as RawComparable objects.
- ByteArray(BytesWritable) -
Constructor for class org.apache.hadoop.zebra.tfile.ByteArray
- Constructing a ByteArray from a
BytesWritable
.
- ByteArray(byte[]) -
Constructor for class org.apache.hadoop.zebra.tfile.ByteArray
- Wrap a whole byte array as a RawComparable.
- ByteArray(byte[], int, int) -
Constructor for class org.apache.hadoop.zebra.tfile.ByteArray
- Wrap a partial byte array as a RawComparable.
- BYTEARRAY -
Static variable in class org.apache.pig.data.BinInterSedes
-
- BYTEARRAY -
Static variable in class org.apache.pig.data.DataType
-
- ByteExpr - Class in org.apache.hadoop.zebra.pig.comparator
-
- ByteExpr(int) -
Constructor for class org.apache.hadoop.zebra.pig.comparator.ByteExpr
-
- bytes -
Variable in class org.apache.hadoop.zebra.pig.comparator.FixedLengthPrimitive
-
- BytesExpr - Class in org.apache.hadoop.zebra.pig.comparator
-
- BytesExpr(int) -
Constructor for class org.apache.hadoop.zebra.pig.comparator.BytesExpr
-
- BytesSchema -
Static variable in class org.apache.pig.piggybank.storage.avro.AvroStorageUtils
-
- 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
-
- bytesToBoolean(byte[]) -
Method in class org.apache.pig.builtin.Utf8StorageConverter
- Note: NOT part of the LoadCaster interface.
- 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.
- 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.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.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.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[]) -
Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
-
- bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) -
Method in class org.apache.pig.backend.hadoop.hbase.HBaseBinaryConverter
- NOT IMPLEMENTED
- bytesToMap(byte[]) -
Method in class org.apache.pig.builtin.TextLoader
-
- bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) -
Method in class org.apache.pig.builtin.TextLoader
- TextLoader does not support conversion to Map
- bytesToMap(byte[], ResourceSchema.ResourceFieldSchema) -
Method in class org.apache.pig.builtin.Utf8StorageConverter
-
- bytesToMap(byte[]) -
Method in class org.apache.pig.builtin.Utf8StorageConverter
-
- bytesToMap(DataInput) -
Static method in class org.apache.pig.data.DataReaderWriter
-
- bytesToMap(byte[]) -
Method in interface org.apache.pig.LoadCaster
- Deprecated.
- 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.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[], 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
-
Math.cbrt(double)
for computing the
cube root of the argument.CBRT
Math.ceil(double)
.CEIL
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
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.
StoreFunc.cleanupOnFailure(String, Job)
.
ExecutableManager
.
InputHandler
since there is no more input
to be sent to the managed process.
OutputHandler
.
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.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)
.
ExecutableManager
.
SIZE
.AvroStorageUtils.containsRecursiveRecord(Schema)
and it recursively checks
whether the input schema contains recursive records.
Math.copySign(double,double)
.COR
Math.cos(double)
.COS
Math.cosh(double)
.COSH
COV
ExecutableManager
depending on the ExecType.
InputHandler
for the given input specification
of the StreamingCommand
.
OutputHandler
for the given output specification
of the StreamingCommand
.
TFile.Reader.createScannerByKey(byte[], byte[])
instead.
TFile.Reader.createScannerByKey(RawComparable, RawComparable)
instead.
comma
as the
field delimiter, terminates records on reading a newline
within a field (even if the field is enclosed in double quotes),
and uses LF
as line terminator.
String Decode(expression, value1, mapping_string1, ..., valueN, mapping_stringN, other_string)
.
Logic:
if (expression==value1) return mapping_string1;
......- Decode() -
Constructor for class org.apache.pig.piggybank.evaluation.decode.Decode
-
- decodeBytes(String) -
Static method in class org.apache.pig.impl.util.ObjectSerializer
-
- 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
-
- DEFAULT_CHUNK_SIZE -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POJoinPackage
-
- DEFAULT_COMPARATOR -
Static variable in class org.apache.hadoop.zebra.types.SortInfo
-
- DEFAULT_DATE_TIME_ZONE -
Static variable in class org.apache.pig.piggybank.evaluation.datetime.truncate.ISOHelper
- Default time zone for use in parsing, regardless of System or JDK's
default time zone.
- DEFAULT_DEFLATE_LEVEL -
Static variable in class org.apache.pig.piggybank.storage.avro.PigAvroOutputFormat
- The default deflate level.
- DEFAULT_PERCENT_MEMUSAGE -
Static variable in class org.apache.pig.impl.builtin.PartitionSkewedKeys
-
- DEFAULT_REPLICATION_FACTOR_KEY -
Static variable in interface org.apache.pig.backend.datastorage.DataStorage
-
- DEFAULT_SCOPE -
Static variable in class org.apache.pig.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. Use
TupleFactory
- DefaultTupleFactory() -
Constructor for class org.apache.pig.data.DefaultTupleFactory
- Deprecated.
- 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.
- DEFLATE_LEVEL_KEY -
Static variable in class org.apache.pig.piggybank.storage.avro.PigAvroOutputFormat
- The configuration key for Avro deflate level.
- delete() -
Method in interface org.apache.pig.backend.datastorage.ElementDescriptor
- Remove entity from the Data Storage.
- delete() -
Method in class org.apache.pig.backend.hadoop.datastorage.HPath
-
- delete(String, PigContext) -
Static method in class org.apache.pig.impl.io.FileLocalizer
-
- DELETED_CG_SEPARATOR_PER_TABLE -
Static variable in class org.apache.hadoop.zebra.io.BasicTable
-
- deleteFile(String) -
Method in class org.apache.pig.PigServer
- Delete a file.
- deleteTempFiles() -
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
-
- 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[]) -
Method in class org.apache.pig.builtin.PigStreaming
-
- deserialize(String) -
Static method in class org.apache.pig.impl.util.ObjectSerializer
-
- deserialize() -
Method in class org.apache.pig.impl.util.UDFContext
- Populate the udfConfs field.
- deserialize(byte[]) -
Method in interface org.apache.pig.StreamToPig
- Given a byte array from a streaming executable, produce a tuple.
- deserializer -
Variable in class org.apache.pig.impl.streaming.OutputHandler
-
- detachInput() -
Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
- Detaches any tuples that are attached
- detachInput() -
Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan
-
- detachInput() -
Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage
-
- detachInput() -
Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
- attachInput's better half!
- detailedMessage -
Variable in exception org.apache.pig.PigException
-
- DETAILS -
Static variable in class org.apache.pig.piggybank.storage.avro.AvroStorageLog
-
- 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
- determineFirstFile(String) -
Method in class org.apache.pig.piggybank.storage.allloader.LoadFuncHelper
- If location is a directory the first file found is returned
- determineFunction(String) -
Method in class org.apache.pig.piggybank.storage.allloader.LoadFuncHelper
- If location is a directory the first file found in the directory is used.
The file extension of the file will be searched against the
file.extension.loaders mappings.
- determineFunction(String, Path) -
Method in class org.apache.pig.piggybank.storage.allloader.LoadFuncHelper
- The file extension of the file will be searched against the
file.extension.loaders mappings.
- 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
-
- DiffDate - Class in org.apache.pig.piggybank.evaluation.datetime
-
Syntax:
int DiffDate(String yyyymmdd1, String yyyymmdd2)
.
Input:
date string in "yyyymmdd" format
.
Output:
(date1-date2) in days, can be negative
.
- DiffDate() -
Constructor for class org.apache.pig.piggybank.evaluation.datetime.DiffDate
-
- 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(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.PigStatsUtil
- Logs the statistics in the Pig log file at INFO level
- distinct -
Variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage
-
- Distinct - Class in org.apache.pig.builtin
- Find the distinct set of tuples in a bag.
- Distinct() -
Constructor for class org.apache.pig.builtin.Distinct
-
- Distinct.Final - Class in org.apache.pig.builtin
-
- Distinct.Final() -
Constructor for class org.apache.pig.builtin.Distinct.Final
-
- Distinct.Initial - Class in org.apache.pig.builtin
-
- Distinct.Initial() -
Constructor for class org.apache.pig.builtin.Distinct.Initial
-
- Distinct.Intermediate - Class in org.apache.pig.builtin
-
- Distinct.Intermediate() -
Constructor for class org.apache.pig.builtin.Distinct.Intermediate
-
- DistinctCombiner - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
- A special implementation of combiner used only for distinct.
- DistinctCombiner() -
Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.DistinctCombiner
-
- DistinctCombiner.Combine - Class in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
-
- DistinctCombiner.Combine() -
Constructor for class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.DistinctCombiner.Combine
-
- DistinctDataBag - Class in org.apache.pig.data
- An unordered collection of Tuples with no multiples.
- DistinctDataBag() -
Constructor for class org.apache.pig.data.DistinctDataBag
-
- Divide - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
-
- Divide(OperatorKey) -
Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
-
- Divide(OperatorKey, int) -
Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide
-
- divide(T, T, 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, Map<String, String>, List<String>) -
Method in class org.apache.pig.PigServer
- Do parameter substitution.
- 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
-
- DOUBLE -
Static variable in class org.apache.pig.data.BinInterSedes
-
- DOUBLE -
Static variable in class org.apache.pig.data.DataType
-
- DOUBLE_QUOTE -
Static variable in class org.apache.pig.piggybank.storage.CSVExcelStorage
-
- DoubleAbs - Class in org.apache.pig.builtin
-
- DoubleAbs() -
Constructor for class org.apache.pig.builtin.DoubleAbs
-
- DoubleAbs - Class in org.apache.pig.piggybank.evaluation.math
- Deprecated. Use
DoubleAbs
- DoubleAbs() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleAbs
- Deprecated.
- 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
-
- DoubleBase - Class in org.apache.pig.piggybank.evaluation.math
- Deprecated. Use
DoubleBase
- DoubleBase() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleBase
- Deprecated.
- DoubleCopySign - Class in org.apache.pig.piggybank.evaluation.math
- math.copySign implements a binding to the Java function
Math.copySign(double,double)
. - DoubleCopySign() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleCopySign
-
- DoubleDoubleBase - Class in org.apache.pig.piggybank.evaluation.math
- base class for math udfs that return Double value
- DoubleDoubleBase() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleDoubleBase
-
- DoubleExpr - Class in org.apache.hadoop.zebra.pig.comparator
-
- DoubleGetExponent - Class in org.apache.pig.piggybank.evaluation.math
- math.getExponent implements a binding to the Java function
Math.getExponent(double)
. - DoubleGetExponent() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleGetExponent
-
- DoubleMax - Class in org.apache.pig.builtin
- This method should never be used directly, use
MAX
. - DoubleMax() -
Constructor for class org.apache.pig.builtin.DoubleMax
-
- DoubleMax - Class in org.apache.pig.piggybank.evaluation.math
- math.max implements a binding to the Java function
Math.max(int,int)
for computing the
the max value of the arguments. - DoubleMax() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleMax
-
- DoubleMax.Final - Class in org.apache.pig.builtin
-
- DoubleMax.Final() -
Constructor for class org.apache.pig.builtin.DoubleMax.Final
-
- DoubleMax.Initial - Class in org.apache.pig.builtin
-
- DoubleMax.Initial() -
Constructor for class org.apache.pig.builtin.DoubleMax.Initial
-
- DoubleMax.Intermediate - Class in org.apache.pig.builtin
-
- DoubleMax.Intermediate() -
Constructor for class org.apache.pig.builtin.DoubleMax.Intermediate
-
- DoubleMin - Class in org.apache.pig.builtin
- This method should never be used directly, use
MIN
. - DoubleMin() -
Constructor for class org.apache.pig.builtin.DoubleMin
-
- DoubleMin - Class in org.apache.pig.piggybank.evaluation.math
- math.min implements a binding to the Java function
Math.min(int,int)
for computing the
the min value of the arguments. - DoubleMin() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleMin
-
- DoubleMin.Final - Class in org.apache.pig.builtin
-
- DoubleMin.Final() -
Constructor for class org.apache.pig.builtin.DoubleMin.Final
-
- DoubleMin.Initial - Class in org.apache.pig.builtin
-
- DoubleMin.Initial() -
Constructor for class org.apache.pig.builtin.DoubleMin.Initial
-
- DoubleMin.Intermediate - Class in org.apache.pig.builtin
-
- DoubleMin.Intermediate() -
Constructor for class org.apache.pig.builtin.DoubleMin.Intermediate
-
- DoubleNextAfter - Class in org.apache.pig.piggybank.evaluation.math
- math.nextAfter implements a binding to the Java function
Math.nextAfter(double,double)
. - DoubleNextAfter() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleNextAfter
-
- DoubleNextup - Class in org.apache.pig.piggybank.evaluation.math
- math.NEXTUP implements a binding to the Java function
Math.nextUp(double)
. - DoubleNextup() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleNextup
-
- DoubleRound - Class in org.apache.pig.builtin
- Given a single data atom it Returns the closest long to the argument.
- DoubleRound() -
Constructor for class org.apache.pig.builtin.DoubleRound
-
- DoubleRound - Class in org.apache.pig.piggybank.evaluation.math
- Deprecated. Use
DoubleRound
- DoubleRound() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleRound
- Deprecated.
- DoubleSchema -
Static variable in class org.apache.pig.piggybank.storage.avro.AvroStorageUtils
-
- DoubleSignum - Class in org.apache.pig.piggybank.evaluation.math
- math.SIGNUM implements a binding to the Java function
Math.signum(double)
. - DoubleSignum() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleSignum
-
- DoubleSum - Class in org.apache.pig.builtin
- 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.Initial - Class in org.apache.pig.builtin
-
- DoubleSum.Initial() -
Constructor for class org.apache.pig.builtin.DoubleSum.Initial
-
- DoubleSum.Intermediate - Class in org.apache.pig.builtin
-
- DoubleSum.Intermediate() -
Constructor for class org.apache.pig.builtin.DoubleSum.Intermediate
-
- DoubleUlp - Class in org.apache.pig.piggybank.evaluation.math
- math.ULP implements a binding to the Java function
Math.ulp(double)
. - DoubleUlp() -
Constructor for class org.apache.pig.piggybank.evaluation.math.DoubleUlp
-
- DoubleWritable - Class in org.apache.pig.backend.hadoop
- Writable for Double values.
- DoubleWritable() -
Constructor for class org.apache.pig.backend.hadoop.DoubleWritable
-
- DoubleWritable(double) -
Constructor for class org.apache.pig.backend.hadoop.DoubleWritable
-
- DoubleWritable.Comparator - Class in org.apache.pig.backend.hadoop
- A Comparator optimized for DoubleWritable.
- DoubleWritable.Comparator() -
Constructor for class org.apache.pig.backend.hadoop.DoubleWritable.Comparator
-
- drop(Path, Configuration) -
Static method in class org.apache.hadoop.zebra.io.BasicTable
- Drop a Basic Table, all files consisting of the BasicTable will be removed.
- drop(FileSystem, Path) -
Static method in class org.apache.hadoop.zebra.types.CGSchema
-
- dropColumnGroup(Path, Configuration, String) -
Static method in class org.apache.hadoop.zebra.io.BasicTable
- Deletes the data for column group specified by cgName.
- 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
-
- dummyBag -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyBool -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyDBA -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyDouble -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyFloat -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyInt -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyLong -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyMap -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyString -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dummyTuple -
Static variable in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
-
- dump() -
Method in class org.apache.pig.impl.plan.DotPlanDumper
-
- dump(PrintStream) -
Method in class org.apache.pig.impl.plan.OperatorPlan
-
- dump() -
Method in class org.apache.pig.impl.plan.PlanDumper
- This is the public interface.
- 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.
- dumpInfo(String, PrintStream, Configuration) -
Static method in class org.apache.hadoop.zebra.io.BasicTable
-
- dumpInfo(String, PrintStream, Configuration, int) -
Static method in class org.apache.hadoop.zebra.io.BasicTable
-
- dumpInvisibleOperators(E) -
Method in class org.apache.pig.impl.plan.DotPlanDumper
-
- 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
-
- 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
-
- DuplicateForEachColumnRewrite - Class in org.apache.pig.newplan.logical.rules
-
- DuplicateForEachColumnRewrite(String) -
Constructor for class org.apache.pig.newplan.logical.rules.DuplicateForEachColumnRewrite
-
- dupNode() -
Method in class org.apache.pig.parser.PigParserNode
-
o
is a DoubleWritable with the same value.
ExecutableManager
manages an external executable which processes data
in a Pig query.ExecutableManager
.
EXP
Math.expm1(double)
.FileLocalizer.fileExists(String, PigContext)
instead
FloatAbs
AVG
.Math.copySign(float,float)
.Math.getExponent(double)
.MAX
.Math.max(int,int)
for computing the
the max value of the arguments.MIN
.Math.min(int,int)
for computing the
the min value of the arguments.Math.nextAfter(double,double)
.Math.nextUp(double)
.Math.round(float)
.FloatRound
Math.signum(float)
.SUM
.Math.ulp(float)
.Math.floor(double)
.FLOOR
Pig
FileLocalizer.fullPath(String, PigContext)
instead
GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder)
to enumerate
array elements.
GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder)
to get the
size of an array.
StreamingCommand
for this StreamSpec
.
StreamingCommand
for the given alias.
PigContext.getProperties()
instead
PigException
Math.getExponent(double)
.PigAvroDatumWriter.writeRecord(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder)
to retrieve
a record field value.
FuncSpec
that performs the casting functionality
Handle
.
StreamingCommand
.
InputType
POStore
HandleSpec
.
Tuple
of the managed process.
StreamingCommand
.
OutputType
.
PigStats
after the script is run.
PigRunner.ReturnCode
BasicTable.Reader.RangeSplit
object, which should be obtained from previous calls
of BasicTable.Reader.rangeSplit(int)
.
BasicTable.Reader.RowSplit
object.
AvroStorage.getAvroSchema(java.lang.String, org.apache.hadoop.mapreduce.Job)
.
SpillableMemoryManager
.
HandleSpec
.
FileLocalizer.getTemporaryPath(PigContext)
instead
InputFormat
) which this class is wrapping.
HadoopExecutableManager
is a specialization of
ExecutableManager
and provides HDFS-specific support for secondary
outputs, task-logs etc.InputHandler
or OutputHandler
depending on the specification of the StreamingCommand
.long HashFNV(String string_to_hash, [int mod])
.
Math.hypot(double,double)
.Math.IEEEremainder(double,double)
.INDEXOF
InputHandler
is responsible for handling the input to the
Pig-Streaming external command.PigAvroDatumWriter.resolveUnion(Schema,Object)
,
PigAvroDatumWriter.unwrappedInstanceOf(Schema,Object)
.
Math.abs(int)
for computing the
absolute value of the argument.IntAbs
AVG
.ScriptEngine
implementation for JavaScript
A = load 'mydata' as (name);
B = foreach A generate LASTINDEXOF(name, ",");
LAST_INDEX_OF
LCFIRST
Math.log(double)
.LOG
Math.log10(double)
.LOG10
Math.log1p(double)
.LongAbs
AVG
.MAX
.Math.max(long,long)
for computing the
the max value of the arguments.MIN
.Math.min(long,long)
for computing the
the min value of the arguments.SUM
.int lookupInFiles(String expression,...- LookupInFiles() -
Constructor for class org.apache.pig.piggybank.evaluation.string.LookupInFiles
-
- LOSort - Class in org.apache.pig.newplan.logical.relational
-
- LOSort(OperatorPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LOSort
-
- LOSort(OperatorPlan, List<LogicalExpressionPlan>, List<Boolean>, FuncSpec) -
Constructor for class org.apache.pig.newplan.logical.relational.LOSort
-
- LOSplit - Class in org.apache.pig.newplan.logical.relational
-
- LOSplit(OperatorPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LOSplit
-
- LOSplitOutput - Class in org.apache.pig.newplan.logical.relational
-
- LOSplitOutput(LogicalPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LOSplitOutput
-
- LOSplitOutput(LogicalPlan, LogicalExpressionPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LOSplitOutput
-
- LOStore - Class in org.apache.pig.newplan.logical.relational
-
- LOStore(LogicalPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LOStore
-
- LOStore(LogicalPlan, FileSpec) -
Constructor for class org.apache.pig.newplan.logical.relational.LOStore
-
- LOStream - Class in org.apache.pig.newplan.logical.relational
-
- LOStream(LogicalPlan, ExecutableManager, StreamingCommand, LogicalSchema) -
Constructor for class org.apache.pig.newplan.logical.relational.LOStream
-
- LOUnion - Class in org.apache.pig.newplan.logical.relational
-
- LOUnion(OperatorPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LOUnion
-
- LOUnion(OperatorPlan, boolean) -
Constructor for class org.apache.pig.newplan.logical.relational.LOUnion
-
- LOWER - Class in org.apache.pig.builtin
- LOWER implements eval function to convert a string to lower case
Example:
A = load 'mydata' as (name);
B = foreach A generate LOWER(name);
- LOWER() -
Constructor for class org.apache.pig.builtin.LOWER
-
- LOWER - Class in org.apache.pig.piggybank.evaluation.string
- Deprecated. Use
LOWER
- LOWER() -
Constructor for class org.apache.pig.piggybank.evaluation.string.LOWER
- Deprecated.
- lowerBound(byte[]) -
Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
- Move the cursor to the first entry whose key is greater than or equal
to the input key.
- lowerBound(byte[], int, int) -
Method in class org.apache.hadoop.zebra.tfile.TFile.Reader.Scanner
- Move the cursor to the first entry whose key is greater than or equal
to the input key.
- lowerBound(List<? extends T>, T, Comparator<? super T>) -
Static method in class org.apache.hadoop.zebra.tfile.Utils
- Lower bound binary search.
- lowerBound(List<? extends Comparable<? super T>>, T) -
Static method in class org.apache.hadoop.zebra.tfile.Utils
- Lower bound binary search.
- lp -
Variable in class org.apache.pig.tools.ToolsPigServer.PigPlans
-
- lt_ -
Variable in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
-
- lt_ -
Variable in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat.HBaseTableIFBuilder
-
- lt_ -
Variable in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat
-
- lte_ -
Variable in class org.apache.pig.backend.hadoop.hbase.HBaseStorage
-
- lte_ -
Variable in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat.HBaseTableIFBuilder
-
- lte_ -
Variable in class org.apache.pig.backend.hadoop.hbase.HBaseTableInputFormat
-
- LTOrEqualToExpr - Class in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
-
- LTOrEqualToExpr(OperatorKey) -
Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LTOrEqualToExpr
-
- LTOrEqualToExpr(OperatorKey, int) -
Constructor for class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LTOrEqualToExpr
-
SIZE
.Math.max(double,double)
.Math.min(double,double)
.Math.nextAfter(double,double)
.Math.nextUp(double)
.FileLocalizer.open(String, PigContext)
instead
InputFormat
and
OutputFormat
adaptor classes for Hadoop
Zebra Table.InputFormat
and
OutputFormat
adaptor classes for Hadoop
Zebra Table.OutputHandler
is responsible for handling the output of the
Pig-Streaming external command.String
into a byte representing the
field delimiter.
GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder)
to retrieve a
value from a reused instance.
PigException
class.PigRunner
.OperatorPlan
whose members are JobStats
PigToStream
and StreamToPig
interfaces.Tuple
to a byte
array.Math.pow(double,double)
.OutputStream
in the
field-delimited form.
Tuple
to the managed executable.
RawComparator
.String RegexExtract(String expression, String regex, int match_index)
.
Input:
expression
-source string
.
regex
-regular expression
.
match_index
-index of the group to extract
.
Output:
extracted group, if fail, return null
.
String RegexExtractAll(String expression, String regex)
.
Input:
expression
-source string
.
regex
-regular expression
.
Output:
A tuple of matched strings
.
REGEX_EXTRACT
REGEX_EXTRACT_ALL
int RegexMatch(String expression, String regex)
.
Output:
return 1 if expression contains regex, 0 otherwise
.
SpillableMemoryManager
.
Pig
Pig
REPLACE
Schema
LogicalSchema
Schema.FieldSchema
as the template.
LogicalSchema.LogicalFieldSchema
as the template.
Math.rint(double)
.Math.round(double)
.ROUND
ExecutableManager
.
Math.scalb(double,int)
.Pig
StreamingCommand
.
StreamingCommand
.
FuncSpec
that performs the casting functionality
StreamingCommand
.
#setMultipleOutputs(JobContext, class extends ZebraOutputPartition>, Path ...)
instead.
HandleSpec
.
StreamingCommand
.
TableInputFormat.setProjection(JobConf, ZebraProjection)
instead.
TableInputFormat.setProjection(JobContext, ZebraProjection)
instead.
BasicTableOutputFormat.setStorageInfo(JobConf, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
BasicTableOutputFormat.setStorageInfo(JobContext, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
BasicTableOutputFormat.setStorageInfo(JobConf, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
BasicTableOutputFormat.setStorageInfo(JobConf, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
BasicTableOutputFormat.setStorageInfo(JobContext, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
BasicTableOutputFormat.setStorageInfo(JobContext, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
HandleSpec
.
BasicTableOutputFormat.setStorageInfo(JobConf, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
BasicTableOutputFormat.setStorageInfo(JobContext, ZebraSchema, ZebraStorageHint, ZebraSortInfo)
instead.
StoreFunc
which it can use to store
information in the UDFContext
which it needs to store between
various method invocations in the front end and back end.
StoreFuncInterface
which it can use to store
information in the UDFContext
which it needs to store between
various method invocations in the front end and back end.
LoadFunc
.
Math.signum(double)
.Math.sin(double)
.SIN
Math.sinh(double)
.SINH
UDFContext
instead in the following way to get
the job's Configuration
:
UdfContext.getUdfContext().getJobConf()
UDFContext
instead in the following way to get
the job's Configuration
:
UdfContext.getUdfContext().getJobConf()
SortInfo
STRSPLIT
Math.sqrt(double)
.SQRT
PigStorage
and streaming class PigStreaming
StreamingCommand
represents the specification of an external
command to be executed in a Pig Query.StreamingCommand
with the given command.
StreamingCommand.Handle
to communicate
with the external process.StreamingCommand.HandleSpec
with a given name using the default
PigStorage
serializer/deserializer.
StreamingCommand.HandleSpec
with a given name using the default
PigStorage
serializer/deserializer.
Tuple
.CONCAT
.MAX
.MIN
.SIZE
.SUBSTRING
InputFormat
class for reading one or more
BasicTables.Math.tan(double)
.TAN
Math.tanh(double)
.TANH
Text
to a Tuple
InterRecordWriter
It
uses the default InterSedes object for deserialization.InterRecordWriter
It uses the default InterSedes object for serialization.TOBAG
Math.toDegrees(double)
.TOP
Math.toRadians(double)
.TOTUPLE
TRIM
SIZE
.DataType
.
UCFIRST
Math.ulp(double)
.PigStats.JobGraph
of the PigStats
.
UPPER
RegexExpression
expects CharArray as input
Itself always returns Boolean
IOException
did not have a constructor which took a
Throwable
argument. Since Pig code is now compiled with Java 1.6 and
EvalFunc
and LoadFunc
user implementations should also use
Java 1.6, they can use IOException
instead. From Java 1.6,
IOException
has constructors which take a Throwable
argument.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |