Package | Description |
---|---|
com.spotify.flo | |
com.spotify.flo.context | |
com.spotify.flo.freezer |
Modifier and Type | Method and Description |
---|---|
default <T> EvalContext.Value<T> |
EvalContext.evaluate(Task<T> task)
The entry point for evaluating a
EvalContext.Value from a Task . |
default <T> EvalContext.Value<T> |
EvalContext.evaluateInternal(Task<T> task,
EvalContext context)
A variant of
EvalContext.evaluate(Task) that allows the caller to specify the EvalContext
that should be used within the graph during evaluation. |
<U> EvalContext.Value<U> |
EvalContext.Value.flatMap(Function<? super T,? extends EvalContext.Value<? extends U>> fn)
Map the enclosed value through a function that return another
EvalContext.Value . |
EvalContext.Value<?> |
ProcessFnArg.get(EvalContext ec) |
default <T> EvalContext.Value<T> |
EvalContext.immediateValue(T value)
Create a
EvalContext.Value with semantics defined by this EvalContext |
default <T> EvalContext.Value<T> |
EvalContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn)
Invoke the process function of a task.
|
default <U> EvalContext.Value<U> |
EvalContext.Value.map(Function<? super T,? extends U> fn)
Map the enclosed value through a function and return a
EvalContext.Value enclosing that result. |
static <T,U,V> EvalContext.Value<V> |
Values.mapBoth(EvalContext context,
EvalContext.Value<T> first,
EvalContext.Value<U> second,
BiFunction<? super T,? super U,? extends V> fn)
Maps a function over two
EvalContext.Value s returning a new EvalContext.Value of the result which
only becomes available when both inputs have completed. |
EvalContext.Value<T> |
EvalContext.Promise.value()
The value for this promise.
|
<T> EvalContext.Value<T> |
EvalContext.value(Fn<T> value)
Create a
EvalContext.Value with semantics defined by this EvalContext |
Modifier and Type | Method and Description |
---|---|
static <T> Collector<EvalContext.Value<T>,?,EvalContext.Value<List<T>>> |
Values.toValueList(EvalContext context)
|
static <T> Collector<EvalContext.Value<T>,?,EvalContext.Value<List<T>>> |
Values.toValueList(EvalContext context)
|
Modifier and Type | Method and Description |
---|---|
static <T,U,V> EvalContext.Value<V> |
Values.mapBoth(EvalContext context,
EvalContext.Value<T> first,
EvalContext.Value<U> second,
BiFunction<? super T,? super U,? extends V> fn)
Maps a function over two
EvalContext.Value s returning a new EvalContext.Value of the result which
only becomes available when both inputs have completed. |
static <T,U,V> EvalContext.Value<V> |
Values.mapBoth(EvalContext context,
EvalContext.Value<T> first,
EvalContext.Value<U> second,
BiFunction<? super T,? super U,? extends V> fn)
Maps a function over two
EvalContext.Value s returning a new EvalContext.Value of the result which
only becomes available when both inputs have completed. |
Modifier and Type | Method and Description |
---|---|
<U> EvalContext.Value<U> |
EvalContext.Value.flatMap(Function<? super T,? extends EvalContext.Value<? extends U>> fn)
Map the enclosed value through a function that return another
EvalContext.Value . |
Modifier and Type | Method and Description |
---|---|
<T> EvalContext.Value<T> |
OverridingContext.evaluateInternal(Task<T> task,
EvalContext context) |
<T> EvalContext.Value<T> |
ForwardingEvalContext.evaluateInternal(Task<T> task,
EvalContext context) |
<T> EvalContext.Value<T> |
MemoizingContext.evaluateInternal(Task<T> task,
EvalContext context) |
<T> EvalContext.Value<T> |
InstrumentedContext.evaluateInternal(Task<T> task,
EvalContext context) |
<T> EvalContext.Value<T> |
AsyncContext.evaluateInternal(Task<T> task,
EvalContext context) |
<T> EvalContext.Value<T> |
ForwardingEvalContext.immediateValue(T value) |
<T> EvalContext.Value<T> |
AsyncContext.immediateValue(T t) |
<T> EvalContext.Value<T> |
TracingContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn) |
<T> EvalContext.Value<T> |
ForwardingEvalContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn) |
<T> EvalContext.Value<T> |
InstrumentedContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn) |
<T> EvalContext.Value<T> |
ForwardingEvalContext.value(Fn<T> value) |
<T> EvalContext.Value<T> |
AsyncContext.value(Fn<T> t) |
<T> EvalContext.Value<T> |
SyncContext.value(Fn<T> value) |
Modifier and Type | Method and Description |
---|---|
<T> EvalContext.Value<T> |
PersistingContext.evaluateInternal(Task<T> task,
EvalContext context) |
<T> EvalContext.Value<T> |
EvaluatingContext.evaluateTaskFrom(Path persistedTask)
Evaluate a persisted task, expecting it's input values to exist as "_out" files in the same
directory.
|
<T> EvalContext.Value<T> |
PersistingContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn) |
Copyright © 2020. All rights reserved.