我想将数据从postgresql流式传输到hdfs,但是我所有的表都有多个timestamp列。我曾经尝试过confluent提供的简单JDBCConnect和HDFSsink从postgres读取数据并将其写入hdfs,但我的所有日期列都转换为bigint格式,而不是日期格式。我不知道这个大int是哪种格式的,但它不是unix时间戳格式的。有什么原因要找出它是哪种格式的吗?我还考虑将日期列转换为jdbc connect中的unix时间戳,然后使用timestampconverter将它们转换为sink中的日期。但我不知道如何在我目前的程序中实现它。这里报道了这个问题。
暂无答案!
目前还没有任何答案,快来回答吧!