THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Option | Type | Default value |
---|---|---|
source.aggregate-push-down.enabled | Boolean | true |
... | Boolean | true |
Add a new source ability options in the TableSourceOptions class.
Code Block | ||
---|---|---|
| ||
@PublicEvolving
public class TableSourceOptions {
public static final ConfigOption<String> ENABLE_FILTER_PUSH_DOWN =
key("source.filter-push-down.enabled")
.booleanType()
.defaultValue(true)
.withDescription("Whether to enable filter push down.");
......
} |
Proposed Changes
For sources that need to support disabling filter pushdown, it is necessary to check this configuration in the applyFilters method to determine whether to perform predicate pushdown.
...