public abstract class AbstractPartitionReducer extends java.lang.Object implements PartitionReducer
PartitionReducer.PartitionStatus| Constructor and Description | 
|---|
AbstractPartitionReducer()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
afterPartitionedStepCompletion(PartitionReducer.PartitionStatus status)
Override this method to take action after 
 partitioned step processing ends. 
 | 
void | 
beforePartitionedStepCompletion()
Override this method to take action before 
 normal partitioned step processing ends. 
 | 
void | 
beginPartitionedStep()
Override this method to take action before 
 partitioned step processing begins. 
 | 
void | 
rollbackPartitionedStep()
Override this method to take action when a  
 partitioned step is rolling back. 
 | 
public void beginPartitionedStep()
                          throws java.lang.Exception
beginPartitionedStep in interface PartitionReducerjava.lang.Exception - is thrown if an error occurs.public void beforePartitionedStepCompletion()
                                     throws java.lang.Exception
beforePartitionedStepCompletion in interface PartitionReducerjava.lang.Exception - is thrown if an error occurs.public void rollbackPartitionedStep()
                             throws java.lang.Exception
rollbackPartitionedStep in interface PartitionReducerjava.lang.Exception - is thrown if an error occurs.public void afterPartitionedStepCompletion(PartitionReducer.PartitionStatus status) throws java.lang.Exception
afterPartitionedStepCompletion in interface PartitionReducerstatus - specifies the outcome of the partitioned step. 
 Values are "COMMIT" or "ROLLBACK".java.lang.Exception - is thrown if an error occurs.