Uses of Class
co.cask.cdap.etl.spark.batch.SparkBatchSinkFactory

Packages that use SparkBatchSinkFactory

Package	Description
co.cask.cdap.etl.spark.batch

Uses of SparkBatchSinkFactory in co.cask.cdap.etl.spark.batch

Methods in co.cask.cdap.etl.spark.batch that return SparkBatchSinkFactory

Modifier and Type	Method and Description
SparkBatchSinkFactory	SparkBatchSourceSinkFactoryInfo.getSparkBatchSinkFactory()

Constructors in co.cask.cdap.etl.spark.batch with parameters of type SparkBatchSinkFactory

Constructor and Description
PairRDDCollection(JavaSparkExecutionContext sec, org.apache.spark.api.java.JavaSparkContext jsc, DatasetContext datasetContext, SparkBatchSinkFactory sinkFactory, org.apache.spark.api.java.JavaPairRDD<K,V> pairRDD)
RDDCollection(JavaSparkExecutionContext sec, org.apache.spark.api.java.JavaSparkContext jsc, DatasetContext datasetContext, SparkBatchSinkFactory sinkFactory, org.apache.spark.api.java.JavaRDD<T> rdd)
SparkBatchSinkContext(SparkBatchSinkFactory sinkFactory, JavaSparkExecutionContext sec, DatasetContext datasetContext, PipelineRuntime pipelineRuntime, StageSpec stageSpec)
SparkBatchSinkContext(SparkBatchSinkFactory sinkFactory, SparkClientContext sparkContext, PipelineRuntime pipelineRuntime, DatasetContext datasetContext, StageSpec stageSpec)
SparkBatchSourceSinkFactoryInfo(co.cask.cdap.etl.spark.batch.SparkBatchSourceFactory sparkBatchSourceFactory, SparkBatchSinkFactory sparkBatchSinkFactory, Map<String,Integer> stagePartitions)