public class ProcessDataPipeline extends Object implements Runnable
| Constructor and Description |
|---|
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor) |
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor,
Semaphore semaphore) |
| Modifier and Type | Method and Description |
|---|---|
ProcessDataBackoff |
getBackoff() |
Semaphore |
getSemaphore() |
void |
run() |
void |
setBackoff(ProcessDataBackoff backoff) |
void |
setReadMaxBytesPerRound(int readMaxBytesPerRound) |
void |
setReadMaxTimesPerRound(int readMaxTimesPerRound) |
void |
setSemaphore(Semaphore semaphore) |
public ProcessDataPipeline(ChannelConnect connect, ExecutorService helperExecutor, ThreadPoolExecutor readRecordsExecutor, ThreadPoolExecutor processRecordsExecutor)
public ProcessDataPipeline(ChannelConnect connect, ExecutorService helperExecutor, ThreadPoolExecutor readRecordsExecutor, ThreadPoolExecutor processRecordsExecutor, Semaphore semaphore)
public ProcessDataBackoff getBackoff()
public void setBackoff(ProcessDataBackoff backoff)
public Semaphore getSemaphore()
public void setSemaphore(Semaphore semaphore)
public void setReadMaxTimesPerRound(int readMaxTimesPerRound)
public void setReadMaxBytesPerRound(int readMaxBytesPerRound)
Copyright © 2024. All Rights Reserved.