[jira] [Created] (FLINK-6073) Support for SQL inner queries for proctime

radu created FLINK-6073: --- Summary: Support for SQL inner queries for proctime Key: FLINK-6073 URL: https://issues.apache.org/jira/browse/FLINK-6073 Project: Flink Issue Type: Sub-task Compone

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from strea

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Attachment: innerquery.png > Support for SQL inner queries for proctime > --

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from strea

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from strea

[jira] [Updated] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6073: Description: Time target: Proc Time **SQL targeted query examples:** Q1) `Select item, (select item2 from strea

[jira] [Created] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

radu created FLINK-6075: --- Summary: Support Limit/Top(Sort) for Stream SQL Key: FLINK-6075 URL: https://issues.apache.org/jira/browse/FLINK-6075 Project: Flink Issue Type: Bug Components: Tabl

[jira] [Updated] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Description: These will be split in 3 separated JIRA issues. However, the design is the same only the processing fu

[jira] [Updated] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Attachment: sort.png > Support Limit/Top(Sort) for Stream SQL > -- > >

[jira] [Created] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

radu created FLINK-6077: --- Summary: Support In/Exists/Except/Any /Some/All for Stream SQL Key: FLINK-6077 URL: https://issues.apache.org/jira/browse/FLINK-6077 Project: Flink Issue Type: Bug C

[jira] [Updated] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6077: Attachment: in.png > Support In/Exists/Except/Any /Some/All for Stream SQL > ---

[jira] [Updated] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6077: Description: Time target: Proc Time SQL targeted query examples: With inner query Q1

[jira] [Created] (FLINK-6081) Offset/Fetch support for SQL Streaming

radu created FLINK-6081: --- Summary: Offset/Fetch support for SQL Streaming Key: FLINK-6081 URL: https://issues.apache.org/jira/browse/FLINK-6081 Project: Flink Issue Type: Bug Components: Tabl

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6081: Attachment: offset.png > Offset/Fetch support for SQL Streaming > -- > >

[jira] [Updated] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6081: Description: Time target: Proc Time The main scope of Offset/Fetch is for pagination support. In the context of str

[jira] [Created] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

radu created FLINK-6082: --- Summary: Support window definition for SQL Queries based on WHERE clause with time condition Key: FLINK-6082 URL: https://issues.apache.org/jira/browse/FLINK-6082 Project: Flink

[jira] [Updated] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6082: Description: Time target: Proc Time Calcite documentation refers to query examples where the (time) boundaries are

[jira] [Assigned] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6073: --- Assignee: radu > Support for SQL inner queries for proctime > -- > >

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932636#comment-15932636 ] radu commented on FLINK-6073: - I will start the implementation to support this rule [~fhueske]

[jira] [Commented] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15936277#comment-15936277 ] radu commented on FLINK-6077: - It is actually more similar with inner queries (that is if you

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15940880#comment-15940880 ] radu commented on FLINK-6073: - the join window can be one window element as we emit for every

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944671#comment-15944671 ] radu commented on FLINK-6073: - Hi [~fhueske], Thanks for the review. I agree that we should s

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15944957#comment-15944957 ] radu commented on FLINK-6082: - Hi [~fhueske] thanks for the review. I agree with the modificat

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945125#comment-15945125 ] radu commented on FLINK-6073: - Hi [~fhueske] thanks again for the feedback - it is really help

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945136#comment-15945136 ] radu commented on FLINK-6082: - I add also [~Yuhong_kyo] as she works on the join design > Sup

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945151#comment-15945151 ] radu commented on FLINK-6082: - [~fhueske] - Fine for me for the time condition to select the s

[jira] [Commented] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15945497#comment-15945497 ] radu commented on FLINK-6081: - After checking with Calcite parser option the query examples ne

[jira] [Commented] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946776#comment-15946776 ] radu commented on FLINK-6081: - Considering that Calcite does not currently support syntax such

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946931#comment-15946931 ] radu commented on FLINK-6075: - Please refer to the comments from [#Flink-6081] Considering t

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946947#comment-15946947 ] radu commented on FLINK-6075: - Calcite grammar also restricts using the limit within the OVER

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946956#comment-15946956 ] radu commented on FLINK-6075: - Queries such as Q3) `SELECT sum(a) OVER (ORDER BY proctime RANG

[jira] [Comment Edited] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946956#comment-15946956 ] radu edited comment on FLINK-6075 at 3/29/17 11:33 AM: --- Queries such

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946959#comment-15946959 ] radu commented on FLINK-6075: - We can therefor start from supporting SELECT a2 FROM s2 ORDER

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946961#comment-15946961 ] radu commented on FLINK-6075: - We use the sort example as a benchamrk from https://calcite.ap

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948765#comment-15948765 ] radu commented on FLINK-6073: - [~fhueske] Thanks for the remarks. My idea of the queries such

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948935#comment-15948935 ] radu commented on FLINK-6073: - [~fhueske] - no i understood what you meant. I think it is corr

[jira] [Commented] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948943#comment-15948943 ] radu commented on FLINK-6077: - Using queries such as SELECT A1 FROM T1 WHERE A2 IN "(SELECT B

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949103#comment-15949103 ] radu commented on FLINK-6073: - LogicalProject(A1=[$0]) LogicalJoin(condition=[AND(=($2, $4),

[jira] [Comment Edited] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949103#comment-15949103 ] radu edited comment on FLINK-6073 at 3/30/17 2:01 PM: -- { LogicalProje

[jira] [Commented] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949735#comment-15949735 ] radu commented on FLINK-6073: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Comment Edited] (FLINK-6073) Support for SQL inner queries for proctime

[ https://issues.apache.org/jira/browse/FLINK-6073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949735#comment-15949735 ] radu edited comment on FLINK-6073 at 3/30/17 9:01 PM: -- [~fhueske] [~s

[jira] [Commented] (FLINK-6077) Support In/Exists/Except/Any /Some/All for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949827#comment-15949827 ] radu commented on FLINK-6077: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Commented] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949857#comment-15949857 ] radu commented on FLINK-6081: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Assigned] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6081: --- Assignee: radu > Offset/Fetch support for SQL Streaming > -- > >

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949864#comment-15949864 ] radu commented on FLINK-6075: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Comment Edited] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949864#comment-15949864 ] radu edited comment on FLINK-6075 at 3/30/17 9:23 PM: -- [~fhueske] [~s

[jira] [Commented] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

[ https://issues.apache.org/jira/browse/FLINK-6082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949878#comment-15949878 ] radu commented on FLINK-6082: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15949899#comment-15949899 ] radu commented on FLINK-5725: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Commented] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953080#comment-15953080 ] radu commented on FLINK-6241: - can you please post a description of what you aim to do? I am c

[jira] [Commented] (FLINK-6243) Continuous Joins: True Sliding Window Joins

[ https://issues.apache.org/jira/browse/FLINK-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953081#comment-15953081 ] radu commented on FLINK-6243: - Hi Elias, Please check also https://issues.apache.org/jira/br

[jira] [Created] (FLINK-6249) Distinct Aggregates for OVER window

radu created FLINK-6249: --- Summary: Distinct Aggregates for OVER window Key: FLINK-6249 URL: https://issues.apache.org/jira/browse/FLINK-6249 Project: Flink Issue Type: New Feature Components:

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1. Boundar

[jira] [Created] (FLINK-6250) Distinct procTime with Rows boundaries

radu created FLINK-6250: --- Summary: Distinct procTime with Rows boundaries Key: FLINK-6250 URL: https://issues.apache.org/jira/browse/FLINK-6250 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Assigned] (FLINK-6250) Distinct procTime with Rows boundaries

[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6250: --- Assignee: Stefano Bortoli Description: Support proctime with rows boundaries Q1.1. `SELECT SUM( DISTI

[jira] [Created] (FLINK-6251) Distinct procTime with time range boundaries

radu created FLINK-6251: --- Summary: Distinct procTime with time range boundaries Key: FLINK-6251 URL: https://issues.apache.org/jira/browse/FLINK-6251 Project: Flink Issue Type: Sub-task Rep

[jira] [Assigned] (FLINK-6251) Distinct procTime with time range boundaries

[ https://issues.apache.org/jira/browse/FLINK-6251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-6251: --- Assignee: radu > Distinct procTime with time range boundaries >

[jira] [Created] (FLINK-6252) Distinct rowTime with Rows boundaries

radu created FLINK-6252: --- Summary: Distinct rowTime with Rows boundaries Key: FLINK-6252 URL: https://issues.apache.org/jira/browse/FLINK-6252 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-6253) Distinct rowTime with time range boundaries

radu created FLINK-6253: --- Summary: Distinct rowTime with time range boundaries Key: FLINK-6253 URL: https://issues.apache.org/jira/browse/FLINK-6253 Project: Flink Issue Type: Sub-task Repo

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953646#comment-15953646 ] radu commented on FLINK-6249: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1. Boundar

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1. Boundar

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1. Boundar

[jira] [Updated] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6249: Description: Time target: ProcTime/EventTime SQL targeted query examples: Q1. Boundar

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954717#comment-15954717 ] radu commented on FLINK-6249: - [~fhueske] Thanks for the feedback! I cleaned the JIRA as you s

[jira] [Comment Edited] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953646#comment-15953646 ] radu edited comment on FLINK-6249 at 4/4/17 7:48 AM: - [~fhueske] [~shi

[jira] [Created] (FLINK-6260) Distinct Aggregates for Group By Windows

radu created FLINK-6260: --- Summary: Distinct Aggregates for Group By Windows Key: FLINK-6260 URL: https://issues.apache.org/jira/browse/FLINK-6260 Project: Flink Issue Type: New Feature Compon

[jira] [Commented] (FLINK-6260) Distinct Aggregates for Group By Windows

[ https://issues.apache.org/jira/browse/FLINK-6260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954739#comment-15954739 ] radu commented on FLINK-6260: - [~fhueske] [~shijinkui] [~Yuhong_kyo] [~sunjincheng121] [~twalt

[jira] [Commented] (FLINK-6241) codeGen dataStream aggregates that use ProcessFunction

[ https://issues.apache.org/jira/browse/FLINK-6241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15954746#comment-15954746 ] radu commented on FLINK-6241: - [~shaoxuan] i realized i did not notify you :) > codeGen dataS

[jira] [Commented] (FLINK-6249) Distinct Aggregates for OVER window

[ https://issues.apache.org/jira/browse/FLINK-6249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15955419#comment-15955419 ] radu commented on FLINK-6249: - [~fhueske] [~twalthr] It seems that the aggregates that are pa

[jira] [Commented] (FLINK-6428) Add support DISTINCT in dataStream SQL

[ https://issues.apache.org/jira/browse/FLINK-6428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15992775#comment-15992775 ] radu commented on FLINK-6428: - [~sunjincheng121] Hi, Please refer to #6249 https://issues.ap

[jira] [Commented] (FLINK-6465) support FIRST_VALUE and LAST_VALUE on Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-6465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15998517#comment-15998517 ] radu commented on FLINK-6465: - How do you plan to implement this? Will you support retraction

[jira] [Created] (FLINK-6476) Table environment register row data stream

radu created FLINK-6476: --- Summary: Table environment register row data stream Key: FLINK-6476 URL: https://issues.apache.org/jira/browse/FLINK-6476 Project: Flink Issue Type: Improvement Comp

[jira] [Commented] (FLINK-6476) Table environment register row data stream

[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1591#comment-1591 ] radu commented on FLINK-6476: - [~fhueske] [~sunjincheng121] [~shijinkui] [~stefano.bortoli] [~

[jira] [Commented] (FLINK-6476) Table environment register row data stream

[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000450#comment-16000450 ] radu commented on FLINK-6476: - [~fhueske] I actually tried also to set the type of the datast

[jira] [Commented] (FLINK-6476) Table environment register row data stream

[ https://issues.apache.org/jira/browse/FLINK-6476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16000512#comment-16000512 ] radu commented on FLINK-6476: - [~fhueske] Great. I will try to implement this. I will ping you

[jira] [Created] (FLINK-6500) RowSerialization problem

radu created FLINK-6500: --- Summary: RowSerialization problem Key: FLINK-6500 URL: https://issues.apache.org/jira/browse/FLINK-6500 Project: Flink Issue Type: Bug Components: Table API & SQL

[jira] [Commented] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16001304#comment-16001304 ] radu commented on FLINK-6500: - [~fhueske] While testing various ways of using the sql i foun

[jira] [Updated] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6500: Description: Relying on implicit types in scala can lead to errors when the arity of the input is different than th

[jira] [Updated] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6500: Description: Relying on implicit types in scala can lead to errors when the arity of the input is different than th

[jira] [Commented] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16002131#comment-16002131 ] radu commented on FLINK-6500: - [~fhueske] Thanks for the info. Considering the workaround - s

[jira] [Created] (FLINK-4969) TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos.

radu created FLINK-4969: --- Summary: TypeInfoParser needs to be extended to parse the java.sql.* types into the corresponding TypeInfos. Key: FLINK-4969 URL: https://issues.apache.org/jira/browse/FLINK-4969 Proje

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15859758#comment-15859758 ] radu commented on FLINK-5654: - I have another dilemma for the implementation. When we build th

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15861207#comment-15861207 ] radu commented on FLINK-5654: - Thanks Haohui for the suggestion. You are right with the sugges

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15888373#comment-15888373 ] radu commented on FLINK-5654: - When we implement the aggregation functions we could use the in

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15893873#comment-15893873 ] radu commented on FLINK-5654: - Thanks sunjincheng - I saw the message to late unfortunately. I

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15894348#comment-15894348 ] radu commented on FLINK-5654: - Hi, I did the rebase yesterday before I did the pull request.

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15896875#comment-15896875 ] radu commented on FLINK-5654: - @shijinkui - thanks for the comment I keeped description becaus

[jira] [Assigned] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu reassigned FLINK-5725: --- Assignee: Yuhong Hong (was: radu) > Support JOIN between two streams in the SQL API > --

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1584#comment-1584 ] radu commented on FLINK-5654: - I would like to implement the this issue. I already have a work

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15842953#comment-15842953 ] radu commented on FLINK-5654: - Discussion about the comment Fabian made in the mail tread for

[jira] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

Title: Message Title radu commented on FLINK-5654

[jira] [Commented] (FLINK-5654) Add processing time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15850152#comment-15850152 ] radu commented on FLINK-5654: - There is another decision point to be made. When we do the pars

[jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1585#comment-1585 ] radu commented on FLINK-5725: - Can you post please a description with the key idea to approach

[jira] [Commented] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15855641#comment-15855641 ] radu commented on FLINK-5657: - Hi Yuhong, In my experience it worked to have the translation

[jira] [Commented] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856004#comment-15856004 ] radu commented on FLINK-5657: - Hi Fabiam Ok. Please ping me when that issue PR #3101 is pushe

[jira] [Comment Edited] (FLINK-5657) Add processing time OVER RANGE BETWEEN UNBOUNDED PRECEDING aggregation to SQL

[ https://issues.apache.org/jira/browse/FLINK-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856004#comment-15856004 ] radu edited comment on FLINK-5657 at 2/7/17 1:45 PM: - Hi Fabian Ok. P

[jira] [Commented] (FLINK-5725) Support JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15857841#comment-15857841 ] radu commented on FLINK-5725: - Ok - thanks. I will work over the next weeks to come up with a

[jira] [Commented] (FLINK-6075) Support Limit/Top(Sort) for Stream SQL

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16028458#comment-16028458 ] radu commented on FLINK-6075: - TOP syntax is not supported by Calcite. Basically top is obtain

[jira] [Created] (FLINK-3176) Window Apply Website Example

radu created FLINK-3176: --- Summary: Window Apply Website Example Key: FLINK-3176 URL: https://issues.apache.org/jira/browse/FLINK-3176 Project: Flink Issue Type: Improvement Components: websit

[jira] [Updated] (FLINK-6075) ORDER BY *time ASC

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] radu updated FLINK-6075: Summary: ORDER BY *time ASC (was: Support Limit/Top(Sort) for Stream SQL) > ORDER BY *time ASC > --

  1   2   >