org.apache.spark.sql.util

Class ExecutionListenerManager

Object

org.apache.spark.sql.util.ExecutionListenerManager

All Implemented Interfaces:

Logging

public class ExecutionListenerManager
extends Object
implements Logging

:: Experimental ::

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

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all the registered QueryExecutionListener.
ExecutionListenerManager	clone() Get an identical copy of this listener manager.
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

initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Method Detail

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)

clear

public void clear()

Removes all the registered QueryExecutionListener.

clone

public ExecutionListenerManager clone()

Get an identical copy of this listener manager.

Overrides:

clone in class Object

Returns:

(undocumented)