java.lang.String filename
java.lang.Long offset
java.lang.String className
java.lang.String[] ctorArgs
Schema inputArgsSchema
java.lang.String alias
int index
java.util.List<E> subFields
byte type
java.util.List<E> fields
int errorCode
byte errorSource
boolean retriable
java.lang.String detailedMessage
boolean markedAsShowToUser
SourceLocation sourceLocation
ResourceSchema.ResourceFieldSchema[] fields
int[] sortKeys
ResourceSchema.Order[] sortKeyOrders
int version
java.lang.String name
byte type
java.lang.String description
ResourceSchema schema
int version
java.lang.Long numDistinctValues
java.lang.Object[] mostCommonValues
float[] mostCommonValuesFreq
java.lang.Object[] valueHistogram
java.lang.String colName
int colIndex
SortColInfo.Order sortOrder
boolean isGloballySorted
java.util.List<E> sortColInfoList
PhysicalPlan mapPlan
PhysicalPlan reducePlan
PhysicalPlan combinePlan
byte mapKeyType
boolean mapDone
boolean reduceDone
boolean endOfAllInputInMap
boolean endOfAllInputInReduce
boolean globalSort
boolean limitAfterSort
boolean limitOnly
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper.OPER_FEATURE feature
boolean needsDistinctCombiner
boolean useSecondaryKey
java.lang.String quantFile
boolean[] sortOrder
boolean[] secondarySortOrder
java.util.Set<E> UDFs
java.util.Set<E> scalars
boolean isUDFComparatorUsed
java.lang.String scope
int requestedParallelism
int estimatedParallelism
int runtimeParallelism
java.lang.String customPartitioner
long limit
PhysicalPlan limitPlan
boolean splitter
boolean skewedJoin
java.lang.String skewedJoinPartitionFile
boolean usingTypedComparator
boolean combineSmallSplits
MultiMap<K,V> phyToMRMap
java.lang.String nativeMRJar
java.lang.String[] params
long totalCount
java.lang.String name
PhysicalPlan plan
int code
int requestedParallelism
java.util.List<E> inputs
java.util.List<E> outputs
byte resultType
PhysicalPlan parentPlan
boolean inputAttached
Tuple input
Result res
java.lang.String alias
LineageTracer lineageTracer
boolean accum
java.util.List<E> originalLocations
java.lang.String alias
int line
int offset
byte returnStatus
java.lang.Object result
byte operandType
ExpressionOperator lhs
ExpressionOperator rhs
java.lang.Object value
Result res
ExpressionOperator cond
ExpressionOperator lhs
ExpressionOperator rhs
private void readObject(java.io.ObjectInputStream is) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
FuncSpec funcSpec
boolean castNotNeeded
java.lang.Byte realType
ResourceSchema.ResourceFieldSchema fieldSchema
java.lang.String key
boolean resultSingleTupleBag
java.util.ArrayList<E> columns
boolean processingBagOfTuples
boolean overloaded
boolean isProjectToEnd
int startCol
RegexImpl impl
boolean sendEmptyBagOnEOP
private void readObject(java.io.ObjectInputStream is) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
FuncSpec funcSpec
FuncSpec origFSpec
boolean initialized
MonitoredUDFExecutor executor
PhysicalOperator referencedOperator
boolean isAccumulationDone
java.lang.String signature
boolean haveCheckedIfTerminatingAccumulator
long numInvocations
boolean doTiming
boolean usingSchemaTupleFactory
boolean isEarlyTerminating
boolean isTerminated
byte operandType
ExpressionOperator expr
PORegexp regexop
int side
boolean rhsConstant
boolean[] mBags
java.util.Map<K,V> keyLookup
int numBags
POOptimizedForEach forEach
boolean newKey
Tuple res
long chunkSize
Result forEachResult
DataBag[] dbs
int lastBagIndex
java.util.Iterator<E> lastBagIter
PigNullableWritable keyWritable
java.util.List<E> packagers
java.util.ArrayList<E> isKeyWrapped
boolean sameMapKeyType
boolean inCombiner
PigNullableWritable keyWritable
boolean[] readOnce
DataBag[] bags
java.lang.Object key
boolean isKeyTuple
boolean isKeyCompound
byte keyType
int numInputs
boolean useSecondaryKey
boolean[] inner
boolean distinct
java.util.Map<K,V> keyInfo
Packager.PackageType pkgType
boolean firstTime
boolean useDefaultBag
POPackage parent
java.util.List<E> counterPlans
java.util.List<E> mAscCols
boolean isDenseRank
boolean isRowNumber
java.lang.Long localCount
java.lang.String taskID
java.lang.String operationID
java.util.ArrayList<E> myPlans
boolean getNext
boolean inpEOP
PhysicalOperator curLeaf
PhysicalPlan curPlan
boolean inCombiner
java.util.BitSet processedSet
boolean inputsAccumulated
DataBag distinctBag
java.lang.String customPartitioner
PhysicalPlan plan
PhysicalOperator comOp
byte compOperandType
java.util.List<E> inputPlans
java.util.List<E> opsToBeReset
boolean processingPlan
java.lang.Object[] bags
java.lang.Object[] data
byte[] resultTypes
java.util.BitSet earlyTermination
boolean[] isToBeFlattenedArray
ExampleTuple tIn
int noItems
PhysicalOperator[] planLeafOps
Tuple inpTuple
Schema schema
boolean isEarlyTerminated
TupleMaker<A extends Tuple> tupleMaker
boolean knownSize
private void readObject(java.io.ObjectInputStream is) throws java.io.IOException, java.lang.ClassNotFoundException, ExecException
java.io.IOException
java.lang.ClassNotFoundException
ExecException
int fragment
java.util.List<E> phyPlanLists
java.util.List<E> keyTypes
POLocalRearrange[] LRs
FileSpec[] replFiles
ConstantExpression[] constExps
POForEach fe
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin.TupleToMapKey[] replicates
boolean processingPlan
Tuple dumTup
boolean setUp
boolean isLeftOuterJoin
DataBag nullBag
Schema[] inputSchemas
Schema[] keySchemas
java.lang.String customPartitioner
long soFar
long mLimit
PhysicalPlan expressionPlan
FileSpec lFile
PigContext pc
boolean setUpDone
java.lang.String signature
boolean isTmpLoad
long limit
java.util.List<E> plans
java.util.List<E> secondaryPlans
java.util.List<E> leafOps
java.util.List<E> secondaryLeafOps
byte index
byte keyType
byte mainKeyType
byte secondaryKeyType
boolean mIsDistinct
boolean isCross
java.util.Map<K,V> mProjectedColsMap
java.util.Map<K,V> mSecondaryProjectedColsMap
Tuple mFakeTuple
boolean mProjectStar
boolean mSecondaryProjectStar
boolean isKeyTuple
boolean isKeyCompound
boolean isSecondaryKeyTuple
int mProjectedColsMapSize
int mSecondaryProjectedColsMapSize
boolean useSecondaryKey
boolean stripKeyFromValue
private void readObject(java.io.ObjectInputStream is) throws java.io.IOException, java.lang.ClassNotFoundException, ExecException
java.io.IOException
java.lang.ClassNotFoundException
ExecException
java.util.List<E> sidFuncSpecs
java.util.List<E> sideFileSpecs
POLocalRearrange[] LRs
java.lang.String indexFileName
FuncSpec idxFuncSpec
java.util.List<E> loaderSignatures
int counter
private void readObject(java.io.ObjectInputStream is) throws java.io.IOException, java.lang.ClassNotFoundException, ExecException
java.io.IOException
java.lang.ClassNotFoundException
ExecException
boolean firstTime
POLocalRearrange[] LRs
OperatorKey opKey
java.lang.Object prevLeftKey
Result prevLeftInp
java.lang.Object prevRightKey
Result prevRightInp
boolean doingJoin
FuncSpec rightLoaderFuncSpec
java.lang.String rightInputFileName
java.lang.String indexFile
MultiMap<K,V> inpPlans
PhysicalOperator rightPipelineLeaf
PhysicalOperator rightPipelineRoot
boolean noInnerPlanOnRightSide
java.lang.Object curJoinKey
Tuple curJoiningRightTup
int counter
int leftTupSize
int rightTupSize
int arrayListSize
LOJoin.JOINTYPE joinType
java.lang.String signature
Schema leftInputSchema
Schema mergedInputSchema
java.lang.String nativeMRjar
java.lang.String[] params
java.lang.Object key
int numInputs
boolean firstTime
boolean useDefaultBag
boolean lastBagReadOnly
Packager pkgr
PigNullableWritable keyWritable
PhysicalPlan keyPlan
ExpressionOperator keyLeaf
java.util.List<E> valuePlans
java.util.List<E> valueLeaves
int numRecsInRawMap
int numRecsInProcessedMap
java.util.Map<K,V> rawInputMap
java.util.Map<K,V> processedInputMap
boolean disableMapAgg
boolean sizeReductionChecked
boolean inputsExhausted
boolean doSpill
int firstTierThreshold
int secondTierThreshold
int sizeReduction
int avgTupleSize
java.util.Iterator<E> spillingIterator
boolean estimatedMemThresholds
java.lang.Integer totalReducers
boolean loaded
PigContext pigContext
java.util.List<E> plans
java.util.List<E> leafOps
byte keyType
java.util.List<E> rankPlans
java.util.List<E> mAscCols
java.util.List<E> ExprOutputTypes
java.lang.String operationID
int localCountIllustrator
java.util.List<E> sortPlans
java.util.List<E> ExprOutputTypes
java.util.List<E> mAscCols
POUserComparisonFunc mSortFunc
java.util.Comparator<T> mComparator
boolean inputsAccumulated
long limit
boolean isUDFComparatorUsed
DataBag sortedBag
FileSpec splitStore
java.util.List<E> myPlans
java.util.BitSet processedSet
boolean inpEOP
java.lang.String executableManagerStr
StreamingCommand command
java.util.Properties properties
boolean initialized
java.util.concurrent.BlockingQueue<E> binaryOutputQueue
java.util.concurrent.BlockingQueue<E> binaryInputQueue
boolean allInputFromPredecessorConsumed
boolean allOutputFromBinaryProcessed
boolean isFetchable
FetchLauncher
pulls out the data from the pipeline. Therefore we need to
skip the case in POStream.getNextTuple()
which is called by map() or reduce() when
processing the next tuple.java.util.BitSet done
boolean nextReturnEOP
int lastInd
org.apache.pig.builtin.BigDecimalWrapper.BigDecimalInfinity infinity
org.apache.pig.builtin.BigIntegerWrapper.BigIntegerInfinity infinity
java.util.Map<K,V> locationToData
java.util.Map<K,V> locationToSchema
int index
java.lang.Object amendKey
Tuple appendedFields
byte[] mData
java.util.Collection<E> mContents
FileList mSpillFiles
long mSize
long aggSampleTupleSize
int sampled
boolean spillableRegistered
boolean isNull
java.util.List<E> mFields
java.util.List<E> mContents
Packager pkgr
PigNullableWritable keyWritable
SelfSpillBag.MemoryLimits memLimit
Tuple item
boolean mReadStarted
Tuple t
java.util.List<E> targetOps
boolean isNull
double timestamp
boolean heartbeat
ExecType execType
java.util.Properties properties
java.util.List<E> scriptFiles
java.util.Map<K,V> aliasedScriptFiles
java.util.Map<K,V> definedFunctions
java.util.Map<K,V> definedCommands
java.util.Properties log4jProperties
org.apache.log4j.Level defaultLogLevel
int defaultParallel
boolean inExplain
boolean inDumpSchema
boolean inIllustrator
java.lang.String last_alias
java.util.List<E> skippedShipPaths
java.util.List<E> params
java.util.List<E> paramFiles
java.lang.String fileName
FuncSpec funcSpec
java.lang.String resourceName
java.lang.String alias
byte type
DataType
.Schema schema
java.lang.String canonicalName
OperatorKey mKey
java.lang.String scope
long id
java.lang.String executable
java.lang.String[] argv
java.util.List<E> shipSpec
java.util.List<E> cacheSpec
java.util.Map<K,V> handleSpecs
boolean persistStderr
java.lang.String logDir
int logFilesLimit
boolean shipFiles
PigContext pigContext
java.lang.String name
java.lang.String spec
java.lang.String message
java.lang.String language
java.lang.Integer lineNumber
int lineNumber
java.util.Map<K,V> mMap
java.lang.Object first
java.lang.Object second
org.apache.avro.generic.GenericArray<T> theArray
org.apache.avro.generic.IndexedRecord avroObject
java.lang.String alias
java.lang.String cmd
java.net.MalformedURLException ex
ScalarExpression scalarExpr
java.lang.String msg
LogicalExpression expr
java.lang.String cause
java.lang.Exception ex
SourceLocation location
java.lang.Exception ex
java.lang.String alias
boolean synthetic
boolean omittable
java.lang.Object expr
Tuple t
DataBag internalDB
DataByteArray internalDBA
Schema internalSchema
org.apache.pig.tools.parameters.Token currentToken
int[][] expectedTokenSequences
java.lang.String[] tokenImage
java.lang.String eol
int kind
int beginLine
int beginColumn
int endLine
int endColumn
java.lang.String image
org.apache.pig.tools.parameters.Token next
org.apache.pig.tools.parameters.Token specialToken
int errorCode
Copyright © 2007-2012 The Apache Software Foundation