public abstract class AbstractStateBackend extends Object implements Serializable
Constructor and Description |
---|
AbstractStateBackend() |
Modifier and Type | Method and Description |
---|---|
abstract <K> AbstractKeyedStateBackend<K> |
createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry)
Creates a new
AbstractKeyedStateBackend that is responsible for keeping keyed state
and can be checkpointed to checkpoint streams. |
OperatorStateBackend |
createOperatorStateBackend(Environment env,
String operatorIdentifier)
Creates a new
OperatorStateBackend that can be used for storing partitionable operator
state in checkpoint streams. |
abstract CheckpointStreamFactory |
createStreamFactory(JobID jobId,
String operatorIdentifier)
Creates a
CheckpointStreamFactory that can be used to create streams
that should end up in a checkpoint. |
public abstract CheckpointStreamFactory createStreamFactory(JobID jobId, String operatorIdentifier) throws IOException
CheckpointStreamFactory
that can be used to create streams
that should end up in a checkpoint.jobId
- The JobID
of the job for which we are creating checkpoint streams.operatorIdentifier
- An identifier of the operator for which we create streams.IOException
public abstract <K> AbstractKeyedStateBackend<K> createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry) throws Exception
AbstractKeyedStateBackend
that is responsible for keeping keyed state
and can be checkpointed to checkpoint streams.Exception
public OperatorStateBackend createOperatorStateBackend(Environment env, String operatorIdentifier) throws Exception
OperatorStateBackend
that can be used for storing partitionable operator
state in checkpoint streams.Exception
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.