Uses of Interface
org.apache.wayang.java.operators.JavaExecutionOperator

Packages that use JavaExecutionOperator

Package	Description
org.apache.wayang.api.sql.sources.fs
org.apache.wayang.genericjdbc.operators
org.apache.wayang.iejoin.operators
org.apache.wayang.java.execution
org.apache.wayang.java.operators
org.apache.wayang.java.operators.graph
org.apache.wayang.jdbc.operators
org.apache.wayang.profiler.java

Uses of JavaExecutionOperator in org.apache.wayang.api.sql.sources.fs

Classes in org.apache.wayang.api.sql.sources.fs that implement JavaExecutionOperator

Modifier and Type	Class	Description
class	JavaCSVTableSource<T>

Uses of JavaExecutionOperator in org.apache.wayang.genericjdbc.operators

Classes in org.apache.wayang.genericjdbc.operators that implement JavaExecutionOperator

Modifier and Type	Class	Description
class	GenericSqlToStreamOperator	This Operator converts SqlQueryChannels to StreamChannels.

Uses of JavaExecutionOperator in org.apache.wayang.iejoin.operators

Classes in org.apache.wayang.iejoin.operators that implement JavaExecutionOperator

Modifier and Type	Class	Description
class	JavaIEJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Java implementation of the IEJoinOperator.
class	JavaIESelfJoinOperator<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>,Input>	Java implementation of the IESelfJoinOperator.

Uses of JavaExecutionOperator in org.apache.wayang.java.execution

Methods in org.apache.wayang.java.execution with parameters of type JavaExecutionOperator

Modifier and Type	Method	Description
static void	JavaExecutor.openFunction(JavaExecutionOperator operator, Object function, ChannelInstance[] inputs, OptimizationContext.OperatorContext operatorContext)	Utility function to open an ExtendedFunction.

Constructors in org.apache.wayang.java.execution with parameters of type JavaExecutionOperator

Modifier	Constructor	Description
	JavaExecutionContext(JavaExecutionOperator operator, ChannelInstance[] inputs, int iterationNumber)

Uses of JavaExecutionOperator in org.apache.wayang.java.operators

Classes in org.apache.wayang.java.operators that implement JavaExecutionOperator

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

Uses of JavaExecutionOperator in org.apache.wayang.java.operators.graph

Classes in org.apache.wayang.java.operators.graph that implement JavaExecutionOperator

Modifier and Type	Class	Description
class	JavaPageRankOperator	Java implementation of the PageRankOperator.

Uses of JavaExecutionOperator in org.apache.wayang.jdbc.operators

Classes in org.apache.wayang.jdbc.operators that implement JavaExecutionOperator

Modifier and Type	Class	Description
class	SqlToStreamOperator	This Operator converts SqlQueryChannels to StreamChannels.

Uses of JavaExecutionOperator in org.apache.wayang.profiler.java

Fields in org.apache.wayang.profiler.java declared as JavaExecutionOperator

Modifier and Type	Field	Description
protected JavaExecutionOperator	OperatorProfiler.operator

Fields in org.apache.wayang.profiler.java with type parameters of type JavaExecutionOperator

Modifier and Type	Field	Description
protected Supplier<JavaExecutionOperator>	OperatorProfiler.operatorGenerator

Methods in org.apache.wayang.profiler.java that return JavaExecutionOperator

Modifier and Type	Method	Description
JavaExecutionOperator	BinaryOperatorProfiler.getOperator()
JavaExecutionOperator	OperatorProfiler.getOperator()
JavaExecutionOperator	UnaryOperatorProfiler.getOperator()

Constructor parameters in org.apache.wayang.profiler.java with type arguments of type JavaExecutionOperator

Modifier	Constructor	Description
	BinaryOperatorProfiler(Supplier<JavaExecutionOperator> operatorGenerator, Supplier<?> dataQuantumGenerator0, Supplier<?> dataQuantumGenerator1)
	OperatorProfiler(Supplier<JavaExecutionOperator> operatorGenerator, Supplier<?>... dataQuantumGenerators)
	SinkProfiler(Supplier<JavaExecutionOperator> operatorGenerator, Supplier<?>... dataQuantumGenerators)
	SourceProfiler(Supplier<JavaExecutionOperator> operatorGenerator, Supplier<?>... dataQuantumGenerators)
	UnaryOperatorProfiler(Supplier<JavaExecutionOperator> operatorGenerator, Supplier<?> dataQuantumGenerator)