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

Interface BulkDecodingFormat<T>

  • All Superinterfaces:
    org.apache.flink.table.connector.format.DecodingFormat<BulkFormat<T,​FileSourceSplit>>, org.apache.flink.table.connector.format.Format
    @Internal
public interface BulkDecodingFormat<T>
extends org.apache.flink.table.connector.format.DecodingFormat<BulkFormat<T,​FileSourceSplit>>
    A Format for a DynamicTableSource for reading rows by BulkFormat.

    • Method Summary

      All Methods Instance Methods Default Methods 
      Modifier and Type Method Description
      default void applyFilters​(List<org.apache.flink.table.expressions.ResolvedExpression> filters)
      Provides a list of filters in conjunctive form for filtering on a best-effort basis.

      • Methods inherited from interface org.apache.flink.table.connector.format.DecodingFormat

        applyReadableMetadata, createRuntimeDecoder, listReadableMetadata

      • Methods inherited from interface org.apache.flink.table.connector.format.Format

        getChangelogMode

    • Method Detail

      • applyFilters

        default void applyFilters​(List<org.apache.flink.table.expressions.ResolvedExpression> filters)
        Provides a list of filters in conjunctive form for filtering on a best-effort basis.