Modifier and Type | Method and Description |
---|---|
protected <I,F extends DecodingFormatFactory<I>> |
FileSystemTableFactory.discoverDecodingFormat(DynamicTableFactory.Context context,
Class<F> formatFactoryClass) |
Constructor and Description |
---|
FileSystemTableSource(ObjectIdentifier tableIdentifier,
DataType physicalRowDataType,
List<String> partitionKeys,
ReadableConfig tableOptions,
DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat,
DecodingFormat<DeserializationSchema<RowData>> deserializationFormat) |
FileSystemTableSource(ObjectIdentifier tableIdentifier,
DataType physicalRowDataType,
List<String> partitionKeys,
ReadableConfig tableOptions,
DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat,
DecodingFormat<DeserializationSchema<RowData>> deserializationFormat) |
Modifier and Type | Interface and Description |
---|---|
interface |
BulkDecodingFormat<T>
|
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
RegistryAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
static class |
CsvFileFormatFactory.CsvBulkDecodingFormat
CsvBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
CanalJsonDecodingFormat
DecodingFormat for Canal using JSON encoding. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
DebeziumJsonDecodingFormat
DecodingFormat for Debezium using JSON encoding. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
MaxwellJsonDecodingFormat
DecodingFormat for Maxwell using JSON encoding. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
MaxwellJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
class |
OggJsonDecodingFormat
DecodingFormat for Ogg using JSON encoding. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
OggJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
static class |
ParquetFileFormatFactory.ParquetBulkDecodingFormat
ParquetBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Class and Description |
---|---|
class |
PbDecodingFormat
DecodingFormat for protobuf decoding. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
PbFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
RawFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Class and Description |
---|---|
static class |
OrcFileFormatFactory.OrcBulkDecodingFormat
OrcBulkDecodingFormat which implements
FileBasedStatisticsReportableInputFormat . |
Modifier and Type | Interface and Description |
---|---|
interface |
ProjectableDecodingFormat<I>
Extension of
DecodingFormat which is able to produce projected rows. |
Modifier and Type | Class and Description |
---|---|
class |
ChangelogCsvFormat
The
ChangelogCsvFormat is a decoding format that uses a DeserializationSchema
during runtime. |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Constructor and Description |
---|
SocketDynamicTableSource(String hostname,
int port,
byte byteDelimiter,
DecodingFormat<DeserializationSchema<RowData>> decodingFormat,
DataType producedDataType) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
<I,F extends DecodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverDecodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
DecodingFormat of the given type using the given option as factory
identifier. |
Modifier and Type | Method and Description |
---|---|
<I,F extends DecodingFormatFactory<I>> |
FactoryUtil.TableFactoryHelper.discoverOptionalDecodingFormat(Class<F> formatFactoryClass,
ConfigOption<String> formatOption)
Discovers a
DecodingFormat of the given type using the given option (if present)
as factory identifier. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.