Package org.apache.wayang.java.operators
package org.apache.wayang.java.operators
-
ClassDescriptionThis is execution operator that implements the
AmazonS3Source
.This is execution operator that implements theAzureBlobStorageSource
.JavaCartesianOperator<InputType0,InputType1> Java implementation of theCartesianOperator
.JavaCoGroupOperator<InputType0,InputType1, KeyType> Java implementation of theCoGroupOperator
.This is execution operator implements theTextFileSource
.JavaCollectOperator<Type>ConvertsStreamChannel
into aCollectionChannel
JavaCountOperator<Type>Java implementation of theCountOperator
.JavaDistinctOperator<Type>Java implementation of theDistinctOperator
.JavaDoWhileOperator<InputType,ConvergenceType> Java implementation of theDoWhileOperator
.Execution operator for the Java platform.JavaFilterOperator<Type>Java implementation of theFilterOperator
.JavaFlatMapOperator<InputType,OutputType> Java implementation of theFlatMapOperator
.Java implementation of theGlobalMaterializedGroupOperator
.JavaGlobalReduceOperator<Type>Java implementation of theGlobalReduceOperator
.JavaIntersectOperator<Type>Java implementation of theIntersectOperator
.JavaJoinOperator<InputType0,InputType1, KeyType> Java implementation of theJoinOperator
.Implementation fo theKafkaTopicSink
for theJavaPlatform
.JavaLocalCallbackSink<T extends Serializable>Implementation of theLocalCallbackSink
operator for the Java platform.JavaLoopOperator<InputType,ConvergenceType> Java implementation of theLoopOperator
.JavaMapOperator<InputType,OutputType> Java implementation of theMapOperator
.JavaMapPartitionsOperator<InputType,OutputType> Java implementation of theMapPartitionsOperator
.JavaMaterializedGroupByOperator<Type,KeyType> Java implementation of theMaterializedGroupByOperator
.Operator
for theJavaPlatform
that creates a sequence file.Utility to chunk aStream
into portions of fixed size.Operator
for theJavaPlatform
that creates a sequence file.This is execution operator implements theParquetSource
.JavaRandomSampleOperator<Type>Java implementation of theJavaRandomSampleOperator
.JavaReduceByOperator<Type,KeyType> Java implementation of theReduceByOperator
.JavaRepeatOperator<Type>Java implementation of theDoWhileOperator
.Java implementation of theJavaReservoirSampleOperator
.JavaSortOperator<Type,Key> Java implementation of theSortOperator
.Implementation fo theTextFileSink
for theJavaPlatform
.This is execution operator implements theTextFileSource
.Operator
for theJavaPlatform
that creates a TSV file.Operator
for theJavaPlatform
that creates a sequence file.JavaUnionAllOperator<Type>Java implementation of theUnionAllOperator
.