public class StorageListener
extends org.apache.spark.storage.BlockStatusListener
This class is thread-safe (unlike JobProgressListener)
Constructor and Description |
---|
StorageListener(StorageStatusListener storageStatusListener)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<StorageStatus> |
activeStorageStatusList()
Deprecated.
|
void |
onBlockUpdated(SparkListenerBlockUpdated blockUpdated)
Deprecated.
|
void |
onStageCompleted(SparkListenerStageCompleted stageCompleted)
Deprecated.
|
void |
onStageSubmitted(SparkListenerStageSubmitted stageSubmitted)
Deprecated.
|
void |
onUnpersistRDD(SparkListenerUnpersistRDD unpersistRDD)
Deprecated.
|
scala.collection.Seq<RDDInfo> |
rddInfoList()
Deprecated.
Filter RDD info to include only those with cached partitions
|
public StorageListener(StorageStatusListener storageStatusListener)
public scala.collection.Seq<StorageStatus> activeStorageStatusList()
public scala.collection.Seq<RDDInfo> rddInfoList()
public void onStageSubmitted(SparkListenerStageSubmitted stageSubmitted)
public void onStageCompleted(SparkListenerStageCompleted stageCompleted)
public void onUnpersistRDD(SparkListenerUnpersistRDD unpersistRDD)
public void onBlockUpdated(SparkListenerBlockUpdated blockUpdated)