public interface IChannelProcessor
限定符和类型 | 方法和说明 |
---|---|
void |
process(ProcessRecordsInput input)
增量数据的消费Callback.
|
void |
shutdown()
用户注册的Shutdown函数,用于注册资源(例如线程池,数据库连接)的回收等。
|
void process(ProcessRecordsInput input)
input:
- 本次的增量数据,包括Stream Records和Next Token等信息。void shutdown()
Copyright © 2019. All Rights Reserved.