Package | Description |
---|---|
org.apache.flink.state.changelog | |
org.apache.flink.state.common |
Class and Description |
---|
PeriodicMaterializationManager.MaterializationRunnable
A
Runnable representing the materialization and the associated metadata. |
PeriodicMaterializationManager.MaterializationTarget
PeriodicMaterializationManager.MaterializationRunnable provider and consumer, i.e. |
Class and Description |
---|
ChangelogMaterializationMetricGroup
Metrics related to the materialization part of Changelog.
|
PeriodicMaterializationManager.MaterializationRunnable
A
Runnable representing the materialization and the associated metadata. |
PeriodicMaterializationManager.MaterializationTarget
PeriodicMaterializationManager.MaterializationRunnable provider and consumer, i.e. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.