@NotThreadSafe public static interface PeriodicMaterializationManager.MaterializationTarget
PeriodicMaterializationManager.MaterializationRunnable
provider and consumer, i.e. state backend.Modifier and Type | Field and Description |
---|---|
static PeriodicMaterializationManager.MaterializationTarget |
NO_OP |
Modifier and Type | Method and Description |
---|---|
void |
handleMaterializationFailureOrCancellation(long materializationID,
SequenceNumber upTo,
Throwable cause) |
void |
handleMaterializationResult(SnapshotResult<KeyedStateHandle> materializedSnapshot,
long materializationID,
SequenceNumber upTo)
Implementations should not trigger materialization until the previous one has been
confirmed or failed.
|
Optional<PeriodicMaterializationManager.MaterializationRunnable> |
initMaterialization()
Initialize state materialization so that materialized data can be persisted durably and
included into the checkpoint.
|
static final PeriodicMaterializationManager.MaterializationTarget NO_OP
Optional<PeriodicMaterializationManager.MaterializationRunnable> initMaterialization() throws Exception
SequenceNumber
identifying the latest change in the changelogException
void handleMaterializationResult(SnapshotResult<KeyedStateHandle> materializedSnapshot, long materializationID, SequenceNumber upTo) throws Exception
Exception
void handleMaterializationFailureOrCancellation(long materializationID, SequenceNumber upTo, Throwable cause)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.