Package | Description |
---|---|
com.spotify.flo | |
com.spotify.flo.context | |
com.spotify.flo.contrib.bigquery | |
com.spotify.flo.freezer |
Modifier and Type | Class and Description |
---|---|
class |
EvalContextWithTask
|
Modifier and Type | Method and Description |
---|---|
static EvalContext |
EvalContext.async(Executor executor)
Create an asynchronous
EvalContext that executes all evaluation on the given
Executor . |
EvalContext |
EvalContext.Value.context()
The
EvalContext that created this value. |
static EvalContext |
EvalContext.sync()
Create a default, synchronous
EvalContext . |
Modifier and Type | Method and Description |
---|---|
default <T> EvalContext.Value<T> |
EvalContext.evaluateInternal(Task<T> task,
EvalContext context)
A variant of
evaluate(Task) that allows the caller to specify the EvalContext
that should be used within the graph during evaluation. |
EvalContext.Value<?> |
ProcessFnArg.get(EvalContext ec) |
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. |
T |
TaskContext.provide(EvalContext evalContext)
Creates a new instance of type
T . |
static <T> Collector<EvalContext.Value<T>,?,EvalContext.Value<List<T>>> |
Values.toValueList(EvalContext context)
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncContext
|
class |
ForwardingEvalContext
A
EvalContext that forwards calls. |
class |
InstrumentedContext
A
EvalContext that instruments the task expansion and invocation process. |
class |
MemoizingContext
A flo
EvalContext that memoizes the results of task evaluations and
ensures that tasks are only evaluated once. |
class |
OverridingContext
An
EvalContext that may return a value without calling the processFn or evaluating its
dependencies. |
class |
SyncContext
A
EvalContext that evaluates tasks immediately. |
class |
TracingContext
|
Modifier and Type | Field and Description |
---|---|
protected EvalContext |
ForwardingEvalContext.delegate |
Modifier and Type | Method and Description |
---|---|
static EvalContext |
TracingContext.composeWith(EvalContext baseContext) |
static EvalContext |
MemoizingContext.composeWith(EvalContext baseContext) |
static EvalContext |
InstrumentedContext.composeWith(EvalContext baseContext,
InstrumentedContext.Listener listener) |
static EvalContext |
OverridingContext.composeWith(EvalContext baseContext,
com.spotify.flo.context.Logging logging) |
static EvalContext |
SyncContext.create() |
static EvalContext |
AsyncContext.create(Executor executor) |
Modifier and Type | Method and Description |
---|---|
static EvalContext |
TracingContext.composeWith(EvalContext baseContext) |
static EvalContext |
MemoizingContext.composeWith(EvalContext baseContext) |
static EvalContext |
InstrumentedContext.composeWith(EvalContext baseContext,
InstrumentedContext.Listener listener) |
static EvalContext |
OverridingContext.composeWith(EvalContext baseContext,
com.spotify.flo.context.Logging logging) |
<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) |
Constructor and Description |
---|
ForwardingEvalContext(EvalContext delegate) |
Modifier and Type | Method and Description |
---|---|
StagingTableId |
BigQueryOutput.provide(EvalContext evalContext) |
BigQueryOperation.Provider<T> |
BigQueryOperator.provide(EvalContext evalContext) |
Modifier and Type | Class and Description |
---|---|
class |
PersistingContext
A
EvalContext that serializes and persist tasks. |
Modifier and Type | Method and Description |
---|---|
<T> EvalContext.Value<T> |
PersistingContext.evaluateInternal(Task<T> task,
EvalContext context) |
Constructor and Description |
---|
EvaluatingContext(Path basePath,
EvalContext delegate) |
PersistingContext(Path basePath,
EvalContext delegate) |
Copyright © 2020. All rights reserved.