[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Huang Xingbo updated FLINK-20482: --------------------------------- Summary: Support General Python UDF for Map Operation in Python Table API (was: Support Map Operation in Python Table API) > Support General Python UDF for Map Operation in Python Table API > ---------------------------------------------------------------- > > Key: FLINK-20482 > URL: https://issues.apache.org/jira/browse/FLINK-20482 > Project: Flink > Issue Type: Sub-task > Components: API / Python > Reporter: Huang Xingbo > Priority: Major > Fix For: 1.13.0 > > > Add Map Operation in Python Table API > The usage: > {code:java} > t = ... # type: Table, table schema: [a: String, b: Int, c: Int] > # map General Python UDF > map_func = udf(lambda x: Row(x + 1, x * x), > result_type=DataTypes.ROW([DataTypes.FIELD("a", DataTypes.INT()), > DataTypes.FIELD("b", DataTypes.INT())])) > t.map(map_func(t.b)).alias("a", "b") > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)