co.cask.cdap.etl.spark.batch

Class SparkBatchSourceSinkFactoryInfo

java.lang.Object

co.cask.cdap.etl.spark.batch.SparkBatchSourceSinkFactoryInfo

public class SparkBatchSourceSinkFactoryInfo
extends Object

Stores all the information of SparkBatchSinkFactory and stagePartitions

Constructor Summary

Constructors

Constructor and Description
SparkBatchSourceSinkFactoryInfo(co.cask.cdap.etl.spark.batch.SparkBatchSourceFactory sparkBatchSourceFactory, SparkBatchSinkFactory sparkBatchSinkFactory, Map<String,Integer> stagePartitions)

Method Summary

Modifier and Type	Method and Description
SparkBatchSinkFactory	getSparkBatchSinkFactory()
co.cask.cdap.etl.spark.batch.SparkBatchSourceFactory	getSparkBatchSourceFactory()
Map<String,Integer>	getStagePartitions()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkBatchSourceSinkFactoryInfo

public SparkBatchSourceSinkFactoryInfo(co.cask.cdap.etl.spark.batch.SparkBatchSourceFactory sparkBatchSourceFactory,
                                       SparkBatchSinkFactory sparkBatchSinkFactory,
                                       Map<String,Integer> stagePartitions)

Method Detail

getSparkBatchSourceFactory

public co.cask.cdap.etl.spark.batch.SparkBatchSourceFactory getSparkBatchSourceFactory()

getSparkBatchSinkFactory

public SparkBatchSinkFactory getSparkBatchSinkFactory()

getStagePartitions

public Map<String,Integer> getStagePartitions()