Package | Description |
---|---|
org.apache.solr.client.solrj.io.stream |
Stream implementations for the Streaming Aggregation API
|
Modifier and Type | Field and Description |
---|---|
protected PushBackStream |
BiJoinStream.leftStream |
protected PushBackStream |
BiJoinStream.rightStream |
Modifier and Type | Method and Description |
---|---|
PushBackStream |
JoinStream.getStream(int idx) |
Modifier and Type | Method and Description |
---|---|
protected Tuple |
JoinStream.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).
|
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.