Uses of Interface
org.apache.pig.data.Tuple

Packages that use Tuple

org.apache.hadoop.zebra.io	Physical I/O management of Hadoop Zebra Tables.
org.apache.hadoop.zebra.mapred	Providing InputFormat and OutputFormat adaptor classes for Hadoop Zebra Table.
org.apache.hadoop.zebra.mapreduce	Providing InputFormat and OutputFormat adaptor classes for Hadoop Zebra Table.
org.apache.hadoop.zebra.pig	Implementation of PIG Storer/Loader Interfaces
org.apache.hadoop.zebra.pig.comparator	Utilities to allow PIG Storer to generate keys for sorted Zebra tables
org.apache.hadoop.zebra.types	Data types being shared between the io and mapred packages.
org.apache.pig	Public interfaces and classes for Pig.
org.apache.pig.backend.executionengine
org.apache.pig.backend.hadoop.executionengine
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
org.apache.pig.backend.hadoop.executionengine.physicalLayer	Implementation of physical operators that use hadoop as the execution engine and data storage.
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators
org.apache.pig.backend.hadoop.executionengine.physicalLayer.util
org.apache.pig.backend.hadoop.hbase
org.apache.pig.builtin	This package contains builtin Pig UDFs.
org.apache.pig.data	This package contains implementations of Pig specific data types as well as support functions for reading, writing, and using all Pig data types.
org.apache.pig.impl.builtin
org.apache.pig.impl.io
org.apache.pig.impl.streaming
org.apache.pig.impl.util
org.apache.pig.pen
org.apache.pig.pen.util
org.apache.pig.piggybank.evaluation
org.apache.pig.piggybank.evaluation.datetime
org.apache.pig.piggybank.evaluation.datetime.convert
org.apache.pig.piggybank.evaluation.datetime.diff
org.apache.pig.piggybank.evaluation.datetime.truncate
org.apache.pig.piggybank.evaluation.decode
org.apache.pig.piggybank.evaluation.math
org.apache.pig.piggybank.evaluation.stats
org.apache.pig.piggybank.evaluation.string
org.apache.pig.piggybank.evaluation.util
org.apache.pig.piggybank.evaluation.util.apachelogparser
org.apache.pig.piggybank.storage
org.apache.pig.piggybank.storage.avro
org.apache.pig.piggybank.storage.hiverc
org.apache.pig.scripting.js
org.apache.pig.scripting.jython
org.apache.pig.tools.pigstats

Uses of Tuple in org.apache.hadoop.zebra.io

Methods in org.apache.hadoop.zebra.io with parameters of type Tuple

void	TableScanner.getValue(Tuple row) Get the row.
void	TableInserter.insert(org.apache.hadoop.io.BytesWritable key, Tuple row) Insert a new row into the table.

Uses of Tuple in org.apache.hadoop.zebra.mapred

Methods in org.apache.hadoop.zebra.mapred that return Tuple

Tuple

TableRecordReader.createValue() Deprecated.

Methods in org.apache.hadoop.zebra.mapred that return types with arguments of type Tuple

org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>	TableInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.mapred.Reporter reporter) Deprecated.
org.apache.hadoop.mapred.RecordWriter<org.apache.hadoop.io.BytesWritable,Tuple>	BasicTableOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignored, org.apache.hadoop.mapred.JobConf conf, String name, org.apache.hadoop.util.Progressable progress) Deprecated.

Methods in org.apache.hadoop.zebra.mapred with parameters of type Tuple

abstract int	ZebraOutputPartition.getOutputPartition(org.apache.hadoop.io.BytesWritable key, Tuple Value)
static org.apache.hadoop.io.BytesWritable	BasicTableOutputFormat.getSortKey(Object builder, Tuple t) Deprecated. Generates a BytesWritable key for the input key using keygenerate provided.
boolean	TableRecordReader.next(org.apache.hadoop.io.BytesWritable key, Tuple value) Deprecated.

Uses of Tuple in org.apache.hadoop.zebra.mapreduce

Methods in org.apache.hadoop.zebra.mapreduce that return Tuple

Tuple

TableRecordReader.getCurrentValue()

Methods in org.apache.hadoop.zebra.mapreduce that return types with arguments of type Tuple

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.BytesWritable,Tuple>	TableInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext taContext)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.BytesWritable,Tuple>	BasicTableOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext taContext)

Methods in org.apache.hadoop.zebra.mapreduce with parameters of type Tuple

abstract int	ZebraOutputPartition.getOutputPartition(org.apache.hadoop.io.BytesWritable key, Tuple Value)
static org.apache.hadoop.io.BytesWritable	BasicTableOutputFormat.getSortKey(Object builder, Tuple t) Generates a BytesWritable key for the input key using keygenerate provided.

Uses of Tuple in org.apache.hadoop.zebra.pig

Methods in org.apache.hadoop.zebra.pig that return Tuple

Tuple

TableLoader.getNext()

Methods in org.apache.hadoop.zebra.pig with parameters of type Tuple

void	TableStorer.putNext(Tuple tuple)
void	TableLoader.seekNear(Tuple tuple) This method is called only once.

Uses of Tuple in org.apache.hadoop.zebra.pig.comparator

Methods in org.apache.hadoop.zebra.pig.comparator with parameters of type Tuple

protected void	LeafExpr.append(org.apache.hadoop.zebra.pig.comparator.EncodingOutputStream out, Tuple tuple)
org.apache.hadoop.io.BytesWritable	KeyGenerator.generateKey(Tuple t) Generate the binary key for the input tuple

Uses of Tuple in org.apache.hadoop.zebra.types

Classes in org.apache.hadoop.zebra.types that implement Tuple

class

ZebraTuple Zebra's implementation of Pig's Tuple.

Methods in org.apache.hadoop.zebra.types that return Tuple

static Tuple	TypesUtils.createTuple(int size) create a tuple based on number of columns
static Tuple	TypesUtils.createTuple(Schema schema) Create a tuple based on a schema

Methods in org.apache.hadoop.zebra.types with parameters of type Tuple

static void	TypesUtils.checkCompatible(Tuple tuple, Schema schema) Check whether the input row object is compatible with the expected schema
static void	TypesUtils.checkNumberColumnCompatible(Tuple tuple, Schema schema) Check whether the input row object is compatible with the expected schema on number of Columns;
static void	TypesUtils.formatTuple(Tuple tuple, int ncols) Checking and formatting an input tuple to conform to the input schema. The current implementation always create a new tuple because PIG expects Slice.next(tuple) always returning a brand new tuple.
void	TypesUtils.TupleReader.get(DataInputStream in, Tuple row) Read a tuple from the stream, and perform projection.
void	Partition.insert(org.apache.hadoop.io.BytesWritable key, Tuple t) insert a tuple after splits
void	TypesUtils.TupleWriter.put(DataOutputStream out, Tuple row) Write a tuple to the output stream.
void	Partition.read(Tuple t) read in a tuple based on stitches
static void	TypesUtils.resetTuple(Tuple tuple) Reset the Tuple so that all fields are NULL field.
void	Partition.setSource(Tuple[] tuples) sets the source tuple for the column group ops

Uses of Tuple in org.apache.pig

Methods in org.apache.pig that return Tuple

Tuple	LoadCaster.bytesToTuple(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) Cast data from bytearray to tuple value.
Tuple	StreamToPig.deserialize(byte[] bytes) Given a byte array from a streaming executable, produce a tuple.
abstract Tuple	LoadFunc.getNext() Retrieves the next tuple to be processed.

Methods in org.apache.pig that return types with arguments of type Tuple

Iterator<Tuple>

PigServer.openIterator(String id) Executes a Pig Latin script up to and including indicated alias.

Methods in org.apache.pig with parameters of type Tuple

void	Accumulator.accumulate(Tuple b) Pass tuples to the UDF.
abstract int	ComparisonFunc.compare(Tuple t1, Tuple t2) Deprecated. This callback method must be implemented by all subclasses.
abstract T	EvalFunc.exec(Tuple input) This callback method must be implemented by all subclasses.
void	StoreFuncInterface.putNext(Tuple t) Write a tuple to the data store.
abstract void	StoreFunc.putNext(Tuple t) Write a tuple to the data store.
void	IndexableLoadFunc.seekNear(Tuple keys) This method is called by the Pig runtime to indicate to the LoadFunc to position its underlying input stream near the keys supplied as the argument.
byte[]	PigToStream.serialize(Tuple t) Given a tuple, produce an array of bytes to be passed to the streaming executable.
byte[]	StoreCaster.toBytes(Tuple t)

Uses of Tuple in org.apache.pig.backend.executionengine

Methods in org.apache.pig.backend.executionengine that return types with arguments of type Tuple

Iterator<Tuple>

ExecJob.getResults() if query has executed successfully we want to retrieve the results via iterating over them.

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine

Methods in org.apache.pig.backend.hadoop.executionengine that return types with arguments of type Tuple

Iterator<Tuple>

HJob.getResults()

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that return Tuple

Tuple	PigRecordReader.getCurrentValue()
Tuple	MergeJoinIndexer.getNext()

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer that return types with arguments of type Tuple

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple>	PigInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>	PigTextOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext job)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>	PigOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext taskattemptcontext)

Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type Tuple

void	PigMapOnly.Map.collect(Context oc, Tuple tuple)
void	PigGenericMapReduce.Map.collect(org.apache.hadoop.mapreduce.Mapper.Context oc, Tuple tuple)
void	PigGenericMapReduce.MapWithComparator.collect(org.apache.hadoop.mapreduce.Mapper.Context oc, Tuple tuple)
void	PigGenericMapReduce.MapWithPartitionIndex.collect(org.apache.hadoop.mapreduce.Mapper.Context oc, Tuple tuple)
abstract void	PigGenericMapBase.collect(org.apache.hadoop.mapreduce.Mapper.Context oc, Tuple tuple)
protected void	PigGenericMapBase.map(org.apache.hadoop.io.Text key, Tuple inpTuple, org.apache.hadoop.mapreduce.Mapper.Context context) The map function that attaches the inpTuple appropriately and executes the map plan if its not empty.
void	PigTextOutputFormat.PigLineRecordWriter.write(org.apache.hadoop.io.WritableComparable key, Tuple value)
void	PigOutputFormat.PigRecordWriter.write(org.apache.hadoop.io.WritableComparable key, Tuple value) We only care about the values, so we are going to skip the keys when we write.

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine.physicalLayer

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer declared as Tuple

protected static Tuple	PhysicalOperator.dummyTuple
protected Tuple	PhysicalOperator.input

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer with parameters of type Tuple

void	PhysicalOperator.attachInput(Tuple t) Shorts the input path of this operator by providing the input tuple directly
Result	PhysicalOperator.getNext(Tuple t)

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators that return Tuple

Tuple	UnaryComparisonOperator.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POUserFunc.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POUserComparisonFunc.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POProject.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	PONegative.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POMapLookUp.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POCast.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POBinCond.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	ConstantExpression.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	BinaryExpressionOperator.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	BinaryComparisonOperator.illustratorMarkup(Object in, Object out, int eqClassIndex)

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators with parameters of type Tuple

protected Result	ExpressionOperator.accumChild(List<ExpressionOperator> child, Tuple t) Drive all the UDFs in accumulative mode
void	POProject.attachInput(Tuple t) Overridden since the attachment of the new input should cause the old processing to end.
void	POBinCond.attachInput(Tuple t)
void	POUserComparisonFunc.attachInput(Tuple t1, Tuple t2)
Result	POUserFunc.getNext(Tuple tIn)
Result	POUserComparisonFunc.getNext(Tuple in)
Result	POProject.getNext(Tuple t) Asked for Tuples.
Result	POMapLookUp.getNext(Tuple t)
Result	POCast.getNext(Tuple t)
Result	POBinCond.getNext(Tuple t)
Result	ConstantExpression.getNext(Tuple t)
Result	ComparisonOperator.getNext(Tuple t)

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans with parameters of type Tuple

void	PhysicalPlan.attachInput(Tuple t)

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Fields in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators declared as Tuple

protected Tuple	POForEach.inpTuple
protected Tuple	POPackage.keyAsTuple
protected Tuple	POLocalRearrange.mFakeTuple

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return Tuple

protected Tuple	POLocalRearrange.constructLROutput(List<Result> resLst, List<Result> secondaryResLst, Tuple value)
protected Tuple	POPreCombinerLocalRearrange.constructLROutput(List<Result> resLst, Tuple value)
protected Tuple	POCollectedGroup.constructOutput(List<Result> resLst, Tuple value)
protected Tuple	POForEach.createTuple(Object[] data)
Tuple	POPackageLite.getKeyAsTuple()
protected Tuple	POPackage.getValueTuple(NullableTuple ntup, int index)
Tuple	POPackageLite.getValueTuple(NullableTuple ntup, int index, Object key) Makes use of the superclass method, but this requires an additional parameter key passed by ReadOnceBag.
Tuple	POUnion.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POStream.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POStore.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POSplit.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POSort.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POSkewedJoin.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POPreCombinerLocalRearrange.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POPackageLite.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POPackage.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	PONative.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POMergeJoin.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POMergeCogroup.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POLocalRearrange.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POLoad.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POLimit.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POGlobalRearrange.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POFRJoin.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POForEach.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POFilter.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	PODistinct.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	PODemux.illustratorMarkup(Object in, Object out, int eqClassIndex)
Tuple	POCollectedGroup.illustratorMarkup(Object in, Object out, int eqClassIndex)

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return types with arguments of type Tuple

Iterator<Tuple>

AccumulativeTupleBuffer.getTuples(int index) Get iterator of tuples in the buffer

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type Tuple

void	POPreCombinerLocalRearrange.attachInput(Tuple t) Overridden since the attachment of the new input should cause the old processing to end.
void	POLocalRearrange.attachInput(Tuple t) Overridden since the attachment of the new input should cause the old processing to end.
void	POCollectedGroup.attachInput(Tuple t) Overridden since the attachment of the new input should cause the old processing to end.
protected void	POForEach.attachInputToPlans(Tuple t)
int	POSort.SortComparator.compare(Tuple o1, Tuple o2)
int	POSort.UDFSortComparator.compare(Tuple t1, Tuple t2)
protected Tuple	POLocalRearrange.constructLROutput(List<Result> resLst, List<Result> secondaryResLst, Tuple value)
protected Tuple	POPreCombinerLocalRearrange.constructLROutput(List<Result> resLst, Tuple value)
protected Tuple	POCollectedGroup.constructOutput(List<Result> resLst, Tuple value)
protected DataBag	POPartitionRearrange.constructPROutput(List<Result> resLst, Tuple value)
Result	POUnion.getNext(Tuple t) The code below, tries to follow our single threaded shared execution model with execution being passed around each non-drained input
Result	POStream.getNext(Tuple t)
Result	POStore.getNext(Tuple t)
Result	POSplit.getNext(Tuple t)
Result	POSortedDistinct.getNext(Tuple t)
Result	POSort.getNext(Tuple t)
Result	POPreCombinerLocalRearrange.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan.
Result	POPartitionRearrange.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan.
Result	POPackageLite.getNext(Tuple t) Similar to POPackage.getNext except that only one input is expected with index 0 and ReadOnceBag is used instead of DefaultDataBag.
Result	POPackage.getNext(Tuple t) From the inputs, constructs the output tuple for this co-group in the required format which is (key, {bag of tuples from input 1}, {bag of tuples from input 2}, ...)
Result	POOptimizedForEach.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
Result	POMultiQueryPackage.getNext(Tuple t) Constructs the output tuple from the inputs.
Result	POMergeJoin.getNext(Tuple t)
Result	POMergeCogroup.getNext(Tuple t)
Result	POLocalRearrange.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan.
Result	POLoad.getNext(Tuple t) The main method used by this operator's successor to read tuples from the specified file using the specified load function.
Result	POLimit.getNext(Tuple t) Counts the number of tuples processed into static variable soFar, if the number of tuples processed reach the limit, return EOP; Otherwise, return the tuple
Result	POJoinPackage.getNext(Tuple t) Calls getNext to get next ForEach result.
Result	POGlobalRearrange.getNext(Tuple t)
Result	POFRJoin.getNext(Tuple t)
Result	POForEach.getNext(Tuple t) Calls getNext on the generate operator inside the nested physical plan and returns it maintaining an additional state to denote the begin and end of the nested plan processing.
Result	POFilter.getNext(Tuple t) Attaches the proccesed input tuple to the expression plan and checks if comparison operator returns a true.
Result	PODistinct.getNext(Tuple t)
Result	PODemux.getNext(Tuple t)
Result	POCombinerPackage.getNext(Tuple t)
Result	POCollectedGroup.getNext(Tuple t)
Result	POStream.getNextHelper(Tuple t)

Constructors in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type Tuple

POFRJoin(OperatorKey k, int rp, List<PhysicalOperator> inp, List<List<PhysicalPlan>> ppLists, List<List<Byte>> keyTypes, FileSpec[] replFiles, int fragment, boolean isLeftOuter, Tuple nullTuple)

Uses of Tuple in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util

Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.util with parameters of type Tuple

Object

MonitoredUDFExecutor.monitorExec(Tuple input)

Uses of Tuple in org.apache.pig.backend.hadoop.hbase

Methods in org.apache.pig.backend.hadoop.hbase that return Tuple

Tuple	HBaseBinaryConverter.bytesToTuple(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema) NOT IMPLEMENTED
Tuple	HBaseStorage.getNext()

Methods in org.apache.pig.backend.hadoop.hbase with parameters of type Tuple

void	HBaseStorage.putNext(Tuple t)
byte[]	HBaseBinaryConverter.toBytes(Tuple t) NOT IMPLEMENTED

Uses of Tuple in org.apache.pig.builtin

Methods in org.apache.pig.builtin that return Tuple

Tuple	Utf8StorageConverter.bytesToTuple(byte[] b, ResourceSchema.ResourceFieldSchema fieldSchema)
Tuple	TextLoader.bytesToTuple(byte[] b, ResourceSchema.ResourceFieldSchema schema) TextLoader does not support conversion to Tuple
protected static Tuple	LongAvg.combine(DataBag values)
protected static Tuple	IntAvg.combine(DataBag values)
protected static Tuple	FloatAvg.combine(DataBag values)
protected static Tuple	DoubleAvg.combine(DataBag values)
protected static Tuple	COV.combine(DataBag values) combine results of different data chunk
protected static Tuple	COR.combine(DataBag values) combine results of different data chunk
protected static Tuple	AVG.combine(DataBag values)
protected static Tuple	COV.computeAll(DataBag first, DataBag second) compute sum(XY), sum(X), sum(Y) from given data sets
protected static Tuple	COR.computeAll(DataBag first, DataBag second) compute sum(XY), sum(X), sum(Y), sum(XX), sum(YY) from given data sets
Tuple	PigStreaming.deserialize(byte[] bytes)
Tuple	TOTUPLE.exec(Tuple input)
Tuple	TOP.Initial.exec(Tuple tuple)
Tuple	TOP.Intermed.exec(Tuple input)
Tuple	SUM.Initial.exec(Tuple input)
Tuple	SUM.Intermediate.exec(Tuple input)
Tuple	STRSPLIT.exec(Tuple input) Wrapper around Java's String.split
Tuple	StringMin.Initial.exec(Tuple input)
Tuple	StringMin.Intermediate.exec(Tuple input)
Tuple	StringMax.Initial.exec(Tuple input)
Tuple	StringMax.Intermediate.exec(Tuple input)
Tuple	REGEX_EXTRACT_ALL.exec(Tuple input)
Tuple	MIN.Initial.exec(Tuple input)
Tuple	MIN.Intermediate.exec(Tuple input)
Tuple	MAX.Initial.exec(Tuple input)
Tuple	MAX.Intermediate.exec(Tuple input)
Tuple	LongSum.Initial.exec(Tuple input)
Tuple	LongSum.Intermediate.exec(Tuple input)
Tuple	LongMin.Initial.exec(Tuple input)
Tuple	LongMin.Intermediate.exec(Tuple input)
Tuple	LongMax.Initial.exec(Tuple input)
Tuple	LongMax.Intermediate.exec(Tuple input)
Tuple	LongAvg.Initial.exec(Tuple input)
Tuple	LongAvg.Intermediate.exec(Tuple input)
Tuple	IntSum.Initial.exec(Tuple input)
Tuple	IntSum.Intermediate.exec(Tuple input)
Tuple	IntMin.Initial.exec(Tuple input)
Tuple	IntMin.Intermediate.exec(Tuple input)
Tuple	IntMax.Initial.exec(Tuple input)
Tuple	IntMax.Intermediate.exec(Tuple input)
Tuple	IntAvg.Initial.exec(Tuple input)
Tuple	IntAvg.Intermediate.exec(Tuple input)
Tuple	FloatSum.Initial.exec(Tuple input)
Tuple	FloatSum.Intermediate.exec(Tuple input)
Tuple	FloatMin.Initial.exec(Tuple input)
Tuple	FloatMin.Intermediate.exec(Tuple input)
Tuple	FloatMax.Initial.exec(Tuple input)
Tuple	FloatMax.Intermediate.exec(Tuple input)
Tuple	FloatAvg.Initial.exec(Tuple input)
Tuple	FloatAvg.Intermediate.exec(Tuple input)
Tuple	DoubleSum.Initial.exec(Tuple input)
Tuple	DoubleSum.Intermediate.exec(Tuple input)
Tuple	DoubleMin.Initial.exec(Tuple input)
Tuple	DoubleMin.Intermediate.exec(Tuple input)
Tuple	DoubleMax.Initial.exec(Tuple input)
Tuple	DoubleMax.Intermediate.exec(Tuple input)
Tuple	DoubleAvg.Initial.exec(Tuple input)
Tuple	DoubleAvg.Intermediate.exec(Tuple input)
Tuple	Distinct.Initial.exec(Tuple input)
Tuple	Distinct.Intermediate.exec(Tuple input)
Tuple	COV.Initial.exec(Tuple input)
Tuple	COV.Intermed.exec(Tuple input)
Tuple	COUNT_STAR.Initial.exec(Tuple input)
Tuple	COUNT_STAR.Intermediate.exec(Tuple input)
Tuple	COUNT.Initial.exec(Tuple input)
Tuple	COUNT.Intermediate.exec(Tuple input)
Tuple	COR.Initial.exec(Tuple input)
Tuple	COR.Intermed.exec(Tuple input)
Tuple	AVG.Initial.exec(Tuple input)
Tuple	AVG.Intermediate.exec(Tuple input)
Tuple	TextLoader.getNext()
Tuple	PigStorage.getNext()
Tuple	BinStorage.getNext()

Methods in org.apache.pig.builtin with parameters of type Tuple

void	SUM.accumulate(Tuple b)
void	StringMin.accumulate(Tuple b)
void	StringMax.accumulate(Tuple b)
void	MIN.accumulate(Tuple b)
void	MAX.accumulate(Tuple b)
void	LongSum.accumulate(Tuple b)
void	LongMin.accumulate(Tuple b)
void	LongMax.accumulate(Tuple b)
void	LongAvg.accumulate(Tuple b)
void	IntSum.accumulate(Tuple b)
void	IntMin.accumulate(Tuple b)
void	IntMax.accumulate(Tuple b)
void	IntAvg.accumulate(Tuple b)
void	FloatSum.accumulate(Tuple b)
void	FloatMin.accumulate(Tuple b)
void	FloatMax.accumulate(Tuple b)
void	FloatAvg.accumulate(Tuple b)
void	DoubleSum.accumulate(Tuple b)
void	DoubleMin.accumulate(Tuple b)
void	DoubleMax.accumulate(Tuple b)
void	DoubleAvg.accumulate(Tuple b)
void	COUNT_STAR.accumulate(Tuple b)
void	COUNT.accumulate(Tuple b)
void	AVG.accumulate(Tuple b)
protected static long	LongAvg.count(Tuple input)
protected static long	IntAvg.count(Tuple input)
protected static long	FloatAvg.count(Tuple input)
protected static long	DoubleAvg.count(Tuple input)
protected static long	AVG.count(Tuple input)
String	UPPER.exec(Tuple input) Upper-cases an input string.
String	UCFIRST.exec(Tuple input)
Long	TupleSize.exec(Tuple input)
String	TRIM.exec(Tuple input)
Tuple	TOTUPLE.exec(Tuple input)
DataBag	TOP.exec(Tuple tuple)
Tuple	TOP.Initial.exec(Tuple tuple)
Tuple	TOP.Intermed.exec(Tuple input)
DataBag	TOP.Final.exec(Tuple tuple)
Map	TOMAP.exec(Tuple input)
DataBag	TOKENIZE.exec(Tuple input)
DataBag	TOBAG.exec(Tuple input)
Double	SUM.exec(Tuple input)
Tuple	SUM.Initial.exec(Tuple input)
Tuple	SUM.Intermediate.exec(Tuple input)
Double	SUM.Final.exec(Tuple input)
String	SUBSTRING.exec(Tuple input) Method invoked on every tuple during foreach evaluation
Tuple	STRSPLIT.exec(Tuple input) Wrapper around Java's String.split
Long	StringSize.exec(Tuple input)
String	StringMin.exec(Tuple input)
Tuple	StringMin.Initial.exec(Tuple input)
Tuple	StringMin.Intermediate.exec(Tuple input)
String	StringMin.Final.exec(Tuple input)
String	StringMax.exec(Tuple input)
Tuple	StringMax.Initial.exec(Tuple input)
Tuple	StringMax.Intermediate.exec(Tuple input)
String	StringMax.Final.exec(Tuple input)
String	StringConcat.exec(Tuple input)
Long	SIZE.exec(Tuple input)
Long	ROUND.exec(Tuple input) java level API
String	REPLACE.exec(Tuple input) Method invoked on every tuple during foreach evaluation
Tuple	REGEX_EXTRACT_ALL.exec(Tuple input)
String	REGEX_EXTRACT.exec(Tuple input)
Double	RANDOM.exec(Tuple input)
Double	MIN.exec(Tuple input)
Tuple	MIN.Initial.exec(Tuple input)
Tuple	MIN.Intermediate.exec(Tuple input)
Double	MIN.Final.exec(Tuple input)
Double	MAX.exec(Tuple input)
Tuple	MAX.Initial.exec(Tuple input)
Tuple	MAX.Intermediate.exec(Tuple input)
Double	MAX.Final.exec(Tuple input)
Long	MapSize.exec(Tuple input)
String	LOWER.exec(Tuple input) Method invoked on every tuple during foreach evaluation
Long	LongSum.exec(Tuple input)
Tuple	LongSum.Initial.exec(Tuple input)
Tuple	LongSum.Intermediate.exec(Tuple input)
Long	LongSum.Final.exec(Tuple input)
Long	LongMin.exec(Tuple input)
Tuple	LongMin.Initial.exec(Tuple input)
Tuple	LongMin.Intermediate.exec(Tuple input)
Long	LongMin.Final.exec(Tuple input)
Long	LongMax.exec(Tuple input)
Tuple	LongMax.Initial.exec(Tuple input)
Tuple	LongMax.Intermediate.exec(Tuple input)
Long	LongMax.Final.exec(Tuple input)
Double	LongAvg.exec(Tuple input)
Tuple	LongAvg.Initial.exec(Tuple input)
Tuple	LongAvg.Intermediate.exec(Tuple input)
Double	LongAvg.Final.exec(Tuple input)
Long	LongAbs.exec(Tuple input) java level API
String	LCFIRST.exec(Tuple input)
Integer	LAST_INDEX_OF.exec(Tuple input) Finds the last location of a substring in a given string.
Boolean	IsEmpty.exec(Tuple input)
Long	IntSum.exec(Tuple input)
Tuple	IntSum.Initial.exec(Tuple input)
Tuple	IntSum.Intermediate.exec(Tuple input)
Long	IntSum.Final.exec(Tuple input)
Integer	IntMin.exec(Tuple input)
Tuple	IntMin.Initial.exec(Tuple input)
Tuple	IntMin.Intermediate.exec(Tuple input)
Integer	IntMin.Final.exec(Tuple input)
Integer	IntMax.exec(Tuple input)
Tuple	IntMax.Initial.exec(Tuple input)
Tuple	IntMax.Intermediate.exec(Tuple input)
Integer	IntMax.Final.exec(Tuple input)
Double	IntAvg.exec(Tuple input)
Tuple	IntAvg.Initial.exec(Tuple input)
Tuple	IntAvg.Intermediate.exec(Tuple input)
Double	IntAvg.Final.exec(Tuple input)
Integer	IntAbs.exec(Tuple input) java level API
Integer	INDEXOF.exec(Tuple input) Method invoked on every tuple during foreach evaluation
T	GenericInvoker.exec(Tuple input)
Double	FloatSum.exec(Tuple input)
Tuple	FloatSum.Initial.exec(Tuple input)
Tuple	FloatSum.Intermediate.exec(Tuple input)
Double	FloatSum.Final.exec(Tuple input)
Integer	FloatRound.exec(Tuple input) java level API
Float	FloatMin.exec(Tuple input)
Tuple	FloatMin.Initial.exec(Tuple input)
Tuple	FloatMin.Intermediate.exec(Tuple input)
Float	FloatMin.Final.exec(Tuple input)
Float	FloatMax.exec(Tuple input)
Tuple	FloatMax.Initial.exec(Tuple input)
Tuple	FloatMax.Intermediate.exec(Tuple input)
Float	FloatMax.Final.exec(Tuple input)
Double	FloatAvg.exec(Tuple input)
Tuple	FloatAvg.Initial.exec(Tuple input)
Tuple	FloatAvg.Intermediate.exec(Tuple input)
Double	FloatAvg.Final.exec(Tuple input)
Float	FloatAbs.exec(Tuple input) java level API
Double	DoubleSum.exec(Tuple input)
Tuple	DoubleSum.Initial.exec(Tuple input)
Tuple	DoubleSum.Intermediate.exec(Tuple input)
Double	DoubleSum.Final.exec(Tuple input)
Long	DoubleRound.exec(Tuple input) java level API
Double	DoubleMin.exec(Tuple input)
Tuple	DoubleMin.Initial.exec(Tuple input)
Tuple	DoubleMin.Intermediate.exec(Tuple input)
Double	DoubleMin.Final.exec(Tuple input)
Double	DoubleMax.exec(Tuple input)
Tuple	DoubleMax.Initial.exec(Tuple input)
Tuple	DoubleMax.Intermediate.exec(Tuple input)
Double	DoubleMax.Final.exec(Tuple input)
Double	DoubleBase.exec(Tuple input) java level API
Double	DoubleAvg.exec(Tuple input)
Tuple	DoubleAvg.Initial.exec(Tuple input)
Tuple	DoubleAvg.Intermediate.exec(Tuple input)
Double	DoubleAvg.Final.exec(Tuple input)
Double	DoubleAbs.exec(Tuple input) java level API
DataBag	Distinct.exec(Tuple input)
Tuple	Distinct.Initial.exec(Tuple input)
Tuple	Distinct.Intermediate.exec(Tuple input)
DataBag	Distinct.Final.exec(Tuple input)
DataBag	DIFF.exec(Tuple input) Compares a tuple with two fields.
DataBag	COV.exec(Tuple input) Function to compute covariance between data sets.
Tuple	COV.Initial.exec(Tuple input)
Tuple	COV.Intermed.exec(Tuple input)
DataBag	COV.Final.exec(Tuple input)
Long	COUNT_STAR.exec(Tuple input)
Tuple	COUNT_STAR.Initial.exec(Tuple input)
Tuple	COUNT_STAR.Intermediate.exec(Tuple input)
Long	COUNT_STAR.Final.exec(Tuple input)
Long	COUNT.exec(Tuple input)
Tuple	COUNT.Initial.exec(Tuple input)
Tuple	COUNT.Intermediate.exec(Tuple input)
Long	COUNT.Final.exec(Tuple input)
DataBag	COR.exec(Tuple input) Function to compute correlation between data sets.
Tuple	COR.Initial.exec(Tuple input)
Tuple	COR.Intermed.exec(Tuple input)
DataBag	COR.Final.exec(Tuple input)
Long	ConstantSize.exec(Tuple input)
DataByteArray	CONCAT.exec(Tuple input)
Long	BagSize.exec(Tuple input)
Double	AVG.exec(Tuple input)
Tuple	AVG.Initial.exec(Tuple input)
Tuple	AVG.Intermediate.exec(Tuple input)
Double	AVG.Final.exec(Tuple input)
Integer	ARITY.exec(Tuple input) Deprecated.
Double	ABS.exec(Tuple input) java level API
protected DataBag	Distinct.getDistinct(Tuple input)
T	Invoker.invoke(Tuple input)
protected static String	StringMax.max(Tuple input)
protected static Double	MAX.max(Tuple input)
protected static Long	LongMax.max(Tuple input)
protected static Integer	IntMax.max(Tuple input)
protected static Float	FloatMax.max(Tuple input)
protected static Double	DoubleMax.max(Tuple input)
protected static Double	MAX.maxDoubles(Tuple input)
protected static String	StringMin.min(Tuple input)
protected static Double	MIN.min(Tuple input)
protected static Long	LongMin.min(Tuple input)
protected static Integer	IntMin.min(Tuple input)
protected static Float	FloatMin.min(Tuple input)
protected static Double	DoubleMin.min(Tuple input)
protected static Double	MIN.minDoubles(Tuple input)
void	PigStorage.putNext(Tuple f)
void	BinStorage.putNext(Tuple t)
byte[]	PigStreaming.serialize(Tuple t)
protected static Double	SUM.sum(Tuple input)
protected static Long	LongSum.sum(Tuple input)
protected static Long	LongAvg.sum(Tuple input)
protected static Long	IntSum.sum(Tuple input)
protected static Long	IntAvg.sum(Tuple input)
protected static Double	FloatSum.sum(Tuple input)
protected static Double	FloatAvg.sum(Tuple input)
protected static Double	DoubleSum.sum(Tuple input)
protected static Double	DoubleAvg.sum(Tuple input)
protected static Long	COUNT_STAR.sum(Tuple input)
protected static Long	COUNT.sum(Tuple input)
protected static Double	AVG.sum(Tuple input)
protected static Double	SUM.sumDoubles(Tuple input)
protected static Double	FloatSum.sumDoubles(Tuple input)
protected static Long	IntSum.sumLongs(Tuple input)
byte[]	Utf8StorageConverter.toBytes(Tuple t)
byte[]	TextLoader.toBytes(Tuple t)
byte[]	BinStorage.toBytes(Tuple t)

Method parameters in org.apache.pig.builtin with type arguments of type Tuple

protected static void

TOP.updateTop(PriorityQueue<Tuple> store, int limit, DataBag inputBag)

Uses of Tuple in org.apache.pig.data

Classes in org.apache.pig.data that implement Tuple

class	AmendableTuple
class	BinSedesTuple This tuple has a faster (de)serialization mechanism.
static class	DefaultAbstractBag.BagDelimiterTuple
static class	DefaultAbstractBag.EndBag
static class	DefaultAbstractBag.StartBag
class	DefaultTuple A default implementation of Tuple.
class	TargetedTuple A tuple composed with the operators to which it needs be attached
class	TimestampedTuple

Fields in org.apache.pig.data declared as Tuple

static Tuple	DefaultAbstractBag.endBag
static Tuple	DefaultAbstractBag.startBag

Fields in org.apache.pig.data with type parameters of type Tuple

protected Collection<Tuple>

DefaultAbstractBag.mContents

Methods in org.apache.pig.data that return Tuple

static Tuple	DataReaderWriter.bytesToTuple(DataInput in)
abstract Tuple	TupleFactory.newTuple() Create an empty tuple.
Tuple	BinSedesTupleFactory.newTuple()
abstract Tuple	TupleFactory.newTuple(int size) Create a tuple with size fields.
Tuple	BinSedesTupleFactory.newTuple(int size)
abstract Tuple	TupleFactory.newTuple(List c) Create a tuple from the provided list of objects.
Tuple	BinSedesTupleFactory.newTuple(List c)
abstract Tuple	TupleFactory.newTuple(Object datum) Create a tuple with a single element.
Tuple	BinSedesTupleFactory.newTuple(Object datum)
abstract Tuple	TupleFactory.newTupleNoCopy(List list) Create a tuple from a provided list of objects, keeping the provided list.
Tuple	BinSedesTupleFactory.newTupleNoCopy(List list)
Tuple	TargetedTuple.toTuple()
static Tuple	DataType.toTuple(Object o) If this object is a tuple, return it as a tuple.

Methods in org.apache.pig.data that return types with arguments of type Tuple

Iterator<Tuple>	SortedDataBag.iterator()
Iterator<Tuple>	SingleTupleBag.iterator()
Iterator<Tuple>	ReadOnceBag.iterator()
Iterator<Tuple>	NonSpillableDataBag.iterator()
Iterator<Tuple>	InternalSortedBag.iterator()
Iterator<Tuple>	InternalDistinctBag.iterator()
Iterator<Tuple>	InternalCachedBag.iterator()
Iterator<Tuple>	DistinctDataBag.iterator()
Iterator<Tuple>	DefaultDataBag.iterator()
Iterator<Tuple>	DataBag.iterator() Get an iterator to the bag.
Iterator<Tuple>	AccumulativeBag.iterator()
abstract Class<? extends Tuple>	TupleFactory.tupleClass() Return the actual class representing a tuple that the implementing factory will be returning.
Class<? extends Tuple>	BinSedesTupleFactory.tupleClass()

Methods in org.apache.pig.data with parameters of type Tuple

void	SingleTupleBag.add(Tuple t)
void	ReadOnceBag.add(Tuple t)
void	NonSpillableDataBag.add(Tuple t)
void	InternalSortedBag.add(Tuple t)
void	InternalDistinctBag.add(Tuple t)
void	InternalCachedBag.add(Tuple t)
void	DistinctDataBag.add(Tuple t)
void	DefaultAbstractBag.add(Tuple t) Add a tuple to the bag.
void	DataBag.add(Tuple t) Add a tuple to the bag.
void	AccumulativeBag.add(Tuple t)
void	InterSedes.addColsToTuple(DataInput in, Tuple t) The type of next object has been determined to be of type Tuple, add the columns that belong to the tuple to given tuple argument t
void	BinInterSedes.addColsToTuple(DataInput in, Tuple t)
void	Tuple.reference(Tuple t) Make this tuple reference the contents of another.
void	TargetedTuple.reference(Tuple t)
void	DefaultTuple.reference(Tuple t) Make this tuple reference the contents of another.
static void	DataType.spillTupleContents(Tuple t, String label) Purely for debugging

Method parameters in org.apache.pig.data with type arguments of type Tuple

void	InternalSortedBag.addAll(Collection<Tuple> c)
void	InternalDistinctBag.addAll(Collection<Tuple> c)
void	InternalCachedBag.addAll(Collection<Tuple> c)
void	DefaultAbstractBag.addAll(Collection<Tuple> c) Add contents of a container to the bag.
DataBag	DefaultBagFactory.newDefaultBag(List<Tuple> listOfTuples) Get a default (unordered, not distinct) data bag from an existing list of tuples.
abstract DataBag	BagFactory.newDefaultBag(List<Tuple> listOfTuples) Get a default (unordered, not distinct) data bag with an existing list of tuples inserted into the bag.
DataBag	DefaultBagFactory.newSortedBag(Comparator<Tuple> comp) Get a sorted data bag.
abstract DataBag	BagFactory.newSortedBag(Comparator<Tuple> comp) Get a sorted data bag.
long	SortedSpillBag.proactive_spill(Comparator<Tuple> comp) Sort contents of mContents and write them to disk

Constructors in org.apache.pig.data with parameters of type Tuple

SingleTupleBag(Tuple t)

TargetedTuple(Tuple t, List<OperatorKey> targetOps)

Constructor parameters in org.apache.pig.data with type arguments of type Tuple

DefaultDataBag(List<Tuple> listOfTuples)
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.

InternalSortedBag(Comparator<Tuple> comp)

InternalSortedBag(int bagCount, Comparator<Tuple> comp)

InternalSortedBag(int bagCount, double percent, Comparator<Tuple> comp)

NonSpillableDataBag(List<Tuple> listOfTuples)
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.

SortedDataBag(Comparator<Tuple> comp)

Uses of Tuple in org.apache.pig.impl.builtin

Methods in org.apache.pig.impl.builtin that return Tuple

Tuple	GetMemNumRows.exec(Tuple in)
Tuple	RandomSampleLoader.getNext() Allocate a buffer for numSamples elements, populate it with the first numSamples tuples, and continue scanning rest of the input.
Tuple	PoissonSampleLoader.getNext()
Tuple	DefaultIndexableLoader.getNext()

Methods in org.apache.pig.impl.builtin with parameters of type Tuple

Object	ReadScalars.exec(Tuple input) Java level API
Map<String,Object>	PartitionSkewedKeys.exec(Tuple in) first field in the input tuple is the number of reducers second field is the *sorted* bag of samples this should be called only once
Object	IdentityColumn.exec(Tuple input)
DataBag	GFReplicate.exec(Tuple input)
DataBag	GFCross.exec(Tuple input)
Integer	GFAny.exec(Tuple input)
Tuple	GetMemNumRows.exec(Tuple in)
Map<String,Object>	FindQuantiles.exec(Tuple in) first field in the input tuple is the number of quantiles to generate second field is the *sorted* bag of samples
void	DefaultIndexableLoader.seekNear(Tuple keys)

Uses of Tuple in org.apache.pig.impl.io

Methods in org.apache.pig.impl.io that return Tuple

Tuple	TFileRecordReader.getCurrentValue()
Tuple	InterRecordReader.getCurrentValue()
Tuple	BinStorageRecordReader.getCurrentValue()
Tuple	TFileStorage.getNext()
Tuple	ReadToEndLoader.getNext()
Tuple	InterStorage.getNext()

Methods in org.apache.pig.impl.io that return types with arguments of type Tuple

org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple>	TFileStorage.TFileInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple>	InterStorage.InterInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple>	BinStorageInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>	TFileStorage.TFileOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext job)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>	InterStorage.InterOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext job)
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple>	BinStorageOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext job)

Methods in org.apache.pig.impl.io with parameters of type Tuple

void	TFileStorage.putNext(Tuple t)
void	InterStorage.putNext(Tuple t)
void	TFileRecordWriter.write(org.apache.hadoop.io.WritableComparable wc, Tuple t)
void	InterRecordWriter.write(org.apache.hadoop.io.WritableComparable wc, Tuple t)
void	BinStorageRecordWriter.write(org.apache.hadoop.io.WritableComparable wc, Tuple t)

Constructors in org.apache.pig.impl.io with parameters of type Tuple

NullableTuple(Tuple t)

Uses of Tuple in org.apache.pig.impl.streaming

Methods in org.apache.pig.impl.streaming that return Tuple

Tuple

OutputHandler.getNext() Get the next output Tuple of the managed process.

Methods in org.apache.pig.impl.streaming with parameters of type Tuple

void	InputHandler.putNext(Tuple t) Send the given input Tuple to the managed executable.

Uses of Tuple in org.apache.pig.impl.util

Methods in org.apache.pig.impl.util that return Tuple

Tuple	LineageTracer.getRepresentative(Tuple t)
static Tuple	StorageUtil.textToTuple(org.apache.hadoop.io.Text val, byte fieldDel) Transform a line of Text to a Tuple

Methods in org.apache.pig.impl.util that return types with arguments of type Tuple

IdentityHashMap<Tuple,Integer>	LineageTracer.getCounts()
Collection<Tuple>	LineageTracer.getMembers(Tuple t)
IdentityHashMap<Tuple,Collection<Tuple>>	LineageTracer.getMembershipMap()
IdentityHashMap<Tuple,Collection<Tuple>>	LineageTracer.getMembershipMap()
IdentityHashMap<Tuple,Integer>	LineageTracer.getWeightedCounts(IdentityHashSet<Tuple> specialTuples, int multiplier)

Methods in org.apache.pig.impl.util with parameters of type Tuple

static String	TupleFormat.format(Tuple tuple) Default implementation of format of tuple (each filed is delimited by tab)
Collection<Tuple>	LineageTracer.getMembers(Tuple t)
Tuple	LineageTracer.getRepresentative(Tuple t)
void	LineageTracer.insert(Tuple t)
void	LineageTracer.union(Tuple t1, Tuple t2)

Method parameters in org.apache.pig.impl.util with type arguments of type Tuple

IdentityHashMap<Tuple,Integer>

LineageTracer.getWeightedCounts(IdentityHashSet<Tuple> specialTuples, int multiplier)

Uses of Tuple in org.apache.pig.pen

Methods in org.apache.pig.pen that return Tuple

Tuple

Illustrable.illustratorMarkup(Object in, Object out, int eqClassIndex) input tuple mark up to be illustrate-able

Methods in org.apache.pig.pen that return types with arguments of type Tuple

Collection<IdentityHashSet<Tuple>>	ExampleGenerator.getEqClasses()
LinkedList<IdentityHashSet<Tuple>>	Illustrator.getEquivalenceClasses()
IdentityHashSet<Tuple>	Illustrator.getInputs()
Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>>	ExampleGenerator.getLoToEqClassMap()
static Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>>	EquivalenceClasses.getLoToEqClassMap(PhysicalPlan plan, LogicalPlan lp, Map<Operator,PhysicalOperator> logToPhyMap, Map<Operator,DataBag> logToDataMap, Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> forEachInnerLogToPhyMap, HashMap<PhysicalOperator,Collection<IdentityHashSet<Tuple>>> poToEqclassesMap)

Methods in org.apache.pig.pen with parameters of type Tuple

void	Illustrator.addData(Tuple t)

Method parameters in org.apache.pig.pen with type arguments of type Tuple

void	Illustrator.addInputs(IdentityHashSet<Tuple> inputs)
static Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>>	EquivalenceClasses.getLoToEqClassMap(PhysicalPlan plan, LogicalPlan lp, Map<Operator,PhysicalOperator> logToPhyMap, Map<Operator,DataBag> logToDataMap, Map<LOForEach,Map<LogicalRelationalOperator,PhysicalOperator>> forEachInnerLogToPhyMap, HashMap<PhysicalOperator,Collection<IdentityHashSet<Tuple>>> poToEqclassesMap)
void	Illustrator.setEquivalenceClasses(LinkedList<IdentityHashSet<Tuple>> eqClasses, PhysicalOperator po)

Constructor parameters in org.apache.pig.pen with type arguments of type Tuple

Illustrator(LineageTracer lineage, LinkedList<IdentityHashSet<Tuple>> equivalenceClasses, IllustratorAttacher attacher, PigContext hadoopPigContext)

Illustrator(LineageTracer lineage, LinkedList<IdentityHashSet<Tuple>> equivalenceClasses, int maxRecords, IllustratorAttacher attacher, LogicalSchema schema, PigContext hadoopPigContext)

Uses of Tuple in org.apache.pig.pen.util

Classes in org.apache.pig.pen.util that implement Tuple

class

ExampleTuple

Methods in org.apache.pig.pen.util that return Tuple

Tuple	LineageTracer.getRepresentative(Tuple t)
Tuple	ExampleTuple.toTuple()

Methods in org.apache.pig.pen.util that return types with arguments of type Tuple

IdentityHashMap<Tuple,Double>	LineageTracer.getCounts()
Collection<Tuple>	LineageTracer.getMembers(Tuple t)
IdentityHashMap<Tuple,Collection<Tuple>>	LineageTracer.getMembershipMap()
IdentityHashMap<Tuple,Collection<Tuple>>	LineageTracer.getMembershipMap()
IdentityHashMap<Tuple,Double>	LineageTracer.getWeightedCounts(float syntheticMultipler, float omittableMultiplier)

Methods in org.apache.pig.pen.util with parameters of type Tuple

Collection<Tuple>	LineageTracer.getMembers(Tuple t)
Tuple	LineageTracer.getRepresentative(Tuple t)
void	LineageTracer.insert(Tuple t)
void	ExampleTuple.reference(Tuple t)
void	LineageTracer.union(Tuple t1, Tuple t2)

Method parameters in org.apache.pig.pen.util with type arguments of type Tuple

static float	MetricEvaluation.getCompleteness(Operator op, Map<Operator,DataBag> exampleData, Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>> OperatorToEqClasses, boolean overallCompleteness)
static float	MetricEvaluation.getConciseness(Operator op, Map<Operator,DataBag> exampleData, Map<LogicalRelationalOperator,Collection<IdentityHashSet<Tuple>>> OperatorToEqClasses, boolean overallConciseness)

Constructors in org.apache.pig.pen.util with parameters of type Tuple

ExampleTuple(Tuple t)

Uses of Tuple in org.apache.pig.piggybank.evaluation

Methods in org.apache.pig.piggybank.evaluation that return Tuple

Tuple	MaxTupleBy1stField.exec(Tuple input)
Tuple	MaxTupleBy1stField.Initial.exec(Tuple input)
Tuple	MaxTupleBy1stField.Intermediate.exec(Tuple input)
Tuple	MaxTupleBy1stField.Final.exec(Tuple input)
Tuple	ExtremalTupleByNthField.exec(Tuple input) The EvalFunc interface
Tuple	ExtremalTupleByNthField.HelperClass.exec(Tuple input)
protected static Tuple	ExtremalTupleByNthField.extreme(int pind, int psign, Tuple input, PigProgressable reporter)
Tuple	ExtremalTupleByNthField.getValue()
protected static Tuple	MaxTupleBy1stField.max(Tuple input, PigProgressable reporter)

Methods in org.apache.pig.piggybank.evaluation with parameters of type Tuple

void	ExtremalTupleByNthField.accumulate(Tuple b)
Tuple	MaxTupleBy1stField.exec(Tuple input)
Tuple	MaxTupleBy1stField.Initial.exec(Tuple input)
Tuple	MaxTupleBy1stField.Intermediate.exec(Tuple input)
Tuple	MaxTupleBy1stField.Final.exec(Tuple input)
Tuple	ExtremalTupleByNthField.exec(Tuple input) The EvalFunc interface
Tuple	ExtremalTupleByNthField.HelperClass.exec(Tuple input)
protected static Tuple	ExtremalTupleByNthField.extreme(int pind, int psign, Tuple input, PigProgressable reporter)
protected static Tuple	MaxTupleBy1stField.max(Tuple input, PigProgressable reporter)

Uses of Tuple in org.apache.pig.piggybank.evaluation.datetime

Methods in org.apache.pig.piggybank.evaluation.datetime with parameters of type Tuple

Integer

DiffDate.exec(Tuple input)

Uses of Tuple in org.apache.pig.piggybank.evaluation.datetime.convert

Methods in org.apache.pig.piggybank.evaluation.datetime.convert with parameters of type Tuple

String	UnixToISO.exec(Tuple input)
Long	ISOToUnix.exec(Tuple input)
String	CustomFormatToISO.exec(Tuple input)

Uses of Tuple in org.apache.pig.piggybank.evaluation.datetime.diff

Methods in org.apache.pig.piggybank.evaluation.datetime.diff with parameters of type Tuple

Long	ISOYearsBetween.exec(Tuple input)
Long	ISOSecondsBetween.exec(Tuple input)
Long	ISOMonthsBetween.exec(Tuple input)
Long	ISOMinutesBetween.exec(Tuple input)
Long	ISOHoursBetween.exec(Tuple input)
Long	ISODaysBetween.exec(Tuple input)

Uses of Tuple in org.apache.pig.piggybank.evaluation.datetime.truncate

Methods in org.apache.pig.piggybank.evaluation.datetime.truncate with parameters of type Tuple

String	ISOToYear.exec(Tuple input)
String	ISOToWeek.exec(Tuple input)
String	ISOToSecond.exec(Tuple input)
String	ISOToMonth.exec(Tuple input)
String	ISOToMinute.exec(Tuple input)
String	ISOToHour.exec(Tuple input)
String	ISOToDay.exec(Tuple input)
static org.joda.time.DateTime	ISOHelper.parseDateTime(Tuple input)

Uses of Tuple in org.apache.pig.piggybank.evaluation.decode

Methods in org.apache.pig.piggybank.evaluation.decode with parameters of type Tuple

String	Decode.exec(Tuple tuple)
String	BinCond.exec(Tuple tuple)
String	Bin.exec(Tuple tuple)

Uses of Tuple in org.apache.pig.piggybank.evaluation.math

Methods in org.apache.pig.piggybank.evaluation.math with parameters of type Tuple

Double	ULP.exec(Tuple input) java level API
Double	SIGNUM.exec(Tuple input) java level API
Double	SCALB.exec(Tuple input) java level API
Long	ROUND.exec(Tuple input) Deprecated. java level API
Double	RANDOM.exec(Tuple input)
Double	NEXTUP.exec(Tuple input) java level API
Double	nextAfter.exec(Tuple input) java level API
Double	MIN.exec(Tuple input) java level API
Double	MAX.exec(Tuple input) java level API
Long	LongMin.exec(Tuple input) java level API
Long	LongMax.exec(Tuple input) java level API
Long	LongAbs.exec(Tuple input) Deprecated. java level API
Integer	IntMin.exec(Tuple input) java level API
Integer	IntMax.exec(Tuple input) java level API
Integer	IntAbs.exec(Tuple input) Deprecated. java level API
Integer	getExponent.exec(Tuple input) java level API
Float	FloatUlp.exec(Tuple input) java level API
Float	FloatSignum.exec(Tuple input) java level API
Integer	FloatRound.exec(Tuple input) Deprecated. java level API
Float	FloatNextup.exec(Tuple input) java level API
Float	FloatNextAfter.exec(Tuple input) java level API
Float	FloatMin.exec(Tuple input) java level API
Float	FloatMax.exec(Tuple input) java level API
Integer	FloatGetExponent.exec(Tuple input) java level API
Float	FloatCopySign.exec(Tuple input) java level API
Float	FloatAbs.exec(Tuple input) Deprecated. java level API
Double	DoubleUlp.exec(Tuple input) java level API
Double	DoubleSignum.exec(Tuple input) java level API
Long	DoubleRound.exec(Tuple input) Deprecated. java level API
Double	DoubleNextup.exec(Tuple input) java level API
Double	DoubleNextAfter.exec(Tuple input) java level API
Double	DoubleMin.exec(Tuple input) java level API
Double	DoubleMax.exec(Tuple input) java level API
Integer	DoubleGetExponent.exec(Tuple input) java level API
Double	DoubleDoubleBase.exec(Tuple input) java level API
Double	DoubleCopySign.exec(Tuple input) java level API
Double	DoubleBase.exec(Tuple input) Deprecated. java level API
Double	DoubleAbs.exec(Tuple input) Deprecated. java level API
Double	copySign.exec(Tuple input) java level API
Double	ABS.exec(Tuple input) Deprecated. java level API

Uses of Tuple in org.apache.pig.piggybank.evaluation.stats

Methods in org.apache.pig.piggybank.evaluation.stats that return Tuple

protected static Tuple	COV.combine(DataBag values) Deprecated. combine results of different data chunk
protected static Tuple	COR.combine(DataBag values) Deprecated. combine results of different data chunk
protected static Tuple	COV.computeAll(DataBag first, DataBag second) Deprecated. compute sum(XY), sum(X), sum(Y) from given data sets
protected static Tuple	COR.computeAll(DataBag first, DataBag second) Deprecated. compute sum(XY), sum(X), sum(Y), sum(XX), sum(YY) from given data sets
Tuple	COV.Initial.exec(Tuple input)
Tuple	COV.Intermed.exec(Tuple input)
Tuple	COR.Initial.exec(Tuple input)
Tuple	COR.Intermed.exec(Tuple input)

Methods in org.apache.pig.piggybank.evaluation.stats with parameters of type Tuple

DataBag	COV.exec(Tuple input) Deprecated. Function to compute covariance between data sets.
Tuple	COV.Initial.exec(Tuple input)
Tuple	COV.Intermed.exec(Tuple input)
DataBag	COV.Final.exec(Tuple input)
DataBag	COR.exec(Tuple input) Deprecated. Function to compute correlation between data sets.
Tuple	COR.Initial.exec(Tuple input)
Tuple	COR.Intermed.exec(Tuple input)
DataBag	COR.Final.exec(Tuple input)

Uses of Tuple in org.apache.pig.piggybank.evaluation.string

Methods in org.apache.pig.piggybank.evaluation.string that return Tuple

Tuple	Split.exec(Tuple input) Deprecated. Wrapper around Java's String.split
Tuple	RegexExtractAll.exec(Tuple input) Deprecated.

Methods in org.apache.pig.piggybank.evaluation.string with parameters of type Tuple

String	UPPER.exec(Tuple input) Deprecated. Upper-cases an input string.
String	UcFirst.exec(Tuple input) Deprecated.
String	Trim.exec(Tuple input) Deprecated.
String	SUBSTRING.exec(Tuple input) Deprecated. Method invoked on every tuple during foreach evaluation
Tuple	Split.exec(Tuple input) Deprecated. Wrapper around Java's String.split
String	Reverse.exec(Tuple input)
String	REPLACE.exec(Tuple input) Deprecated. Method invoked on every tuple during foreach evaluation
Integer	RegexMatch.exec(Tuple input)
Tuple	RegexExtractAll.exec(Tuple input) Deprecated.
String	RegexExtract.exec(Tuple input) Deprecated.
String	LOWER.exec(Tuple input) Deprecated. Method invoked on every tuple during foreach evaluation
Integer	LookupInFiles.exec(Tuple input)
Integer	LENGTH.exec(Tuple input)
String	LcFirst.exec(Tuple input) Deprecated.
Integer	LASTINDEXOF.exec(Tuple input) Deprecated. Finds the last location of a substring in a given string.
Integer	INDEXOF.exec(Tuple input) Deprecated. Method invoked on every tuple during foreach evaluation
Long	HashFNV2.exec(Tuple input)
Long	HashFNV1.exec(Tuple input)
Long	HashFNV.exec(Tuple input)
void	LookupInFiles.init(Tuple tuple)

Uses of Tuple in org.apache.pig.piggybank.evaluation.util

Methods in org.apache.pig.piggybank.evaluation.util that return Tuple

Tuple	ToTuple.exec(Tuple input) Deprecated.
Tuple	Top.Initial.exec(Tuple tuple)
Tuple	Top.Intermed.exec(Tuple input)

Methods in org.apache.pig.piggybank.evaluation.util with parameters of type Tuple

Tuple	ToTuple.exec(Tuple input) Deprecated.
DataBag	Top.exec(Tuple tuple) Deprecated.
Tuple	Top.Initial.exec(Tuple tuple)
Tuple	Top.Intermed.exec(Tuple input)
DataBag	Top.Final.exec(Tuple tuple)
DataBag	ToBag.exec(Tuple input) Deprecated.
String	SearchQuery.exec(Tuple tuple)

Method parameters in org.apache.pig.piggybank.evaluation.util with type arguments of type Tuple

protected static void

Top.updateTop(PriorityQueue<Tuple> store, int limit, DataBag inputBag) Deprecated.

Uses of Tuple in org.apache.pig.piggybank.evaluation.util.apachelogparser

Methods in org.apache.pig.piggybank.evaluation.util.apachelogparser with parameters of type Tuple

String	SearchTermExtractor.exec(Tuple input)
String	SearchEngineExtractor.exec(Tuple input)
String	HostExtractor.exec(Tuple input)
String	DateExtractor.exec(Tuple input)

Uses of Tuple in org.apache.pig.piggybank.storage

Methods in org.apache.pig.piggybank.storage that return Tuple

Tuple	XMLLoader.createTuple(byte[] content)
Tuple	XMLLoader.getNext() Retrieves the next tuple to be processed.
Tuple	SequenceFileLoader.getNext()
Tuple	RegExLoader.getNext()
Tuple	PigStorageSchema.getNext()
Tuple	HiveColumnarLoader.getNext()
Tuple	HadoopJobHistoryLoader.getNext()
Tuple	CSVLoader.getNext()
Tuple	CSVExcelStorage.getNext()
Tuple	AllLoader.getNext()

Methods in org.apache.pig.piggybank.storage that return types with arguments of type Tuple

org.apache.hadoop.mapreduce.RecordWriter<String,Tuple>

MultiStorage.MultiStorageOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)

Methods in org.apache.pig.piggybank.storage with parameters of type Tuple

void	MultiStorage.putNext(Tuple tuple)
void	DBStorage.putNext(Tuple tuple) Write the tuple to Database directly here.
void	CSVExcelStorage.putNext(Tuple tupleToWrite)

Uses of Tuple in org.apache.pig.piggybank.storage.avro

Methods in org.apache.pig.piggybank.storage.avro that return Tuple

Tuple	AvroStorage.getNext()
protected Tuple	PigAvroRecordReader.wrapAsTuple(Object in) Wrap non-tuple value as a tuple

Methods in org.apache.pig.piggybank.storage.avro with parameters of type Tuple

void	AvroStorage.putNext(Tuple t)

Uses of Tuple in org.apache.pig.piggybank.storage.hiverc

Methods in org.apache.pig.piggybank.storage.hiverc that return Tuple

static Tuple

HiveRCSchemaUtil.parseLazyArrayToPigArray(org.apache.hadoop.hive.serde2.lazy.LazyArray arr) Converts the LazyArray to a Tuple.

Uses of Tuple in org.apache.pig.scripting.js

Methods in org.apache.pig.scripting.js with parameters of type Tuple

Object

JsFunction.exec(Tuple tuple)

Uses of Tuple in org.apache.pig.scripting.jython

Methods in org.apache.pig.scripting.jython with parameters of type Tuple

Object	JythonFunction.exec(Tuple tuple)
static org.python.core.PyTuple	JythonUtils.pigTupleToPyTuple(Tuple tuple)

Uses of Tuple in org.apache.pig.tools.pigstats

Methods in org.apache.pig.tools.pigstats that return types with arguments of type Tuple

Iterator<Tuple>

OutputStats.iterator()