Uses of Class
org.apache.wayang.spark.channels.RddChannel.Instance
Packages that use RddChannel.Instance
-
Uses of RddChannel.Instance in org.apache.wayang.profiler.spark
Methods in org.apache.wayang.profiler.spark that return RddChannel.InstanceModifier and TypeMethodDescriptionprotected static RddChannel.InstanceSparkOperatorProfiler.createChannelInstance(org.apache.spark.api.java.JavaRDD<?> rdd, SparkExecutor sparkExecutor) Creates aChannelInstancethat carries the givenrdd.protected static RddChannel.InstanceSparkOperatorProfiler.createChannelInstance(SparkExecutor sparkExecutor) Creates an emptyChannelInstance. -
Uses of RddChannel.Instance in org.apache.wayang.spark.channels
Methods in org.apache.wayang.spark.channels that return RddChannel.InstanceModifier and TypeMethodDescriptionRddChannel.createInstance(Executor executor, OptimizationContext.OperatorContext producerOperatorContext, int producerOutputIndex)