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 classEvaluationFilter -
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 voidBranchProcessor. addPredicate(Predicate<? super T> predicate, String stream)Constructors in org.apache.storm.streams.processors with parameters of type Predicate Constructor Description FilterProcessor(Predicate<T> predicate)
-