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

Interface BulkReaderFormatFactory

  • All Superinterfaces:
    org.apache.flink.table.factories.DecodingFormatFactory<BulkFormat<org.apache.flink.table.data.RowData,​FileSourceSplit>>, org.apache.flink.table.factories.Factory, org.apache.flink.table.factories.FormatFactory
    @Internal
public interface BulkReaderFormatFactory
extends org.apache.flink.table.factories.DecodingFormatFactory<BulkFormat<org.apache.flink.table.data.RowData,​FileSourceSplit>>
    Base interface for configuring a BulkFormat for file system connector.
    See Also:
    FactoryUtil.createTableFactoryHelper(DynamicTableFactory, DynamicTableFactory.Context)

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      BulkDecodingFormat<org.apache.flink.table.data.RowData> createDecodingFormat​(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.configuration.ReadableConfig formatOptions)
      Creates a BulkDecodingFormat from the given context and format options.

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

        factoryIdentifier, optionalOptions, requiredOptions

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

        forwardOptions

    • Method Detail

      • createDecodingFormat

        BulkDecodingFormat<org.apache.flink.table.data.RowData> createDecodingFormat​(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                                                             org.apache.flink.configuration.ReadableConfig formatOptions)
        Creates a BulkDecodingFormat from the given context and format options.
        Specified by:
        createDecodingFormat in interface org.apache.flink.table.factories.DecodingFormatFactory<BulkFormat<org.apache.flink.table.data.RowData,​FileSourceSplit>>