com.spotify.flo.contrib.bigquery

Class BigQueryOperator<T>

java.lang.Object

com.spotify.flo.contrib.bigquery.BigQueryOperator<T>

All Implemented Interfaces:

TaskContext<BigQueryOperation.Provider<T>,T>, TaskOperator<BigQueryOperation.Provider<T>,BigQueryOperation<T>,T>, Serializable

public class BigQueryOperator<T>
extends Object
implements TaskOperator<BigQueryOperation.Provider<T>,BigQueryOperation<T>,T>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.spotify.flo.TaskOperator

TaskOperator.Listener

Method Summary

Modifier and Type	Method and Description
static <T> BigQueryOperator<T>	create()
T	perform(BigQueryOperation<T> spec, TaskOperator.Listener listener)
BigQueryOperation.Provider<T>	provide(EvalContext evalContext) Creates a new instance of type T.

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

Method Detail

perform

public T perform(BigQueryOperation<T> spec,
                 TaskOperator.Listener listener)

Specified by:

perform in interface TaskOperator<BigQueryOperation.Provider<T>,BigQueryOperation<T>,T>

create

public static <T> BigQueryOperator<T> create()

provide

public BigQueryOperation.Provider<T> provide(EvalContext evalContext)

Description copied from interface: TaskContext

Creates a new instance of type T. The given EvalContext will be the evaluation context for the task. The task itself can be accessed through EvalContext.currentTask().

Specified by:

provide in interface TaskContext<BigQueryOperation.Provider<T>,T>

Parameters:

evalContext - The evaluation context in which the current task is being evaluated

Returns:

An instance of the provided task context type