Uses of Interface
org.apache.wayang.flink.operators.FlinkExecutionOperator

Packages that use FlinkExecutionOperator

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

Uses of FlinkExecutionOperator in org.apache.wayang.flink.execution

Constructors in org.apache.wayang.flink.execution with parameters of type FlinkExecutionOperator

Constructor	Description
FlinkExecutionContext(FlinkExecutionOperator operator, ChannelInstance[] inputs, int iterationNumber)

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

Classes in org.apache.wayang.flink.operators that implement FlinkExecutionOperator

Modifier and Type	Class	Description
class	FlinkCartesianOperator<InputType0,InputType1>	Flink implementation of the CartesianOperator.
class	FlinkCoGroupOperator<InputType0,InputType1,TypeKey>	Flink implementation of the CoGroupOperator.
class	FlinkCollectionSink<Type>	Converts DataSetChannel into a CollectionChannel
class	FlinkCollectionSource<Type>	This is execution operator implements the CollectionSource.
class	FlinkCountOperator<Type>	Flink implementation of the CountOperator.
class	FlinkDistinctOperator<Type>	Flink implementation of the DistinctOperator.
class	FlinkDoWhileOperator<InputType,ConvergenceType>	Flink implementation of the DoWhileOperator.
class	FlinkFilterOperator<Type>	Flink implementation of the FilterOperator.
class	FlinkFlatMapOperator<InputType,OutputType>	Flink implementation of the FlatMapOperator.
class	FlinkGlobalMaterializedGroupOperator<Type>	Flink implementation of the GlobalMaterializedGroupOperator.
class	FlinkGlobalReduceOperator<Type>	Flink implementation of the GlobalReduceOperator.
class	FlinkGroupByOperator<InputType,KeyType>	Flink implementation of the GroupByOperator.
class	FlinkIntersectOperator<Type>	Flink implementation of the IntersectOperator.
class	FlinkJoinOperator<InputType0,InputType1,KeyType>	Flink implementation of the JoinOperator.
class	FlinkLocalCallbackSink<Type extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.
class	FlinkLoopOperator<InputType,ConvergenceType>	Flink implementation of the RepeatOperator.
class	FlinkMapOperator<InputType,OutputType>	Flink implementation of the MapOperator.
class	FlinkMapPartitionsOperator<InputType,OutputType>	Flink implementation of the MapPartitionsOperator.
class	FlinkMaterializedGroupByOperator<Type,KeyType>	Flink implementation of the MaterializedGroupByOperator.
class	FlinkObjectFileSink<Type>	Operator for the FlinkPlatform that creates a sequence file.
class	FlinkObjectFileSource<Type>	Operator for the FlinkPlatform that creates a sequence file.
class	FlinkPageRankOperator	Flink implementation of the PageRankOperator.
class	FlinkReduceByOperator<InputType,KeyType>	Flink implementation of the ReduceByOperator.
class	FlinkRepeatExpandedOperator<Type>	Flink implementation of the RepeatOperator.
class	FlinkRepeatOperator<Type>	Flink implementation of the RepeatOperator.
class	FlinkSampleOperator<Type>	Flink implementation of the SampleOperator.
class	FlinkSortOperator<InputType,KeyType>	Flink implementation of the SortOperator.
class	FlinkTextFileSink<Type>	Implementation of the TextFileSink operator for the Flink platform.
class	FlinkTextFileSource	Provides a Collection to a Flink job.
class	FlinkTsvFileSink<Type extends Tuple2<?,?>>	Created by bertty on 31-10-17.
class	FlinkUnionAllOperator<Type>	Flink implementation of the UnionAllOperator.
class	FlinkZipWithIdOperator<InputType>	Flink implementation of the MapOperator.