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