SupportsStreamingUpdate¶

SupportsStreamingUpdate is an extension of the WriteBuilder abstraction for tables that support streaming update.

Contract¶

Streaming Update¶

update(): WriteBuilder

WriteBuilder

Used when:

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

Implementations¶

• ConsoleTable
• ForeachWriterTable
• KafkaTable
• MemorySink
• NoopWriteBuilder