You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Chris Riccomini (JIRA)" <ji...@apache.org> on 2015/02/13 22:35:11 UTC

[jira] [Resolved] (SAMZA-483) A common representation of relational algebra for streaming SQL

     [ https://issues.apache.org/jira/browse/SAMZA-483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chris Riccomini resolved SAMZA-483.
-----------------------------------
    Resolution: Fixed

+1 Merged and committed. I don't want to merge this into master until we understand the details about conjars and the \-jhyde JARs.

> A common representation of relational algebra for streaming SQL 
> ----------------------------------------------------------------
>
>                 Key: SAMZA-483
>                 URL: https://issues.apache.org/jira/browse/SAMZA-483
>             Project: Samza
>          Issue Type: Sub-task
>          Components: sql
>    Affects Versions: 0.9.0
>            Reporter: Yi Pan (Data Infrastructure)
>            Assignee: Milinda Lakmal Pathirage
>            Priority: Minor
>              Labels: project
>         Attachments: SAMZA-483-1.patch, SAMZA-483-2.patch, SAMZA-483-3.patch, SAMZA-483-4.patch, SAMZA-483-5.patch, SAMZA-483-6.patch, SAMZA-483-7.patch, calcite-integration-prototype.patch
>
>
> Per discussion with [~criccomini] and [~milinda], we agreed that it seems to be a good idea to define a common representation of relational algebra on top of the operators defined in the operator layer (see SAMZA-482), which can be the common base that we can use to generate the description/configuration of a Samza job.
> This common layer can also be used by DSL-like language parser as a result of parsing a DSL program.
> Some additional requirements needed in addition to pure relational algebra:
> 1) the common representation should include window operators and stream operators (i.e. IStream/DStream/RStream)
> 2) the common representation should include description on parallelism of the jobs (i.e. how many partitions the resultant Samza job will use)
> Some references:
> http://web.cs.wpi.edu/~mukherab/i/DCAPE.pdf
> https://cs.uwaterloo.ca/~david/cs848/stream-cql.pdf
> http://davis.wpi.edu/dsrg/PROJECTS/CAPE/publications.htm
> http://davis.wpi.edu/dsrg/PROJECTS/CAPE/slides.htm



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)