flink-connector无法获取date类型的数据

mile_z · 2022年06月17日 02:45

【详述】问题详细描述 flink-connector无法获取date类型的数据
【导入/导出方式】数据从sr中导出到flink，date类型的数据能从sr中读取，但是get的时候无法获取，没有对应的getdate的方法，试过将将获取source换成string，timestamp都不行，通过getstring，gettimestamp也获取不到，最后通过getint能获取到，但是获取的日期数据成了一串数字，试过了simpleDateFormat也不行

jingdan · 2022年06月19日 02:24

请问下sr里面定义的是date类型吗

mile_z · 2022年06月20日 02:19

是的没错，请问有没有处理办法？我目前急需，感谢，还有timestamp带时区，datetime数据类型没有，您也可以看看

waittting · 2022年06月20日 07:36

试一下这个，这个获取的 object 是一个 org.apache.flink.table.data.TimestampData

mile_z · 2022年06月20日 08:04

你这个是哪个版本的flink - connector，我用的1.2.2_flink-1.14_2.12，没有你这个getField方法

waittting · 2022年06月20日 08:17

依赖的 flink 版本是 1.14

mile_z · 2022年06月20日 08:32

com.starrocks flink-connector-starrocks 1.2.2_flink-1.14_2.12 依赖是这个吗，麻烦给我一下完整的，感谢，我的get了，确实没有getField这个方法

waittting · 2022年06月20日 08:37

这个 1.14 就是代表的依赖的 flink 的版本，1.14 版本的 flink 应该都有这个方法

mile_z · 2022年06月20日 08:52

并没有，不知道是不是我用的方法有问题

waittting · 2022年06月20日 09:12

把 RowData 转成 GenericRowData

mile_z · 2022年06月21日 08:28

百度官网查了下没搞懂怎么转，这是我的流:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource rowDataDataStreamSource = env.addSource(StarRocksSource.source(tableSchema, options)).setParallelism(1);

waittting · 2022年06月21日 09:03

waittting · 2022年06月21日 09:04

这个地方不是有个 RowData 吗直接转成 GenericRowData

mile_z · 2022年06月21日 09:21

这样？没玩过，报错

dxndxn · 2022年06月21日 10:29

我是这样的，在你代码这里把rdr_search 转一下就行了
GenericRowData row= (GenericRowData) rdr_search;
xx.setUpdateTime(((TimestampData) row.getField(3)).toTimestamp());
测试Timestamp类型是能转出来的