T
- The type of the elements in the broadcast data set.public class BroadcastVariableMaterialization<T,C> extends Object
Constructor and Description |
---|
BroadcastVariableMaterialization(BroadcastVariableKey key) |
Modifier and Type | Method and Description |
---|---|
boolean |
decrementReference(BatchTask<?,?> referenceHolder) |
boolean |
decrementReferenceIfHeld(BatchTask<?,?> referenceHolder) |
List<T> |
getVariable() |
C |
getVariable(BroadcastVariableInitializer<T,C> initializer) |
void |
materializeVariable(MutableReader<?> reader,
TypeSerializerFactory<?> serializerFactory,
BatchTask<?,?> referenceHolder) |
public BroadcastVariableMaterialization(BroadcastVariableKey key)
public void materializeVariable(MutableReader<?> reader, TypeSerializerFactory<?> serializerFactory, BatchTask<?,?> referenceHolder) throws MaterializationExpiredException, IOException
public boolean decrementReference(BatchTask<?,?> referenceHolder)
public boolean decrementReferenceIfHeld(BatchTask<?,?> referenceHolder)
public List<T> getVariable() throws InitializationTypeConflictException
public C getVariable(BroadcastVariableInitializer<T,C> initializer)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.