org.apache.flink.runtime.state

Interface SharedStateRegistryFactory

public interface SharedStateRegistryFactory

Simple factory to produce SharedStateRegistry objects.

Method Summary

Modifier and Type	Method and Description
SharedStateRegistry	create(Executor deleteExecutor, Collection<CompletedCheckpoint> checkpoints, RestoreMode restoreMode) Factory method for SharedStateRegistry.

Method Detail

create

SharedStateRegistry create(Executor deleteExecutor,
                           Collection<CompletedCheckpoint> checkpoints,
                           RestoreMode restoreMode)

Factory method for SharedStateRegistry.

Parameters:

deleteExecutor - executor used to run (async) deletes.

checkpoints - whose shared state will be registered.

restoreMode - the mode in which the given checkpoints were restored

Returns:

a SharedStateRegistry object