[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-02-08 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859039#comment-15859039 ] Shaoxuan Wang commented on FLINK-5564: -- Thanks [~fhueske], Obsoletely, I agree with you that it is

[jira] [Comment Edited] (FLINK-5564) User Defined Aggregates

2017-02-08 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859039#comment-15859039 ] Shaoxuan Wang edited comment on FLINK-5564 at 2/9/17 5:16 AM: -- Thanks

[jira] [Comment Edited] (FLINK-5564) User Defined Aggregates

2017-02-08 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859039#comment-15859039 ] Shaoxuan Wang edited comment on FLINK-5564 at 2/9/17 5:16 AM: -- Thanks

[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-02-06 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854160#comment-15854160 ] Shaoxuan Wang commented on FLINK-5564: -- Thanks Fabian, I will create the Jira for each subIssues. I

[jira] [Comment Edited] (FLINK-5564) User Defined Aggregates

2017-02-06 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854168#comment-15854168 ] Shaoxuan Wang edited comment on FLINK-5564 at 2/6/17 3:02 PM: -- Hi all, as

[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-02-06 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15854168#comment-15854168 ] Shaoxuan Wang commented on FLINK-5564: -- Hi all, as also discussed in the dev email thread for the

[jira] [Updated] (FLINK-5564) User Defined Aggregates

2017-01-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5564: - Description: User-defined aggregates would be a great addition to the Table API / SQL. The

[jira] [Updated] (FLINK-5564) User Defined Aggregates

2017-01-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5564: - Description: User-defined aggregates would be a great addition to the Table API / SQL. The

[jira] [Created] (FLINK-5813) code generation for user-defined aggregate functions

2017-02-15 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5813: Summary: code generation for user-defined aggregate functions Key: FLINK-5813 URL: https://issues.apache.org/jira/browse/FLINK-5813 Project: Flink Issue

[jira] [Created] (FLINK-5878) Add stream-stream inner join on TableAPI

2017-02-21 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5878: Summary: Add stream-stream inner join on TableAPI Key: FLINK-5878 URL: https://issues.apache.org/jira/browse/FLINK-5878 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-5767) New aggregate function interface and built-in aggregate functions

2017-02-18 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5767: - Summary: New aggregate function interface and built-in aggregate functions (was: Add a new

[jira] [Created] (FLINK-5900) Add non-partial merge Aggregates and unit tests

2017-02-23 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5900: Summary: Add non-partial merge Aggregates and unit tests Key: FLINK-5900 URL: https://issues.apache.org/jira/browse/FLINK-5900 Project: Flink Issue Type:

[jira] [Created] (FLINK-5899) Fix the bug in initializing the DataSetTumbleTimeWindowAggReduceGroupFunction

2017-02-23 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5899: Summary: Fix the bug in initializing the DataSetTumbleTimeWindowAggReduceGroupFunction Key: FLINK-5899 URL: https://issues.apache.org/jira/browse/FLINK-5899 Project:

[jira] [Updated] (FLINK-5899) Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate

2017-02-23 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5899: - Summary: Fix the bug in EventTimeTumblingWindow for non-partialMerge aggregate (was: Fix the bug

[jira] [Assigned] (FLINK-5906) Add support to register UDAGGs in TableEnvironment

2017-02-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5906: Assignee: Shaoxuan Wang > Add support to register UDAGGs in TableEnvironment >

[jira] [Created] (FLINK-5915) Add support for the aggregate on multi fields

2017-02-24 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5915: Summary: Add support for the aggregate on multi fields Key: FLINK-5915 URL: https://issues.apache.org/jira/browse/FLINK-5915 Project: Flink Issue Type:

[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-02-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15884070#comment-15884070 ] Shaoxuan Wang commented on FLINK-5564: -- It is hard to separate the PRs for dataStream (FLINK-5768)

[jira] [Created] (FLINK-5914) remove aggregateResultType from streaming.api.datastream.aggregate

2017-02-24 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5914: Summary: remove aggregateResultType from streaming.api.datastream.aggregate Key: FLINK-5914 URL: https://issues.apache.org/jira/browse/FLINK-5914 Project: Flink

[jira] [Created] (FLINK-5769) Apply new aggregation functions for dataset tables

2017-02-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5769: Summary: Apply new aggregation functions for dataset tables Key: FLINK-5769 URL: https://issues.apache.org/jira/browse/FLINK-5769 Project: Flink Issue Type:

[jira] [Created] (FLINK-5767) Add a new aggregate function interface

2017-02-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5767: Summary: Add a new aggregate function interface Key: FLINK-5767 URL: https://issues.apache.org/jira/browse/FLINK-5767 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5768) Apply new aggregation functions and aggregate DataStream API for streaming tables

2017-02-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5768: Summary: Apply new aggregation functions and aggregate DataStream API for streaming tables Key: FLINK-5768 URL: https://issues.apache.org/jira/browse/FLINK-5768

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-17 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15826380#comment-15826380 ] Shaoxuan Wang commented on FLINK-5386: -- Yes [~fhueske], we should not support groupby() without keys

[jira] [Commented] (FLINK-5498) OuterJoins with non-equality predicates compute wrong results

2017-01-16 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824142#comment-15824142 ] Shaoxuan Wang commented on FLINK-5498: -- Hello, [~fhueske]. I agree with you that we should fix the

[jira] [Comment Edited] (FLINK-5386) Refactoring Window Clause

2017-01-16 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824844#comment-15824844 ] Shaoxuan Wang edited comment on FLINK-5386 at 1/17/17 3:37 AM: ---

[jira] [Assigned] (FLINK-5564) User Defined Aggregates

2017-01-18 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5564: Assignee: Shaoxuan Wang > User Defined Aggregates > --- > >

[jira] [Created] (FLINK-5564) User Defined Aggregates

2017-01-18 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5564: Summary: User Defined Aggregates Key: FLINK-5564 URL: https://issues.apache.org/jira/browse/FLINK-5564 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-5386) Refactoring Window Clause

2017-01-16 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15824844#comment-15824844 ] Shaoxuan Wang commented on FLINK-5386: -- [~sunjincheng121], thanks for the updates. Hi [~fhueske],

[jira] [Created] (FLINK-5927) Remove old Aggregate interface and built-in functions

2017-02-27 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5927: Summary: Remove old Aggregate interface and built-in functions Key: FLINK-5927 URL: https://issues.apache.org/jira/browse/FLINK-5927 Project: Flink Issue

[jira] [Updated] (FLINK-5768) Apply new aggregation functions for datastream and dataset tables

2017-02-26 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5768: - Summary: Apply new aggregation functions for datastream and dataset tables (was: Apply new

[jira] [Updated] (FLINK-5768) Apply new aggregation functions for datastream and dataset tables

2017-02-26 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5768: - Description: Apply new aggregation functions for datastream and dataset tables This includes: 1.

[jira] [Created] (FLINK-4781) Add User Defined Function(UDF) API for DataStream

2016-10-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-4781: Summary: Add User Defined Function(UDF) API for DataStream Key: FLINK-4781 URL: https://issues.apache.org/jira/browse/FLINK-4781 Project: Flink Issue Type:

[jira] [Closed] (FLINK-4781) Add User Defined Function(UDF) API for Table API

2016-10-10 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-4781. Resolution: Duplicate > Add User Defined Function(UDF) API for Table API >

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-10-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601682#comment-15601682 ] Shaoxuan Wang commented on FLINK-4469: -- Thanks for checking this, Fabian. I replied this thread

[jira] [Commented] (FLINK-4469) Add support for user defined table function in Table API & SQL

2016-10-28 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15615002#comment-15615002 ] Shaoxuan Wang commented on FLINK-4469: -- Hi Jark, Sounds good to me. Can you please update the Jira

[jira] [Created] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation

2017-01-10 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5433: Summary: initiate function of Aggregate does not take effect for DataStream aggregation Key: FLINK-5433 URL: https://issues.apache.org/jira/browse/FLINK-5433

[jira] [Assigned] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation

2017-01-10 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5433: Assignee: Shaoxuan Wang > initiate function of Aggregate does not take effect for

[jira] [Commented] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation

2017-01-10 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15814399#comment-15814399 ] Shaoxuan Wang commented on FLINK-5433: -- It seems initiate function has only been used in

[jira] [Assigned] (FLINK-6091) Implement and turn on the retraction for grouping window aggregate

2017-03-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-6091: Assignee: Hequn Cheng (was: Shaoxuan Wang) > Implement and turn on the retraction for

[jira] [Assigned] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate

2017-03-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-6090: Assignee: Hequn Cheng (was: Shaoxuan Wang) > Implement optimizer for retraction and turn

[jira] [Created] (FLINK-6216) DataStream unbounded groupby aggregate with early firing

2017-03-29 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6216: Summary: DataStream unbounded groupby aggregate with early firing Key: FLINK-6216 URL: https://issues.apache.org/jira/browse/FLINK-6216 Project: Flink Issue

[jira] [Assigned] (FLINK-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase

2017-03-17 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-6089: Assignee: Hequn Cheng (was: Shaoxuan Wang) > Implement decoration phase for rewriting

[jira] [Created] (FLINK-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase

2017-03-16 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6089: Summary: Implement decoration phase for rewriting predicated logical plan after volcano optimization phase Key: FLINK-6089 URL: https://issues.apache.org/jira/browse/FLINK-6089

[jira] [Created] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate

2017-03-16 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6090: Summary: Implement optimizer for retraction and turn on retraction for over window aggregate Key: FLINK-6090 URL: https://issues.apache.org/jira/browse/FLINK-6090

[jira] [Created] (FLINK-6094) Implement and turn on retraction for stream-stream inner join

2017-03-16 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6094: Summary: Implement and turn on retraction for stream-stream inner join Key: FLINK-6094 URL: https://issues.apache.org/jira/browse/FLINK-6094 Project: Flink

[jira] [Updated] (FLINK-6047) Master Jira for "Retraction for Flink Streaming"

2017-03-16 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-6047: - Description: [Design doc]:

[jira] [Created] (FLINK-6092) Implement and turn on retraction for table source

2017-03-16 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6092: Summary: Implement and turn on retraction for table source Key: FLINK-6092 URL: https://issues.apache.org/jira/browse/FLINK-6092 Project: Flink Issue Type:

[jira] [Created] (FLINK-6093) Implement and turn on retraction for table sink

2017-03-16 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6093: Summary: Implement and turn on retraction for table sink Key: FLINK-6093 URL: https://issues.apache.org/jira/browse/FLINK-6093 Project: Flink Issue Type:

[jira] [Created] (FLINK-6091) Implement and turn on the retraction for grouping window aggregate

2017-03-16 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6091: Summary: Implement and turn on the retraction for grouping window aggregate Key: FLINK-6091 URL: https://issues.apache.org/jira/browse/FLINK-6091 Project: Flink

[jira] [Commented] (FLINK-5564) User Defined Aggregates

2017-04-01 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15952127#comment-15952127 ] Shaoxuan Wang commented on FLINK-5564: -- [~fhueske], implementing the entire codeGen into one PR

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

2017-04-01 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6241: Summary: codeGen dataStream aggregates that use ProcessFunction Key: FLINK-6241 URL: https://issues.apache.org/jira/browse/FLINK-6241 Project: Flink Issue

[jira] [Created] (FLINK-6240) codeGen dataStream aggregates that use AggregateAggFunction

2017-04-01 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6240: Summary: codeGen dataStream aggregates that use AggregateAggFunction Key: FLINK-6240 URL: https://issues.apache.org/jira/browse/FLINK-6240 Project: Flink

[jira] [Created] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates

2017-04-01 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6242: Summary: codeGen DataSet Goupingwindow Aggregates Key: FLINK-6242 URL: https://issues.apache.org/jira/browse/FLINK-6242 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-6334) Refactoring UDTF interface

2017-04-19 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-6334: - Description: The current UDTF leverages the table.join(expression) interface, which is not a

[jira] [Resolved] (FLINK-5813) code generation for user-defined aggregate functions

2017-04-22 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang resolved FLINK-5813. -- Resolution: Fixed All required issues are solved. > code generation for user-defined aggregate

[jira] [Created] (FLINK-6361) Finalize the AggregateFunction interface and refactoring built-in aggregates

2017-04-22 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6361: Summary: Finalize the AggregateFunction interface and refactoring built-in aggregates Key: FLINK-6361 URL: https://issues.apache.org/jira/browse/FLINK-6361 Project:

[jira] [Updated] (FLINK-5984) Add resetAccumulator method for AggregateFunction

2017-03-08 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5984: - Summary: Add resetAccumulator method for AggregateFunction (was: Allow reusing of accumulators

[jira] [Assigned] (FLINK-5984) Allow reusing of accumulators in AggregateFunction

2017-03-08 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5984: Assignee: Shaoxuan Wang > Allow reusing of accumulators in AggregateFunction >

[jira] [Created] (FLINK-6047) Master Jira for "Retraction for Flink Streaming"

2017-03-14 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6047: Summary: Master Jira for "Retraction for Flink Streaming" Key: FLINK-6047 URL: https://issues.apache.org/jira/browse/FLINK-6047 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-5655) Add event time OVER RANGE BETWEEN x PRECEDING aggregation to SQL

2017-03-06 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5655: Assignee: sunjincheng (was: Shaoxuan Wang) > Add event time OVER RANGE BETWEEN x

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

2017-03-06 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15898814#comment-15898814 ] Shaoxuan Wang commented on FLINK-5655: -- [~sunjincheng121] and I want to start the implementation on

[jira] [Issue Comment Deleted] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-07 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5983: - Comment: was deleted (was: ok, the plan sounds good to me. The runtime processing function for

[jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-07 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899620#comment-15899620 ] Shaoxuan Wang commented on FLINK-5983: -- ok, the plan sounds good to me. The runtime processing

[jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-07 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899619#comment-15899619 ] Shaoxuan Wang commented on FLINK-5983: -- ok, the plan sounds good to me. The runtime processing

[jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-07 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899577#comment-15899577 ] Shaoxuan Wang commented on FLINK-5983: -- I love this proposal to replace scala for loops by while

[jira] [Commented] (FLINK-5983) Replace for/foreach/map in aggregates by while loops

2017-03-07 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15899594#comment-15899594 ] Shaoxuan Wang commented on FLINK-5983: -- Can we consider implementing the runtime code and even the

[jira] [Created] (FLINK-5956) Add retract method into the aggregateFunction

2017-03-03 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5956: Summary: Add retract method into the aggregateFunction Key: FLINK-5956 URL: https://issues.apache.org/jira/browse/FLINK-5956 Project: Flink Issue Type:

[jira] [Created] (FLINK-5955) Merging a list of buffered records will have problem when ObjectReuse is turned on

2017-03-02 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-5955: Summary: Merging a list of buffered records will have problem when ObjectReuse is turned on Key: FLINK-5955 URL: https://issues.apache.org/jira/browse/FLINK-5955

[jira] [Commented] (FLINK-5984) Allow reusing of accumulators in AggregateFunction

2017-03-07 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15900597#comment-15900597 ] Shaoxuan Wang commented on FLINK-5984: -- [~twalthr] Thanks for the suggestion. This seems a new

[jira] [Commented] (FLINK-5905) Add user-defined aggregation functions to documentation.

2017-08-15 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16127439#comment-16127439 ] Shaoxuan Wang commented on FLINK-5905: -- This issue will be solved once FLINK-6751 is merged > Add

[jira] [Commented] (FLINK-7146) FLINK SQLs support DDL

2017-07-12 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16083614#comment-16083614 ] Shaoxuan Wang commented on FLINK-7146: -- [~yuemeng], DDL is an important interface (it is a customer

[jira] [Closed] (FLINK-6725) make requiresOver as a contracted method in udagg

2017-07-17 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-6725. Resolution: Won't Fix > make requiresOver as a contracted method in udagg >

[jira] [Updated] (FLINK-5878) Add stream-stream inner/left-out join

2017-07-17 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5878: - Summary: Add stream-stream inner/left-out join (was: Add stream-stream inner join on TableAPI)

[jira] [Assigned] (FLINK-5878) Add stream-stream inner/left-out join

2017-07-17 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5878: Assignee: Hequn Cheng (was: Shaoxuan Wang) > Add stream-stream inner/left-out join >

[jira] [Commented] (FLINK-6751) Table API / SQL Docs: UDFs Page

2017-07-19 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092970#comment-16092970 ] Shaoxuan Wang commented on FLINK-6751: -- Sorry for being no update. I will work on this in the next

[jira] [Commented] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

2017-07-19 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092983#comment-16092983 ] Shaoxuan Wang commented on FLINK-7194: -- [~fhueske], I am ok with your proposal for the changes to the

[jira] [Comment Edited] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

2017-07-19 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16092983#comment-16092983 ] Shaoxuan Wang edited comment on FLINK-7194 at 7/19/17 12:15 PM:

[jira] [Assigned] (FLINK-6544) Expose Backend State Interface for UDAGG

2017-05-12 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-6544: Assignee: Kaibo Zhou > Expose Backend State Interface for UDAGG >

[jira] [Updated] (FLINK-6544) Expose State Backend Interface for UDAGG

2017-05-12 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-6544: - Summary: Expose State Backend Interface for UDAGG (was: Expose Backend State Interface for

[jira] [Created] (FLINK-6962) SQL DDL for input and output tables

2017-06-21 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6962: Summary: SQL DDL for input and output tables Key: FLINK-6962 URL: https://issues.apache.org/jira/browse/FLINK-6962 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6963) User Defined Operator

2017-06-21 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6963: Summary: User Defined Operator Key: FLINK-6963 URL: https://issues.apache.org/jira/browse/FLINK-6963 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6961) Enable configurable early-firing rate

2017-06-21 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6961: Summary: Enable configurable early-firing rate Key: FLINK-6961 URL: https://issues.apache.org/jira/browse/FLINK-6961 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6637) Move registerFunction to TableEnvironment

2017-05-19 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6637: Summary: Move registerFunction to TableEnvironment Key: FLINK-6637 URL: https://issues.apache.org/jira/browse/FLINK-6637 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-6751) Table API / SQL Docs: UDFs Page

2017-05-28 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-6751: Assignee: Shaoxuan Wang > Table API / SQL Docs: UDFs Page >

[jira] [Commented] (FLINK-5354) Split up Table API documentation into multiple pages

2017-05-28 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16027842#comment-16027842 ] Shaoxuan Wang commented on FLINK-5354: -- [~fhueske], thanks for kicking off this. I would like to work

[jira] [Created] (FLINK-6725) make requiresOver as a contracted method in udagg

2017-05-25 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-6725: Summary: make requiresOver as a contracted method in udagg Key: FLINK-6725 URL: https://issues.apache.org/jira/browse/FLINK-6725 Project: Flink Issue Type:

[jira] [Updated] (FLINK-6637) Move registerFunction to TableEnvironment

2017-05-23 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-6637: - Component/s: Table API & SQL > Move registerFunction to TableEnvironment >

[jira] [Resolved] (FLINK-5915) Add support for the aggregate on multi fields

2017-05-04 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang resolved FLINK-5915. -- Resolution: Fixed This is completely resolved with FLINK-5906. > Add support for the aggregate

[jira] [Closed] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation

2017-05-04 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-5433. Resolution: Fixed Fixed by UDAGG subtasks FLINK-5564 > initiate function of Aggregate does not

[jira] [Updated] (FLINK-5906) Add support to register UDAGG in Table and SQL API

2017-05-02 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-5906: - Summary: Add support to register UDAGG in Table and SQL API (was: Add support to register UDAGGs

[jira] [Assigned] (FLINK-5905) Add user-defined aggregation functions to documentation.

2017-05-02 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang reassigned FLINK-5905: Assignee: Shaoxuan Wang > Add user-defined aggregation functions to documentation. >

[jira] [Closed] (FLINK-11004) Wrong ProcessWindowFunction.process argument in example of Incremental Window Aggregation with ReduceFunction

2018-11-28 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-11004. - Resolution: Fixed Fixed and merged into master > Wrong ProcessWindowFunction.process argument

[jira] [Created] (FLINK-12597) Remove the legacy flink-libraries/flink-ml

2019-05-23 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-12597: - Summary: Remove the legacy flink-libraries/flink-ml Key: FLINK-12597 URL: https://issues.apache.org/jira/browse/FLINK-12597 Project: Flink Issue Type:

[jira] [Closed] (FLINK-12473) Add the interface of ML pipeline and ML lib

2019-05-24 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-12473. - Resolution: Fixed Fix Version/s: 1.9.0 Fixed in

[jira] [Updated] (FLINK-12473) Add the interface of ML pipeline and ML lib

2019-05-10 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang updated FLINK-12473: -- Summary: Add the interface of ML pipeline and ML lib (was: Add ML pipeline and ML lib Core

[jira] [Closed] (FLINK-11095) Table based ML Pipeline

2019-05-09 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-11095. - Resolution: Fixed We decided to move the entire ml pipeline and ml lib development under FLIP39

[jira] [Created] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs

2019-05-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-12470: - Summary: FLIP39: Flink ML pipeline and ML libs Key: FLINK-12470 URL: https://issues.apache.org/jira/browse/FLINK-12470 Project: Flink Issue Type: New

[jira] [Comment Edited] (FLINK-11095) Table based ML Pipeline

2019-05-09 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16836837#comment-16836837 ] Shaoxuan Wang edited comment on FLINK-11095 at 5/10/19 2:48 AM: We

[jira] [Closed] (FLINK-11096) Create a new table based flink ML package

2019-05-09 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-11096. - Resolution: Duplicate We decided to move the entire ml pipeline and ml lib development under

[jira] [Created] (FLINK-12473) Add ML pipeline and ML lib Core API

2019-05-09 Thread Shaoxuan Wang (JIRA)
Shaoxuan Wang created FLINK-12473: - Summary: Add ML pipeline and ML lib Core API Key: FLINK-12473 URL: https://issues.apache.org/jira/browse/FLINK-12473 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-11113) Support periodically update models when inferencing

2019-05-09 Thread Shaoxuan Wang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shaoxuan Wang closed FLINK-3. - Resolution: Duplicate We decided to move the entire ml pipeline and ml lib development under

  1   2   >