public class ProcessDataPipeline extends Object implements Runnable
构造器和说明 |
---|
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor) |
限定符和类型 | 方法和说明 |
---|---|
ProcessDataBackoff |
getBackoff() |
void |
run() |
void |
setBackoff(ProcessDataBackoff backoff) |
public ProcessDataPipeline(ChannelConnect connect, ExecutorService helperExecutor, ThreadPoolExecutor readRecordsExecutor, ThreadPoolExecutor processRecordsExecutor)
public ProcessDataBackoff getBackoff()
public void setBackoff(ProcessDataBackoff backoff)
Copyright © 2019. All Rights Reserved.