Package org.apache.wayang.flink.operators

Interface Summary

Interface	Description
FlinkExecutionOperator	Execution operator for the Flink platform.

Class Summary

Class	Description
FlinkCartesianOperator<InputType0,InputType1>	Flink implementation of the CartesianOperator.
FlinkCoGroupOperator<InputType0,InputType1,TypeKey>	Flink implementation of the CoGroupOperator.
FlinkCollectionSink<Type>	Converts DataSetChannel into a CollectionChannel
FlinkCollectionSource<Type>	This is execution operator implements the CollectionSource.
FlinkCountOperator<Type>	Flink implementation of the CountOperator.
FlinkDistinctOperator<Type>	Flink implementation of the DistinctOperator.
FlinkDoWhileOperator<InputType,ConvergenceType>	Flink implementation of the DoWhileOperator.
FlinkFilterOperator<Type>	Flink implementation of the FilterOperator.
FlinkFlatMapOperator<InputType,OutputType>	Flink implementation of the FlatMapOperator.
FlinkGlobalMaterializedGroupOperator<Type>	Flink implementation of the GlobalMaterializedGroupOperator.
FlinkGlobalReduceOperator<Type>	Flink implementation of the GlobalReduceOperator.
FlinkGroupByOperator<InputType,KeyType>	Flink implementation of the GroupByOperator.
FlinkIntersectOperator<Type>	Flink implementation of the IntersectOperator.
FlinkJoinOperator<InputType0,InputType1,KeyType>	Flink implementation of the JoinOperator.
FlinkLocalCallbackSink<Type extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.
FlinkLoopOperator<InputType,ConvergenceType>	Flink implementation of the RepeatOperator.
FlinkMapOperator<InputType,OutputType>	Flink implementation of the MapOperator.
FlinkMapPartitionsOperator<InputType,OutputType>	Flink implementation of the MapPartitionsOperator.
FlinkMaterializedGroupByOperator<Type,KeyType>	Flink implementation of the MaterializedGroupByOperator.
FlinkObjectFileSink<Type>	Operator for the FlinkPlatform that creates a sequence file.
FlinkObjectFileSource<Type>	Operator for the FlinkPlatform that creates a sequence file.
FlinkPageRankOperator	Flink implementation of the PageRankOperator.
FlinkPageRankOperator.BuildOutgoingEdgeList	A reduce function that takes a sequence of edges and builds the adjacency list for the vertex where the edges originate.
FlinkPageRankOperator.Dampener	The function that applies the page rank dampening formula.
FlinkPageRankOperator.EpsilonFilter	Filter that filters vertices where the rank difference is below a threshold.
FlinkPageRankOperator.JoinVertexWithEdgesMatch	Join function that distributes a fraction of a vertex's rank to all neighbors.
FlinkPageRankOperator.RankAssigner	A map function that assigns an initial rank to all pages.
FlinkReduceByOperator<InputType,KeyType>	Flink implementation of the ReduceByOperator.
FlinkRepeatExpandedOperator<Type>	Flink implementation of the RepeatOperator.
FlinkRepeatOperator<Type>	Flink implementation of the RepeatOperator.
FlinkSampleOperator<Type>	Flink implementation of the SampleOperator.
FlinkSortOperator<InputType,KeyType>	Flink implementation of the SortOperator.
FlinkTextFileSink<Type>	Implementation of the TextFileSink operator for the Flink platform.
FlinkTextFileSource	Provides a Collection to a Flink job.
FlinkTsvFileSink<Type extends Tuple2<?,?>>	Created by bertty on 31-10-17.
FlinkUnionAllOperator<Type>	Flink implementation of the UnionAllOperator.
FlinkZipWithIdOperator<InputType>	Flink implementation of the MapOperator.