public class EnvironmentListener extends Object implements SparkListener
Constructor and Description |
---|
EnvironmentListener() |
Modifier and Type | Method and Description |
---|---|
scala.collection.Seq<scala.Tuple2<String,String>> |
classpathEntries() |
scala.collection.Seq<scala.Tuple2<String,String>> |
jvmInformation() |
void |
onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
Called when environment properties have been updated
|
scala.collection.Seq<scala.Tuple2<String,String>> |
sparkProperties() |
scala.collection.Seq<scala.Tuple2<String,String>> |
systemProperties() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onApplicationEnd, onApplicationStart, onBlockManagerAdded, onBlockManagerRemoved, onExecutorMetricsUpdate, onJobEnd, onJobStart, onStageCompleted, onStageSubmitted, onTaskEnd, onTaskGettingResult, onTaskStart, onUnpersistRDD
public scala.collection.Seq<scala.Tuple2<String,String>> jvmInformation()
public scala.collection.Seq<scala.Tuple2<String,String>> sparkProperties()
public scala.collection.Seq<scala.Tuple2<String,String>> systemProperties()
public scala.collection.Seq<scala.Tuple2<String,String>> classpathEntries()
public void onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
SparkListener
onEnvironmentUpdate
in interface SparkListener