EvalContext that executes all evaluation on the given
Executor.Consumer that allows for synchronously waiting for the value to arrive.BigQueryOperator.TableResultEvalContext that created this value.TaskId.Task
currently being processed.Task evaluation and EvalContext.Value computation.EvalContext.Value that is supposed to be EvalContext.Promise.set(Object).EvalContext.Value from a Task.EvalContext.evaluate(Task) that allows the caller to specify the EvalContext
that should be used within the graph during evaluation.EvalContext.Value.InstrumentedContext.Listener.Tasks.EvalContext that forwards calls.EvalContext.Value with semantics defined by this EvalContextEvalContext that instruments the task expansion and invocation process.InstrumentedContext.Listener that prints to an slf4j Logger.EvalContext.Value enclosing that result.EvalContext.Values returning a new EvalContext.Value of the result which
only becomes available when both inputs have completed.EvalContext that memoizes the results of task evaluations and
ensures that tasks are only evaluated once.BigQueryMocking instance to be used for mocking bigquery tables and checking
tables outputed by a task output.TaskBuilder api which only holds the task name.EvalContext that may return a value without calling the processFn or evaluating its
dependencies.TaskId based on a string representation.EvalContext.Value that is created by
PersistingContext.EvalContext that serializes and persist tasks.T.FloRunner.Result containing the last value or throwable.FloRunner.Result containing the last value or throwable.Serialization.serialize(java.lang.Object, java.nio.file.Path) and Serialization.deserialize(java.nio.file.Path)
if serialization or deserialization fails.Encoder that emits log messages decorated with Styx and Flo metadata.EvalContext.EvalContext that evaluates tasks immediately.Task is discovered.Task.named(String, Object...)}.TaskContext that does not have requirements on the
type of the value returned by the task.Task.Task.EvaluatingContext for evaluating a specific task which has
been persisted by PersistingContext.Future.get()EvalContext.Value with semantics defined by this EvalContextEvalContext.Value.System.exit() exits
with an appropriate status code.Copyright © 2020. All rights reserved.