Class and Description |
---|
BroadcastVariableKey
An identifier for a
BroadcastVariableMaterialization based on the task's JobVertexID , broadcast
variable name and iteration superstep. |
BroadcastVariableMaterialization
This class represents a single materialization of a broadcast variable and maintains a reference count for it.
|
DefaultBroadcastVariableInitializer
The default
BroadcastVariableInitializer implementation that initializes the broadcast variable into a list. |
InitializationTypeConflictException
Indicates that a broadcast variable was initialized with a
DefaultBroadcastVariableInitializer as a
non-List type, and later accessed using RuntimeContext.getBroadcastVariable(String) which
may only return lists. |
MaterializationExpiredException
Indicates that the
BroadcastVariableMaterialization has materialized the broadcast variable at some point
but discarded it already. |
Class and Description |
---|
BroadcastVariableManager
The BroadcastVariableManager is used to manage the materialization of broadcast variables.
|
Class and Description |
---|
BroadcastVariableMaterialization
This class represents a single materialization of a broadcast variable and maintains a reference count for it.
|
Class and Description |
---|
BroadcastVariableManager
The BroadcastVariableManager is used to manage the materialization of broadcast variables.
|
Class and Description |
---|
BroadcastVariableManager
The BroadcastVariableManager is used to manage the materialization of broadcast variables.
|
Class and Description |
---|
BroadcastVariableManager
The BroadcastVariableManager is used to manage the materialization of broadcast variables.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.