public abstract class AbstractPartitionReducer extends 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 Exception
beginPartitionedStep in interface PartitionReducerException - is thrown if an error occurs.public void beforePartitionedStepCompletion()
throws Exception
beforePartitionedStepCompletion in interface PartitionReducerException - is thrown if an error occurs.public void rollbackPartitionedStep()
throws Exception
rollbackPartitionedStep in interface PartitionReducerException - is thrown if an error occurs.public void afterPartitionedStepCompletion(PartitionReducer.PartitionStatus status) throws Exception
afterPartitionedStepCompletion in interface PartitionReducerstatus - specifies the outcome of the partitioned step.
Values are "COMMIT" or "ROLLBACK".Exception - is thrown if an error occurs.Copyright © 2018,2020 Eclipse Foundation.
Use is subject to license terms.