com.spotify.flo

Interface TaskOperator<ContextT,SpecT,ResultT>

All Superinterfaces:

Serializable, TaskContext<ContextT,ResultT>

All Known Implementing Classes:

BigQueryOperator

public interface TaskOperator<ContextT,SpecT,ResultT>
extends TaskContext<ContextT,ResultT>

An operator controls the execution of a job for a task, e.g. a data processing job on some processing platform.

The concrete operator implementation should TaskContext.provide(EvalContext) the task with some means of constructing an operation description. The operation description should be returned from the process fn.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	TaskOperator.Listener

Method Summary

Modifier and Type	Method and Description
ResultT	perform(SpecT spec, TaskOperator.Listener listener)

Methods inherited from interface com.spotify.flo.TaskContext

onFail, onSuccess, preRun, provide

Method Detail

perform

ResultT perform(SpecT spec,
                TaskOperator.Listener listener)