Uses of Class
org.apache.wayang.java.execution.JavaExecutor

Packages that use JavaExecutor

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

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

Methods in org.apache.wayang.api.sql.sources.fs with parameters of type JavaExecutor

Modifier and Type	Method	Description
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaCSVTableSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)

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

Methods in org.apache.wayang.genericjdbc.operators with parameters of type JavaExecutor

Modifier and Type	Method	Description
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	GenericSqlToStreamOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor executor, OptimizationContext.OperatorContext operatorContext)

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

Methods in org.apache.wayang.iejoin.operators with parameters of type JavaExecutor

Modifier and Type	Method	Description
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaIEJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaIESelfJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)

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

Methods in org.apache.wayang.java.operators with parameters of type JavaExecutor

Modifier and Type	Method	Description
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaCartesianOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaCoGroupOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaCollectionSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaCollectOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaCountOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaDistinctOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaDoWhileOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaExecutionOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)	Evaluates this operator.
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaFilterOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaFlatMapOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaGlobalMaterializedGroupOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaGlobalReduceOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaIntersectOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaKafkaTopicSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaKafkaTopicSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaLocalCallbackSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor executor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaLoopOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaMapOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaMapPartitionsOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaMaterializedGroupByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaObjectFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaObjectFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaRandomSampleOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaReduceByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaRepeatOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaReservoirSampleOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaSortOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaTextFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaTextFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaTsvFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaTsvFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaUnionAllOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)

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

Methods in org.apache.wayang.java.operators.graph with parameters of type JavaExecutor

Modifier and Type	Method	Description
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	JavaPageRankOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor javaExecutor, OptimizationContext.OperatorContext operatorContext)

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

Methods in org.apache.wayang.jdbc.operators with parameters of type JavaExecutor

Modifier and Type	Method	Description
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>	SqlToStreamOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, JavaExecutor executor, OptimizationContext.OperatorContext operatorContext)

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

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

Modifier and Type	Field	Description
protected JavaExecutor	OperatorProfiler.executor

Uses of JavaExecutor in org.apache.wayang.profiler.util

Methods in org.apache.wayang.profiler.util that return JavaExecutor

Modifier and Type	Method	Description
static JavaExecutor	ProfilingUtils.fakeJavaExecutor()	Provides a JavaExecutor.