Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
FileSystemTableSink.getSinkRuntimeProvider(DynamicTableSink.Context sinkContext) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
KinesisFirehoseDynamicSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
HBaseDynamicTableSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
HBaseDynamicTableSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
JdbcDynamicTableSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
KinesisDynamicSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
HiveTableSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
SerializationSchema<RowData> |
UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.createRuntimeEncoder(DynamicTableSink.Context context,
DataType consumedDataType) |
DynamicTableSink.SinkRuntimeProvider |
KafkaDynamicSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
I |
EncodingFormat.createRuntimeEncoder(DynamicTableSink.Context context,
DataType physicalDataType)
Creates runtime encoder implementation that is configured to consume data of the given data
type.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
DynamicTableSink.getSinkRuntimeProvider(DynamicTableSink.Context context)
Returns a provider of runtime implementation for writing the data.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink.SinkRuntimeProvider |
CollectDynamicSink.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
SinkRuntimeProviderContext
Implementation of
DynamicTableSink.Context . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.