Jingsong Lee created FLINK-19356: ------------------------------------ Summary: Introduce FileLifeCycleListener to Buckets Key: FLINK-19356 URL: https://issues.apache.org/jira/browse/FLINK-19356 Project: Flink Issue Type: New Feature Components: Runtime / Task Reporter: Jingsong Lee Fix For: 1.12.0
The interface: {code:java} /** * Listener about the status of file. */ @Internal public interface FileLifeCycleListener<IN, BucketID> { /** * Notifies a new file has been created. * * @param bucket The bucket of newly created file. * @param path The path of newly created file. */ void fileCreated(Bucket<IN, BucketID> bucket, Path path); } {code} Currently, only supports fileCreated. It can be set to Buckets like {{BucketLifeCycleListener}} -- This message was sent by Atlassian Jira (v8.3.4#803005)