bugouyongxin opened a new issue, #10162: URL: https://github.com/apache/seatunnel/issues/10162
[根据时间监听器的文档](https://seatunnel.apache.org/zh-CN/docs/2.3.12/concept/event-listener/#2-%E5%AE%9E%E7%8E%B0%E4%BA%8B%E4%BB%B6%E5%A4%84%E7%90%86%E5%99%A8)中的示例代码 /** * 处理读取器打开事件 */ private void handleReaderOpenEvent(ReaderOpenEvent event) { log.info("读取器打开 | 插件ID: {}, 并行度: {}, 时间: {}", event.getPluginId(), event.getParallelism(), event.getEventTime()); // 处理读取器初始化逻辑 } /** * 处理写入器关闭事件 */ private void handleWriterCloseEvent(WriterCloseEvent event) { log.info("写入器关闭 | 插件ID: {}, 处理记录数: {}, 时间: {}", event.getPluginId(), event.getRecordCount(), event.getEventTime()); // 处理写入器资源清理逻辑 } 请问2.3.12版本seatunne-api中的这两个方法event.getParallelism() 、event.getRecordCount()在哪里？ -- 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]
