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 |
KafkaDynamicSinkBase.getSinkRuntimeProvider(DynamicTableSink.Context context) |
Modifier and Type | Method and Description |
---|---|
I |
EncodingFormat.createRuntimeEncoder(DynamicTableSink.Context context,
DataType consumedDataType)
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 | Class and Description |
---|---|
class |
SinkRuntimeProviderContext
Implementation of
DynamicTableSink.Context . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.