[jira] [Updated] (FLINK-20616) Support row-based operation to accept user-defined function directly
[ https://issues.apache.org/jira/browse/FLINK-20616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20616: - Description: Usage {code:java} @udf(result_type=DataTypes.ROW([DataTypes.FIELD("a", DataTypes.INT()), DataTypes.FIELD("b", DataTypes.INT())]) def map_func(*args): return Row(*args) t = ... # type: Table, table schema: [a: String, b: Int] t.map(map_func){code} was: 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} > Support row-based operation to accept user-defined function directly > > > 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 > Labels: pull-request-available > 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): > return Row(*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)
[jira] [Updated] (FLINK-20616) Support row-based operation to accept user-defined function directly
[ https://issues.apache.org/jira/browse/FLINK-20616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20616: --- Labels: pull-request-available (was: ) > Support row-based operation to accept user-defined function directly > > > 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 > Labels: pull-request-available > 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)
[jira] [Updated] (FLINK-20616) Support row-based operation to accept user-defined function directly
[ https://issues.apache.org/jira/browse/FLINK-20616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20616: Summary: Support row-based operation to accept user-defined function directly (was: Support Row-based Operation Accept Function Name) > Support row-based operation to accept user-defined function directly > > > 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)