| 程序包 | 说明 |
|---|---|
| com.alibaba.schedulerx.worker.pull |
| 构造器和说明 |
|---|
ConsumerThread(BlockingContainerQueue queue,
ContainerPool containerPool,
String taskMasterAkkaPath) |
PullThread(long jobInstanceId,
int pageSize,
String taskMasterAkkaPath,
BlockingContainerQueue queue) |
Copyright © 2021. All rights reserved.