[FLINK-21894] Update type of HiveTablePartition#partitionSpec from Map<String, Object> to Map<String, String>

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 21/Mar/21 15:38
• Updated: 22/Mar/21 13:58
• Resolved: 22/Mar/21 13:58

Description

In order to support watermark for Hive connector (FLINK-21871), we need to extract time from the partition string values. However, currently HiveTablePartition#partitionSpec uses Map<String, Object> type to store the partition spec which is hard convert back to string values. Therefore, I propose to use the raw Map<String, String> type instead which is easier to convert into Map<String, Object> when needed.

Issue Links

• links to: GitHub Pull Request #15308