luoyuxia commented on code in PR #21257:
URL: https://github.com/apache/flink/pull/21257#discussion_r1070883134
##########
flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/PartitionWriter.java:
##########
@@ -62,4 +62,24 @@ OutputFormat<T> createNewOutputFormat(Path path) throws
IOException {
return format;
}
}
+
+ /** Listener for partition writer. */
+ interface PartitionWriterListener {
+ /**
+ * Notifies a new file has been created.
+ *
+ * @param partition The partition for the newly created file.
+ * @param file The newly created file.
+ */
+ void onFileOpen(String partition, Path file);
Review Comment:
Actually it should be `onFileOpen`. but I change the doc for the method,
```java
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.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
