org.apache.storm.sql.runtime.trident.functions

Class EvaluationCalc

java.lang.Object

org.apache.storm.sql.runtime.trident.functions.EvaluationCalc

All Implemented Interfaces:

Serializable, FlatMapFunction, Operation, OperationAwareFlatMapFunction

public class EvaluationCalc
extends Object
implements OperationAwareFlatMapFunction

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EvaluationCalc(ExecutableExpression filterInstance, ExecutableExpression projectionInstance, int outputCount, org.apache.calcite.DataContext dataContext)

Method Summary

Modifier and Type	Method and Description
void	cleanup() When running in local mode, called when the local cluster is being shut down.
Iterable<Values>	execute(TridentTuple input) Invoked by the framework for each trident tuple in a stream.
void	prepare(Map conf, TridentOperationContext context) Called when the Operation is first initialized.

Methods inherited from class java.lang.Object

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

Constructor Detail

EvaluationCalc

public EvaluationCalc(ExecutableExpression filterInstance,
                      ExecutableExpression projectionInstance,
                      int outputCount,
                      org.apache.calcite.DataContext dataContext)

Method Detail

prepare

public void prepare(Map conf,
                    TridentOperationContext context)

Description copied from interface: Operation

Called when the Operation is first initialized.

Specified by:

prepare in interface Operation

Parameters:

conf - the Storm configuration map

context - the operation context which provides information such as the number of partitions in the stream, and the current partition index. It also provides methods for registering operation-specific metrics.

See Also:

TridentOperationContext

cleanup

public void cleanup()

Description copied from interface: Operation

When running in local mode, called when the local cluster is being shut down.

Specified by:

cleanup in interface Operation

execute

public Iterable<Values> execute(TridentTuple input)

Description copied from interface: FlatMapFunction

Invoked by the framework for each trident tuple in a stream.

Specified by:

execute in interface FlatMapFunction

Parameters:

input - the input trident tuple

Returns:

an iterable over the resultant values