public class BroadcastObject<T extends CacheBlock> extends LineageObject
| Constructor and Description | 
|---|
BroadcastObject()  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.spark.broadcast.Broadcast<T> | 
getNonPartitionedBroadcast()  | 
PartitionedBroadcast | 
getPartitionedBroadcast()  | 
long | 
getSize()  | 
boolean | 
isNonPartitionedBroadcastValid()  | 
boolean | 
isPartitionedBroadcastValid()  | 
void | 
setNonPartitionedBroadcast(org.apache.spark.broadcast.Broadcast<T> bvar,
                          long size)  | 
void | 
setPartitionedBroadcast(PartitionedBroadcast<T> bvar,
                       long size)  | 
addLineageChild, decrementNumReferences, getLineageChilds, getNumReferences, hasBackReference, incrementNumReferences, setBackReferencepublic void setNonPartitionedBroadcast(org.apache.spark.broadcast.Broadcast<T> bvar, long size)
public void setPartitionedBroadcast(PartitionedBroadcast<T> bvar, long size)
public PartitionedBroadcast getPartitionedBroadcast()
public org.apache.spark.broadcast.Broadcast<T> getNonPartitionedBroadcast()
public long getSize()
public boolean isPartitionedBroadcastValid()
public boolean isNonPartitionedBroadcastValid()
Copyright © 2021 The Apache Software Foundation. All rights reserved.