You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Jun Zhang <82...@qq.com> on 2020/11/20 06:35:12 UTC
关于CatalogPartitionSpec类的一些想法
大家好:
我现在在使用flink中Catalog的查询分区的方法:Catalog#listPartitions(ObjectPath, CatalogPartitionSpec)的时候遇到一个问题。
我发现CatalogPartitionSpec中存放分区信息的字partitionSpec类型是Map<String, String>,
这个对于hivecatalog是没有问题的,但是我这个Catalog的子类需要精准的类型,比如分区是int类型,传入一个 ”123“ 是不行的,
所以我想flink的CatalogPartitionSpec的partitionSpec字段改为Map<String, Object>类型是否会更加合理和通用呢?
谢谢