public class HashJoinStream extends TupleStream implements Expressible
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected TupleStream |
fullStream |
protected HashMap<Integer,List<Tuple>> |
hashedTuples |
protected TupleStream |
hashStream |
protected List<String> |
leftHashOn |
protected List<String> |
rightHashOn |
protected Integer |
workingFullHash |
protected Tuple |
workingFullTuple |
protected int |
workngHashSetIdx |
Constructor and Description |
---|
HashJoinStream(StreamExpression expression,
StreamFactory factory) |
HashJoinStream(TupleStream fullStream,
TupleStream hashStream,
List<String> hashOn) |
Modifier and Type | Method and Description |
---|---|
protected Integer |
calculateHash(Tuple tuple,
List<String> hashOn) |
List<TupleStream> |
children() |
void |
close() |
int |
getCost() |
StreamComparator |
getStreamSort() |
void |
open() |
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpression |
toExpression(StreamFactory factory) |
getShards, getSlices, getStreamNodeId, writeMap
protected TupleStream hashStream
protected TupleStream fullStream
protected Tuple workingFullTuple
protected Integer workingFullHash
protected int workngHashSetIdx
public HashJoinStream(TupleStream fullStream, TupleStream hashStream, List<String> hashOn) throws IOException
IOException
public HashJoinStream(StreamExpression expression, StreamFactory factory) 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 List<TupleStream> children()
children
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 Tuple read() throws IOException
read
in class TupleStream
IOException
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public int getCost()
getCost
in class TupleStream
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.