public class EnvironmentListener extends 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() |
onApplicationEnd, onApplicationStart, onBlockManagerAdded, onBlockManagerRemoved, onBlockUpdated, onExecutorAdded, onExecutorMetricsUpdate, onExecutorRemoved, onJobEnd, onJobStart, onOtherEvent, onStageCompleted, onStageSubmitted, onTaskEnd, onTaskGettingResult, onTaskStart, onUnpersistRDDpublic 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)
onEnvironmentUpdate in class SparkListenerenvironmentUpdate - (undocumented)