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

Class BiJoinStream

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

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

Direct Known Subclasses:

FullOuterJoinStream, InnerJoinStream, LeftOuterJoinStream

public abstract class BiJoinStream
extends JoinStream
implements Expressible

Joins leftStream with rightStream based on an StreamEqualitor. 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

Modifier and Type	Field	Description
protected StreamComparator	iterationComparator
protected PushBackStream	leftStream
protected StreamComparator	leftStreamComparator
protected PushBackStream	rightStream
protected StreamComparator	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
BiJoinStream(StreamExpression expression, StreamFactory factory)
BiJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)

Method Summary

Modifier and Type	Method	Description
protected void	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, getStreamSort, read, 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

Field Details

leftStream

protected PushBackStream leftStream

rightStream

protected PushBackStream rightStream

iterationComparator

protected StreamComparator iterationComparator

leftStreamComparator

protected StreamComparator leftStreamComparator

rightStreamComparator

protected StreamComparator rightStreamComparator

Constructor Details

BiJoinStream

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

Throws:

IOException

BiJoinStream

public BiJoinStream(StreamExpression expression,
 StreamFactory factory)
             throws IOException

Throws:

IOException

Method Details

validateTupleOrder

protected void validateTupleOrder()
                           throws IOException

Specified by:

validateTupleOrder in class JoinStream

Throws:

IOException