public class ApplicationEventListener extends Object implements SparkListener
This listener expects to hear events from a single application only. If events from multiple applications are seen, the behavior is unspecified.
Constructor and Description |
---|
ApplicationEventListener() |
Modifier and Type | Method and Description |
---|---|
scala.Option<String> |
adminAcls() |
scala.Option<String> |
appId() |
scala.Option<String> |
appName() |
scala.Option<Object> |
endTime() |
void |
onApplicationEnd(SparkListenerApplicationEnd applicationEnd)
Called when the application ends
|
void |
onApplicationStart(SparkListenerApplicationStart applicationStart)
Called when the application starts
|
void |
onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
Called when environment properties have been updated
|
scala.Option<String> |
sparkUser() |
scala.Option<Object> |
startTime() |
scala.Option<String> |
viewAcls() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onBlockManagerAdded, onBlockManagerRemoved, onExecutorAdded, onExecutorMetricsUpdate, onExecutorRemoved, onJobEnd, onJobStart, onStageCompleted, onStageSubmitted, onTaskEnd, onTaskGettingResult, onTaskStart, onUnpersistRDD
public scala.Option<String> appName()
public scala.Option<String> appId()
public scala.Option<String> sparkUser()
public scala.Option<Object> startTime()
public scala.Option<Object> endTime()
public scala.Option<String> viewAcls()
public scala.Option<String> adminAcls()
public void onApplicationStart(SparkListenerApplicationStart applicationStart)
SparkListener
onApplicationStart
in interface SparkListener
public void onApplicationEnd(SparkListenerApplicationEnd applicationEnd)
SparkListener
onApplicationEnd
in interface SparkListener
public void onEnvironmentUpdate(SparkListenerEnvironmentUpdate environmentUpdate)
SparkListener
onEnvironmentUpdate
in interface SparkListener