com.spotify.flo

Class TaskOutput<T,S>

java.lang.Object

com.spotify.flo.TaskOutput<T,S>

All Implemented Interfaces:

TaskContext<T,S>, Serializable

Direct Known Subclasses:

BigQueryOutput

public abstract class TaskOutput<T,S>
extends Object
implements TaskContext<T,S>

An external output produced by a Task. If the output already exists, then the existing value is used and the task is not evaluated.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskOutput()

Method Summary

Modifier and Type	Method and Description
Optional<S>	lookup(Task<S> task) Perform a lookup of the value this task would have produced if it ran.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.spotify.flo.TaskContext

onFail, onSuccess, preRun, provide

Constructor Detail

TaskOutput

public TaskOutput()

Method Detail

lookup

public Optional<S> lookup(Task<S> task)

Perform a lookup of the value this task would have produced if it ran. Override to be able to short-circuit a task with a previously calculated value.

Parameters:

task - a task with a TaskOutput to lookup a value for

Returns:

the value for this TaskOutput (e.g. from a previous run)