You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "appleyuchi (Jira)" <ji...@apache.org> on 2020/12/10 15:44:00 UTC
[jira] [Updated] (FLINK-20567) Document Error

     [ https://issues.apache.org/jira/browse/FLINK-20567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

appleyuchi updated FLINK-20567:
-------------------------------
    Description: 
||item||Content||
|Document|[Link|https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html]|
|part|Inner Join with Table Function (UDTF)|
|origin|TableFunction<String> split = new MySplitUDTF();|
|change to|TableFunction<Tuple3<String,String,String>> split = new MySplitUDTF();|


I have run the following the codes successfully 
that contain all the contents from the above.
①[InnerJoinwithTableFunction.java|https://paste.ubuntu.com/p/MMXJPrfRWC]
②[MySplitUDTF.java|https://paste.ubuntu.com/p/Q6fDHxw4Td/]

Reason:
In this part, 
it says:
joinLateral(call("split", $("c")).as("s", "t", "v"))

it means:
the udtf has 1 input "c",
and 3 outputs "s", "t", "v"

So:
these outputs should have 3 types.
such as TableFunction<String,String,String>
instead of only 
-TableFunction<String> split-











  was:

||item||Content||
|Document|[Link|https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html]|
|part|Inner Join with Table Function (UDTF)|
|origin|TableFunction<String> split = new MySplitUDTF();|
|change to|TableFunction<Tuple3<String,String,String>> split = new MySplitUDTF();|


I have run the following the codes successfully 
that contain all the contents from the above.
①[InnerJoinwithTableFunction.java|https://paste.ubuntu.com/p/MMXJPrfRWC]
②[MySplitUDTF.java|https://paste.ubuntu.com/p/Q6fDHxw4Td/]










> Document Error
> --------------
>
>                 Key: FLINK-20567
>                 URL: https://issues.apache.org/jira/browse/FLINK-20567
>             Project: Flink
>          Issue Type: Test
>            Reporter: appleyuchi
>            Priority: Major
>
> ||item||Content||
> |Document|[Link|https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html]|
> |part|Inner Join with Table Function (UDTF)|
> |origin|TableFunction<String> split = new MySplitUDTF();|
> |change to|TableFunction<Tuple3<String,String,String>> split = new MySplitUDTF();|
> I have run the following the codes successfully 
> that contain all the contents from the above.
> ①[InnerJoinwithTableFunction.java|https://paste.ubuntu.com/p/MMXJPrfRWC]
> ②[MySplitUDTF.java|https://paste.ubuntu.com/p/Q6fDHxw4Td/]
> Reason:
> In this part, 
> it says:
> joinLateral(call("split", $("c")).as("s", "t", "v"))
> it means:
> the udtf has 1 input "c",
> and 3 outputs "s", "t", "v"
> So:
> these outputs should have 3 types.
> such as TableFunction<String,String,String>
> instead of only 
> -TableFunction<String> split-



--
This message was sent by Atlassian Jira
(v8.3.4#803005)