You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "appleyuchi (Jira)" <ji...@apache.org> on 2020/06/27 03:57:00 UTC
[jira] [Created] (FLINK-18436) how to implement the class
`MyTupleReducer`in flink official document
appleyuchi created FLINK-18436:
----------------------------------
Summary: how to implement the class `MyTupleReducer`in flink official document
Key: FLINK-18436
URL: https://issues.apache.org/jira/browse/FLINK-18436
Project: Flink
Issue Type: Test
Reporter: appleyuchi
This question has been posted in
[https://stackoverflow.com/questions/62553572/how-to-implement-the-class-mytuplereducerin-flink-official-document]
but no final result:
I'm learning [flink document-dataset api |https://ci.apache.org/projects/flink/flink-docs-stable/dev/batch/dataset_transformations.html]
there's a class called{{mytupleReducer}}
I'm trying to complete it: [https://paste.ubuntu.com/p/3CjphGQrXP/]
but it' full of red line in Intellij.
could you give me a right style of above code?
Thanks for your help~!
PS:
I'm writing part of MyTupleReduce [https://pastebin.ubuntu.com/p/m4rjs6t8QP/]
but the return part is Wrong.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)