OptionalFailure (Flink : 2.0-preview1 API)

java.lang.Object
- org.apache.flink.util.OptionalFailure<T>

All Implemented Interfaces:

Serializable
```
public class OptionalFailure<T>
extends Object
implements Serializable
```
Wrapper around an object representing either a success (with a given value) or a failure cause.

See Also:

Serialized Form

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static <T> OptionalFailure<T>`	`createFrom(CheckedSupplier<T> valueSupplier)`
`boolean`	`equals(Object obj)`
`T`	`get()`
`Throwable`	`getFailureCause()`
`T`	`getUnchecked()`
`int`	`hashCode()`
`boolean`	`isFailure()`
`static <T> OptionalFailure<T>`	`of(T value)`
`static <T> OptionalFailure<T>`	`ofFailure(Throwable failureCause)`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

of

public static <T> OptionalFailure<T> of(T value)

ofFailure

public static <T> OptionalFailure<T> ofFailure(Throwable failureCause)

createFrom
```
public static <T> OptionalFailure<T> createFrom(CheckedSupplier<T> valueSupplier)
```
Returns:

wrapped OptionalFailure returned by valueSupplier or wrapped failure if valueSupplier has thrown an Exception.

get
```
public T get()
      throws FlinkException
```
Returns:

stored value or throw a FlinkException with failureCause.

Throws:

FlinkException

getUnchecked
```
public T getUnchecked()
               throws FlinkRuntimeException
```
Returns:

same as get() but throws a FlinkRuntimeException.

Throws:

FlinkRuntimeException

getFailureCause
```
public Throwable getFailureCause()
```

isFailure
```
public boolean isFailure()
```

hashCode
```
public int hashCode()
```
Overrides:

hashCode in class Object

equals
```
public boolean equals(Object obj)
```
Overrides:

equals in class Object

toString
```
public String toString()
```
Overrides:

toString in class Object