Package org.apache.wayang.flink.operators

package org.apache.wayang.flink.operators

Related Packages

Package	Description
org.apache.wayang.flink

Class	Description
CollectionSplittableIterator<T>
FlinkBoundedTextFileSource	Opens a Flink bounded DataStream on a TextFileSource.
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.
FlinkDataStreamCollectionSink<T>	Converts DataStreamChannel into a CollectionChannel
FlinkDataStreamJoinOperator<I0,I1,K>
FlinkDataStreamLocalCallbackSink<T extends Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.
FlinkDataStreamMapOperator<I,O>
FlinkDistinctOperator<Type>	Flink implementation of the DistinctOperator.
FlinkDoWhileOperator<InputType,ConvergenceType>	Flink implementation of the DoWhileOperator.
FlinkExecutionOperator	Execution operator for the Flink platform.
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 Serializable>	Implementation of the LocalCallbackSink operator for the Flink platform.
FlinkLoopOperator<InputType,ConvergenceType>	Flink implementation of the LoopOperator.
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	Implementation of the TextFileSource operator for FlinkPlatform.
FlinkTsvFileSink<Type extends Tuple2<?,?>>	Execution operator that writes tab-separated values (TSV) for FlinkPlatform
FlinkUnionAllOperator<Type>	Flink implementation of the UnionAllOperator.
FlinkZipWithIdOperator<InputType>	Flink implementation of the ZipWithIdOperator.
ScalaTupleSerializer