public interface Filter extends EachOperation
Filters take in a tuple as input and decide whether or not to keep that tuple or not.
isKeep() method of a Filter returns
false for a tuple, that tuple will be filtered out of the Stream
Filter implementation has configuration requirements, you will typically want to extend
BaseFilter and override the
Operation.prepare(Map, TridentOperationContext) method to perform your custom initialization.
boolean isKeep(TridentTuple tuple)
Determines if a tuple should be filtered out of a stream
tuple- the tuple being evaluated
falseto drop the tuple,
trueto keep the tuple
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.