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	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	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	Description
void	BranchProcessor.addPredicate(Predicate<? super T> predicate, String stream)

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

Modifier	Constructor	Description
	FilterProcessor(Predicate<T> predicate)