org.apache.flink.connector.file.table.factories

Interface BulkReaderFormatFactory

All Superinterfaces:

DecodingFormatFactory<BulkFormat<RowData,FileSourceSplit>>, Factory, FormatFactory

All Known Implementing Classes:

AvroFileFormatFactory, CsvFileFormatFactory, OrcFileFormatFactory, ParquetFileFormatFactory, PbFileFormatFactory

@Internal
public interface BulkReaderFormatFactory
extends DecodingFormatFactory<BulkFormat<RowData,FileSourceSplit>>

Base interface for configuring a BulkFormat for file system connector.

See Also:

FactoryUtil.createTableFactoryHelper(DynamicTableFactory, DynamicTableFactory.Context)

Method Summary

Modifier and Type	Method and Description
BulkDecodingFormat<RowData>	createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions) Creates a BulkDecodingFormat from the given context and format options.

Methods inherited from interface org.apache.flink.table.factories.FormatFactory

forwardOptions

Methods inherited from interface org.apache.flink.table.factories.Factory

factoryIdentifier, optionalOptions, requiredOptions

Method Detail

createDecodingFormat

BulkDecodingFormat<RowData> createDecodingFormat(DynamicTableFactory.Context context,
                                                 ReadableConfig formatOptions)

Creates a BulkDecodingFormat from the given context and format options.

Specified by:

createDecodingFormat in interface DecodingFormatFactory<BulkFormat<RowData,FileSourceSplit>>