public interface ManagedInitializationContext
Operator state is available to all operators, while keyed state is only available for operators after keyBy.
For the purpose of initialization, the context signals if the state is empty (new operator) or was restored from a previous execution of this operator.
Modifier and Type | Method and Description |
---|---|
KeyedStateStore |
getKeyedStateStore()
Returns an interface that allows for registering keyed state with the backend.
|
OperatorStateStore |
getOperatorStateStore()
Returns an interface that allows for registering operator state with the backend.
|
boolean |
isRestored()
Returns true, if state was restored from the snapshot of a previous execution.
|
boolean isRestored()
OperatorStateStore getOperatorStateStore()
KeyedStateStore getKeyedStateStore()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.