Bucketing/Rolling Sink: How to overwrite method "openNewPartFile" - to append a new timestamp to part file path every time a new part file is being created

[Raja . Aravapalli]

Hi,

I want to overwrite the method “openNewPartFile” in the BucketingSink Class 
such that it creates part file name with inclusion of timestamp whenever it 
rolls a new part file.

Can someone share some thoughts on how I can do this.

Thanks a ton, in advance.


Regards,
Raja.