co.cask.cdap.etl.spark.batch

Class SparkBatchSinkFactory

java.lang.Object

co.cask.cdap.etl.spark.batch.SparkBatchSinkFactory

public final class SparkBatchSinkFactory
extends Object

Handles writes to batch sinks. Maintains a mapping from sinks to their outputs and handles serialization and deserialization for those mappings.

Constructor Summary

Constructors

Constructor and Description
SparkBatchSinkFactory()

Method Summary

Modifier and Type	Method and Description
<K,V> void	writeFromRDD(org.apache.spark.api.java.JavaPairRDD<K,V> rdd, JavaSparkExecutionContext sec, String sinkName, Class<K> keyClass, Class<V> valueClass)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkBatchSinkFactory

public SparkBatchSinkFactory()

Method Detail

writeFromRDD

public <K,V> void writeFromRDD(org.apache.spark.api.java.JavaPairRDD<K,V> rdd,
                               JavaSparkExecutionContext sec,
                               String sinkName,
                               Class<K> keyClass,
                               Class<V> valueClass)