Interface | Description |
---|---|
AppendStreamTableSink<T> |
Defines an external
TableSink to emit streaming Table with only insert changes. |
BatchTableSink<T> |
Defines an external
TableSink to emit a batch Table . |
RetractStreamTableSink<T> |
Defines an external
TableSink to emit a streaming Table with insert, update, and delete
changes. |
TableSink<T> |
A
TableSink specifies how to emit a Table to an external
system or location. |
TableSinkBase<T> | |
UpsertStreamTableSink<T> |
Defines an external
TableSink to emit a streaming Table with insert, update, and delete
changes. |
Class | Description |
---|---|
CsvFormatter |
Formats a
Row into a String with fields separated by the field delimiter. |
CsvTableSink |
A simple
TableSink to emit data as CSV files. |
CsvTableSink$ |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.