Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
InitializeOnMaster和FinalizeOnM
aster接口为什么只有OutputFormat能用,Inpu
tFormat为什么不能用?
Classic
List
Threaded
♦
♦
Locked
2 messages
kanata163
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
InitializeOnMaster和FinalizeOnM
aster接口为什么只有OutputFormat能用,Inpu
tFormat为什么不能用?
如题。
我理解对于写文件类型OutputFormat,用这两个方法在jobmanager里面在任务开始前删除/创建文件夹,在任务结束后把文件移动到正式目录,使文件可见。
但是比如对于RDB类型的InputFormat,如果也能用这两个接口,那么比如说在任务开始前查询当前数据库的记录数,这样对于构建数据分片做多通道,以及增加执行进度指标都很有帮助。
--
Sent from:
http://apache-flink.147419.n8.nabble.com/
kanata163
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Re: InitializeOnMaster和FinalizeOnM
aster接口为什么只有OutputFormat能用,Inpu
tFormat为什么不能用?
把InputOutputFormatVertex这个类简单改下就可以支持了,但是不理解官方不支持的原因,有人能解答一下吗?
--
Sent from:
http://apache-flink.147419.n8.nabble.com/
Free forum by Nabble
Edit this page