Uses of Class
org.apache.storm.bolt.JoinBolt.JoinInfo
-
Uses of JoinBolt.JoinInfo in org.apache.storm.bolt
Modifier and TypeFieldDescriptionprotected LinkedHashMap<String,
JoinBolt.JoinInfo> JoinBolt.joinCriteria
Modifier and TypeMethodDescriptionprotected JoinBolt.JoinAccumulator
JoinBolt.doInnerJoin
(JoinBolt.JoinAccumulator probe, Map<Object, ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin) protected JoinBolt.JoinAccumulator
JoinBolt.doJoin
(JoinBolt.JoinAccumulator probe, HashMap<Object, ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin) protected JoinBolt.JoinAccumulator
JoinBolt.doLeftJoin
(JoinBolt.JoinAccumulator probe, Map<Object, ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin) ModifierConstructorDescriptionJoinInfo
(JoinBolt.FieldSelector field, String otherStream, JoinBolt.JoinInfo otherStreamJoinInfo, JoinBolt.JoinType joinType)