SupportsRuntimeV2Filtering¶

SupportsRuntimeV2Filtering is an extension of the Scan abstraction for connectors that can filter initially planned InputPartitions using predicates Spark infers at runtime.

Contract¶

filterAttributes¶

NamedReference[] filterAttributes()

filter¶

void filter(
  Predicate[] predicates)

Implementations¶

• SupportsRuntimeFiltering