Class PartitionWriter.DefaultPartitionWriterListener
- java.lang.Object
-
- org.apache.flink.connector.file.table.PartitionWriter.DefaultPartitionWriterListener
-
- All Implemented Interfaces:
PartitionWriter.PartitionWriterListener
- Enclosing interface:
- PartitionWriter<T>
public static class PartitionWriter.DefaultPartitionWriterListener extends Object implements PartitionWriter.PartitionWriterListener
Default implementation for PartitionWriterListener.
-
-
Constructor Summary
Constructors Constructor Description DefaultPartitionWriterListener()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onFileOpened(String partition, Path file)
Notifies a new file has been opened.
-
-
-
Method Detail
-
onFileOpened
public void onFileOpened(String partition, Path file)
Description copied from interface:PartitionWriter.PartitionWriterListener
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.
- Specified by:
onFileOpened
in interfacePartitionWriter.PartitionWriterListener
- Parameters:
partition
- The partition for the newly opened file.file
- The newly created file.
-
-