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

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] [Created] (FLINK-12473) Add ML pipeline and ML lib Core API

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] [Created] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs

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] [Created] (FLINK-6963) User Defined Operator

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-6962) SQL DDL for input and output tables

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-6961) Enable configurable early-firing rate

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-6725) make requiresOver as a contracted method in udagg

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] [Created] (FLINK-6637) Move registerFunction to TableEnvironment

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] [Created] (FLINK-6242) codeGen DataSet Goupingwindow Aggregates

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] [Created] (FLINK-6240) codeGen dataStream aggregates that use AggregateAggFunction

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-6216) DataStream unbounded groupby aggregate with early firing

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] [Created] (FLINK-6094) Implement and turn on retraction for stream-stream inner join

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] [Created] (FLINK-6093) Implement and turn on retraction for table sink

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-6092) Implement and turn on retraction for table source

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-6091) Implement and turn on the retraction for grouping window aggregate

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] [Created] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate

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-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase

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-6047) Master Jira for "Retraction for Flink Streaming"

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] [Created] (FLINK-5956) Add retract method into the aggregateFunction

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

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] [Created] (FLINK-5927) Remove old Aggregate interface and built-in functions

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] [Created] (FLINK-5915) Add support for the aggregate on multi fields

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] [Created] (FLINK-5914) remove aggregateResultType from streaming.api.datastream.aggregate

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-5900) Add non-partial merge Aggregates and unit tests

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

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] [Created] (FLINK-5878) Add stream-stream inner join on TableAPI

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] [Created] (FLINK-5813) code generation for user-defined aggregate functions

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-5769) Apply new aggregation functions for dataset tables

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

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-5564) User Defined Aggregates

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] [Created] (FLINK-5433) initiate function of Aggregate does not take effect for DataStream aggregation

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] [Created] (FLINK-4781) Add User Defined Function(UDF) API for DataStream

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: