Package | Description |
---|---|
com.spotify.flo | |
com.spotify.flo.context | |
com.spotify.flo.freezer |
Modifier and Type | Method and Description |
---|---|
static TaskId |
TaskId.create(String name,
Object... args)
Creates a
TaskId . |
static TaskId |
Tracing.currentTaskId() |
abstract TaskId |
TaskInfo.id() |
abstract TaskId |
Task.id() |
static TaskId |
TaskId.parse(String stringId)
Parses a
TaskId based on a string representation. |
Modifier and Type | Method and Description |
---|---|
static TaskInfo |
TaskInfo.create(TaskId id,
List<TaskInfo> upstreams) |
default <T> EvalContext.Value<T> |
EvalContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn)
Invoke the process function of a task.
|
void |
TaskOperator.Listener.meta(TaskId task,
Map<String,String> data)
Called to report some piece of task metadata.
|
static TaskInfo |
TaskInfo.ref(TaskId id) |
static <T> Fn<T> |
Tracing.trace(TaskId taskId,
Fn<T> fn) |
Modifier and Type | Method and Description |
---|---|
static TaskInfo |
TaskInfo.ofTask(Task<?> task,
Set<TaskId> visits) |
Modifier and Type | Method and Description |
---|---|
<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) |
default void |
InstrumentedContext.Listener.meta(TaskId task,
Map<String,String> data)
Called to report some piece of task metadata.
|
void |
InstrumentedContext.Listener.status(TaskId task,
InstrumentedContext.Listener.Phase phase)
Called when a task starts and finished it's evaluation.
|
Modifier and Type | Method and Description |
---|---|
Map<TaskId,Path> |
PersistingContext.getFiles() |
Modifier and Type | Method and Description |
---|---|
<T> EvalContext.Value<T> |
PersistingContext.invokeProcessFn(TaskId taskId,
Fn<T> processFn) |
void |
LoggingListener.status(TaskId task,
InstrumentedContext.Listener.Phase phase) |
Copyright © 2020. All rights reserved.