根据事件监听器的文档中的示例代码
/**
* 处理读取器打开事件
*/
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()在哪里?