Object
org.apache.spark.status.SchedulerPool
public class SchedulerPool
extends Object
-
Constructor Summary
Constructors
-
Method Summary
long
scala.collection.immutable.Set<Object>
void
write(org.apache.spark.status.ElementTrackingStore store,
long now,
boolean checkTriggers)
-
Constructor Details
-
SchedulerPool
public SchedulerPool(String name)
-
Method Details
-
stageIds
public scala.collection.immutable.Set<Object> stageIds()
-
lastWriteTime
public long lastWriteTime()
-
write
public void write(org.apache.spark.status.ElementTrackingStore store,
long now,
boolean checkTriggers)