BaseStreamingSink Contract — Base of Streaming Writers and Sinks

BaseStreamingSink is the abstraction of streaming writers and sinks with the only purpose of sharing a common abstraction between the former Data Source API V1 (Sink API) and the modern Data Source API V2 (until Spark Structured Streaming migrates to the Data Source API V2 fully).

BaseStreamingSink defines no methods.

Table 1. BaseStreamingSinks (Extensions Only)
BaseStreamingSink Description

MemorySinkBase

Base contract for data sinks in memory data source

Sink

Streaming sinks for Micro-Batch Stream Processing (based on Data Source API V1)

StreamWriteSupport

Data source writers (based on Data Source API V2)

results matching ""

    No results matching ""