public class BatchletStepController extends SingleThreadedStepController
collectorProxy
analyzerStatusQueue, jobExecutionImpl, jobInstance, kernelService, persistenceManagerService, restartAfterCompletion, rootJobExecutionId, step, stepContext, stepName, stepStatus, transactionManager
Constructor and Description |
---|
BatchletStepController(RuntimeJobExecution jobExecutionImpl,
Step step,
StepContextImpl stepContext,
long rootJobExecutionId,
BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
ServicesManager manager) |
Modifier and Type | Method and Description |
---|---|
protected void |
invokeCoreStep() |
void |
stop() |
protected boolean |
wasStopIssued() |
invokeCollectorIfPresent, invokePostStepArtifacts, invokePreStepArtifacts, sendCollectorDataToAnalyzerIfPresent, sendStatusFromPartitionToAnalyzerIfPresent, setupStepArtifacts
execute, getLastRunStepExecutions, isRestartExecution, markJobAndStepFailed, persistExitStatusAndEndTimestamp, persistUserData, resolveUserData, setParentStepContext, setStepContext, shouldStepBeExecuted, statusStarting, storeUserData, toString, updateBatchStatus
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getLastRunStepExecutions
public BatchletStepController(RuntimeJobExecution jobExecutionImpl, Step step, StepContextImpl stepContext, long rootJobExecutionId, BlockingQueue<PartitionDataWrapper> analyzerStatusQueue, ServicesManager manager)
protected boolean wasStopIssued()
protected void invokeCoreStep() throws BatchContainerServiceException
invokeCoreStep
in class BaseStepController
BatchContainerServiceException
public void stop()
Copyright © 2017 The Apache Software Foundation. All rights reserved.