org.apache.spark.sql.sources

Interface StreamSinkProvider

public interface StreamSinkProvider

Implemented by objects that can produce a streaming Sink for a specific format or system.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.execution.streaming.Sink	createSink(SQLContext sqlContext, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters, scala.collection.Seq<java.lang.String> partitionColumns)

Method Detail

createSink

org.apache.spark.sql.execution.streaming.Sink createSink(SQLContext sqlContext,
                                                       scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters,
                                                       scala.collection.Seq<java.lang.String> partitionColumns)