@PublicEvolving public abstract class AbstractStateBackend extends Object implements StateBackend, Serializable
This class has currently no contents and only kept to not break the prior class hierarchy for users.
|Constructor and Description|
|Modifier and Type||Method and Description|
Creates a new
Creates a new
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public abstract <K> AbstractKeyedStateBackend<K> createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup) throws IOException
AbstractKeyedStateBackendthat is responsible for holding keyed state and checkpointing it.
Keyed State is state where each value is bound to a key.
public abstract OperatorStateBackend createOperatorStateBackend(Environment env, String operatorIdentifier) throws Exception
OperatorStateBackendthat can be used for storing operator state.
Operator state is state that is associated with parallel operator (or function) instances, rather than with keys.
env- The runtime environment of the executing task.
operatorIdentifier- The identifier of the operator whose state should be stored.
Exception- This method may forward all exceptions that occur while instantiating the backend.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.