Package org.apache.wayang.java.operators

package org.apache.wayang.java.operators

Related Packages

Package	Description
org.apache.wayang.java
org.apache.wayang.java.operators.graph

Class	Description
JavaAmazonS3Source	This is execution operator that implements the AmazonS3Source.
JavaAzureBlobStorageSource	This is execution operator that implements the AzureBlobStorageSource.
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.
JavaExecutionOperator	Execution operator for the Java platform.
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.
JavaGoogleCloudStorageSource
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 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.
JavaParquetSource	This is execution operator implements the ParquetSource.
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.