Package org.apache.flink.state.common

Class PeriodicMaterializationManager

java.lang.Object

org.apache.flink.state.common.PeriodicMaterializationManager

All Implemented Interfaces:

Closeable, AutoCloseable

@Internal
public class PeriodicMaterializationManager
extends Object
implements Closeable

Stateless Materialization Manager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PeriodicMaterializationManager.MaterializationRunnable	A Runnable representing the materialization and the associated metadata.
static interface	PeriodicMaterializationManager.MaterializationTarget	PeriodicMaterializationManager.MaterializationRunnable provider and consumer, i.e. state backend.

Constructor Summary

Constructors

Constructor

Description

PeriodicMaterializationManager(MailboxExecutor mailboxExecutor, ExecutorService asyncOperationsThreadPool, String subtaskName, AsyncExceptionHandler asyncExceptionHandler, PeriodicMaterializationManager.MaterializationTarget target, ChangelogMaterializationMetricGroup metricGroup, boolean isPeriodicMaterializeEnabled, long periodicMaterializeDelay, int allowedNumberOfFailures, String operatorSubtaskId)

Method Summary

Modifier and Type	Method	Description
void	close()
void	start()
void	triggerMaterialization()

Methods inherited from class java.lang.Object

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

Constructor Detail

PeriodicMaterializationManager

public PeriodicMaterializationManager(MailboxExecutor mailboxExecutor,
                                      ExecutorService asyncOperationsThreadPool,
                                      String subtaskName,
                                      AsyncExceptionHandler asyncExceptionHandler,
                                      PeriodicMaterializationManager.MaterializationTarget target,
                                      ChangelogMaterializationMetricGroup metricGroup,
                                      boolean isPeriodicMaterializeEnabled,
                                      long periodicMaterializeDelay,
                                      int allowedNumberOfFailures,
                                      String operatorSubtaskId)

Method Detail

start

public void start()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

triggerMaterialization

@VisibleForTesting
public void triggerMaterialization()