org.apache.spark.sql.sources

Interface StreamSinkProvider

public interface StreamSinkProvider

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

Since:

2.0.0

Method Summary

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

Method Detail

createSink

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