spark-sql-streaming-StreamSinkProvider.adoc

StreamSinkProvider

StreamSinkProvider is an interface for objects that can create streaming sinks for a specific format or system, e.g. ConsoleSinkProvider for console format.

It defines the one and only method createSink that creates a Sink.

package org.apache.spark.sql.sources

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