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–2021 The Apache Software Foundation. All rights reserved.