|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
Math.abs(double) for computing the
absolute value of the argument.ABSTuple
with an empty column family and doesn't group column families together on
read (creates on Map for all columns)
Math.acos(double) for computing the
arc cosine of value of the argument.ACOSStreamingCommand.HandleSpec to a given StreamingCommand.Handle
GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to add a
value.
E in the process.
SIZE instead.Math.asin(double) for computing the
arc sine of value of the argument.ASINMath.atan(double) for computing the
arc tangent of value of the argument.ATANMath.atan2(double,double).FSDataInputStream to SeekableInput.SIZE.BaseAVG.MAX.MIN.SUM.AVG.MAX.MIN.SUM.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
-
- 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
-
- 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
-
- BooleanSchema -
Static variable in class org.apache.pig.piggybank.storage.avro.AvroStorageUtils
-
- 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
-
- 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.LimitOptimizer
-
- buildPattern() -
Method in class org.apache.pig.newplan.logical.rules.LoadTypeCastInserter
-
- 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.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
-
- BytesSchema -
Static variable in class org.apache.pig.piggybank.storage.avro.AvroStorageUtils
-
- 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
-
Math.cbrt(double) for computing the
cube root of the argument.CBRTMath.ceil(double).CEILObject.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)
and StoreFunc.cleanupOnSuccess(String, Job).
StoreFunc.
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.containsGenericUnion(Schema) and it recursively checks
whether the input schema contains generic unions.
AvroStorageUtils.containsRecursiveRecord(Schema) and it recursively checks
whether the input schema contains recursive records.
Math.copySign(double,double).CORMath.cos(double).COSMath.cosh(double).COSHCOVExecutableManager depending on the ExecType.
InputHandler for the given input specification
of the StreamingCommand.
OutputHandler for the given output specification
of the StreamingCommand.
MAX.MAX.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_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_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_DELIMITERS -
Static variable in class org.apache.pig.impl.util.StorageUtil
-
- DEFAULT_EXTENSION -
Static variable in class org.apache.pig.piggybank.storage.hiverc.HiveRCOutputFormat
-
- 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_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(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.
- DEFLATE_CODEC -
Static variable in class org.apache.pig.piggybank.storage.avro.PigAvroOutputFormat
- The deflate codec
- 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
-
- 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
-
- depthFirstPP(Element) -
Method in class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.XMLPhysicalPlanPrinter
-
- depthFirstSearchForFile(FileStatus[], FileSystem) -
Method in class org.apache.pig.builtin.AvroStorage
- 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
-
- destroy() -
Method in class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigHadoopLogger
-
- destroy() -
Method in class org.apache.pig.tools.pigstats.PigStatusReporter
-
- 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
-
- 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.
- 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
-
- 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.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
-
- 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.
- doubleColonsToDoubleUnderscores -
Variable in class org.apache.pig.builtin.AvroStorage
-
- 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
-
- 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.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.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.
- 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
-
- 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.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
-
- 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
-
- 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
-
tuple.get(0) against tuple.get(1)
to determine if the first argument ends with the string in the second.o is a DateTimeWritable with the same
value.
o is a DoubleWritable with the same value.
ExecutableManager manages an external executable which processes data
in a Pig query.ExecutableManager.
EXPMath.expm1(double).FileLocalizer.fileExists(String, PigContext) instead
PColFilterExtractor
We traverse the expression plan bottom up and separate it into two plans
- pushdownExprPlan, plan that can be pushed down to the loader and
- filterExprPlan, remaining plan that needs to be evaluated by pigByteArrayOutputStream.FloatAbsAVG.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).FloatRoundMath.signum(float).SUM.Math.ulp(float).Math.floor(double).FLOORPig
MRPigStatsUtil.FS_COUNTER_GROUP instead.
FileLocalizer.fullPath(String, PigContext) instead
Function and
ExceptionalFunction.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.
MRJobStats.getAvgMapTime() instead.
MRJobStats.getAvgREduceTime() instead.
StreamingCommand for this StreamSpec.
StreamingCommand for the given alias.
PigContext.getProperties() instead
PigStatusReporter.incrCounter(java.lang.Enum, long) instead.
This method returns MR counter which is not compatible with Tez mode. Use
incrCounter() that is compatible with both MR and Tez mode.
PigStatusReporter.incrCounter(java.lang.Enum, long) instead.
This method returns MR counter which is not compatible with Tez mode. Use
incrCounter() that is compatible with both MR and Tez mode.
PigException
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
MRJobStats.getHadoopCounters() instead.
Handle.
EvalFunc to get the input
schema of the EvalFunc
StreamingCommand.
InputType
MRJobStats.getMapInputRecords() instead.
MRJobStats.getMapOutputRecords() instead.
LoadMetadata#getPartitionKeys(String, org.apache.hadoop.conf.Configuration).
MRJobStats.getMaxMapTime() instead.
MRJobStats.getMaxReduceTime() instead.
MRJobStats.getMinMapTime() instead.
MRJobStats.getMinReduceTime() instead.
MRJobStats.getMultiInputCounters() instead.
POStore
MRJobStats.getMultiStoreCounters() instead.
HandleSpec.
Tuple of the managed process.
MRJobStats.getNumberMaps() instead.
MRJobStats.getNumberReduces() instead.
LogicalRelationalOperators present in the
pig script.
StreamingCommand.
OutputType.
PigStats after the script is run.
MRJobStats.getProactiveSpillCountObjects() instead.
MRJobStats.getProactiveSpillCountRecs() instead.
MRJobStats.getReduceInputRecords() instead.
MRJobStats.getReduceOutputRecords() instead.
PigRunner.ReturnCode
AvroStorage.getAvroSchema(java.util.Set, org.apache.hadoop.conf.Configuration) .
#getAvroSchema.
Schema#toString.
EvalFunc.SchemaType of the EvalFunc.
MRJobStats.getSMMSpillCount() instead.
SpillableMemoryManager.
HandleSpec.
contextSignature.
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).IndexedStorage is a form of PigStorage that supports a
per record seek.io.file.buffer.size specified in the given
Configuration.
IndexManager manages the index file (both writing and reading)
It keeps track of the last index read during reading.INDEXOFDataByteArray.set(byte[]).
InputHandler is responsible for handling the input to the
Pig-Streaming external command.PigAvroDatumWriter.resolveUnionSchema(Schema,Object),
PigAvroDatumWriter.unwrappedInstanceOf(Schema,Object).
-Dpig.notification.listener=MyClass
-Dpig.notification.listener.arg=myConstructorStringArg
This method will properly initialize the class with the args, if they exist.
Math.abs(int) for computing the
absolute value of the argument.IntAbsAVG.InterRecordWriter
It uses the default InterSedes object for deserialization.InterRecordWriter
It uses the default InterSedes object for serialization.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.SUM.FileLocalizer.isDirectory(String, PigContext) instead.
FileLocalizer.isFile(String, PigContext) instead
FetchablePlanVisitor and checks whether the
plan is fetchable.
JsonStorage.ScriptEngine implementation for JavaScript
A = load 'mydata' as (name);
B = foreach A generate LASTINDEXOF(name, ",");
LAST_INDEX_OFLCFIRSTMath.log(double).LOGMath.log10(double).LOG10Math.log1p(double).LongAbsAVG.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
-
- LORank - Class in org.apache.pig.newplan.logical.relational
- RANK operator implementation.
- LORank(OperatorPlan) -
Constructor for class org.apache.pig.newplan.logical.relational.LORank
-
- LORank(OperatorPlan, List<LogicalExpressionPlan>, List<Boolean>) -
Constructor for class org.apache.pig.newplan.logical.relational.LORank
-
- 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, FileSpec, StoreFuncInterface, String) -
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
-
- LOStream.CastState - Enum in org.apache.pig.newplan.logical.relational
-
- 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.
- 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
-
- LTRIM - Class in org.apache.pig.builtin
- Returns a string, with only leading whitespace omitted.
- LTRIM() -
Constructor for class org.apache.pig.builtin.LTRIM
-
SIZE.Math.max(double,double).Math.min(double,double).MROpPlanVisitor that gathers the paths for all
intermediate data from a MROperPlanMath.nextAfter(double,double).Math.nextUp(double).FileLocalizer.open(String, PigContext) instead
OutputHandler is responsible for handling the output of the
Pig-Streaming external command.OutputSchema to
tell Pig what the expected output is.StoreFunc should implement this interface to enable overwriting its
store/output location if it already exists.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.
PigCommandFilter.validate(Command) method to operate on itPigException
class.PigRunner.OperatorPlan whose members are JobStatsPigStreamingBase.Tuple to a byte array.PigStreamingBaseMath.pow(double,double).OutputStream in the
field-delimited form.
Tuple to the managed executable.
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.
Matching strategy:
Try to only match the first sequence by using Matcher.find() instead of
Matcher.matches() (default useMatches=false).
DEFINE NON_GREEDY_EXTRACT REGEX_EXTRACT('true');
String RegexExtractAll(String expression, String regex).
Input:
expression-source string.
regex-regular expression.
Output:
A tuple of matched strings.
Matching strategy:
Trying to match the entire input by using Matcher.matches() instead of
Matcher.find() (default useMatches=true).
DEFINE GREEDY_EXTRACT REGEX_EXTRACT_ALL('false');
REGEX_EXTRACTREGEX_EXTRACT_ALLint RegexMatch(String expression, String regex).
Output:
return 1 if expression contains regex, 0 otherwise.
SpillableMemoryManager themselves.
Register a bag with the
SpillableMemoryManager.
If the bags created by an implementation of BagFactory are managed by
the SpillableMemoryManager then this
method should be called each time a new bag is created.
Pig
Pig
REPLACESchema
LogicalSchema
Schema.FieldSchema as the template.
LogicalSchema.LogicalFieldSchema as the template.
Math.rint(double).Math.round(double).ROUNDUtils.getSchemaFromString(java.lang.String).
ExecutableManager.
Math.scalb(double,int).Pig
StreamingCommand.
StreamingCommand.
FuncSpec that performs the casting functionality
StreamingCommand.
ResourceStatistics.setSizeInBytes(Long) instead
HandleSpec.
StreamingCommand.
HandleSpec.
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.
EvalFunc.
LoadFunc.
PigOutputFormat.checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext) and InputOutputFileValidator#validate) and to delete the existing output.
Math.signum(double).Math.sin(double).SINMath.sinh(double).SINHUDFContext 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()
SortInfoSTRSPLITMath.sqrt(double).SQRTScriptState.start(ScriptState) instead.
tuple.get(0) against tuple.get(1)
to determine if the first argument starts with the string in the second.PigStorage and streaming class PigStreamingStreamingCommand 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.
PigStreamingBaseCONCAT.MAX.MIN.SIZE.SUBSTRINGMath.tan(double).TANMath.tanh(double).TANHMRPigStatsUtil.TASK_COUNTER_GROUP instead.
Text to a Tuple
InterRecordWriter It
uses the default InterSedes object for deserialization.InterRecordWriter
It uses the default InterSedes object for serialization.TOBAGToDate.ToDate.ToDate.Math.toDegrees(double).TOPMath.toRadians(double).TOTUPLETRIMSIZE.DataType.
UCFIRSTMath.ulp(double).PigStats.JobGraph of the PigStats.
UPPERPigCommandFilter.Command.
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 | |||||||||