Uses of Class
org.apache.storm.bolt.JoinBolt
Packages that use JoinBolt
-
Uses of JoinBolt in org.apache.storm.bolt
Methods in org.apache.storm.bolt that return JoinBoltModifier and TypeMethodDescriptionPerforms inner Join with the newStream.Performs left Join with the newStream.Specify projection fields. i.e.JoinBolt.withLateTupleStream
(String streamId) JoinBolt.withOutputStream
(String streamName) Optional.JoinBolt.withTimestampExtractor
(TimestampExtractor timestampExtractor) JoinBolt.withTimestampField
(String fieldName) JoinBolt.withTumblingWindow
(BaseWindowedBolt.Count count) JoinBolt.withTumblingWindow
(BaseWindowedBolt.Duration duration) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Count slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Count windowLength, BaseWindowedBolt.Duration slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Count slidingInterval) JoinBolt.withWindow
(BaseWindowedBolt.Duration windowLength, BaseWindowedBolt.Duration slidingInterval)