Uses of Class
org.apache.wayang.flink.execution.FlinkExecutor

Packages that use FlinkExecutor

Package	Description
org.apache.wayang.flink.channels
org.apache.wayang.flink.operators

Uses of FlinkExecutor in org.apache.wayang.flink.channels

Methods in org.apache.wayang.flink.channels with parameters of type FlinkExecutor

Modifier and Type	Method	Description
void	DataSetChannel.Instance.accept(org.apache.flink.api.java.DataSet dataSet, FlinkExecutor flinkExecutor)

Constructors in org.apache.wayang.flink.channels with parameters of type FlinkExecutor

Modifier	Constructor	Description
	Instance(FlinkExecutor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)

Uses of FlinkExecutor in org.apache.wayang.flink.operators

Methods in org.apache.wayang.flink.operators with parameters of type FlinkExecutor

Modifier and Type	Method	Description
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkCartesianOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkCoGroupOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkCollectionSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkCollectionSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkCountOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkDistinctOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkDoWhileOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkExecutionOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkFilterOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkFlatMapOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkGlobalMaterializedGroupOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkGlobalReduceOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkGroupByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkIntersectOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkLocalCallbackSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkLoopOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkMapOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkMapPartitionsOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkMaterializedGroupByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkObjectFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkObjectFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkPageRankOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkReduceByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkRepeatExpandedOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkRepeatOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkSampleOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkSortOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkTextFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkTextFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkTsvFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkUnionAllOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	FlinkZipWithIdOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, FlinkExecutor flinkExecutor, OptimizationContext.OperatorContext operatorContext)