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, 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)
onEnvironmentUpdate
in class SparkListener
environmentUpdate
- (undocumented)