You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jingsong Lee (Jira)" <ji...@apache.org> on 2020/09/22 10:28:00 UTC

[jira] [Created] (FLINK-19356) Introduce FileLifeCycleListener to Buckets

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)