Skip to content

WriteBuilder

WriteBuilder is an abstraction of write builders for batch and streaming.

Contract

Creating BatchWrite

BatchWrite buildForBatch()

BatchWrite for writing data to a batch source

Used when:

Creating StreamingWrite

StreamingWrite buildForStreaming()

StreamingWrite for writing data to a streaming source

Used when:

  • StreamExecution stream execution engine (Spark Structured Streaming) is requested to createStreamingWrite

Implementations


Last update: 2020-11-13