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