CommT
- @PublicEvolving public static interface Committer.CommitRequest<CommT>
Modifier and Type | Method and Description |
---|---|
CommT |
getCommittable()
Returns the committable.
|
int |
getNumberOfRetries()
Returns how many times this particular committable has been retried.
|
void |
retryLater()
The commit failed for a retriable reason.
|
void |
signalAlreadyCommitted()
Signals that a committable is skipped as it was committed already in a previous run.
|
void |
signalFailedWithKnownReason(Throwable t)
The commit failed for known reason and should not be retried.
|
void |
signalFailedWithUnknownReason(Throwable t)
The commit failed for unknown reason and should not be retried.
|
void |
updateAndRetryLater(CommT committable)
Updates the underlying committable and retries later (see
retryLater() for a
description). |
CommT getCommittable()
int getNumberOfRetries()
void signalFailedWithKnownReason(Throwable t)
Currently calling this method only logs the error, discards the comittable and continues. In the future the behaviour might be configurable.
void signalFailedWithUnknownReason(Throwable t)
Currently calling this method fails the job. In the future the behaviour might be configurable.
void retryLater()
void updateAndRetryLater(CommT committable)
retryLater()
for a
description). This method can be used if a committable partially succeeded.void signalAlreadyCommitted()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.