Uses of Interface
org.apache.storm.streams.operations.Predicate
Package
Description
-
Uses of Predicate in org.apache.storm.sql.runtime.streams.functions
-
Uses of Predicate in org.apache.storm.streams
Modifier and TypeMethodDescriptionPairStream<K,
V>[] Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.Returns an array of streams by splitting the given stream into multiple branches based on the given predicates.PairStream<K,
V> Returns a stream consisting of the elements of this stream that matches the given filter.Returns a stream consisting of the elements of this stream that matches the given filter. -
Uses of Predicate in org.apache.storm.streams.processors
Modifier and TypeMethodDescriptionvoid
BranchProcessor.addPredicate
(Predicate<? super T> predicate, String stream)