[SAMZA-562] Implement Calcite SchemaFactory on top of Kafka Schema Registry

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 0.9.0
• Component/s: sql
• Assignee: Unassigned
• Reporter: Milinda Pathirage
• Created: 12/Feb/15 20:52
• Updated: 23/Feb/15 17:05

Description

Having knowledge about the schema of tuples in a stream is important during stream query validation. We don't have a metadata catalogue implemented for Samza. Because we are mainly going to interact with Kafka topics in stream queries, we can start by integrating Kafka schema registry to Calcite based query planner implementation.

Implementations of Calcite's SchemaFactory, TableFactory and related interfaces are required to plug Kafka schema registry to Calcite.

Issue Links

• is blocked by: SAMZA-573 Schema metadata store for operator layer