Uses of Interface
org.apache.storm.streams.operations.Predicate

Packages that use Predicate

Package	Description
org.apache.storm.sql.runtime.streams.functions
org.apache.storm.streams
org.apache.storm.streams.processors

Uses of Predicate in org.apache.storm.sql.runtime.streams.functions

Classes in org.apache.storm.sql.runtime.streams.functions that implement Predicate

Modifier and Type	Class and Description
class	EvaluationFilter

Uses of Predicate in org.apache.storm.streams

Methods in org.apache.storm.streams with parameters of type Predicate

Modifier and Type	Method and Description
PairStream<K,V>[]	PairStream.branch(Predicate<? super Pair<K,V>>... predicates) Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.
Stream<T>[]	Stream.branch(Predicate<? super T>... predicates) Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.
PairStream<K,V>	PairStream.filter(Predicate<? super Pair<K,V>> predicate) Returns a stream consisting of the elements of this stream that matches the given filter.
Stream<T>	Stream.filter(Predicate<? super T> predicate) Returns a stream consisting of the elements of this stream that matches the given filter.

Uses of Predicate in org.apache.storm.streams.processors

Methods in org.apache.storm.streams.processors with parameters of type Predicate

Modifier and Type	Method and Description
void	BranchProcessor.addPredicate(Predicate<? super T> predicate, String stream)

Constructors in org.apache.storm.streams.processors with parameters of type Predicate

Constructor and Description
FilterProcessor(Predicate<T> predicate)