spark-sql-streaming-StreamSinkProvider.adoc

StreamSinkProvider

StreamSinkProvider is the contract for creating streaming sinks for a specific format or system.

StreamSinkProvider defines the one and only createSink method that creates a streaming sink.

package org.apache.spark.sql.sources

trait StreamSinkProvider {
  def createSink(
      sqlContext: SQLContext,
      parameters: Map[String, String],
      partitionColumns: Seq[String],
      outputMode: OutputMode): Sink
}