Class OuterHashJoinStream

  • All Implemented Interfaces:
    Closeable, Serializable, AutoCloseable, Expressible, MapSerializable, MapWriter, NavigableObject

    public class OuterHashJoinStream
    extends HashJoinStream
    implements Expressible
    Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream. The difference in a OuterHashJoinStream is that the tuples in the hashStream will all be read and hashed when this stream is opened. This provides a few optimizations iff the hashStream has a relatively small number of documents. The difference between this and a HashJoinStream is that a tuple in the fullStream will be returned even if it doesn't have any matching tuples in the hashStream. You are expected to provide a set of fields for which the hash will be calculated from. If a tuple from the hashStream does not contain a value (ie, null) for one of the fields the hash is being computed on then that tuple will not be considered a match to anything. If a tuple from the fullStream does not contain a value (ie, null) for one of the fields the hash is being computed on then that tuple will be returned without any joined tuples from the hashStream
    Since:
    6.0.0
    See Also:
    Serialized Form