Class AbstractPartitionReducer

  • All Implemented Interfaces:
    PartitionReducer


    public abstract class AbstractPartitionReducer
    extends java.lang.Object
    implements PartitionReducer
    The AbstractBatchlet provides default implementations of less commonly implemented methods.
    • Constructor Detail

      • AbstractPartitionReducer

        public AbstractPartitionReducer​()
    • Method Detail

      • beginPartitionedStep

        public void beginPartitionedStep​()
                                  throws java.lang.Exception
        Override this method to take action before partitioned step processing begins.
        Specified by:
        beginPartitionedStep in interface PartitionReducer
        Throws:
        java.lang.Exception - is thrown if an error occurs.
      • beforePartitionedStepCompletion

        public void beforePartitionedStepCompletion​()
                                             throws java.lang.Exception
        Override this method to take action before normal partitioned step processing ends.
        Specified by:
        beforePartitionedStepCompletion in interface PartitionReducer
        Throws:
        java.lang.Exception - is thrown if an error occurs.
      • rollbackPartitionedStep

        public void rollbackPartitionedStep​()
                                     throws java.lang.Exception
        Override this method to take action when a partitioned step is rolling back.
        Specified by:
        rollbackPartitionedStep in interface PartitionReducer
        Throws:
        java.lang.Exception - is thrown if an error occurs.
      • afterPartitionedStepCompletion

        public void afterPartitionedStepCompletion​(PartitionReducer.PartitionStatus status)
                                            throws java.lang.Exception
        Override this method to take action after partitioned step processing ends.
        Specified by:
        afterPartitionedStepCompletion in interface PartitionReducer
        Parameters:
        status - specifies the outcome of the partitioned step. Values are "COMMIT" or "ROLLBACK".
        Throws:
        java.lang.Exception - is thrown if an error occurs.