public class ProxyStateSnapshotContext extends Object implements org.apache.flink.runtime.state.StateSnapshotContext
StateSnapshotContext
for the wrapped operators.Constructor and Description |
---|
ProxyStateSnapshotContext(org.apache.flink.runtime.state.StateSnapshotContext wrappedContext) |
Modifier and Type | Method and Description |
---|---|
long |
getCheckpointId() |
long |
getCheckpointTimestamp() |
org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream |
getRawKeyedOperatorStateOutput() |
org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream |
getRawOperatorStateOutput() |
public ProxyStateSnapshotContext(org.apache.flink.runtime.state.StateSnapshotContext wrappedContext)
public org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream getRawKeyedOperatorStateOutput() throws Exception
getRawKeyedOperatorStateOutput
in interface org.apache.flink.runtime.state.StateSnapshotContext
Exception
public org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream getRawOperatorStateOutput() throws Exception
getRawOperatorStateOutput
in interface org.apache.flink.runtime.state.StateSnapshotContext
Exception
public long getCheckpointId()
getCheckpointId
in interface org.apache.flink.runtime.state.ManagedSnapshotContext
public long getCheckpointTimestamp()
getCheckpointTimestamp
in interface org.apache.flink.runtime.state.ManagedSnapshotContext
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.