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