Package org.apache.spark.sql.pipelines.graph

Class UncaughtExceptionHandler

Object

org.apache.spark.sql.pipelines.graph.UncaughtExceptionHandler

All Implemented Interfaces:

Thread.UncaughtExceptionHandler

public class UncaughtExceptionHandler
extends Object
implements Thread.UncaughtExceptionHandler

Uncaught exception handler which first calls the delegate and then calls the OnFailure function with the uncaught exception.

Constructor Summary

Constructors

Constructor	Description
UncaughtExceptionHandler(scala.Option<Thread.UncaughtExceptionHandler> delegate, scala.Function1<Throwable,scala.runtime.BoxedUnit> onFailure)

Method Summary

Modifier and Type	Method	Description
static void	addHandler(Thread thread, scala.Function1<Throwable,scala.runtime.BoxedUnit> onFailure)	Sets a handler which calls 'onFailure' function with the uncaught exception.
void	uncaughtException(Thread t, Throwable e)

Methods inherited from class java.lang.Object

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

Constructor Details

UncaughtExceptionHandler

public UncaughtExceptionHandler(scala.Option<Thread.UncaughtExceptionHandler> delegate,
 scala.Function1<Throwable,scala.runtime.BoxedUnit> onFailure)

Method Details

addHandler

public static void addHandler(Thread thread,
 scala.Function1<Throwable,scala.runtime.BoxedUnit> onFailure)

Sets a handler which calls 'onFailure' function with the uncaught exception. If the thread already has a uncaught exception handler, it will be called first before calling the 'onFailure' function.

Parameters:

thread - (undocumented)

onFailure - (undocumented)

uncaughtException

public void uncaughtException(Thread t,
 Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler