Package org.apache.wayang.java.operators

Interface Summary

Interface	Description
JavaExecutionOperator	Execution operator for the Java platform.

Class Summary

Class	Description
JavaCartesianOperator<InputType0,InputType1>	Java implementation of the CartesianOperator.
JavaCoGroupOperator<InputType0,InputType1,KeyType>	Java implementation of the CoGroupOperator.
JavaCollectionSource<T>	This is execution operator implements the TextFileSource.
JavaCollectOperator<Type>	Converts StreamChannel into a CollectionChannel
JavaCountOperator<Type>	Java implementation of the CountOperator.
JavaDistinctOperator<Type>	Java implementation of the DistinctOperator.
JavaDoWhileOperator<InputType,ConvergenceType>	Java implementation of the DoWhileOperator.
JavaFilterOperator<Type>	Java implementation of the FilterOperator.
JavaFlatMapOperator<InputType,OutputType>	Java implementation of the FlatMapOperator.
JavaGlobalMaterializedGroupOperator<Type>	Java implementation of the GlobalMaterializedGroupOperator.
JavaGlobalReduceOperator<Type>	Java implementation of the GlobalReduceOperator.
JavaIntersectOperator<Type>	Java implementation of the IntersectOperator.
JavaJoinOperator<InputType0,InputType1,KeyType>	Java implementation of the JoinOperator.
JavaKafkaTopicSink<T>	Implementation fo the KafkaTopicSink for the JavaPlatform.
JavaKafkaTopicSource
JavaLocalCallbackSink<T extends java.io.Serializable>	Implementation of the LocalCallbackSink operator for the Java platform.
JavaLoopOperator<InputType,ConvergenceType>	Java implementation of the LoopOperator.
JavaMapOperator<InputType,OutputType>	Java implementation of the MapOperator.
JavaMapPartitionsOperator<InputType,OutputType>	Java implementation of the MapPartitionsOperator.
JavaMaterializedGroupByOperator<Type,KeyType>	Java implementation of the MaterializedGroupByOperator.
JavaObjectFileSink<T>	Operator for the JavaPlatform that creates a sequence file.
JavaObjectFileSink.StreamChunker	Utility to chunk a Stream into portions of fixed size.
JavaObjectFileSource<T>	Operator for the JavaPlatform that creates a sequence file.
JavaRandomSampleOperator<Type>	Java implementation of the JavaRandomSampleOperator.
JavaReduceByOperator<Type,KeyType>	Java implementation of the ReduceByOperator.
JavaRepeatOperator<Type>	Java implementation of the DoWhileOperator.
JavaReservoirSampleOperator<Type>	Java implementation of the JavaReservoirSampleOperator.
JavaSortOperator<Type,Key>	Java implementation of the SortOperator.
JavaTextFileSink<T>	Implementation fo the TextFileSink for the JavaPlatform.
JavaTextFileSource	This is execution operator implements the TextFileSource.
JavaTsvFileSink<T extends Tuple2<?,?>>	Operator for the JavaPlatform that creates a TSV file.
JavaTsvFileSource<T>	Operator for the JavaPlatform that creates a sequence file.
JavaUnionAllOperator<Type>	Java implementation of the UnionAllOperator.