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
### Configuration If your
Filter implementation has configuration requirements, you will typically want to extend
BaseFilter and override the
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 © 2021 The Apache Software Foundation. All rights reserved.