com.cloudera.oryx.common.lang

Class LoggingCallable<V>

java.lang.Object

com.cloudera.oryx.common.lang.LoggingCallable<V>

Type Parameters:

V - result type

All Implemented Interfaces:

Callable<V>

public final class LoggingCallable<V>
extends Object
implements Callable<V>

A Callable that logs errors thrown from call(). Useful in cases where it would otherwise silently disappear into an executor. Static factory methods can create a Callable from most any lambda expression.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	LoggingCallable.AllowExceptionSupplier Like Supplier but allows Exception from Supplier.get().

Method Summary

Modifier and Type	Method and Description
Runnable	asRunnable()
V	call()
static <V> LoggingCallable<V>	log(Callable<V> delegate)
static LoggingCallable<Void>	log(LoggingCallable.AllowExceptionSupplier delegate)

Methods inherited from class java.lang.Object

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

Method Detail

log

public static <V> LoggingCallable<V> log(Callable<V> delegate)

log

public static LoggingCallable<Void> log(LoggingCallable.AllowExceptionSupplier delegate)

call

public V call()
       throws Exception

Specified by:

call in interface Callable<V>

Throws:

Exception

asRunnable

public Runnable asRunnable()