Interface FileLifeCycleListener<BucketID>
-
@Internal public interface FileLifeCycleListener<BucketID>Listener about the status of file.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidonPartFileOpened(BucketID bucketID, org.apache.flink.core.fs.Path newPath)Notifies a new file has been opened.
-
-
-
Method Detail
-
onPartFileOpened
void onPartFileOpened(BucketID bucketID, org.apache.flink.core.fs.Path newPath)
Notifies a new file has been opened.Note that this does not mean that the file has been created in the file system. It is only created logically and the actual file will be generated after it is committed.
- Parameters:
bucketID- The bucketID of newly opened file.newPath- The path of newly opened file.
-
-