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 . |
SinkProvider | Deprecated
Please convert your sink to
Sink and use
SinkV2Provider . |
SinkV2Provider |
Provider of a
Sink instance as a runtime implementation for DynamicTableSink . |
Class | Description |
---|---|
SinkStagingContext |
Implementation of
SupportsStaging.StagingContext . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.