Class | Description |
---|---|
BroadcastVariableKey |
An identifier for a
BroadcastVariableMaterialization based on the task's JobVertexID , broadcast
variable name and iteration superstep. |
BroadcastVariableManager |
The BroadcastVariableManager is used to manage the materialization of broadcast variables.
|
BroadcastVariableMaterialization<T,C> |
This class represents a single materialization of a broadcast variable and maintains a reference count for it.
|
DefaultBroadcastVariableInitializer<T> |
The default
BroadcastVariableInitializer implementation that initializes the broadcast variable into a list. |
Exception | Description |
---|---|
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. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.