public abstract class BiJoinStream extends JoinStream implements Expressible
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected StreamComparator |
iterationComparator |
protected PushBackStream |
leftStream |
protected StreamComparator |
leftStreamComparator |
protected PushBackStream |
rightStream |
protected StreamComparator |
rightStreamComparator |
eq
Constructor and Description |
---|
BiJoinStream(StreamExpression expression,
StreamFactory factory) |
BiJoinStream(TupleStream leftStream,
TupleStream rightStream,
StreamEqualitor eq) |
Modifier and Type | Method and Description |
---|---|
protected void |
validateTupleOrder() |
children, close, getCost, getStream, isValidTupleOrder, loadEqualTupleGroup, open, setStreamContext, toExplanation, toExpression
getShards, getStreamNodeId, getStreamSort, read, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
toExplanation, toExpression
protected PushBackStream leftStream
protected PushBackStream rightStream
protected StreamComparator iterationComparator
protected StreamComparator leftStreamComparator
protected StreamComparator rightStreamComparator
public BiJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq) throws IOException
IOException
public BiJoinStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
protected void validateTupleOrder() throws IOException
validateTupleOrder
in class JoinStream
IOException
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.