[SAMZA-1889] Extend ExecutionPlanner to support Stream-Table Joins

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0
• Assignee: Ahmed Abdul Hamid
• Reporter: Ahmed Abdul Hamid
• Created: 19/Sep/18 19:37
• Updated: 20/Nov/19 22:40
• Resolved: 11/Oct/18 00:44

Description

We need to extend ExecutionPlanner to support Tables. In particular, we need it to verify agreement in partition count between stream(s) behind the table and all other streams participating in Stream-Table Joins with said stream(s).

All the details are documented in the following documents:

• Extending Samza’s Execution Planner to Support Stream-Table Joins.pdf
• Modularizing Join Validation in Samza’s Execution Planner.pdf

Issue Links

• contains: SAMZA-1612 Stream-table join: Number of partitions deduced for partitionBy for the stream to be joined does not take into account the partitions in the table
• is required by: SAMZA-1601 Add stream-table join support for Samza Sql
• links to: GitHub Pull Request #665
• mentioned in: Page Loading...