[
https://issues.apache.org/jira/browse/FLINK-12744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-12744.
-
Resolution: Fixed
Fix Version/s: 1.9.0
> ML common paramet
[
https://issues.apache.org/jira/browse/FLINK-12744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879343#comment-16879343
]
Shaoxuan Wang commented on FLINK-12744:
---
Fixed in ma
[
https://issues.apache.org/jira/browse/FLINK-12758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-12758.
-
Resolution: Fixed
> Add flink-ml-lib module
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-12758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879055#comment-16879055
]
Shaoxuan Wang commented on FLINK-12758:
---
Fixed in ma
[
https://issues.apache.org/jira/browse/FLINK-12597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-12597.
-
Resolution: Fixed
Fix Version/s: 1.9.0
> Remove the legacy flink-libraries/flink
[
https://issues.apache.org/jira/browse/FLINK-12597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16879052#comment-16879052
]
Shaoxuan Wang commented on FLINK-12597:
---
Fixed in ma
[
https://issues.apache.org/jira/browse/FLINK-12881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-12881.
-
Resolution: Fixed
Fix Version/s: 1.9.0
> Add more functionalities for ML Params
[
https://issues.apache.org/jira/browse/FLINK-12881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875719#comment-16875719
]
Shaoxuan Wang commented on FLINK-12881:
---
Fixed in ma
[
https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang updated FLINK-12470:
--
Comment: was deleted
(was: Fixed in master:1660c6b47af789fa5c9bf6a3ff77e868ca90
[
https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875717#comment-16875717
]
Shaoxuan Wang commented on FLINK-12470:
---
Fixed in ma
[
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 master
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
[
https://issues.apache.org/jira/browse/FLINK-12473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang reassigned FLINK-12473:
-
Assignee: Luo Gen
> Add the interface of ML pipeline and ML
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-5?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-5.
-
Resolution: Duplicate
We decided to move the entire ml pipeline and ml lib development under
[
https://issues.apache.org/jira/browse/FLINK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-4.
-
Resolution: Duplicate
We decided to move the entire ml pipeline and ml lib development under
[
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
[
https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-1.
-
Resolution: Duplicate
We decided to move the entire ml pipeline and ml lib development under
[
https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-2.
-
Resolution: Duplicate
We decided to move the entire ml pipeline and ml lib development under
[
https://issues.apache.org/jira/browse/FLINK-11109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-11109.
-
Resolution: Duplicate
We decided to move the entire ml pipeline and ml lib development under
[
https://issues.apache.org/jira/browse/FLINK-11108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shaoxuan Wang closed FLINK-11108.
-
Resolution: Duplicate
We decided to move the entire ml pipeline and ml lib development under
[
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
[
https://issues.apache.org/jira/browse/FLINK-11095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836837#comment-16836837
]
Shaoxuan Wang edited comment on FLINK-11095 at 5/10/19 2:4
[
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
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
[
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 argum
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/4471#discussion_r140951770
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamJoinRule.scala
---
@@ -0,0 +1,93
[
https://issues.apache.org/jira/browse/FLINK-5905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16127439#comment-16127439
]
Shaoxuan Wang commented on FLINK-5905:
--
This issue will be solved once FLINK-675
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/4546
[FLINK-6751] [docs] Add missing documentation for User-Defined Functions
Page
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink
[
https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16092983#comment-16092983
]
Shaoxuan Wang edited comment on FLINK-7194 at 7/19/17 12:1
[
https://issues.apache.org/jira/browse/FLINK-7194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16092983#comment-16092983
]
Shaoxuan Wang commented on FLINK-7194:
--
[~fhueske], I am ok with your proposal
[
https://issues.apache.org/jira/browse/FLINK-6751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16092970#comment-16092970
]
Shaoxuan Wang commented on FLINK-6751:
--
Sorry for being no update. I will wor
[
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
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3993
@fhueske @sunjincheng121 @wuchong, thanks for the valuable inputs. We
talked offline and get an agreement that we'd better to put
`getAccumulatorType()`, `getResultType()` et
Github user shaoxuan-wang closed the pull request at:
https://github.com/apache/flink/pull/3993
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
[
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
[
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 j
[
https://issues.apache.org/jira/browse/FLINK-7146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16083614#comment-16083614
]
Shaoxuan Wang commented on FLINK-7146:
--
[~yuemeng], DDL is an important inter
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-6963:
Summary: User Defined Operator
Key: FLINK-6963
URL: https://issues.apache.org/jira/browse/FLINK-6963
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
[
https://issues.apache.org/jira/browse/FLINK-5354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16027842#comment-16027842
]
Shaoxuan Wang commented on FLINK-5354:
--
[~fhueske], thanks for kicking off thi
[
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 P
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3993
Thanks for the review @fhueske @sunjincheng121 .
Fabian, yes, I do not think this will be a blocker for release. In fact,
this is a similar interface clean-up issue as FLINK-6457 that we
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3993
[FLINK-6725][table] make requiresOver as a contracted method in udagg
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
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
[
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 TableEnvi
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
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3923
@twalthr, it seems we have reserved the keyword with the case insensitive.
For instance, we cannot use "Sum" and "SUM", as "sum" is reserved. Did we
intent t
[
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 UDAGG
[
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 UD
[
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
[
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 aggreg
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114692346
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala
---
@@ -0,0 +1,177
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114692276
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala
---
@@ -0,0 +1,177
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114690845
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/expressions/aggregations.scala
---
@@ -130,3 +142,63 @@ case class Avg
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114579772
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/table/DSetUDAGGITCase.scala
---
@@ -0,0 +1,192
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114576600
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -178,4 +178,24 @@ class
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114571910
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -327,4 +332,56 @@ object
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3809#discussion_r114498337
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/DStreamUDAGGITCase.scala
---
@@ -0,0 +1,309
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3809
Thanks for the review, @fhueske , and very good point regarding to the
approach to "replace UDAGGFunctionCall". I have addressed your comments. Please
take a look.
---
If your proj
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3809
[FLINK-5906] [table] Add support to register UDAGG in Table and SQL API
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
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 documentat
[
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
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3768
I ran into the same problem today when adding the new test cases for UDAGG.
Thanks for the fix, @xccui
---
If your project is set up for it, you can reply to this email and have your
reply
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3762
Hi @fhueske , it is good to have a dedicated Iterable for pair-merge.
Please go ahead. Thanks.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3762
[FLINK-6361] [table] Refactoring the AggregateFunction interface and
built-in aggregates
This PR includes the following changes:
1) remove Accumulator trait;
2) move accumulate
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
[
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 aggreg
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3735
@fhueske , your changes look good to me, I left a few comments.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project
[
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
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3735
@fhueske thanks for your feedback.
Yes, we could keep GeneratedAggregations interface very clean as
```
abstract class GeneratedAggregations extends Function {
def
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3735#discussion_r111986331
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala
---
@@ -36,6 +36,15
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3735
[FLINK-6242] [table] Add code generation for DataSet Aggregates
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3694
Thanks @fhueske , I have addressed your comments, please take a look.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r111813245
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -792,6 +792,20 @@ object
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3696
@fhueske, thanks for the review and valuable comments.
Yes, we'd better add the attributes (which provide information for deriving
ACCMode) inside the DataStreamRel interface, such
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110345902
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -18,69 +18,51
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3694#discussion_r110344806
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -403,6 +403,41 @@ class CodeGenerator
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3694
[FLINK-6240] [table] codeGen dataStream aggregates that use
AggregateAggFunction
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following
Github user shaoxuan-wang closed the pull request at:
https://github.com/apache/flink/pull/3646
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3646#discussion_r110073336
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/WindowAggregateTest.scala
---
@@ -299,27 +299,6
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3676
Thanks @fhueske, these changes look good to me.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3646
@fhueske, thanks for your review. I have addressed all your comments, and
rebased the code to the master. Please take a look.
---
If your project is set up for it, you can reply to this
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3676
[FLINK-6241] [table] codeGen dataStream aggregates that use ProcessFunction
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3665
So we finally got those supported by Calcite 1.12ï¼Really excited to see
those features supported in flinkSQL. Thanks @haohui.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-5564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15952127#comment-15952127
]
Shaoxuan Wang commented on FLINK-5564:
--
[~fhueske], implementing the entire cod
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
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
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3647
Thanks @fhueske, I overlooked a list is not always an arraylist. I change
it to scala array, but keep the type as integer, as this is type returned (and
not easy to be casted to Int) from
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3647
[FLINK-5915] [table] forward the entire aggregate ArgList to aggregate
runtime functions
This PR partially solved "FLINK-5915 Add support for the aggregate on multi
fields".
T
GitHub user shaoxuan-wang opened a pull request:
https://github.com/apache/flink/pull/3646
[FLINK-6216] [table] DataStream unbounded groupby aggregate with early
firing
1. Implemented an unbounded groupby aggregate with early firing (period is
1, emit per every record)
2
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
[
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
[
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 t
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3585#discussion_r107649062
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -317,4 +397,24 @@ class
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3564#discussion_r107594707
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -162,6 +162,27 @@ abstract class
Github user shaoxuan-wang commented on the issue:
https://github.com/apache/flink/pull/3579
@twalthr thanks for the reply and explanation.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
1 - 100 of 215 matches
Mail list logo
