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
byte[] mapKeyTypeOfSplittees
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
long totalCount
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
byte operandType
ExpressionOperator lhs
ExpressionOperator rhs
ExpressionOperator cond
ExpressionOperator lhs
ExpressionOperator rhs
private void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
FuncSpec funcSpec
boolean castNotNeeded
Byte realType
ResourceSchema.ResourceFieldSchema fieldSchema
String key
RegexImpl impl
boolean sendEmptyBagOnEOP
private void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void readObject(ObjectInputStream is) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
FuncSpec funcSpec
FuncSpec origFSpec
boolean initialized
MonitoredUDFExecutor executor
PhysicalOperator referencedOperator
boolean isAccumulationDone
String signature
boolean haveCheckedIfTerminatingAccumulator
long numInvocations
long timingFrequency
boolean doTiming
boolean usingSchemaTupleFactory
boolean isEarlyTerminating
boolean isTerminated
byte operandType
ExpressionOperator expr
PORegexp regexop
int side
boolean rhsConstant
PigNullableWritable keyWritable
List<E> packagers
ArrayList<E> isKeyWrapped
boolean sameMapKeyType
boolean inCombiner
PigNullableWritable keyWritable
boolean[] readOnce
DataBag[] bags
Object key
boolean isKeyTuple
boolean isKeyCompound
byte keyType
int numInputs
boolean useSecondaryKey
boolean[] inner
boolean distinct
Map<K,V> keyInfo
Packager.PackageType pkgType
POPackage parent
String broadcastedVariableName
List<E> counterPlans
List<E> mAscCols
boolean isDenseRank
boolean isRowNumber
Long localCount
Integer taskID
String operationID
ArrayList<E> myPlans
boolean getNext
boolean inpEOP
PhysicalOperator curLeaf
PhysicalPlan curPlan
boolean inCombiner
BitSet processedSet
String customPartitioner
PhysicalPlan plan
PhysicalOperator comOp
List<E> inputPlans
List<E> opsToBeReset
PhysicalOperator[] planLeafOps
byte[] resultTypes
boolean[] isToBeFlattenedArray
int noItems
boolean mapSideOnly
Boolean endOfAllInputProcessing
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
boolean isLeftOuterJoin
DataBag nullBag
Schema[] inputSchemas
Schema[] keySchemas
SchemaTupleFactory tf
String customPartitioner
boolean cross
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
byte endOfRecordMark
boolean leftInputConsumedInSpark
Schema leftInputSchema
Schema mergedInputSchema
SchemaTupleFactory tf
Object key
int numInputs
boolean lastBagReadOnly
Packager pkgr
PigNullableWritable keyWritable
int listSizeThreshold
PhysicalPlan keyPlan
ExpressionOperator keyLeaf
List<E> valuePlans
List<E> valueLeaves
boolean isGroupAll
PigContext pigContext
int sampleRate
float heapPerc
Long totalMemory
List<E> rankPlans
List<E> mAscCols
List<E> ExprOutputTypes
String operationID
int localCountIllustrator
int numSamples
List<E> sortPlans
List<E> ExprOutputTypes
List<E> mAscCols
POUserComparisonFunc mSortFunc
Comparator<T> mComparator
long limit
boolean isUDFComparatorUsed
String executableManagerStr
StreamingCommand command
Properties properties
BlockingQueue<E> binaryOutputQueue
BlockingQueue<E> binaryInputQueue
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.BitSet done
boolean nextReturnEOP
int lastInd
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
Properties properties
PigSplit pigSplit
PigSplit pigSplit
byte index
Object key
boolean useSecondaryKey
boolean[] secondarySortOrder
POLocalRearrange[] LRs
POSkewedJoin poSkewedJoin
String skewedJoinPartitionFile
boolean useSecondaryKey
boolean[] secondarySortOrder
String customPartitioner
POLocalRearrange lr
POPackage pkg
boolean useSecondaryKey
boolean[] secondarySortOrder
String name
PhysicalPlan plan
int code
PhysicalPlan physicalPlan
Set<E> UDFs
String customPartitioner
Set<E> scalars
int requestedParallelism
BitSet feature
boolean splitter
String skewedJoinPartitionFile
boolean usingTypedComparator
boolean combineSmallSplits
List<E> crossKeys
MultiMap<K,V> multiQueryOptimizeConnectionMap
boolean isUDFComparatorUsed
String quantFile
boolean globalSort
boolean needsDistinctCombiner
Boolean combinerInMap
Boolean combinerInReducer
String inputClassName
String outputClassName
org.apache.tez.dag.api.EdgeProperty.SchedulingType schedulingType
org.apache.tez.dag.api.EdgeProperty.DataSourceType dataSourceType
org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType
Class<T> partitionerClass
boolean useSecondaryKey
boolean[] secondarySortOrder
String intermediateOutputKeyClass
String intermediateOutputValueClass
String intermediateOutputKeyComparatorClass
Map<K,V> outEdges
Map<K,V> inEdges
Set<E> UDFs
Set<E> scalars
AtomicInteger requestedParallelism
int estimatedParallelism
boolean dontEstimateParallelism
boolean overrideIntermediateParallelism
int vertexParallelism
boolean splitter
OperatorKey splitParent
boolean closed
boolean segmentBelow
boolean[] sortOrder
boolean combineSmallSplits
TezOperator sampleOperator
TezOperator sortOperator
boolean needEstimateParallelism
boolean useSecondaryKey
List<E> crossKeys
boolean useMRMapSettings
boolean useGraceParallelism
Map<K,V> parallelismFactorPerSuccessor
Boolean intermediateReducer
BitSet feature
List<E> vertexGroupMembers
Map<K,V> vertexGroupStores
boolean isVertexGroup
TezOperator.LoaderInfo loaderInfo
long totalInputFilesSize
int estimatedTotalParallelism
PigContext pigContext
String jobName
long dagId
TezOperPlan tezPlan
boolean bloomCreatedInMap
int vectorSizeBytes
int numHash
int hashType
byte bloomKeyType
boolean isCombiner
String inputKey
int numBloomFilters
String bloomOutputKey
boolean skipNullKeys
boolean createBloomInMap
int numBloomFilters
int vectorSizeBytes
int numHash
int hashType
String inputKey
String outputKey
boolean connectedToPackage
boolean isSkewedJoin
String inputKey
String outputKey
String inputKey
org.apache.pig.builtin.BigDecimalWrapper.BigDecimalInfinity infinity
org.apache.pig.builtin.BigIntegerWrapper.BigIntegerInfinity infinity
int index
Object amendKey
Tuple appendedFields
byte[] mData
Collection<E> mContents
FileList mSpillFiles
long mSize
long aggSampleTupleSize
int sampled
boolean spillableRegistered
Comparator<T> mComp
PriorityQueue<E> priorityQ
long limit
Packager pkgr
PigNullableWritable keyWritable
SelfSpillBag.MemoryLimits memLimit
long maxMemUsage
long cacheLimit
long memUsage
long numObjsSizeChecked
Tuple item
boolean mReadStarted
double timestamp
boolean heartbeat
ExecType execType
Properties properties
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 inDumpSchema
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
int lineNumber
org.apache.avro.generic.GenericArray<T> theArray
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
String alias
String cmd
MalformedURLException ex
ScalarExpression scalarExpr
String msg
LogicalExpression expr
SourceLocation location
Exception ex
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
int errorCode
Copyright © 2007-2017 The Apache Software Foundation