org.apache.spark.sql.util

Class ExecutionListenerManager

Object

org.apache.spark.sql.util.ExecutionListenerManager

All Implemented Interfaces:

org.apache.spark.internal.Logging

public class ExecutionListenerManager
extends Object
implements org.apache.spark.internal.Logging

Manager for QueryExecutionListener. See org.apache.spark.sql.SQLContext.listenerManager.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

org.apache.spark.internal.Logging.SparkShellLoggingFilter

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all the registered QueryExecutionListener.
void	register(QueryExecutionListener listener) Registers the specified QueryExecutionListener.
void	unregister(QueryExecutionListener listener) Unregisters the specified QueryExecutionListener.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.internal.Logging

$init$, initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, initLock, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning, org$apache$spark$internal$Logging$$log__$eq, org$apache$spark$internal$Logging$$log_, uninitialize

Method Detail

clear

public void clear()

Removes all the registered QueryExecutionListener.

register

public void register(QueryExecutionListener listener)

Registers the specified QueryExecutionListener.

Parameters:

listener - (undocumented)

unregister

public void unregister(QueryExecutionListener listener)

Unregisters the specified QueryExecutionListener.

Parameters:

listener - (undocumented)