Package org.apache.flink.runtime.entrypoint

Class DeterminismEnvelope<T>

java.lang.Object

org.apache.flink.runtime.entrypoint.DeterminismEnvelope<T>

Type Parameters:

T - type of the wrapped value

public class DeterminismEnvelope<T>
extends Object

Envelope that carries whether the wrapped value is deterministic or not.

Method Summary

Modifier and Type	Method	Description
static <T> DeterminismEnvelope<T>	deterministicValue(T value)
boolean	isDeterministic()
<V,E extends Exception> DeterminismEnvelope<V>	map(FunctionWithException<? super T,? extends V,E> mapper)
static <T> DeterminismEnvelope<T>	nondeterministicValue(T value)
String	toString()
T	unwrap()

Methods inherited from class java.lang.Object

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

Method Detail

isDeterministic

public boolean isDeterministic()

unwrap

public T unwrap()

map

public <V,E extends Exception> DeterminismEnvelope<V> map(FunctionWithException<? super T,? extends V,E> mapper)
                                                         throws E extends Exception

Throws:

E extends Exception

deterministicValue

public static <T> DeterminismEnvelope<T> deterministicValue(T value)

nondeterministicValue

public static <T> DeterminismEnvelope<T> nondeterministicValue(T value)

toString

public String toString()

Overrides:

toString in class Object