guoweiM commented on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-629604823


   Hi, @kl0u thanks for your review.
   1. You are right. We could rename the `PartFileWriter` to 
`InProgressFileWriter`.
   2. You are very careful. We should remove the `getRecoverable` from 
`PendingFile`. :-)
   3. Maybe I am missing something but I am a little wonder about the rename 
the `PartFileFacory` to the `BulkWriter`:
       1. The methods in the `BulkWriter` are all about how to handle the part 
file. Such as create/resume InProgressWriter which is responsible for writing 
data to the in-progress part file and recover the pending part file. 
       1. The subtype of `BulkWriter` is also about handling the part file 
differently such as format or commit and so on.
   4. So I think the old `PartFileFactory` is more suitable and we could call 
the `WriterProperties` to `PartFileFactoryProperites`. What do you think? 
Correct me if I misunderstand some thing.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to