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

Class EvaluationFilter

java.lang.Object

org.apache.storm.trident.operation.BaseOperation

org.apache.storm.trident.operation.BaseFilter

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

All Implemented Interfaces:

Serializable, EachOperation, Filter, Operation

public class EvaluationFilter
extends BaseFilter

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EvaluationFilter(ExecutableExpression filterInstance, org.apache.calcite.DataContext dataContext)

Method Summary

Modifier and Type	Method and Description
boolean	isKeep(TridentTuple tuple) Determines if a tuple should be filtered out of a stream
void	prepare(Map conf, TridentOperationContext context) No-op implementation.

Methods inherited from class org.apache.storm.trident.operation.BaseOperation

cleanup

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup

Constructor Detail

EvaluationFilter

public EvaluationFilter(ExecutableExpression filterInstance,
                        org.apache.calcite.DataContext dataContext)

Method Detail

prepare

public void prepare(Map conf,
                    TridentOperationContext context)

Description copied from class: BaseOperation

No-op implementation.

Specified by:

prepare in interface Operation

Overrides:

prepare in class BaseOperation

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

isKeep

public boolean isKeep(TridentTuple tuple)

Description copied from interface: Filter

Determines if a tuple should be filtered out of a stream

Parameters:

tuple - the tuple being evaluated

Returns:

false to drop the tuple, true to keep the tuple