StreamSinkProvider¶

StreamSinkProvider is the <> of <> that can <> for a file format (e.g. parquet) or system (e.g. kafka).

[[contract]] .StreamSinkProvider Contract [cols="30m,70",options="header",width="100%"] |=== | Method | Description

| createSink a| [[createSink]]

[source, scala]¶

createSink( sqlContext: SQLContext, parameters: Map[String, String], partitionColumns: Seq[String], outputMode: OutputMode): Sink

Creates a streaming sink

Used when DataSource is requested for a streaming sink (when DataStreamWriter is requested to start a streaming query)

|===

[[implementations]] NOTE: KafkaSourceProvider is the only known StreamSinkProvider in Spark Structured Streaming.