Method join

storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:89–91

Performs inner Join with the newStream. SQL: from priorStream inner join newStream on newStream.field = priorStream.field1 same as: new WindowedQueryBolt(priorStream,field1). join(newStream, field, priorStream); Note: priorStream must be previously joined. Valid ex: n

(String newStream, String field, String priorStream)

     * @param field     the field on which to perform the join
     */
    public JoinBolt join(String newStream, String field, String priorStream) {
        return joinCommon(newStream, field, priorStream, JoinType.INNER);
    }

    /**
     * Performs left Join with the newStream. SQL    :   from stream1  left join stream2  on stream2.field = stream1.field1 same as:   new