Modifier and Type | Method and Description |
---|---|
Environment |
DbStateBackend.getEnvironment() |
Modifier and Type | Method and Description |
---|---|
void |
DbStateBackend.initializeForJob(Environment env,
String operatorIdentifier,
TypeSerializer<?> keySerializer) |
void |
RocksDBStateBackend.initializeForJob(Environment env,
String operatorIdentifier,
TypeSerializer<?> keySerializer) |
Modifier and Type | Method and Description |
---|---|
Environment |
AbstractInvokable.getEnvironment()
Returns the environment of this task.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractInvokable.setEnvironment(Environment environment)
Sets the environment of this task.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractStateBackend.initializeForJob(Environment env,
String operatorIdentifier,
TypeSerializer<?> keySerializer)
This method is called by the task upon deployment to initialize the state backend for
data for a specific job.
|
Modifier and Type | Method and Description |
---|---|
void |
FsStateBackend.initializeForJob(Environment env,
String operatorIdentifier,
TypeSerializer<?> keySerializer) |
Modifier and Type | Class and Description |
---|---|
class |
RuntimeEnvironment
In implementation of the
Environment . |
Constructor and Description |
---|
StreamingRuntimeContext(AbstractStreamOperator<?> operator,
Environment env,
Map<String,Accumulator<?,?>> accumulators) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.