程序包 | 说明 |
---|---|
com.alicloud.openservices.tablestore.tunnel.pipeline |
构造器和说明 |
---|
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor) |
ProcessDataPipeline(ChannelConnect connect,
ExecutorService helperExecutor,
ThreadPoolExecutor readRecordsExecutor,
ThreadPoolExecutor processRecordsExecutor,
Semaphore semaphore) |
ProcessDataPipelineContext(ChannelConnect connect) |
Copyright © 2019. All Rights Reserved.