org.apache.flink.state.common

Interface PeriodicMaterializationManager.MaterializationTarget

All Known Implementing Classes:

ChangelogKeyedStateBackend

Enclosing class:

PeriodicMaterializationManager

public static interface PeriodicMaterializationManager.MaterializationTarget

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

Field Summary

Fields

Modifier and Type	Field and Description
static PeriodicMaterializationManager.MaterializationTarget	NO_OP

Method Summary

Modifier and Type	Method and Description
void	handleMaterializationResult(SnapshotResult<KeyedStateHandle> materializedSnapshot, long materializationID, SequenceNumber upTo) This method is not thread safe.
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.

This method is not thread safe. It should be called either under a lock or through task mailbox executor.

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

This method is not thread safe. It should be called either under a lock or through task mailbox executor.

Throws:

Exception