Skip to content

[flink] Add Flink filter pushdown integration and documentation#3032

Open
platinumhamburg wants to merge 2 commits intoapache:mainfrom
platinumhamburg:flink-filter-pushdown-integration
Open

[flink] Add Flink filter pushdown integration and documentation#3032
platinumhamburg wants to merge 2 commits intoapache:mainfrom
platinumhamburg:flink-filter-pushdown-integration

Conversation

@platinumhamburg
Copy link
Copy Markdown
Contributor

Purpose

Linked issue: close #3031 3031

Brief change log

Tests

API and Format

Documentation

@platinumhamburg platinumhamburg force-pushed the flink-filter-pushdown-integration branch 6 times, most recently from 5513ce7 to 177c62b Compare April 9, 2026 13:40
@platinumhamburg platinumhamburg force-pushed the flink-filter-pushdown-integration branch from 177c62b to de2995c Compare April 10, 2026 01:16
Add table.statistics.columns to the alterable table options whitelist,
and add an integration test that verifies filter pushdown works correctly
across dynamic statistics configuration changes: disabled → subset → wildcard.

The test covers 4 phases:
- Phase 1: Statistics disabled — filter NOT pushed to source
- Phase 2: ALTER to subset ('amount') — filter pushed for amount, not for score
- Phase 3: ALTER to wildcard ('*') — all column filters pushed, combined filter verified
- Phase 4: Cross-phase query — mixed statistics coverage batches coexist correctly
@platinumhamburg platinumhamburg force-pushed the flink-filter-pushdown-integration branch from f966154 to 5cb3175 Compare April 10, 2026 04:13
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[flink] Add Flink filter pushdown integration and documentation

1 participant