public interface IChannelProcessor
| Modifier and Type | Method and Description |
|---|---|
void |
process(ProcessRecordsInput input)
增量数据的消费Callback.
|
void |
shutdown()
用户注册的Shutdown函数,用于注册资源(例如线程池,数据库连接)的回收等。
|
void process(ProcessRecordsInput input)
input: - 本次的增量数据,包括Stream Records和Next Token等信息。void shutdown()
Copyright © 2024. All Rights Reserved.