beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tyler Akidau (JIRA)" <>
Subject [jira] [Commented] (BEAM-301) Add a Beam SQL DSL
Date Mon, 21 Nov 2016 17:53:58 GMT


Tyler Akidau commented on BEAM-301:

You may already be aware of these, Neelesh, but I'd like to reference some docs here that
are relevant to this effort here in case you aren't (or for others). I've been chatting on
and off w/ the Calcite folks regarding SQL this year, in particular regarding adding robust
streaming semantics into the Calcite algebra. We don't need any additions to get something
basic, similar to what Apache Flink has (and there's plenty of work around just defining how
schemas are mapped, how SQL is expressed in the pipeline, etc). But we will want them some

At any rate, the relevant docs so far that I'm aware of:

1. Streaming SQL - Julian Hyde’s initial manifesto on integrating streaming in Calcite SQL:

2. Triggers in Streaming SQL - My first attempt at tackling out-of-order processing semantics
for streaming SQL:

3. Streams, joins and temporal tables - Julian’s proposal for tables which are parameterized
on a timestamp value:

4. Relational Queries on Data Streams - Apache Flink proposal for standard SQL based queries
on data streams:

I've been wanting to write up one more doc trying to reconcile #2 with #3, but haven't gotten
around to finishing it yet.

> Add a Beam SQL DSL
> ------------------
>                 Key: BEAM-301
>                 URL:
>             Project: Beam
>          Issue Type: New Feature
>          Components: sdk-ideas
>            Reporter: Jean-Baptiste Onofré
>            Assignee: Neelesh Srinivas Salian

This message was sent by Atlassian JIRA

View raw message