Package io.streamthoughts.azkarra.runtime.context

Class DefaultStreamThreadExceptionHandlerFactory

java.lang.Object

io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory

All Implemented Interfaces:

Configurable, Supplier<StreamThreadExceptionHandler>

public class DefaultStreamThreadExceptionHandlerFactory
extends Object
implements Configurable, Supplier<StreamThreadExceptionHandler>

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER

Constructor Summary

Constructors

Constructor	Description
DefaultStreamThreadExceptionHandlerFactory()

Method Summary

Modifier and Type	Method	Description
void	configure(Conf configuration)	Configures this instance with the specified Conf.
StreamThreadExceptionHandler	get()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER

public static String DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER

Constructor Detail

DefaultStreamThreadExceptionHandlerFactory

public DefaultStreamThreadExceptionHandlerFactory()

Method Detail

configure

public void configure(Conf configuration)

Configures this instance with the specified Conf.

Specified by:

configure in interface Configurable

Parameters:

configuration - the Conf instance used to configure this instance.

get

public StreamThreadExceptionHandler get()

Specified by:

get in interface Supplier<StreamThreadExceptionHandler>