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() |
long |
getNonPartitionedBroadcastSize() |
PartitionedBroadcast |
getPartitionedBroadcast() |
long |
getPartitionedBroadcastSize() |
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, setBackReference
public 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 getPartitionedBroadcastSize()
public long getNonPartitionedBroadcastSize()
public boolean isPartitionedBroadcastValid()
public boolean isNonPartitionedBroadcastValid()
Copyright © 2020 The Apache Software Foundation. All rights reserved.