Interface | Description |
---|---|
DataStreamSinkProvider |
Provider that consumes a Java
DataStream as a runtime implementation for DynamicTableSink . |
DynamicTableSink |
Sink of a dynamic table to an external storage system.
|
DynamicTableSink.Context |
Context for creating runtime implementation via a
DynamicTableSink.SinkRuntimeProvider . |
DynamicTableSink.DataStructureConverter |
Converter for mapping between Flink's internal data structures and objects specified by the
given
DataType that can be passed into a runtime implementation. |
DynamicTableSink.SinkRuntimeProvider |
Provides actual runtime implementation for writing the data.
|
OutputFormatProvider |
Provider of an
OutputFormat instance as a runtime implementation for DynamicTableSink . |
SinkFunctionProvider |
Provider of a
SinkFunction instance as a runtime implementation for DynamicTableSink . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.