[FLINK-8094] Support other types for ExistingField rowtime extractor

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 1.4.0, 1.5.0
• Fix Version/s: 1.6.0
• Component/s: Table SQL / API
• Labels: pull-request-available
• Assignee: Jungtaek Lim
• Reporter: Xingcan Cui
• Created: 16/Nov/17 15:24
• Updated: 25/Jul/18 12:38
• Resolved: 05/Jul/18 19:57

Description

Currently, the ExistingField rowtime extractor only supports Long and Timestamp fields. To enable other data types (e.g., String), we can provide some system extraction functions and allow users to pass some parameters via the constructor of ExistingField. There's a simple demo which enables the String type rowtime by adding a UDF str2EventTime.

Issue Links

• relates to: FLINK-8353 Add support for timezones
• links to: GitHub Pull Request #6253