Package | Description |
---|---|
org.apache.flink.iteration.proxy.state |
Constructor and Description |
---|
ProxyInternalTimeServiceManager(org.apache.flink.streaming.api.operators.InternalTimeServiceManager<K> wrappedManager,
StateNamePrefix stateNamePrefix) |
ProxyKeyedStateBackend(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> wrappedBackend,
StateNamePrefix stateNamePrefix) |
ProxyOperatorStateBackend(org.apache.flink.runtime.state.OperatorStateBackend wrappedBackend,
StateNamePrefix stateNamePrefix) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.