类 TaskletStep

字段详细资料

• TASKLET_TYPE_KEY

  public static final java.lang.String TASKLET_TYPE_KEY

  另请参阅:

  常量字段值

构造器详细资料

• TaskletStep

  public TaskletStep()

  Default constructor.

• TaskletStep

  public TaskletStep​(java.lang.String name)

  参数:

  name - the name for the TaskletStep

方法详细资料

• afterPropertiesSet

  public void afterPropertiesSet()
                          throws java.lang.Exception

  指定者:

  afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

  覆盖:

  afterPropertiesSet 在类中 AbstractStep

  抛出:

  java.lang.Exception

• setTransactionManager

  public void setTransactionManager​(org.springframework.transaction.PlatformTransactionManager transactionManager)

  Public setter for the PlatformTransactionManager.

  参数:

  transactionManager - the transaction manager to set

• setTransactionAttribute

  public void setTransactionAttribute​(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)

  Public setter for the TransactionAttribute.

  参数:

  transactionAttribute - the TransactionAttribute to set

• setTasklet

  public void setTasklet​(Tasklet tasklet)

  Public setter for the Tasklet.

  参数:

  tasklet - the Tasklet to set

• registerChunkListener

  public void registerChunkListener​(ChunkListener listener)

  Register a chunk listener for callbacks at the appropriate stages in a step execution.

  参数:

  listener - a ChunkListener

• setChunkListeners

  public void setChunkListeners​(ChunkListener[] listeners)

  Register each of the objects as listeners.

  参数:

  listeners - an array of listener objects of known types.

• setStreams

  public void setStreams​(ItemStream[] streams)

  Register each of the streams for callbacks at the appropriate time in the step. The ItemReader and ItemWriter are automatically registered, but it doesn't hurt to also register them here. Injected dependencies of the reader and writer are not automatically registered, so if you implement ItemWriter using delegation to another object which itself is a ItemStream, you need to register the delegate here.

  参数:

  streams - an array of ItemStream objects.

• registerStream

  public void registerStream​(ItemStream stream)

  Register a single ItemStream for callbacks to the stream interface.

  参数:

  stream - instance of ItemStream

• setStepOperations

  public void setStepOperations​(RepeatOperations stepOperations)

  The RepeatOperations to use for the outer loop of the batch processing. Should be set up by the caller through a factory. Defaults to a plain RepeatTemplate.

  参数:

  stepOperations - a RepeatOperations instance.

• setInterruptionPolicy

  public void setInterruptionPolicy​(StepInterruptionPolicy interruptionPolicy)

  Setter for the StepInterruptionPolicy. The policy is used to check whether an external request has been made to interrupt the job execution.

  参数:

  interruptionPolicy - a StepInterruptionPolicy

• doExecute

  protected void doExecute​(StepExecution stepExecution)
                    throws java.lang.Exception

  Process the step and update its context so that progress can be monitored by the caller. The step is broken down into chunks, each one executing in a transaction. The step and its execution and execution context are all given an up to date BatchStatus, and the JobRepository is used to store the result. Various reporting information are also added to the current context governing the step execution, which would normally be available to the caller through the step's ExecutionContext.
  

  指定者:

  doExecute 在类中 AbstractStep

  参数:

  stepExecution - the current step context

  抛出:

  JobInterruptedException - if the step or a chunk is interrupted

  java.lang.RuntimeException - if there is an exception during a chunk execution

  java.lang.Exception - checked exception thrown by implementation

• createSemaphore

  protected java.util.concurrent.Semaphore createSemaphore()

  Extension point mainly for test purposes so that the behaviour of the lock can be manipulated to simulate various pathologies.

  返回:

  a semaphore for locking access to the JobRepository

• close

  protected void close​(ExecutionContext ctx)
                throws java.lang.Exception

  从类复制的说明: AbstractStep
  Extension point for subclasses to provide callbacks to their collaborators at the end of a step (right at the end of the finally block), to close or release resources. Does nothing by default.

  覆盖:

  close 在类中 AbstractStep

  参数:

  ctx - the ExecutionContext to use

  抛出:

  java.lang.Exception - checked exception thrown by implementation

• open

  protected void open​(ExecutionContext ctx)
               throws java.lang.Exception

  从类复制的说明: AbstractStep
  Extension point for subclasses to provide callbacks to their collaborators at the beginning of a step, to open or acquire resources. Does nothing by default.

  覆盖:

  open 在类中 AbstractStep

  参数:

  ctx - the ExecutionContext to use

  抛出:

  java.lang.Exception - checked exception thrown by implementation

• getTasklet

  public Tasklet getTasklet()

  retrieve the tasklet - helper method for JobOperator

  返回:

  the Tasklet instance being executed within this step