org.apache.flink.state.common

Class PeriodicMaterializationManager.MaterializationRunnable

java.lang.Object

org.apache.flink.state.common.PeriodicMaterializationManager.MaterializationRunnable

Enclosing class:

PeriodicMaterializationManager

public static class PeriodicMaterializationManager.MaterializationRunnable
extends Object

A Runnable representing the materialization and the associated metadata.

Constructor Summary

Constructors

Constructor and Description
MaterializationRunnable(RunnableFuture<SnapshotResult<KeyedStateHandle>> materializationRunnable, long materializationID, SequenceNumber materializedTo)

Method Summary

Modifier and Type	Method and Description
long	getMaterializationID()
SequenceNumber	getMaterializedTo()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MaterializationRunnable

public MaterializationRunnable(RunnableFuture<SnapshotResult<KeyedStateHandle>> materializationRunnable,
                               long materializationID,
                               SequenceNumber materializedTo)

Method Detail

getMaterializedTo

public SequenceNumber getMaterializedTo()

getMaterializationID

public long getMaterializationID()