public static interface FileTierPartitionState.MaterializationListener
Modifier and Type | Interface and Description |
---|---|
static class |
FileTierPartitionState.MaterializationListener.Initialization
Listener for materialization to reach or surpass a minimum leader epoch.
|
static class |
FileTierPartitionState.MaterializationListener.LeaderEpoch
Listener for materialization to reach or surpass a particular leader epoch.
|
static class |
FileTierPartitionState.MaterializationListener.ReplicationTargetObjectId
Listener for materialization to witness a particular objectId at an FileTierPartitionState restore epoch
equal to or greater than the provided target restore epoch.
|
static class |
FileTierPartitionState.MaterializationListener.ReplicationTargetOffset
Listener for materialization to reach or surpass a particular offset.
|
Modifier and Type | Method and Description |
---|---|
void |
cancel(Exception e)
Complete this MaterializationListener without a result.
|
boolean |
complete(FileTierPartitionState.State flushedState)
Try to complete this listener.
|
boolean |
mayComplete(FileTierPartitionState.State unflushedState,
Optional<AbstractTierMetadata> unflushedMessage)
Observe the unflushed FileTierPartitionState.State to determine if this listener can be completed after a flush.
|
boolean mayComplete(FileTierPartitionState.State unflushedState, Optional<AbstractTierMetadata> unflushedMessage) throws IOException
unflushedState
- The unflushed TierPartitionState.StateunflushedMessage
- Optionally, an unflushed message which has mutated the provided FileTierPartitionState.State.
This is sometimes useful for situations where it is expensive to query the unflushedState, but
a cheaper check is possible by observing the most recently applied AbstractTierMetadata.IOException
boolean complete(FileTierPartitionState.State flushedState) throws IOException
flushedState
- The flushed TierPartitionState.State.IOException
void cancel(Exception e)