Uses of Interface
org.apache.wayang.java.operators.JavaExecutionOperator
Packages that use JavaExecutionOperator
Package
Description
-
Uses of JavaExecutionOperator in org.apache.wayang.api.sql.sources.fs
Classes in org.apache.wayang.api.sql.sources.fs that implement JavaExecutionOperator -
Uses of JavaExecutionOperator in org.apache.wayang.genericjdbc.operators
Classes in org.apache.wayang.genericjdbc.operators that implement JavaExecutionOperatorModifier and TypeClassDescriptionclass
-
Uses of JavaExecutionOperator in org.apache.wayang.iejoin.operators
Classes in org.apache.wayang.iejoin.operators that implement JavaExecutionOperatorModifier and TypeClassDescriptionclass
JavaIEJoinOperator<Type0 extends Comparable<Type0>,
Type1 extends Comparable<Type1>, Input> Java implementation of theIEJoinOperator
.class
JavaIESelfJoinOperator<Type0 extends Comparable<Type0>,
Type1 extends Comparable<Type1>, Input> Java implementation of theIESelfJoinOperator
. -
Uses of JavaExecutionOperator in org.apache.wayang.java.execution
Methods in org.apache.wayang.java.execution with parameters of type JavaExecutionOperatorModifier and TypeMethodDescriptionstatic void
JavaExecutor.openFunction
(JavaExecutionOperator operator, Object function, ChannelInstance[] inputs, OptimizationContext.OperatorContext operatorContext) Utility function to open anExtendedFunction
.Constructors in org.apache.wayang.java.execution with parameters of type JavaExecutionOperatorModifierConstructorDescriptionJavaExecutionContext
(JavaExecutionOperator operator, ChannelInstance[] inputs, int iterationNumber) -
Uses of JavaExecutionOperator in org.apache.wayang.java.operators
Classes in org.apache.wayang.java.operators that implement JavaExecutionOperatorModifier and TypeClassDescriptionclass
This is execution operator that implements theAmazonS3Source
.class
This is execution operator that implements theAzureBlobStorageSource
.class
JavaCartesianOperator<InputType0,
InputType1> Java implementation of theCartesianOperator
.class
JavaCoGroupOperator<InputType0,
InputType1, KeyType> Java implementation of theCoGroupOperator
.class
This is execution operator implements theTextFileSource
.class
JavaCollectOperator<Type>
ConvertsStreamChannel
into aCollectionChannel
class
JavaCountOperator<Type>
Java implementation of theCountOperator
.class
JavaDistinctOperator<Type>
Java implementation of theDistinctOperator
.class
JavaDoWhileOperator<InputType,
ConvergenceType> Java implementation of theDoWhileOperator
.class
JavaFilterOperator<Type>
Java implementation of theFilterOperator
.class
JavaFlatMapOperator<InputType,
OutputType> Java implementation of theFlatMapOperator
.class
Java implementation of theGlobalMaterializedGroupOperator
.class
JavaGlobalReduceOperator<Type>
Java implementation of theGlobalReduceOperator
.class
class
JavaIntersectOperator<Type>
Java implementation of theIntersectOperator
.class
JavaJoinOperator<InputType0,
InputType1, KeyType> Java implementation of theJoinOperator
.class
Implementation fo theKafkaTopicSink
for theJavaPlatform
.class
class
JavaLocalCallbackSink<T extends Serializable>
Implementation of theLocalCallbackSink
operator for the Java platform.class
JavaLoopOperator<InputType,
ConvergenceType> Java implementation of theLoopOperator
.class
JavaMapOperator<InputType,
OutputType> Java implementation of theMapOperator
.class
JavaMapPartitionsOperator<InputType,
OutputType> Java implementation of theMapPartitionsOperator
.class
JavaMaterializedGroupByOperator<Type,
KeyType> Java implementation of theMaterializedGroupByOperator
.class
Operator
for theJavaPlatform
that creates a sequence file.class
Operator
for theJavaPlatform
that creates a sequence file.class
This is execution operator implements theParquetSource
.class
JavaRandomSampleOperator<Type>
Java implementation of theJavaRandomSampleOperator
.class
JavaReduceByOperator<Type,
KeyType> Java implementation of theReduceByOperator
.class
JavaRepeatOperator<Type>
Java implementation of theDoWhileOperator
.class
Java implementation of theJavaReservoirSampleOperator
.class
JavaSortOperator<Type,
Key> Java implementation of theSortOperator
.class
Implementation fo theTextFileSink
for theJavaPlatform
.class
This is execution operator implements theTextFileSource
.class
JavaTsvFileSink<T extends Tuple2<?,
?>> Operator
for theJavaPlatform
that creates a TSV file.class
Operator
for theJavaPlatform
that creates a sequence file.class
JavaUnionAllOperator<Type>
Java implementation of theUnionAllOperator
. -
Uses of JavaExecutionOperator in org.apache.wayang.java.operators.graph
Classes in org.apache.wayang.java.operators.graph that implement JavaExecutionOperator -
Uses of JavaExecutionOperator in org.apache.wayang.jdbc.operators
Classes in org.apache.wayang.jdbc.operators that implement JavaExecutionOperatorModifier and TypeClassDescriptionclass
-
Uses of JavaExecutionOperator in org.apache.wayang.profiler.java
Fields in org.apache.wayang.profiler.java declared as JavaExecutionOperatorFields in org.apache.wayang.profiler.java with type parameters of type JavaExecutionOperatorModifier and TypeFieldDescriptionprotected Supplier<JavaExecutionOperator>
OperatorProfiler.operatorGenerator
Methods in org.apache.wayang.profiler.java that return JavaExecutionOperatorModifier and TypeMethodDescriptionBinaryOperatorProfiler.getOperator()
OperatorProfiler.getOperator()
UnaryOperatorProfiler.getOperator()
Constructor parameters in org.apache.wayang.profiler.java with type arguments of type JavaExecutionOperatorModifierConstructorDescriptionBinaryOperatorProfiler
(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)