Hi Chen,
with Flink 1.2, conditions in select clauses are supported in the Table API
with the following syntax:
table.select('name, 'age, ('yearOfBirth < 1997) ? ("adult", "teenager") )
See also the documentation of built-in functions [1].
Best, Fabian
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/table_api.html#built-in-functions2017-02-01 0:29 GMT+01:00 Chen Qin <
[hidden email]>: