Package org.apache.wayang.java.operators
Class JavaReservoirSampleOperator<Type>
- java.lang.Object
-
- org.apache.wayang.core.plan.wayangplan.OperatorBase
-
- org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator<Type,Type>
-
- org.apache.wayang.basic.operators.SampleOperator<Type>
-
- org.apache.wayang.java.operators.JavaReservoirSampleOperator<Type>
-
- All Implemented Interfaces:
java.io.Serializable
,ActualOperator
,ElementaryOperator
,ExecutionOperator
,Operator
,JavaExecutionOperator
public class JavaReservoirSampleOperator<Type> extends SampleOperator<Type> implements JavaExecutionOperator
Java implementation of theJavaReservoirSampleOperator
.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.wayang.basic.operators.SampleOperator
SampleOperator.Methods
-
Nested classes/interfaces inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
OperatorBase.GsonSerializer
-
-
Field Summary
-
Fields inherited from class org.apache.wayang.basic.operators.SampleOperator
datasetSize, logger, sampleSizeFunction, seedFunction, UNKNOWN_DATASET_SIZE
-
Fields inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
inputSlots, outputSlots, STANDARD_OPERATOR_ARGS
-
Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
FIRST_EPOCH
-
-
Constructor Summary
Constructors Constructor Description JavaReservoirSampleOperator(SampleOperator<Type> that)
Copies an instance (exclusive of broadcasts).JavaReservoirSampleOperator(FunctionDescriptor.SerializableIntUnaryOperator sampleSizeFunction, DataSetType<Type> type, FunctionDescriptor.SerializableLongUnaryOperator seed)
Creates a new instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected ExecutionOperator
createCopy()
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>
evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Evaluates this operator.java.util.Collection<java.lang.String>
getLoadProfileEstimatorConfigurationKeys()
Provide theConfiguration
keys for theLoadProfileEstimator
specification of this instance.java.util.List<ChannelDescriptor>
getSupportedInputChannels(int index)
java.util.List<ChannelDescriptor>
getSupportedOutputChannels(int index)
Display the supportedChannel
s for a certainOutputSlot
.-
Methods inherited from class org.apache.wayang.basic.operators.SampleOperator
createCardinalityEstimator, getDatasetSize, getSampleMethod, getSampleSize, getSeed, getType, isDataSetSizeKnown, randomSeed, setDatasetSize, setSampleMethod, setSeedFunction
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator
getInput, getInputType, getOutput, getOutputType
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
accept, addBroadcastInput, addTargetPlatform, at, collectMappedInputSlots, collectMappedOutputSlots, copy, getAllInputs, getAllOutputs, getCardinalityEstimator, getContainer, getEpoch, getName, getOriginal, getSimpleClassName, getTargetPlatforms, isAuxiliary, isSupportingBroadcastInputs, propagateInputCardinality, propagateOutputCardinality, setAuxiliary, setCardinalityEstimator, setContainer, setEpoch, setName, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ActualOperator
accept
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ElementaryOperator
createCardinalityEstimator, getCardinalityEstimator, isAuxiliary, setAuxiliary, setCardinalityEstimator
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ExecutionOperator
copy, createLoadProfileEstimator, createOutputChannelInstances, getLimitBaseKey, getLoadProfileEstimatorConfigurationKey, getOriginal, getOutputChannelDescriptor, isFiltered
-
Methods inherited from interface org.apache.wayang.java.operators.JavaExecutionOperator
getPlatform
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
addBroadcastInput, addTargetPlatform, broadcastTo, broadcastTo, collectMappedInputSlots, collectMappedOutputSlots, connectTo, connectTo, getAllInputs, getAllOutputs, getCardinalityPusher, getContainer, getEffectiveOccupant, getEffectiveOccupant, getEpoch, getEstimationContextProperties, getForwards, getInnermostLoop, getInput, getInput, getLoopStack, getName, getNumBroadcastInputs, getNumInputs, getNumOutputs, getNumRegularInputs, getOuterInputSlot, getOutermostInputSlot, getOutermostOutputSlots, getOutput, getOutput, getParent, getTargetPlatforms, isAlternative, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, setContainer, setEpoch, setInput, setName, setOutput
-
-
-
-
Constructor Detail
-
JavaReservoirSampleOperator
public JavaReservoirSampleOperator(FunctionDescriptor.SerializableIntUnaryOperator sampleSizeFunction, DataSetType<Type> type, FunctionDescriptor.SerializableLongUnaryOperator seed)
Creates a new instance.
-
JavaReservoirSampleOperator
public JavaReservoirSampleOperator(SampleOperator<Type> that)
Copies an instance (exclusive of broadcasts).- Parameters:
that
- that should be copied
-
-
Method Detail
-
evaluate
public Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>> evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Description copied from interface:JavaExecutionOperator
Evaluates this operator. Takes a set of JavaStream
s according to the operator inputs and produces a set ofStream
s according to the operator outputs -- unless the operator is a sink, then it triggers execution.In addition, this method should give feedback of what this instance was doing by wiring the
LazyExecutionLineageNode
s of input and ouputChannelInstance
s and providing aCollection
of executedOptimizationContext.OperatorContext
s.- Specified by:
evaluate
in interfaceJavaExecutionOperator
- Parameters:
inputs
-ChannelInstance
s that satisfy the inputs of this operatoroutputs
-ChannelInstance
s that collect the outputs of this operatorjavaExecutor
- that executes this instanceoperatorContext
- optimization information for this instance- Returns:
Collection
s of what has been executed and produced
-
getLoadProfileEstimatorConfigurationKeys
public java.util.Collection<java.lang.String> getLoadProfileEstimatorConfigurationKeys()
Description copied from interface:ExecutionOperator
Provide theConfiguration
keys for theLoadProfileEstimator
specification of this instance.- Specified by:
getLoadProfileEstimatorConfigurationKeys
in interfaceExecutionOperator
- Returns:
- the
Configuration
keys
-
createCopy
protected ExecutionOperator createCopy()
- Overrides:
createCopy
in classOperatorBase
-
getSupportedInputChannels
public java.util.List<ChannelDescriptor> getSupportedInputChannels(int index)
Description copied from interface:ExecutionOperator
- Specified by:
getSupportedInputChannels
in interfaceExecutionOperator
- Parameters:
index
- the index of theInputSlot
- Returns:
- an
List
ofChannel
s'Class
es, ordered by their preference of use
-
getSupportedOutputChannels
public java.util.List<ChannelDescriptor> getSupportedOutputChannels(int index)
Description copied from interface:ExecutionOperator
Display the supportedChannel
s for a certainOutputSlot
.- Specified by:
getSupportedOutputChannels
in interfaceExecutionOperator
- Parameters:
index
- the index of theOutputSlot
- Returns:
- an
List
ofChannel
s'Class
es, ordered by their preference of use - See Also:
ExecutionOperator.getOutputChannelDescriptor(int)
-
-