Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
JsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
CanalJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<SerializationSchema<RowData>> |
DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Field and Description |
---|---|
protected EncodingFormat<SerializationSchema<RowData>> |
KafkaDynamicSinkBase.encodingFormat
Sink format for encoding records to Kafka.
|
Constructor and Description |
---|
Kafka010DynamicSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
Kafka011DynamicSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
KafkaDynamicSink(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
KafkaDynamicSinkBase(DataType consumedDataType,
String topic,
Properties properties,
Optional<FlinkKafkaPartitioner<RowData>> partitioner,
EncodingFormat<SerializationSchema<RowData>> encodingFormat) |
Modifier and Type | Method and Description |
---|---|
EncodingFormat<I> |
EncodingFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
<I,F extends EncodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverEncodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
EncodingFormat of the given type using the given option as factory
identifier. |
Modifier and Type | Method and Description |
---|---|
<I,F extends EncodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverOptionalEncodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
EncodingFormat of the given type using the given option (if present)
as factory identifier. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.