Piotrek, thanks for your reply. Yes, now I’m looking for the most suitable way to extend BucketingSink functionality, to handle moments of moving the file into final state. I thought, that maybe someone has already implemented such thing or knows any other approaches that will help me to not copy/ paste existing sink impl ))
Thx ! > On 20 Oct 2017, at 14:37, Piotr Nowojski <pi...@data-artisans.com> wrote: > > Piotrek
