Uses of Interface
org.apache.flink.table.factories.DecodingFormatFactory
-
-
Uses of DecodingFormatFactory in org.apache.flink.connector.file.table
Methods in org.apache.flink.connector.file.table with type parameters of type DecodingFormatFactory Modifier and Type Method Description protected <I,F extends DecodingFormatFactory<I>>
DecodingFormat<I>FileSystemTableFactory. discoverDecodingFormat(DynamicTableFactory.Context context, Class<F> formatFactoryClass)
-
Uses of DecodingFormatFactory in org.apache.flink.connector.file.table.factories
Subinterfaces of DecodingFormatFactory in org.apache.flink.connector.file.table.factories Modifier and Type Interface Description interface
BulkReaderFormatFactory
Base interface for configuring aBulkFormat
for file system connector. -
Uses of DecodingFormatFactory in org.apache.flink.formats.avro
Classes in org.apache.flink.formats.avro that implement DecodingFormatFactory Modifier and Type Class Description class
AvroFileFormatFactory
Avro format factory for file system.class
AvroFormatFactory
Table format factory for providing configured instances of Avro to RowDataSerializationSchema
andDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.avro.registry.confluent
Classes in org.apache.flink.formats.avro.registry.confluent that implement DecodingFormatFactory Modifier and Type Class Description class
RegistryAvroFormatFactory
Table format factory for providing configured instances of Schema Registry Avro to RowDataSerializationSchema
andDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.avro.registry.confluent.debezium
Classes in org.apache.flink.formats.avro.registry.confluent.debezium that implement DecodingFormatFactory Modifier and Type Class Description class
DebeziumAvroFormatFactory
Format factory for providing configured instances of Debezium Avro to RowDataDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.csv
Classes in org.apache.flink.formats.csv that implement DecodingFormatFactory Modifier and Type Class Description class
CsvFileFormatFactory
CSV format factory for file system.class
CsvFormatFactory
Format factory for providing configured instances of CSV to RowDataSerializationSchema
andDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.json
Classes in org.apache.flink.formats.json that implement DecodingFormatFactory Modifier and Type Class Description class
JsonFormatFactory
Table format factory for providing configured instances of JSON to RowDataSerializationSchema
andDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.json.canal
Classes in org.apache.flink.formats.json.canal that implement DecodingFormatFactory Modifier and Type Class Description class
CanalJsonFormatFactory
Format factory for providing configured instances of Canal JSON to RowDataDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.json.debezium
Classes in org.apache.flink.formats.json.debezium that implement DecodingFormatFactory Modifier and Type Class Description class
DebeziumJsonFormatFactory
Format factory for providing configured instances of Debezium JSON to RowDataDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.json.maxwell
Classes in org.apache.flink.formats.json.maxwell that implement DecodingFormatFactory Modifier and Type Class Description class
MaxwellJsonFormatFactory
Format factory for providing configured instances of Maxwell JSON to RowDataDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.json.ogg
Classes in org.apache.flink.formats.json.ogg that implement DecodingFormatFactory Modifier and Type Class Description class
OggJsonFormatFactory
Format factory for providing configured instances of Ogg JSON to RowDataDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.parquet
Classes in org.apache.flink.formats.parquet that implement DecodingFormatFactory Modifier and Type Class Description class
ParquetFileFormatFactory
Parquet format factory for file system. -
Uses of DecodingFormatFactory in org.apache.flink.formats.protobuf
Classes in org.apache.flink.formats.protobuf that implement DecodingFormatFactory Modifier and Type Class Description class
PbFileFormatFactory
Throw aValidationException
when using Protobuf format factory for file system.class
PbFormatFactory
Table format factory for providing configured instances of Protobuf to RowDataSerializationSchema
andDeserializationSchema
. -
Uses of DecodingFormatFactory in org.apache.flink.formats.raw
Classes in org.apache.flink.formats.raw that implement DecodingFormatFactory Modifier and Type Class Description class
RawFormatFactory
Format factory for raw format which allows to read and write raw (byte based) values as a single column. -
Uses of DecodingFormatFactory in org.apache.flink.orc
Classes in org.apache.flink.orc that implement DecodingFormatFactory Modifier and Type Class Description class
OrcFileFormatFactory
Orc format factory for file system. -
Uses of DecodingFormatFactory in org.apache.flink.table.examples.java.connectors
Classes in org.apache.flink.table.examples.java.connectors that implement DecodingFormatFactory Modifier and Type Class Description class
ChangelogCsvFormatFactory
TheChangelogCsvFormatFactory
translates format-specific options to a format. -
Uses of DecodingFormatFactory in org.apache.flink.table.factories
Subinterfaces of DecodingFormatFactory in org.apache.flink.table.factories Modifier and Type Interface Description interface
DeserializationFormatFactory
Factory for creating aDecodingFormat
forDeserializationSchema
.Methods in org.apache.flink.table.factories with type parameters of type DecodingFormatFactory Modifier and Type Method Description <I,F extends DecodingFormatFactory<I>>
DecodingFormat<I>FactoryUtil.TableFactoryHelper. discoverDecodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption)
Discovers aDecodingFormat
of the given type using the given option as factory identifier.<I,F extends DecodingFormatFactory<I>>
Optional<DecodingFormat<I>>FactoryUtil.TableFactoryHelper. discoverOptionalDecodingFormat(Class<F> formatFactoryClass, ConfigOption<String> formatOption)
Discovers aDecodingFormat
of the given type using the given option (if present) as factory identifier.
-