org.apache.pig.backend.hadoop.executionengine.spark.operator

Class POPoissonSampleSpark

java.lang.Object

org.apache.pig.impl.plan.Operator<PhyPlanVisitor>

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

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

org.apache.pig.backend.hadoop.executionengine.spark.operator.POPoissonSampleSpark

All Implemented Interfaces:

Serializable, Cloneable, Comparable<Operator>, Illustrable

public class POPoissonSampleSpark
extends POPoissonSample

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

PhysicalOperator.OriginalLocation

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPoissonSample

avgTupleMemSz, DEFAULT_SAMPLE_RATE, heapPerc, initialized, memToSkipPerSample, newSample, numRowSplTupleReturned, numRowsSampled, numSkipped, rowNum, sampleRate, serialVersionUID, skipInterval, totalMemory

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType

Fields inherited from class org.apache.pig.impl.plan.Operator

mKey

Constructor Summary

Constructors

Constructor and Description
POPoissonSampleSpark(OperatorKey k, int rp, int sr, float hp, long tm)

Method Summary

Modifier and Type	Method and Description
Result	getNextTuple()
boolean	isEndOfInput()
String	name()
void	setEndOfInput(boolean isEndOfInput)

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPoissonSample

createNumRowTuple, illustratorMarkup, supportsMultipleInputs, supportsMultipleOutputs, updateSkipInterval, visit

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

addOriginalLocation, addOriginalLocation, attachInput, clone, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup

Methods inherited from class org.apache.pig.impl.plan.Operator

compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

POPoissonSampleSpark

public POPoissonSampleSpark(OperatorKey k,
                            int rp,
                            int sr,
                            float hp,
                            long tm)

Method Detail

isEndOfInput

public boolean isEndOfInput()

setEndOfInput

public void setEndOfInput(boolean isEndOfInput)

getNextTuple

public Result getNextTuple()
                    throws ExecException

Overrides:

getNextTuple in class POPoissonSample

Throws:

ExecException

name

public String name()

Overrides:

name in class POPoissonSample