public abstract class JoinStream extends TupleStream implements Expressible
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected StreamEqualitor |
eq |
Constructor and Description |
---|
JoinStream(StreamEqualitor eq,
TupleStream first,
TupleStream second,
TupleStream... others) |
JoinStream(StreamExpression expression,
StreamFactory factory) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close() |
int |
getCost() |
PushBackStream |
getStream(int idx) |
protected boolean |
isValidTupleOrder() |
protected Tuple |
loadEqualTupleGroup(PushBackStream stream,
LinkedList<Tuple> group,
StreamComparator groupComparator)
Given the stream, start from beginning and load group with all tuples that are equal to the first in stream
(including the first one in the stream).
|
void |
open() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
protected abstract void |
validateTupleOrder() |
getShards, getStreamNodeId, getStreamSort, read, writeMap
protected StreamEqualitor eq
public JoinStream(StreamEqualitor eq, TupleStream first, TupleStream second, TupleStream... others)
public JoinStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
protected abstract void validateTupleOrder() throws IOException
IOException
public StreamExpression toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class TupleStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public void open() throws IOException
open
in class TupleStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
IOException
public List<TupleStream> children()
children
in class TupleStream
public PushBackStream getStream(int idx)
protected boolean isValidTupleOrder()
protected Tuple loadEqualTupleGroup(PushBackStream stream, LinkedList<Tuple> group, StreamComparator groupComparator) throws IOException
group
- - should be emptyIOException
public int getCost()
getCost
in class TupleStream
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.