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: Sub-
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
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 Featu
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
Compone
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
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
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: I
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: Improveme
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: F
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
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 Ty
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
Is
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
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
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: Su
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:
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
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
Pro
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
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: Ne
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: Sub-t
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
Proj
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 Typ
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: Sub-t
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
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: Imp
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:
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 Featur
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 Type
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:
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
Proje
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
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
Compo
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
Project:
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: N
35 matches
Mail list logo