Package org.apache.wayang.flink.operators
package org.apache.wayang.flink.operators
-
ClassDescriptionFlinkCartesianOperator<InputType0,
InputType1> Flink implementation of theCartesianOperator.FlinkCoGroupOperator<InputType0,InputType1, TypeKey> Flink implementation of theCoGroupOperator.FlinkCollectionSink<Type>ConvertsDataSetChannelinto aCollectionChannelFlinkCollectionSource<Type>This is execution operator implements theCollectionSource.FlinkCountOperator<Type>Flink implementation of theCountOperator.FlinkDistinctOperator<Type>Flink implementation of theDistinctOperator.FlinkDoWhileOperator<InputType,ConvergenceType> Flink implementation of theDoWhileOperator.Execution operator for the Flink platform.FlinkFilterOperator<Type>Flink implementation of theFilterOperator.FlinkFlatMapOperator<InputType,OutputType> Flink implementation of theFlatMapOperator.Flink implementation of theGlobalMaterializedGroupOperator.Flink implementation of theGlobalReduceOperator.FlinkGroupByOperator<InputType,KeyType> Flink implementation of theGroupByOperator.FlinkIntersectOperator<Type>Flink implementation of theIntersectOperator.FlinkJoinOperator<InputType0,InputType1, KeyType> Flink implementation of theJoinOperator.FlinkLocalCallbackSink<Type extends Serializable>Implementation of theLocalCallbackSinkoperator for the Flink platform.FlinkLoopOperator<InputType,ConvergenceType> Flink implementation of theRepeatOperator.FlinkMapOperator<InputType,OutputType> Flink implementation of theMapOperator.FlinkMapPartitionsOperator<InputType,OutputType> Flink implementation of theMapPartitionsOperator.FlinkMaterializedGroupByOperator<Type,KeyType> Flink implementation of theMaterializedGroupByOperator.FlinkObjectFileSink<Type>Operatorfor theFlinkPlatformthat creates a sequence file.FlinkObjectFileSource<Type>Operatorfor theFlinkPlatformthat creates a sequence file.Flink implementation of thePageRankOperator.A reduce function that takes a sequence of edges and builds the adjacency list for the vertex where the edges originate.The function that applies the page rank dampening formula.Filter that filters vertices where the rank difference is below a threshold.Join function that distributes a fraction of a vertex's rank to all neighbors.A map function that assigns an initial rank to all pages.FlinkReduceByOperator<InputType,KeyType> Flink implementation of theReduceByOperator.Flink implementation of theRepeatOperator.FlinkRepeatOperator<Type>Flink implementation of theRepeatOperator.FlinkSampleOperator<Type>Flink implementation of theSampleOperator.FlinkSortOperator<InputType,KeyType> Flink implementation of theSortOperator.FlinkTextFileSink<Type>Implementation of theTextFileSinkoperator for the Flink platform.Provides aCollectionto a Flink job.Created by bertty on 31-10-17.FlinkUnionAllOperator<Type>Flink implementation of theUnionAllOperator.FlinkZipWithIdOperator<InputType>Flink implementation of theMapOperator.