Package | Description |
---|---|
org.apache.solr.client.solrj.io |
Streaming Aggregation API
|
org.apache.solr.client.solrj.io.comp |
Comparators for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.stream |
Stream implementations for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.stream.expr |
Expression language for the Streaming Aggregation API
|
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.clone() |
Modifier and Type | Method and Description |
---|---|
int |
FieldComparator.compare(Tuple leftTuple,
Tuple rightTuple) |
int |
MultiComp.compare(Tuple t1,
Tuple t2) |
int |
ComparatorLambda.compare(Tuple leftTuple,
Tuple rightTuple) |
Modifier and Type | Field and Description |
---|---|
protected Comparator<Tuple> |
CloudSolrStream.comp |
protected Map<String,Tuple> |
CloudSolrStream.eofTuples |
Modifier and Type | Method and Description |
---|---|
protected Tuple |
CloudSolrStream._read() |
Tuple |
CloudSolrStream.TupleWrapper.getTuple() |
Tuple |
UniqueStream.read() |
abstract Tuple |
TupleStream.read() |
Tuple |
SolrStream.read()
Reads a Tuple from the stream.
|
Tuple |
ReducerStream.read() |
Tuple |
RankStream.read() |
Tuple |
PushBackStream.read() |
Tuple |
ParallelStream.read() |
Tuple |
MergeStream.read() |
Tuple |
CloudSolrStream.read() |
Modifier and Type | Method and Description |
---|---|
Comparator<Tuple> |
RankStream.getComparator() |
Modifier and Type | Method and Description |
---|---|
void |
PushBackStream.pushBack(Tuple tuple) |
Modifier and Type | Method and Description |
---|---|
void |
UniqueStream.setComp(Comparator<Tuple> comp) |
Constructor and Description |
---|
CloudSolrStream.StreamOpener(SolrStream stream,
Comparator<Tuple> comp) |
MergeStream(TupleStream streamA,
TupleStream streamB,
Comparator<Tuple> comp) |
ParallelStream(String zkHost,
String collection,
String expressionString,
int workers,
Comparator<Tuple> comp) |
ParallelStream(String zkHost,
String collection,
TupleStream tupleStream,
int workers,
Comparator<Tuple> comp) |
RankStream(TupleStream tupleStream,
int size,
Comparator<Tuple> comp) |
ReducerStream(TupleStream tupleStream,
Comparator<Tuple> comp) |
UniqueStream(TupleStream tupleStream,
Comparator<Tuple> comp) |
Modifier and Type | Method and Description |
---|---|
Comparator<Tuple> |
StreamFactory.constructComparator(String comparatorString,
Class comparatorType) |
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.