int errorCode
byte errorSource
boolean retriable
String detailedMessage
boolean markedAsShowToUser
SourceLocation sourceLocation
ResourceSchema.ResourceFieldSchema[] fields
int[] sortKeys
ResourceSchema.Order[] sortKeyOrders
int version
String name
byte type
String description
ResourceSchema schema
int version
Long numDistinctValues
Object[] mostCommonValues
float[] mostCommonValuesFreq
Object[] valueHistogram
String colName
int colIndex
SortColInfo.Order sortOrder
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
String quantFile
boolean[] sortOrder
boolean[] secondarySortOrder
Set<E> UDFs
Set<E> scalars
boolean isUDFComparatorUsed
String scope
int requestedParallelism
int estimatedParallelism
int runtimeParallelism
String customPartitioner
long limit
PhysicalPlan limitPlan
boolean splitter
boolean skewedJoin
String skewedJoinPartitionFile
boolean usingTypedComparator
boolean combineSmallSplits
MultiMap<K,V> phyToMRMap
String name
PhysicalPlan plan
int code
int requestedParallelism
List<E> inputs
List<E> outputs
byte resultType
PhysicalPlan parentPlan
boolean inputAttached
Tuple input
Result res
String alias
LineageTracer lineageTracer
boolean accum
List<E> originalLocations
String alias
int line
int offset
byte returnStatus
Object result
ExpressionOperator lhs
ExpressionOperator rhs
ExpressionOperator cond
ExpressionOperator lhs
ExpressionOperator rhs
private void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionFuncSpec funcSpec
boolean castNotNeeded
Byte realType
ResourceSchema.ResourceFieldSchema fieldSchema
String key
RegexImpl impl
private void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprivate void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionFuncSpec funcSpec
FuncSpec origFSpec
boolean initialized
MonitoredUDFExecutor executor
PhysicalOperator referencedOperator
boolean isAccumulationDone
String signature
boolean haveCheckedIfTerminatingAccumulator
long numInvocations
boolean doTiming
boolean usingSchemaTupleFactory
boolean isEarlyTerminating
boolean isTerminated
ExpressionOperator expr
PORegexp regexop
int side
boolean rhsConstant
ArrayList<E> ptNodesVisited
OperatorPlan<E extends Operator> currentPlan
List<E> counterPlans
List<E> mAscCols
boolean isDenseRank
boolean isRowNumber
Long localCount
String taskID
String operationID
ArrayList<E> myPlans
boolean getNext
boolean inpEOP
PhysicalOperator curLeaf
PhysicalPlan curPlan
boolean inCombiner
BitSet processedSet
PhysicalPlan plan
PhysicalOperator comOp
byte compOperandType
List<E> inputPlans
List<E> opsToBeReset
boolean processingPlan
Object[] bags
Object[] data
byte[] resultTypes
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(ObjectInputStream is) throws IOException, ClassNotFoundException, ExecException
int fragment
List<E> phyPlanLists
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
String customPartitioner
POOptimizedForEach forEach
boolean newKey
Tuple res
boolean lastInputTuple
boolean firstTime
boolean useDefaultBag
long chunkSize
Result forEachResult
DataBag[] dbs
int lastBagIndex
long soFar
long mLimit
PhysicalPlan expressionPlan
FileSpec lFile
PigContext pc
boolean setUpDone
String signature
boolean isTmpLoad
long limit
List<E> plans
List<E> secondaryPlans
List<E> leafOps
List<E> secondaryLeafOps
byte index
byte keyType
byte mainKeyType
byte secondaryKeyType
boolean mIsDistinct
boolean isCross
Map<K,V> mProjectedColsMap
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(ObjectInputStream is) throws IOException, ClassNotFoundException, ExecException
private void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException, ExecException
boolean firstTime
POLocalRearrange[] LRs
OperatorKey opKey
Object prevLeftKey
Result prevLeftInp
Object prevRightKey
Result prevRightInp
boolean doingJoin
FuncSpec rightLoaderFuncSpec
String rightInputFileName
String indexFile
MultiMap<K,V> inpPlans
PhysicalOperator rightPipelineLeaf
PhysicalOperator rightPipelineRoot
boolean noInnerPlanOnRightSide
Object curJoinKey
Tuple curJoiningRightTup
int counter
int leftTupSize
int rightTupSize
int arrayListSize
LOJoin.JOINTYPE joinType
String signature
Schema leftInputSchema
Schema mergedInputSchema
List<E> packages
ArrayList<E> isKeyWrapped
boolean sameMapKeyType
boolean inCombiner
Object key
boolean isKeyTuple
boolean isKeyCompound
Tuple keyAsTuple
byte keyType
int numInputs
boolean useSecondaryKey
boolean[] inner
boolean distinct
Map<K,V> keyInfo
boolean firstTime
boolean useDefaultBag
POPackage.PackageType pkgType
PhysicalPlan keyPlan
ExpressionOperator keyLeaf
List<E> valuePlans
List<E> valueLeaves
int numRecsInRawMap
int numRecsInProcessedMap
Map<K,V> rawInputMap
Map<K,V> processedInputMap
boolean disableMapAgg
boolean sizeReductionChecked
boolean inputsExhausted
boolean doSpill
int firstTierThreshold
int secondTierThreshold
int sizeReduction
int avgTupleSize
Iterator<E> spillingIterator
boolean estimatedMemThresholds
Integer totalReducers
boolean loaded
PigContext pigContext
List<E> rankPlans
List<E> mAscCols
List<E> ExprOutputTypes
String operationID
int localCountIllustrator
List<E> sortPlans
List<E> ExprOutputTypes
List<E> mAscCols
POUserComparisonFunc mSortFunc
Comparator<T> mComparator
boolean inputsAccumulated
long limit
boolean isUDFComparatorUsed
DataBag sortedBag
String executableManagerStr
StreamingCommand command
Properties properties
boolean initialized
BlockingQueue<E> binaryOutputQueue
BlockingQueue<E> binaryInputQueue
boolean allInputFromPredecessorConsumed
boolean allOutputFromBinaryProcessed
BitSet done
boolean nextReturnEOP
int lastInd
Object amendKey
Tuple appendedFields
Collection<E> mContents
FileList mSpillFiles
long mSize
int mLastContentsSize
long avgTupleSize
boolean spillableRegistered
POPackageLite pkg
Object key
SelfSpillBag.MemoryLimits memLimit
Tuple item
ExecType execType
Properties properties
List<E> scriptJars
List<E> scriptFiles
Map<K,V> aliasedScriptFiles
Map<K,V> definedFunctions
Map<K,V> definedCommands
Properties log4jProperties
org.apache.log4j.Level defaultLogLevel
int defaultParallel
boolean inExplain
boolean inIllustrator
String last_alias
List<E> skippedShipPaths
List<E> params
List<E> paramFiles
String resourceName
String alias
byte type
DataType.Schema schema
String canonicalName
OperatorKey mKey
String scope
long id
String executable
String[] argv
List<E> shipSpec
List<E> cacheSpec
Map<K,V> handleSpecs
boolean persistStderr
String logDir
int logFilesLimit
boolean shipFiles
PigContext pigContext
SourceLocation location
String name
OperatorPlan plan
FuncSpec castFunc
LogicalSchema.LogicalFieldSchema castSchema
Object val
LogicalSchema.LogicalFieldSchema fieldSchema
LogicalSchema.LogicalFieldSchema uidOnlyFieldSchema
String mMapKey
int input
int col
String alias
Operator projectedOperator
LogicalRelationalOperator attachedRelationalOp
boolean isRangeProject
int startCol
int endCol
String startAlias
String endAlias
boolean[] mIsInner
MultiMap<K,V> mExpressionPlans
LOCogroup.GROUPTYPE mGroupType
LogicalSchema.LogicalFieldSchema groupKeyUidOnlySchema
Map<K,V> generatedInputUids
LogicalExpressionPlan filterPlan
boolean isSample
LogicalPlan innerPlan
LogicalSchema schema
int requestedParallelism
String alias
int lineNum
String mCustomPartitioner
HashSet<E> mPinnedOptions
String alias
byte type
long uid
LogicalSchema schema
ProjectExpression prj
LOForEach foreach
boolean sourceIsBag
MultiMap<K,V> mJoinPlans
boolean[] mInnerFlags
LOJoin.JOINTYPE mJoinType
long mLimit
LogicalExpressionPlan mlimitPlan
LogicalSchema scriptSchema
FileSpec fs
LogicalSchema determinedSchema
List<E> requiredFields
LOLoad.CastState castState
LogicalSchema uidOnlySchema
String schemaFile
String signature
long limit
boolean isTmpLoad
List<E> rankColPlans
List<E> ascCols
boolean isDenseRank
boolean isRowNumber
LogicalExpressionPlan filterPlan
Map<K,V> uidMapping
LogicalSchema scriptSchema
StreamingCommand command
LogicalSchema uidOnlySchema
LOStream.CastState castState
String alias
String cmd
MalformedURLException ex
ScalarExpression scalarExpr
String msg
LogicalExpression expr
SourceLocation location
Exception ex
String file
int line
int offset
String alias
DataBag internalDB
DataByteArray internalDBA
Schema internalSchema
int kind
int beginLine
int beginColumn
int endLine
int endColumn
String image
org.apache.pig.tools.parameters.Token next
org.apache.pig.tools.parameters.Token specialToken
JobStats.JobState state
org.apache.hadoop.conf.Configuration conf
List<E> mapStores
List<E> reduceStores
List<E> loads
ArrayList<E> outputs
ArrayList<E> inputs
String errorMsg
Exception exception
Boolean disableCounter
org.apache.hadoop.mapred.JobID jobId
long maxMapTime
long minMapTime
long avgMapTime
long medianMapTime
long maxReduceTime
long minReduceTime
long avgReduceTime
long medianReduceTime
int numberMaps
int numberReduces
long mapInputRecords
long mapOutputRecords
long reduceInputRecords
long reduceOutputRecords
long hdfsBytesWritten
long hdfsBytesRead
long spillCount
long activeSpillCountObj
long activeSpillCountRecs
HashMap<K,V> multiStoreCounters
HashMap<K,V> multiInputCounters
org.apache.hadoop.mapred.Counters counters
Copyright © 2007-2012 The Apache Software Foundation