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) |
|