[FLINK-25643] Introduce Predicate to table store

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: table-store-0.1.0
• Component/s: Table Store
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 13/Jan/22 09:58
• Updated: 14/Feb/22 08:33
• Resolved: 14/Jan/22 08:31

Description

Flink Expression is not serializable. Although it has asSerializableString, the method is not implemented by all Expressions, and the deserialization requires many parameters.

So table store introduces Predicate to be a serializable class to do filter and partition push down.

Issue Links

• links to: GitHub Pull Request #7