flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Raja.Aravapalli <Raja.Aravapa...@target.com>
Subject 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
Date Fri, 06 Oct 2017 21:02:45 GMT


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.

View raw message