spark-instrumented-optimizer/external/kafka-0-10-sql/src
Jose Torres 49b0207dc9 [SPARK-23196] Unify continuous and microbatch V2 sinks
## What changes were proposed in this pull request?

Replace streaming V2 sinks with a unified StreamWriteSupport interface, with a shim to use it with microbatch execution.

Add a new SQL config to use for disabling V2 sinks, falling back to the V1 sink implementation.

## How was this patch tested?

Existing tests, which in the case of Kafka (the only existing continuous V2 sink) now use V2 for microbatch.

Author: Jose Torres <jose@databricks.com>

Closes #20369 from jose-torres/streaming-sink.
2018-01-29 13:10:38 +08:00
..
main [SPARK-23196] Unify continuous and microbatch V2 sinks 2018-01-29 13:10:38 +08:00
test [SPARK-23196] Unify continuous and microbatch V2 sinks 2018-01-29 13:10:38 +08:00