InitializeOnMaster和FinalizeOnMaster接口为什么只有OutputFormat能用,InputFormat为什么不能用?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

InitializeOnMaster和FinalizeOnMaster接口为什么只有OutputFormat能用,InputFormat为什么不能用?

kanata163
      如题。
     
我理解对于写文件类型OutputFormat,用这两个方法在jobmanager里面在任务开始前删除/创建文件夹,在任务结束后把文件移动到正式目录,使文件可见。
     
但是比如对于RDB类型的InputFormat,如果也能用这两个接口,那么比如说在任务开始前查询当前数据库的记录数,这样对于构建数据分片做多通道,以及增加执行进度指标都很有帮助。




--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: InitializeOnMaster和FinalizeOnMaster接口为什么只有OutputFormat能用,InputFormat为什么不能用?

kanata163
把InputOutputFormatVertex这个类简单改下就可以支持了,但是不理解官方不支持的原因,有人能解答一下吗?



--
Sent from: http://apache-flink.147419.n8.nabble.com/