Interface | Description |
---|---|
AppendStreamTableSink<T> | |
BatchTableSink<T> | Deprecated
use
OutputFormatTableSink instead. |
OverwritableTableSink |
A
TableSink that supports INSERT OVERWRITE should implement this trait. |
PartitionableTableSink |
An interface for partitionable
TableSink . |
RetractStreamTableSink<T> | |
StreamTableSink<T> |
Defines an external stream table and provides write access to its data.
|
TableSink<T> |
A
TableSink specifies how to emit a table to an external
system or location. |
UpsertStreamTableSink<T> |
Class | Description |
---|---|
CsvAppendTableSinkFactory |
Factory base for creating configured instances of
CsvTableSink in a stream environment. |
CsvBatchTableSinkFactory |
Factory base for creating configured instances of
CsvTableSink in a batch environment. |
CsvTableSink |
A simple
TableSink to emit data as CSV files. |
CsvTableSink.CsvFormatter |
Formats a Row into a String with fields separated by the field delimiter.
|
CsvTableSinkFactoryBase |
Factory base for creating configured instances of
CsvTableSink . |
OutputFormatTableSink<T> | |
TableSinkBase<T> |
Base class for
TableSink . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.