Package org.apache.solr.client.solrj.io.stream

Class InnerJoinStream

java.lang.Object

org.apache.solr.client.solrj.io.stream.TupleStream

org.apache.solr.client.solrj.io.stream.JoinStream

org.apache.solr.client.solrj.io.stream.BiJoinStream

org.apache.solr.client.solrj.io.stream.InnerJoinStream

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Expressible, org.apache.solr.common.MapSerializable, org.apache.solr.common.MapWriter, org.apache.solr.common.NavigableObject, org.noggit.JSONWriter.Writable

public class InnerJoinStream
extends BiJoinStream
implements Expressible

Joins leftStream with rightStream based on an Equalitor. Both streams must be sorted by the fields being joined on. Resulting stream is sorted by the equalitor.

Since:

6.0.0

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.client.solrj.io.stream.TupleStream

TupleStream.IgnoreException

Nested classes/interfaces inherited from interface org.apache.solr.common.MapWriter

org.apache.solr.common.MapWriter.EntryWriter

Field Summary

Fields inherited from class org.apache.solr.client.solrj.io.stream.BiJoinStream

iterationComparator, leftStream, leftStreamComparator, rightStream, rightStreamComparator

Fields inherited from class org.apache.solr.client.solrj.io.stream.JoinStream

eq

Fields inherited from interface org.apache.solr.common.MapWriter

EMPTY

Constructor Summary

Constructors

Constructor	Description
InnerJoinStream(StreamExpression expression, StreamFactory factory)
InnerJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)

Method Summary

Modifier and Type	Method	Description
StreamComparator	getStreamSort()
Tuple	read()

Methods inherited from class org.apache.solr.client.solrj.io.stream.BiJoinStream

validateTupleOrder

Methods inherited from class org.apache.solr.client.solrj.io.stream.JoinStream

children, close, getCost, getStream, isValidTupleOrder, loadEqualTupleGroup, open, setStreamContext, toExplanation, toExpression

Methods inherited from class org.apache.solr.client.solrj.io.stream.TupleStream

getShards, getShards, getStreamNodeId, writeMap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.solr.client.solrj.io.stream.expr.Expressible

toExplanation, toExpression

Methods inherited from interface org.apache.solr.common.MapWriter

jsonStr, toMap, write

Methods inherited from interface org.apache.solr.common.NavigableObject

_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size

Constructor Details

InnerJoinStream

public InnerJoinStream(TupleStream leftStream,
 TupleStream rightStream,
 StreamEqualitor eq)
                throws IOException

Throws:

IOException

InnerJoinStream

public InnerJoinStream(StreamExpression expression,
 StreamFactory factory)
                throws IOException

Throws:

IOException

Method Details

read

public Tuple read()
           throws IOException

Specified by:

read in class TupleStream

Throws:

IOException

getStreamSort

public StreamComparator getStreamSort()

Specified by:

getStreamSort in class TupleStream