[ https://issues.apache.org/jira/browse/FLINK-20616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dian Fu reassigned FLINK-20616: ------------------------------- Assignee: Huang Xingbo > Support Row-based Operation Accept Function Name > ------------------------------------------------ > > Key: FLINK-20616 > URL: https://issues.apache.org/jira/browse/FLINK-20616 > Project: Flink > Issue Type: Sub-task > Components: API / Python > Reporter: Huang Xingbo > Assignee: Huang Xingbo > Priority: Major > Fix For: 1.13.0 > > > Usage > {code:java} > @udf(result_type=DataTypes.ROW([DataTypes.FIELD("a", DataTypes.INT()), > DataTypes.FIELD("b", DataTypes.INT())]) > def map_func(args): > args # Row(a:Int, b: Int) > return args > t = ... # type: Table, table schema: [a: String, b: Int] > t.map(map_func){code} -- This message was sent by Atlassian Jira (v8.3.4#803005)