Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<PartitionDataWrapper> |
BaseStepController.analyzerStatusQueue |
Modifier and Type | Method and Description |
---|---|
static BaseStepController |
ExecutionElementControllerFactory.getStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
ServicesManager servicesManager) |
Constructor and Description |
---|
BaseStepController(RuntimeJobExecution jobExecution,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
ExecutionTransitioner(RuntimeJobExecution jobExecution,
long rootJobExecutionId,
ModelNavigator<JSLJob> jobNavigator,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
ServicesManager manager) |
JobThreadRootController(RuntimeJobExecution jobExecution,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
ServicesManager servicesManager) |
SingleThreadedStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
Constructor and Description |
---|
BatchletStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager manager) |
Constructor and Description |
---|
ChunkStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
BlockingQueue<PartitionDataWrapper> |
PartitionsBuilderConfig.getAnalyzerQueue() |
Constructor and Description |
---|
PartitionsBuilderConfig(List<JSLJob> jobModels,
Properties[] partitionProperties,
BlockingQueue<PartitionDataWrapper> analyzerQueue,
BlockingQueue<BatchPartitionWorkUnit> completedQueue,
long rootJobExecutionId) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.