Uses of Class
org.apache.wayang.spark.execution.SparkExecutor

Packages that use SparkExecutor

Package	Description
org.apache.wayang.iejoin.operators
org.apache.wayang.jdbc.operators
org.apache.wayang.profiler.spark
org.apache.wayang.profiler.util
org.apache.wayang.spark.channels
org.apache.wayang.spark.operators
org.apache.wayang.spark.operators.ml

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

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

Modifier and Type	Method	Description
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkIEJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkIESelfJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)

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

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

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

Uses of SparkExecutor in org.apache.wayang.profiler.spark

Fields in org.apache.wayang.profiler.spark declared as SparkExecutor

Modifier and Type	Field	Description
protected SparkExecutor	SparkOperatorProfiler.sparkExecutor

Methods in org.apache.wayang.profiler.spark with parameters of type SparkExecutor

Modifier and Type	Method	Description
protected static RddChannel.Instance	SparkOperatorProfiler.createChannelInstance(org.apache.spark.api.java.JavaRDD<?> rdd, SparkExecutor sparkExecutor)	Creates a ChannelInstance that carries the given rdd.
protected static RddChannel.Instance	SparkOperatorProfiler.createChannelInstance(SparkExecutor sparkExecutor)	Creates an empty ChannelInstance.

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

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

Modifier and Type	Method	Description
static SparkExecutor	ProfilingUtils.fakeSparkExecutor(String... udfJars)	Provides a SparkExecutor.

Uses of SparkExecutor in org.apache.wayang.spark.channels

Methods in org.apache.wayang.spark.channels with parameters of type SparkExecutor

Modifier and Type	Method	Description
void	RddChannel.Instance.accept(org.apache.spark.api.java.JavaRDD<?> rdd, SparkExecutor sparkExecutor)

Constructors in org.apache.wayang.spark.channels with parameters of type SparkExecutor

Modifier	Constructor	Description
	Instance(SparkExecutor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)
	Instance(SparkExecutor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)

Uses of SparkExecutor in org.apache.wayang.spark.operators

Methods in org.apache.wayang.spark.operators with parameters of type SparkExecutor

Modifier and Type	Method	Description
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkBernoulliSampleOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkBroadcastOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkCacheOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkCartesianOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkCoGroupOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkCollectionSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkCollectOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkCountOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkDistinctOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkDoWhileOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkExecutionOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)	Evaluates this operator.
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkFilterOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkFlatMapOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkGlobalMaterializedGroupOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkGlobalReduceOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkIntersectOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkJoinOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkKafkaTopicSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkKafkaTopicSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkLocalCallbackSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkLoopOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkMapOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkMapPartitionsOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkMaterializedGroupByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkObjectFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkObjectFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkParquetSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkRandomPartitionSampleOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkReduceByOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkRepeatOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkShufflePartitionSampleOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkSortOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkTextFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkTextFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkTsvFileSink.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkTsvFileSource.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkUnionAllOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkZipWithIdOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)

Uses of SparkExecutor in org.apache.wayang.spark.operators.ml

Methods in org.apache.wayang.spark.operators.ml with parameters of type SparkExecutor

Modifier and Type	Method	Description
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkDecisionTreeClassificationOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkDecisionTreeRegressionOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkKMeansOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkLinearRegressionOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkLinearSVCOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkLogisticRegressionOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkModelTransformOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)	Deprecated.
Tuple<Collection<ExecutionLineageNode>,Collection<ChannelInstance>>	SparkPredictOperator.evaluate(ChannelInstance[] inputs, ChannelInstance[] outputs, SparkExecutor sparkExecutor, OptimizationContext.OperatorContext operatorContext)