Class AbstractPartitionHandler

    • Constructor Detail

      • AbstractPartitionHandler

        public AbstractPartitionHandler()
    • Method Detail

      • doHandle

        protected abstract java.util.Set<StepExecution> doHandle​(StepExecution masterStepExecution,
                                                                 java.util.Set<StepExecution> partitionStepExecutions)
                                                          throws java.lang.Exception
        Executes the specified StepExecution instances and returns an updated view of them. Throws an Exception if anything goes wrong.
        Parameters:
        masterStepExecution - the whole partition execution
        partitionStepExecutions - the StepExecution instances to execute
        Returns:
        an updated view of these completed StepExecution instances
        Throws:
        java.lang.Exception - if anything goes wrong. This allows implementations to be liberal and rely on the caller to translate an exception into a step failure as necessary.
      • handle

        public java.util.Collection<StepExecution> handle​(StepExecutionSplitter stepSplitter,
                                                          StepExecution masterStepExecution)
                                                   throws java.lang.Exception
        Description copied from interface: PartitionHandler
        Main entry point for PartitionHandler interface. The splitter creates all the executions that need to be farmed out, along with their input parameters (in the form of their ExecutionContext). The master step execution is used to identify the partition and group together the results logically.
        Specified by:
        handle in interface PartitionHandler
        Parameters:
        stepSplitter - a strategy for generating a collection of StepExecution instances
        masterStepExecution - the master step execution for the whole partition
        Returns:
        a collection of completed StepExecution instances
        Throws:
        java.lang.Exception - if anything goes wrong. This allows implementations to be liberal and rely on the caller to translate an exception into a step failure as necessary.
        See Also:
        PartitionHandler.handle(StepExecutionSplitter, StepExecution)
      • getGridSize

        public int getGridSize()
        Returns the number of step executions.
        Returns:
        the number of step executions