public class DefaultChannelProcessor extends Object implements IChannelProcessor
| Constructor and Description |
|---|
DefaultChannelProcessor(IChannelProcessor recordProcessor,
ICheckpointer checkpointer,
long checkpointIntervalInMillis) |
| Modifier and Type | Method and Description |
|---|---|
void |
process(ProcessRecordsInput input)
增量数据的消费Callback.
|
void |
shutdown()
用户注册的Shutdown函数,用于注册资源(例如线程池,数据库连接)的回收等。
|
public DefaultChannelProcessor(IChannelProcessor recordProcessor, ICheckpointer checkpointer, long checkpointIntervalInMillis)
public void process(ProcessRecordsInput input)
IChannelProcessorprocess in interface IChannelProcessorpublic void shutdown()
IChannelProcessorshutdown in interface IChannelProcessorCopyright © 2024. All Rights Reserved.