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 PartitionReducer
java.lang.Exception
- is thrown if an error occurs.public void beforePartitionedStepCompletion() throws java.lang.Exception
beforePartitionedStepCompletion
in interface PartitionReducer
java.lang.Exception
- is thrown if an error occurs.public void rollbackPartitionedStep() throws java.lang.Exception
rollbackPartitionedStep
in interface PartitionReducer
java.lang.Exception
- is thrown if an error occurs.public void afterPartitionedStepCompletion(PartitionReducer.PartitionStatus status) throws java.lang.Exception
afterPartitionedStepCompletion
in interface PartitionReducer
status
- specifies the outcome of the partitioned step.
Values are "COMMIT" or "ROLLBACK".java.lang.Exception
- is thrown if an error occurs.