org.apache.flink.table.connector.format

Interface BulkDecodingFormat<T>

All Superinterfaces:

DecodingFormat<BulkFormat<T,FileSourceSplit>>, Format

@Internal
public interface BulkDecodingFormat<T>
extends DecodingFormat<BulkFormat<T,FileSourceSplit>>

A Format for a DynamicTableSource for reading rows by BulkFormat.

Method Summary

Modifier and Type	Method and Description
default void	applyFilters(List<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<ResolvedExpression> filters)

Provides a list of filters in conjunctive form for filtering on a best-effort basis.