org.apache.flink.streaming.api.functions.sink.filesystem

Interface FileLifeCycleListener<BucketID>

@Internal
public interface FileLifeCycleListener<BucketID>

Listener about the status of file.

Method Summary

Modifier and Type	Method and Description
void	onPartFileOpened(BucketID bucketID, Path newPath) Notifies a new file has been opened.

Method Detail

onPartFileOpened

void onPartFileOpened(BucketID bucketID,
                      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.