Package org.apache.flink.state.common

Interface PeriodicMaterializationManager.MaterializationTarget

All Known Implementing Classes:

ChangelogKeyedStateBackend

Enclosing class:

PeriodicMaterializationManager

@NotThreadSafe
public static interface PeriodicMaterializationManager.MaterializationTarget

PeriodicMaterializationManager.MaterializationRunnable provider and consumer, i.e. state backend.

Field Summary

Fields

Modifier and Type	Field	Description
static PeriodicMaterializationManager.MaterializationTarget	NO_OP

Method Summary

Modifier and Type	Method	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.

Field Detail

NO_OP

static final PeriodicMaterializationManager.MaterializationTarget NO_OP

Method Detail

initMaterialization

Optional<PeriodicMaterializationManager.MaterializationRunnable> initMaterialization()
                                                                              throws Exception

Initialize state materialization so that materialized data can be persisted durably and included into the checkpoint.

Returns:

a tuple of - future snapshot result from the underlying state backend - a SequenceNumber identifying the latest change in the changelog

Throws:

Exception

handleMaterializationResult

void handleMaterializationResult(SnapshotResult<KeyedStateHandle> materializedSnapshot,
                                 long materializationID,
                                 SequenceNumber upTo)
                          throws Exception

Implementations should not trigger materialization until the previous one has been confirmed or failed.

Throws:

Exception

handleMaterializationFailureOrCancellation

void handleMaterializationFailureOrCancellation(long materializationID,
                                                SequenceNumber upTo,
                                                Throwable cause)