public class DefaultChannelProcessor extends Object implements IChannelProcessor
构造器和说明 |
---|
DefaultChannelProcessor(IChannelProcessor recordProcessor,
ICheckpointer checkpointer,
long checkpointIntervalInMillis) |
public DefaultChannelProcessor(IChannelProcessor recordProcessor, ICheckpointer checkpointer, long checkpointIntervalInMillis)
public void process(ProcessRecordsInput input)
IChannelProcessor
process
在接口中 IChannelProcessor
public void shutdown()
IChannelProcessor
shutdown
在接口中 IChannelProcessor
Copyright © 2019. All Rights Reserved.