Uploaded image for project: 'Samza'
  1. Samza
  2. SAMZA-390 High-Level Language for Samza
  3. SAMZA-562

Implement Calcite SchemaFactory on top of Kafka Schema Registry

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 0.9.0
    • None
    • sql
    • None

    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.

      Attachments

        Issue Links

          is blocked by

          Task - A task that needs to be done. SAMZA-573 Schema metadata store for operator layer

          • Major - Major loss of function.
          • Open

          Activity

            People

              Unassigned Unassigned
              milinda Milinda Pathirage
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: