Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
flink在source中定义了eventtime和wate
rmark,可以在sink时从context中获取eventt
ime吗
Classic
List
Threaded
♦
♦
Locked
2 messages
bigjar3344
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
flink在source中定义了eventtime和wate
rmark,可以在sink时从context中获取eventt
ime吗
source是kafka,在ddl中定义了eventtime和watermark,sink是streamfilesink,想在sink时根据事件时间进行分区,事件事件想从context中获取timestamp,但是发现为空。请问,context中的timestamp是值的是source中定义的eventtime吗?
marble.zhong@coinflex.com.INVALID
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Re: flink在source中定义了eventtime和wate
rmark,可以在sink时从context中获取eventt
ime吗
方便贴出代码吗,这样容易理解。
--
Sent from:
http://apache-flink.147419.n8.nabble.com/
Free forum by Nabble
Edit this page