org.apache.batchee.container.impl.controller.chunk

Class ChunkStepController

java.lang.Object

org.apache.batchee.container.impl.controller.BaseStepController

org.apache.batchee.container.impl.controller.SingleThreadedStepController

org.apache.batchee.container.impl.controller.chunk.ChunkStepController

All Implemented Interfaces:

Controller, ExecutionElementController

public class ChunkStepController
extends SingleThreadedStepController

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	checkpointAtThisItemCount
protected org.apache.batchee.container.impl.controller.chunk.ChunkStepController.ChunkStatus	currentChunkStatus
protected org.apache.batchee.container.impl.controller.chunk.ChunkStepController.SingleItemStatus	currentItemStatus
protected boolean	customCheckpointPolicy
protected static int	DEFAULT_TRAN_TIMEOUT_SECONDS
protected int	stepPropertyTranTimeoutSeconds

Fields inherited from class org.apache.batchee.container.impl.controller.SingleThreadedStepController

collectorProxy

Fields inherited from class org.apache.batchee.container.impl.controller.BaseStepController

analyzerStatusQueue, jobExecutionImpl, jobInstance, kernelService, restartAfterCompletion, rootJobExecutionId, step, stepContext, stepName, stepStatus, transactionManager

Constructor Summary

Constructors

Constructor and Description
ChunkStepController(RuntimeJobExecution jobExecutionImpl, Step step, StepContextImpl stepContext, long rootJobExecutionId, BlockingQueue<PartitionDataWrapper> analyzerStatusQueue, ServicesManager servicesManager)

Method Summary

Modifier and Type	Method and Description
protected void	invokeCoreStep()
void	stop()

Methods inherited from class org.apache.batchee.container.impl.controller.SingleThreadedStepController

invokeCollectorIfPresent, invokePostStepArtifacts, invokePreStepArtifacts, sendCollectorDataToAnalyzerIfPresent, sendStatusFromPartitionToAnalyzerIfPresent, setupStepArtifacts

Methods inherited from class org.apache.batchee.container.impl.controller.BaseStepController

execute, getLastRunStepExecutions, isRestartExecution, markJobAndStepFailed, persistExitStatusAndEndTimestamp, persistUserData, resolveUserData, setParentStepContext, setStepContext, shouldStepBeExecuted, statusStarting, storeUserData, toString, updateBatchStatus

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.batchee.container.Controller

getLastRunStepExecutions

Field Detail

DEFAULT_TRAN_TIMEOUT_SECONDS

protected static final int DEFAULT_TRAN_TIMEOUT_SECONDS

See Also:

Constant Field Values

currentChunkStatus

protected org.apache.batchee.container.impl.controller.chunk.ChunkStepController.ChunkStatus currentChunkStatus

currentItemStatus

protected org.apache.batchee.container.impl.controller.chunk.ChunkStepController.SingleItemStatus currentItemStatus

customCheckpointPolicy

protected boolean customCheckpointPolicy

checkpointAtThisItemCount

protected Integer checkpointAtThisItemCount

stepPropertyTranTimeoutSeconds

protected int stepPropertyTranTimeoutSeconds

Constructor Detail

ChunkStepController

public ChunkStepController(RuntimeJobExecution jobExecutionImpl,
                           Step step,
                           StepContextImpl stepContext,
                           long rootJobExecutionId,
                           BlockingQueue<PartitionDataWrapper> analyzerStatusQueue,
                           ServicesManager servicesManager)

Method Detail

invokeCoreStep

protected void invokeCoreStep()
                       throws BatchContainerServiceException

Specified by:

invokeCoreStep in class BaseStepController

Throws:

BatchContainerServiceException

stop

public void stop()