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)
Locked
