Uses of Class
org.apache.storm.bolt.JoinBolt
-
Uses of JoinBolt in org.apache.storm.bolt
Modifier 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)