How to get the number of records in the event listener
- Dominant language
- Java
- Stars
- 9.7k
- Forks
- 2.4k
- Avg merge
- 3d 9h
- Merged PRs (30d)
- 204
Description
[根据事件监听器的文档](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()在哪里?
Contributor guide
No contributing guide indexed for this repository
Research direction
Start with the linked SeaTunnel event-listener documentation and inspect the 2.3.12 seatunnel-api event definitions for getParallelism() and getRecordCount(). Compare the documented example with the available API, then confirm whether the methods exist or the example needs correction; done means the documentation and API usage agree.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- documentation
- Issue type
- Documentation
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100