Uses of Interface
org.apache.flink.table.connector.format.EncodingFormat
-
-
Uses of EncodingFormat in org.apache.flink.connector.base.table
Methods in org.apache.flink.connector.base.table that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
AsyncDynamicTableSinkFactory.AsyncDynamicSinkContext. getEncodingFormat()
-
Uses of EncodingFormat in org.apache.flink.formats.avro
Methods in org.apache.flink.formats.avro that return EncodingFormat Modifier and Type Method Description EncodingFormat<BulkWriter.Factory<RowData>>
AvroFileFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>
AvroFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.avro.registry.confluent
Methods in org.apache.flink.formats.avro.registry.confluent that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
RegistryAvroFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.avro.registry.confluent.debezium
Methods in org.apache.flink.formats.avro.registry.confluent.debezium that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
DebeziumAvroFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.csv
Methods in org.apache.flink.formats.csv that return EncodingFormat Modifier and Type Method Description EncodingFormat<BulkWriter.Factory<RowData>>
CsvFileFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>
CsvFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.json
Methods in org.apache.flink.formats.json that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
JsonFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.json.canal
Methods in org.apache.flink.formats.json.canal that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
CanalJsonFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.json.debezium
Methods in org.apache.flink.formats.json.debezium that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
DebeziumJsonFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.json.maxwell
Methods in org.apache.flink.formats.json.maxwell that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
MaxwellJsonFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.json.ogg
Methods in org.apache.flink.formats.json.ogg that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
OggJsonFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.parquet
Methods in org.apache.flink.formats.parquet that return EncodingFormat Modifier and Type Method Description EncodingFormat<BulkWriter.Factory<RowData>>
ParquetFileFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.protobuf
Classes in org.apache.flink.formats.protobuf that implement EncodingFormat Modifier and Type Class Description class
PbEncodingFormat
EncodingFormat
for protobuf encoding.Methods in org.apache.flink.formats.protobuf that return EncodingFormat Modifier and Type Method Description EncodingFormat<BulkWriter.Factory<RowData>>
PbFileFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
EncodingFormat<SerializationSchema<RowData>>
PbFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.formats.raw
Methods in org.apache.flink.formats.raw that return EncodingFormat Modifier and Type Method Description EncodingFormat<SerializationSchema<RowData>>
RawFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.orc
Methods in org.apache.flink.orc that return EncodingFormat Modifier and Type Method Description EncodingFormat<BulkWriter.Factory<RowData>>
OrcFileFormatFactory. createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
-
Uses of EncodingFormat in org.apache.flink.table.factories
Methods in org.apache.flink.table.factories that return EncodingFormat Modifier and Type Method 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>>
EncodingFormat<I>FactoryUtil.TableFactoryHelper. discoverEncodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption)
Discovers aEncodingFormat
of the given type using the given option as factory identifier.Methods in org.apache.flink.table.factories that return types with arguments of type EncodingFormat Modifier and Type Method Description <I,F extends EncodingFormatFactory<I>>
Optional<EncodingFormat<I>>FactoryUtil.TableFactoryHelper. discoverOptionalEncodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption)
Discovers aEncodingFormat
of the given type using the given option (if present) as factory identifier.
-