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)