Serialized Form

Package org.apache.hadoop.zebra.tfile

Class org.apache.hadoop.zebra.tfile.CompareUtils.MemcmpRawComparator extends Object implements Serializable

Class org.apache.hadoop.zebra.tfile.CompareUtils.ScalarComparator extends Object implements Serializable

Class org.apache.hadoop.zebra.tfile.MetaBlockAlreadyExists extends IOException implements Serializable

Class org.apache.hadoop.zebra.tfile.MetaBlockDoesNotExist extends IOException implements Serializable

Package org.apache.hadoop.zebra.types

Class org.apache.hadoop.zebra.types.ZebraTuple extends DefaultTuple implements Serializable

serialVersionUID: 1L

Package org.apache.pig

Class org.apache.pig.FileSplitComparable extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

filename

String filename

offset

Long offset

Class org.apache.pig.FuncSpec extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

className

String className

ctorArgs

String[] ctorArgs

inputArgsSchema

Schema inputArgsSchema

Class org.apache.pig.LoadPushDown.RequiredField extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

alias

String alias

index

int index

subFields

List<E> subFields

type

byte type

Class org.apache.pig.LoadPushDown.RequiredFieldList extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

fields

List<E> fields

Class org.apache.pig.PigException extends IOException implements Serializable

serialVersionUID: 1L

Serialized Fields

errorCode

int errorCode

errorSource

byte errorSource

retriable

boolean retriable

detailedMessage

String detailedMessage

markedAsShowToUser

boolean markedAsShowToUser

Class org.apache.pig.ResourceSchema extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

fields

ResourceSchema.ResourceFieldSchema[] fields

sortKeys

int[] sortKeys

sortKeyOrders

ResourceSchema.Order[] sortKeyOrders

version

int version

Class org.apache.pig.ResourceSchema.ResourceFieldSchema extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

String name

type

byte type

description

String description

schema

ResourceSchema schema

Class org.apache.pig.ResourceStatistics.ResourceFieldStatistics extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

version

int version

numDistinctValues

Long numDistinctValues

mostCommonValues

Object[] mostCommonValues

We need some way to represent a histogram of values in the field, as those will be useful. However, we can't count on being able to hold such histograms in memory. Have to figure out how they can be kept on disk and represented here. for now.. don't create so many buckets you can't hold them in memory an ordered array of the most common values, in descending order of frequency

mostCommonValuesFreq

float[] mostCommonValuesFreq

an array that matches the mostCommonValues array, and lists the frequencies of those values as a fraction (0 through 1) of the total number of records

valueHistogram

Object[] valueHistogram

an ordered array of values, from min val to max val such that the number of records with values between valueHistogram[i] and and valueHistogram[i+1] is roughly equal for all values of i. NOTE: if mostCommonValues is non-empty, the values in that array should not be included in the histogram. Adjust accordingly.

Class org.apache.pig.SortColInfo extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

colName

String colName

colIndex

int colIndex

sortOrder

SortColInfo.Order sortOrder

Class org.apache.pig.SortInfo extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

isGloballySorted

boolean isGloballySorted

sortColInfoList

List<E> sortColInfoList

Package org.apache.pig.backend

Class org.apache.pig.backend.BackendException extends PigException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.backend.datastorage

Class org.apache.pig.backend.datastorage.DataStorageException extends BackendException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.backend.executionengine

Class org.apache.pig.backend.executionengine.ExecException extends BackendException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.backend.hadoop.datastorage

Class org.apache.pig.backend.hadoop.datastorage.HConfiguration extends Properties implements Serializable

serialVersionUID: 1L

Package org.apache.pig.backend.hadoop.executionengine.mapReduceLayer

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobCreationException extends FrontendException implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper extends Operator<MROpPlanVisitor> implements Serializable

serialVersionUID: 1L

Serialized Fields

mapPlan

PhysicalPlan mapPlan

reducePlan

PhysicalPlan reducePlan

combinePlan

PhysicalPlan combinePlan

mapKeyType

byte mapKeyType

mapDone

boolean mapDone

reduceDone

boolean reduceDone

endOfAllInputInMap

boolean endOfAllInputInMap

endOfAllInputInReduce

boolean endOfAllInputInReduce

globalSort

boolean globalSort

limitAfterSort

boolean limitAfterSort

limitOnly

boolean limitOnly

feature

org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper.OPER_FEATURE feature

needsDistinctCombiner

boolean needsDistinctCombiner

useSecondaryKey

boolean useSecondaryKey

quantFile

String quantFile

sortOrder

boolean[] sortOrder

secondarySortOrder

boolean[] secondarySortOrder

UDFs

Set<E> UDFs

scalars

Set<E> scalars

isUDFComparatorUsed

boolean isUDFComparatorUsed

scope

String scope

requestedParallelism

int requestedParallelism

customPartitioner

String customPartitioner

limit

long limit

splitter

boolean splitter

skewedJoin

boolean skewedJoin

skewedJoinPartitionFile

String skewedJoinPartitionFile

usingTypedComparator

boolean usingTypedComparator

combineSmallSplits

boolean combineSmallSplits

phyToMRMap

MultiMap<K,V> phyToMRMap

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRCompilerException extends VisitorException implements Serializable

serialVersionUID: 2L

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.NativeMapReduceOper extends MapReduceOper implements Serializable

serialVersionUID: 1L

Serialized Fields

nativeMRJar

String nativeMRJar

params

String[] params

Package org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.partitioners.CountingMap extends HashMap<K,Integer> implements Serializable

serialVersionUID: 1L

Serialized Fields

totalCount

long totalCount

Package org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter.InnerOperator extends Operator<PlanVisitor> implements Serializable

serialVersionUID: 1L

Serialized Fields

name

String name

plan

PhysicalPlan plan

code

int code

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.DotMRPrinter.InnerPlan extends OperatorPlan<DotMRPrinter.InnerOperator> implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.plans.MROperPlan extends OperatorPlan<MapReduceOper> implements Serializable

serialVersionUID: 1L

Package org.apache.pig.backend.hadoop.executionengine.physicalLayer

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.LogicalToPhysicalTranslatorException extends VisitorException implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator extends Operator<PhyPlanVisitor> implements Serializable

serialVersionUID: 1L

Serialized Fields

requestedParallelism

int requestedParallelism

inputs

List<E> inputs

outputs

List<E> outputs

resultType

byte resultType

parentPlan

PhysicalPlan parentPlan

inputAttached

boolean inputAttached

input

Tuple input

res

Result res

alias

String alias

lineageTracer

LineageTracer lineageTracer

accum

boolean accum

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.Result extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

returnStatus

byte returnStatus

result

Object result

Package org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Add extends BinaryExpressionOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryComparisonOperator extends BinaryExpressionOperator implements Serializable

Serialized Fields

operandType

byte operandType

trueRef

Boolean trueRef

falseRef

Boolean falseRef

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.BinaryExpressionOperator extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

lhs

ExpressionOperator lhs

rhs

ExpressionOperator rhs

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ConstantExpression extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

value

Object value

res

Result res

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Divide extends BinaryExpressionOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.EqualToExpr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.ExpressionOperator extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.GreaterThanExpr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.GTOrEqualToExpr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LessThanExpr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.LTOrEqualToExpr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Mod extends BinaryExpressionOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Multiply extends BinaryExpressionOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.NotEqualToExpr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POAnd extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POBinCond extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

cond

ExpressionOperator cond

lhs

ExpressionOperator lhs

rhs

ExpressionOperator rhs

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POCast extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialization Methods

readObject

private void readObject(ObjectInputStream is)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

Serialized Fields

funcSpec

FuncSpec funcSpec

castNotNeeded

boolean castNotNeeded

realType

Byte realType

fieldSchema

ResourceSchema.ResourceFieldSchema fieldSchema

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POIsNull extends UnaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POMapLookUp extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

key

String key

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONegative extends UnaryExpressionOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PONot extends UnaryComparisonOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

trueRes

Result trueRes

falseRes

Result falseRes

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POOr extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

resultSingleTupleBag

boolean resultSingleTupleBag

columns

ArrayList<E> columns

processingBagOfTuples

boolean processingBagOfTuples

overloaded

boolean overloaded

isProjectToEnd

boolean isProjectToEnd

startCol

int startCol

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp extends BinaryComparisonOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

impl

RegexImpl impl

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORelationToExprProject extends POProject implements Serializable

serialVersionUID: 1L

Serialized Fields

sendEmptyBagOnEOP

boolean sendEmptyBagOnEOP

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserComparisonFunc extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialization Methods

readObject

private void readObject(ObjectInputStream is)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

Serialized Fields

funcSpec

FuncSpec funcSpec

t1

Tuple t1

t2

Tuple t2

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc extends ExpressionOperator implements Serializable

serialVersionUID: 1L

Serialization Methods

readObject

private void readObject(ObjectInputStream is)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

Serialized Fields

funcSpec

FuncSpec funcSpec

origFSpec

FuncSpec origFSpec

initialized

boolean initialized

executor

MonitoredUDFExecutor executor

referencedOperator

PhysicalOperator referencedOperator

isAccumulationDone

boolean isAccumulationDone

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.Subtract extends BinaryExpressionOperator implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.UnaryComparisonOperator extends UnaryExpressionOperator implements Serializable

Serialized Fields

operandType

byte operandType

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.UnaryExpressionOperator extends ExpressionOperator implements Serializable

Serialized Fields

expr

ExpressionOperator expr

Package org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.regex.RegexInit extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

regexop

PORegexp regexop

side

int side

rhsConstant

boolean rhsConstant

Package org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhysicalPlan extends OperatorPlan<PhysicalOperator> implements Serializable

serialVersionUID: 1L

Serialized Fields

endOfAllInput

boolean endOfAllInput

opmap

MultiMap<K,V> opmap

Package org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCollectedGroup extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

plans

List<E> plans

leafOps

List<E> leafOps

keyType

byte keyType

output

Tuple output

outputBag

DataBag outputBag

prevKey

Object prevKey

useDefaultBag

boolean useDefaultBag

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCombinerPackage extends POPackage implements Serializable

serialVersionUID: 1L

Serialized Fields

mBags

boolean[] mBags

keyLookup

Map<K,V> keyLookup

numBags

int numBags

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODemux extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

myPlans

ArrayList<E> myPlans

getNext

boolean getNext

inpEOP

boolean inpEOP

curLeaf

PhysicalOperator curLeaf

curPlan

PhysicalPlan curPlan

The current pipeline plan

inCombiner

boolean inCombiner

processedSet

BitSet processedSet

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

inputsAccumulated

boolean inputsAccumulated

distinctBag

DataBag distinctBag

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

plan

PhysicalPlan plan

comOp

PhysicalOperator comOp

compOperandType

byte compOperandType

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

inputPlans

List<E> inputPlans

opsToBeReset

List<E> opsToBeReset

processingPlan

boolean processingPlan

bags

Object[] bags

data

Object[] data

resultTypes

byte[] resultTypes

isToBeFlattenedArray

boolean[] isToBeFlattenedArray

tIn

ExampleTuple tIn

noItems

int noItems

planLeafOps

PhysicalOperator[] planLeafOps

inpTuple

Tuple inpTuple

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialization Methods

readObject

private void readObject(ObjectInputStream is)
                 throws IOException,
                        ClassNotFoundException,
                        ExecException

Throws:

IOException

ClassNotFoundException

ExecException

Serialized Fields

fragment

int fragment

phyPlanLists

List<E> phyPlanLists

keyTypes

List<E> keyTypes

LRs

POLocalRearrange[] LRs

replFiles

FileSpec[] replFiles

constExps

ConstantExpression[] constExps

fe

POForEach fe

replicates

Map<K,V>[] replicates

processingPlan

boolean processingPlan

dumTup

Tuple dumTup

setUp

boolean setUp

isLeftOuterJoin

boolean isLeftOuterJoin

nullBag

DataBag nullBag

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POGlobalRearrange extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

customPartitioner

String customPartitioner

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POJoinPackage extends POPackage implements Serializable

serialVersionUID: 1L

Serialized Fields

forEach

POOptimizedForEach forEach

newKey

boolean newKey

res

Tuple res

lastInputTuple

boolean lastInputTuple

firstTime

boolean firstTime

useDefaultBag

boolean useDefaultBag

chunkSize

long chunkSize

forEachResult

Result forEachResult

dbs

DataBag[] dbs

lastBagIndex

int lastBagIndex

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLimit extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

soFar

long soFar

mLimit

long mLimit

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLoad extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

lFile

FileSpec lFile

pc

PigContext pc

setUpDone

boolean setUpDone

signature

String signature

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

plans

List<E> plans

secondaryPlans

List<E> secondaryPlans

leafOps

List<E> leafOps

secondaryLeafOps

List<E> secondaryLeafOps

index

byte index

keyType

byte keyType

mainKeyType

byte mainKeyType

secondaryKeyType

byte secondaryKeyType

mIsDistinct

boolean mIsDistinct

isCross

boolean isCross

mProjectedColsMap

Map<K,V> mProjectedColsMap

mSecondaryProjectedColsMap

Map<K,V> mSecondaryProjectedColsMap

mFakeTuple

Tuple mFakeTuple

mProjectStar

boolean mProjectStar

mSecondaryProjectStar

boolean mSecondaryProjectStar

isKeyTuple

boolean isKeyTuple

isSecondaryKeyTuple

boolean isSecondaryKeyTuple

mProjectedColsMapSize

int mProjectedColsMapSize

mSecondaryProjectedColsMapSize

int mSecondaryProjectedColsMapSize

useSecondaryKey

boolean useSecondaryKey

stripKeyFromValue

boolean stripKeyFromValue

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeCogroup extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialization Methods

readObject

private void readObject(ObjectInputStream is)
                 throws IOException,
                        ClassNotFoundException,
                        ExecException

Throws:

IOException

ClassNotFoundException

ExecException

Serialized Fields

sidFuncSpecs

List<E> sidFuncSpecs

sideFileSpecs

List<E> sideFileSpecs

LRs

POLocalRearrange[] LRs

indexFileName

String indexFileName

idxFuncSpec

FuncSpec idxFuncSpec

loaderSignatures

List<E> loaderSignatures

counter

int counter

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMergeJoin extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialization Methods

readObject

private void readObject(ObjectInputStream is)
                 throws IOException,
                        ClassNotFoundException,
                        ExecException

Throws:

IOException

ClassNotFoundException

ExecException

Serialized Fields

firstTime

boolean firstTime

LRs

POLocalRearrange[] LRs

opKey

OperatorKey opKey

prevLeftKey

Object prevLeftKey

prevLeftInp

Result prevLeftInp

prevRightKey

Object prevRightKey

prevRightInp

Result prevRightInp

doingJoin

boolean doingJoin

rightLoaderFuncSpec

FuncSpec rightLoaderFuncSpec

rightInputFileName

String rightInputFileName

indexFile

String indexFile

leftTuples

List<E> leftTuples

inpPlans

MultiMap<K,V> inpPlans

rightPipelineLeaf

PhysicalOperator rightPipelineLeaf

rightPipelineRoot

PhysicalOperator rightPipelineRoot

noInnerPlanOnRightSide

boolean noInnerPlanOnRightSide

curJoinKey

Object curJoinKey

curJoiningRightTup

Tuple curJoiningRightTup

counter

int counter

leftTupSize

int leftTupSize

rightTupSize

int rightTupSize

arrayListSize

int arrayListSize

signature

String signature

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POMultiQueryPackage extends POPackage implements Serializable

serialVersionUID: 1L

Serialized Fields

packages

List<E> packages

isKeyWrapped

ArrayList<E> isKeyWrapped

If the POLocalRearranges corresponding to the reduce plans in myPlans (the list of inner plans of the demux) have different key types then the MultiQueryOptimizer converts all the keys to be of type tuple by wrapping any non-tuple keys into Tuples (keys which are already tuples are left alone). The list below is a list of booleans indicating whether extra tuple wrapping was done for the key in the corresponding POLocalRearranges and if we need to "unwrap" the tuple to get to the key

sameMapKeyType

boolean sameMapKeyType

inCombiner

boolean inCombiner

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PONative extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

nativeMRjar

String nativeMRjar

params

String[] params

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POOptimizedForEach extends POForEach implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

key

Object key

isKeyTuple

boolean isKeyTuple

keyAsTuple

Tuple keyAsTuple

keyType

byte keyType

numInputs

int numInputs

useSecondaryKey

boolean useSecondaryKey

inner

boolean[] inner

distinct

boolean distinct

keyInfo

Map<K,V> keyInfo

firstTime

boolean firstTime

useDefaultBag

boolean useDefaultBag

pkgType

POPackage.PackageType pkgType

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackageLite extends POPackage implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPartitionRearrange extends POLocalRearrange implements Serializable

serialVersionUID: 1L

Serialized Fields

totalReducers

Integer totalReducers

loaded

boolean loaded

pigContext

PigContext pigContext

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

plans

List<E> plans

leafOps

List<E> leafOps

keyType

byte keyType

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSkewedJoin extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

mInnerFlags

boolean[] mInnerFlags

mJoinPlans

MultiMap<K,V> mJoinPlans

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

sortPlans

List<E> sortPlans

ExprOutputTypes

List<E> ExprOutputTypes

mAscCols

List<E> mAscCols

mSortFunc

POUserComparisonFunc mSortFunc

mComparator

Comparator<T> mComparator

inputsAccumulated

boolean inputsAccumulated

limit

long limit

isUDFComparatorUsed

boolean isUDFComparatorUsed

sortedBag

DataBag sortedBag

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort.SortComparator extends Object implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort.UDFSortComparator extends Object implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSortedDistinct extends PODistinct implements Serializable

serialVersionUID: 1L

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSplit extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

splitStore

FileSpec splitStore

myPlans

List<E> myPlans

processedSet

BitSet processedSet

inpEOP

boolean inpEOP

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStore extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

sFile

FileSpec sFile

schema

Schema schema

isTmpStore

boolean isTmpStore

isMultiStore

boolean isMultiStore

disableCounter

boolean disableCounter

index

int index

lFile

FileSpec lFile

sortInfo

SortInfo sortInfo

signature

String signature

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POStream extends PhysicalOperator implements Serializable

serialVersionUID: 2L

Serialized Fields

executableManagerStr

String executableManagerStr

command

StreamingCommand command

properties

Properties properties

initialized

boolean initialized

binaryOutputQueue

BlockingQueue<E> binaryOutputQueue

binaryInputQueue

BlockingQueue<E> binaryInputQueue

allInputFromPredecessorConsumed

boolean allInputFromPredecessorConsumed

allOutputFromBinaryProcessed

boolean allOutputFromBinaryProcessed

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POUnion extends PhysicalOperator implements Serializable

serialVersionUID: 1L

Serialized Fields

done

BitSet done

nextReturnEOP

boolean nextReturnEOP

lastInd

int lastInd

Package org.apache.pig.backend.hadoop.executionengine.physicalLayer.util

Class org.apache.pig.backend.hadoop.executionengine.physicalLayer.util.MonitoredUDFExecutor extends Object implements Serializable

Package org.apache.pig.data

Class org.apache.pig.data.AccumulativeBag extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

index

int index

Class org.apache.pig.data.AmendableTuple extends DefaultTuple implements Serializable

serialVersionUID: 2L

Serialized Fields

amendKey

Object amendKey

Class org.apache.pig.data.BinSedesTuple extends DefaultTuple implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.DataByteArray extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

mData

byte[] mData

Class org.apache.pig.data.DefaultAbstractBag extends Object implements Serializable

Serialized Fields

mContents

Collection<E> mContents

mSpillFiles

FileList mSpillFiles

mSize

long mSize

mLastContentsSize

int mLastContentsSize

mMemSize

long mMemSize

Class org.apache.pig.data.DefaultAbstractBag.BagDelimiterTuple extends DefaultTuple implements Serializable

Class org.apache.pig.data.DefaultAbstractBag.EndBag extends DefaultAbstractBag.BagDelimiterTuple implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.DefaultAbstractBag.StartBag extends DefaultAbstractBag.BagDelimiterTuple implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.DefaultDataBag extends DefaultAbstractBag implements Serializable

serialVersionUID: 2L

Class org.apache.pig.data.DefaultTuple extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

isNull

boolean isNull

mFields

List<E> mFields

Class org.apache.pig.data.DistinctDataBag extends DefaultAbstractBag implements Serializable

serialVersionUID: 2L

Class org.apache.pig.data.FileList extends ArrayList<File> implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.InternalCachedBag extends DefaultAbstractBag implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.InternalDistinctBag extends SortedSpillBag implements Serializable

serialVersionUID: 2L

Class org.apache.pig.data.InternalMap extends HashMap<Object,Object> implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.InternalSortedBag extends SortedSpillBag implements Serializable

serialVersionUID: 2L

Class org.apache.pig.data.NonSpillableDataBag extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

mContents

List<E> mContents

Class org.apache.pig.data.ReadOnceBag extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

pkg

POPackageLite pkg

key

Object key

Class org.apache.pig.data.SingleTupleBag extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

item

Tuple item

Class org.apache.pig.data.SortedDataBag extends DefaultAbstractBag implements Serializable

serialVersionUID: 2L

Serialized Fields

mReadStarted

boolean mReadStarted

Class org.apache.pig.data.SortedSpillBag extends DefaultAbstractBag implements Serializable

serialVersionUID: 1L

Class org.apache.pig.data.TargetedTuple extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

t

Tuple t

targetOps

List<E> targetOps

isNull

boolean isNull

Class org.apache.pig.data.TimestampedTuple extends DefaultTuple implements Serializable

serialVersionUID: 2L

Serialized Fields

timestamp

double timestamp

heartbeat

boolean heartbeat

Package org.apache.pig.impl

Class org.apache.pig.impl.PigContext extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

execType

ExecType execType

properties

Properties properties

scriptFiles

List<E> scriptFiles

scriptJars

List<E> scriptJars

definedFunctions

Map<K,V> definedFunctions

a table mapping function names to function specs.

definedCommands

Map<K,V> definedCommands

a table mapping names to streaming commands.

log4jProperties

Properties log4jProperties

defaultLogLevel

org.apache.log4j.Level defaultLogLevel

defaultParallel

int defaultParallel

inExplain

boolean inExplain

inIllustrator

boolean inIllustrator

last_alias

String last_alias

skippedShipPaths

List<E> skippedShipPaths

Package org.apache.pig.impl.io

Class org.apache.pig.impl.io.FileSpec extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

fileName

String fileName

funcSpec

FuncSpec funcSpec

Package org.apache.pig.impl.logicalLayer

Class org.apache.pig.impl.logicalLayer.FrontendException extends PigException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.impl.logicalLayer.schema

Class org.apache.pig.impl.logicalLayer.schema.Schema extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

mFields

List<E> mFields

mAliases

Map<K,V> mAliases

mFieldSchemas

MultiMap<K,V> mFieldSchemas

twoLevelAccessRequired

boolean twoLevelAccessRequired

Class org.apache.pig.impl.logicalLayer.schema.Schema.FieldSchema extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

alias

String alias

Alias for this field.

type

byte type

Datatype, using codes from DataType.

schema

Schema schema

If this is a tuple itself, it can have a schema. Otherwise this field must be null.

canonicalName

String canonicalName

Canonical name. This name uniquely identifies a field throughout the query. Unlike a an alias, it cannot be changed. It will change when the field is transformed in some way (such as being used in an arithmetic expression or passed to a udf). At that point a new canonical name will be generated for the field.

Class org.apache.pig.impl.logicalLayer.schema.SchemaMergeException extends FrontendException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.impl.logicalLayer.validators

Class org.apache.pig.impl.logicalLayer.validators.TypeCheckerException extends VisitorException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.impl.plan

Class org.apache.pig.impl.plan.Operator extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

mKey

OperatorKey mKey

OperatorKey associated with this operator. This key is used to find the operator in an OperatorPlan.

Class org.apache.pig.impl.plan.OperatorKey extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

scope

String scope

id

long id

Class org.apache.pig.impl.plan.OperatorPlan extends Object implements Serializable

Serialized Fields

mOps

Map<K,V> mOps

mKeys

Map<K,V> mKeys

mFromEdges

MultiMap<K,V> mFromEdges

mToEdges

MultiMap<K,V> mToEdges

mSoftFromEdges

MultiMap<K,V> mSoftFromEdges

mSoftToEdges

MultiMap<K,V> mSoftToEdges

mRoots

List<E> mRoots

mLeaves

List<E> mLeaves

Class org.apache.pig.impl.plan.PlanException extends FrontendException implements Serializable

serialVersionUID: 1L

Class org.apache.pig.impl.plan.PlanValidationException extends VisitorException implements Serializable

serialVersionUID: 1L

Class org.apache.pig.impl.plan.VisitorException extends FrontendException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.impl.plan.optimizer

Class org.apache.pig.impl.plan.optimizer.OptimizerException extends VisitorException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.impl.streaming

Class org.apache.pig.impl.streaming.StreamingCommand extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

executable

String executable

argv

String[] argv

shipSpec

List<E> shipSpec

cacheSpec

List<E> cacheSpec

handleSpecs

Map<K,V> handleSpecs

Map from the the stdin/stdout/stderr handles to their specifications

persistStderr

boolean persistStderr

logDir

String logDir

logFilesLimit

int logFilesLimit

shipFiles

boolean shipFiles

pigContext

PigContext pigContext

Class org.apache.pig.impl.streaming.StreamingCommand.HandleSpec extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

name

String name

spec

String spec

Package org.apache.pig.impl.util

Class org.apache.pig.impl.util.LinkedMultiMap extends MultiMap<K,V> implements Serializable

serialVersionUID: 1L

Class org.apache.pig.impl.util.MultiMap extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

mMap

Map<K,V> mMap

Class org.apache.pig.impl.util.Pair extends Object implements Serializable

serialVersionUID: 1L

Serialized Fields

first

Object first

second

Object second

Package org.apache.pig.newplan

Class org.apache.pig.newplan.PlanEdge extends MultiMap<Operator,Operator> implements Serializable

serialVersionUID: 1L

Package org.apache.pig.newplan.logical.relational

Class org.apache.pig.newplan.logical.relational.SchemaNotDefinedException extends RuntimeException implements Serializable

serialVersionUID: 1L

Package org.apache.pig.newplan.logical.rules

Class org.apache.pig.newplan.logical.rules.NotConversionVisitor extends Object implements Serializable

Package org.apache.pig.parser

Class org.apache.pig.parser.DuplicatedSchemaAliasException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

alias

String alias

Class org.apache.pig.parser.InvalidCommandException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

cmd

String cmd

Class org.apache.pig.parser.InvalidPathException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

ex

MalformedURLException ex

Class org.apache.pig.parser.InvalidScalarProjectionException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

scalarExpr

ScalarExpression scalarExpr

msg

String msg

Class org.apache.pig.parser.NonProjectExpressionException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

expr

LogicalExpression expr

Class org.apache.pig.parser.ParserException extends FrontendException implements Serializable

serialVersionUID: 1L

Class org.apache.pig.parser.ParserValidationException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

cause

String cause

ex

Exception ex

Class org.apache.pig.parser.PigRecognitionException extends org.antlr.runtime.RecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

location

SourceLocation location

Class org.apache.pig.parser.PlanGenerationFailureException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

ex

Exception ex

Class org.apache.pig.parser.UndefinedAliasException extends PigRecognitionException implements Serializable

serialVersionUID: 1L

Serialized Fields

alias

String alias

Package org.apache.pig.pen.util

Class org.apache.pig.pen.util.ExampleTuple extends Object implements Serializable

serialVersionUID: 2L

Serialized Fields

synthetic

boolean synthetic

omittable

boolean omittable

expr

Object expr

t

Tuple t

Package org.apache.pig.piggybank.evaluation.stats

Class org.apache.pig.piggybank.evaluation.stats.COR extends EvalFunc<DataBag> implements Serializable

Serialized Fields

schemaName

Vector<E> schemaName

Deprecated.

flag

boolean flag

Deprecated.

Class org.apache.pig.piggybank.evaluation.stats.COR.Final extends EvalFunc<DataBag> implements Serializable

Serialized Fields

schemaName

Vector<E> schemaName

flag

boolean flag

Class org.apache.pig.piggybank.evaluation.stats.COR.Initial extends EvalFunc<Tuple> implements Serializable

Class org.apache.pig.piggybank.evaluation.stats.COR.Intermed extends EvalFunc<Tuple> implements Serializable

Class org.apache.pig.piggybank.evaluation.stats.COV extends EvalFunc<DataBag> implements Serializable

Serialized Fields

schemaName

Vector<E> schemaName

Deprecated.

flag

boolean flag

Deprecated.

Class org.apache.pig.piggybank.evaluation.stats.COV.Final extends EvalFunc<DataBag> implements Serializable

Serialized Fields

schemaName

Vector<E> schemaName

flag

boolean flag

Class org.apache.pig.piggybank.evaluation.stats.COV.Initial extends EvalFunc<Tuple> implements Serializable

Class org.apache.pig.piggybank.evaluation.stats.COV.Intermed extends EvalFunc<Tuple> implements Serializable