Package org.apache.wayang.flink.operators

Interface FlinkExecutionOperator

All Superinterfaces:

ActualOperator, ElementaryOperator, ExecutionOperator, Operator, Serializable

All Known Implementing Classes:

FlinkCartesianOperator, FlinkCoGroupOperator, FlinkCollectionSink, FlinkCollectionSource, FlinkCountOperator, FlinkDistinctOperator, FlinkDoWhileOperator, FlinkFilterOperator, FlinkFlatMapOperator, FlinkGlobalMaterializedGroupOperator, FlinkGlobalReduceOperator, FlinkGroupByOperator, FlinkIntersectOperator, FlinkJoinOperator, FlinkLocalCallbackSink, FlinkLoopOperator, FlinkMapOperator, FlinkMapPartitionsOperator, FlinkMaterializedGroupByOperator, FlinkObjectFileSink, FlinkObjectFileSource, FlinkPageRankOperator, FlinkReduceByOperator, FlinkRepeatExpandedOperator, FlinkRepeatOperator, FlinkSampleOperator, FlinkSortOperator, FlinkTextFileSink, FlinkTextFileSource, FlinkTsvFileSink, FlinkUnionAllOperator, FlinkZipWithIdOperator

public interface FlinkExecutionOperator
extends ExecutionOperator, Serializable

Execution operator for the Flink platform.

Field Summary

Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator

FIRST_EPOCH

Method Summary

Modifier and Type	Method	Description
boolean	containsAction()	Tell whether this instances is a Flink action.
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
default <Type> Collection<Type>	getBroadCastFunction(String name)
default FlinkPlatform	getPlatform()

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, getLoadProfileEstimatorConfigurationKeys, getOriginal, getOutputChannelDescriptor, getSupportedInputChannels, getSupportedOutputChannels, isFiltered

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, isConversion, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, replaceWith, setContainer, setEpoch, setInput, setName, setOutput

Method Details

getPlatform

default FlinkPlatform getPlatform()

Specified by:

getPlatform in interface ExecutionOperator

Returns:

the platform that can run this operator

evaluate

Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>> evaluate(ChannelInstance[] inputs,
 ChannelInstance[] outputs,
 FlinkExecutor flinkExecutor,
 OptimizationContext.OperatorContext operatorContext)
                                                                      throws Exception

Throws:

Exception

containsAction

boolean containsAction()

Tell whether this instances is a Flink action. This is important to keep track on when Flink is actually initialized.

Returns:

whether this instance issues Flink actions

getBroadCastFunction

default <Type> Collection<Type> getBroadCastFunction(String name)