Package | Description |
---|---|
org.apache.solr.client.solrj.io.comp |
Comparators for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.eq |
Equalitors for the Streaming Aggregation API
|
org.apache.solr.client.solrj.io.ops |
Operations 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 | Class and Description |
---|---|
class |
FieldComparator
An equality field Comparator which compares a field of two Tuples and determines sort order.
|
class |
MultipleFieldComparator
Wraps multiple Comparators to provide sub-sorting.
|
Modifier and Type | Method and Description |
---|---|
StreamComparator |
StreamComparator.copyAliased(Map<String,String> aliases) |
StreamComparator[] |
MultipleFieldComparator.getComps() |
Modifier and Type | Method and Description |
---|---|
boolean |
MultipleFieldComparator.isDerivedFrom(StreamComparator base) |
boolean |
FieldComparator.isDerivedFrom(StreamComparator base) |
boolean |
StreamComparator.isDerivedFrom(StreamComparator base) |
Constructor and Description |
---|
MultipleFieldComparator(StreamComparator... comps) |
Modifier and Type | Method and Description |
---|---|
boolean |
FieldEqualitor.isDerivedFrom(StreamComparator base) |
boolean |
StreamEqualitor.isDerivedFrom(StreamComparator base) |
boolean |
MultipleFieldEqualitor.isDerivedFrom(StreamComparator base) |
Constructor and Description |
---|
GroupOperation(StreamComparator streamComparator,
int size) |
Modifier and Type | Field and Description |
---|---|
protected StreamComparator |
CloudSolrStream.comp |
protected StreamComparator |
BiJoinStream.iterationComparator |
protected StreamComparator |
BiJoinStream.leftStreamComparator |
protected StreamComparator |
BiJoinStream.rightStreamComparator |
Modifier and Type | Method and Description |
---|---|
StreamComparator |
RankStream.getComparator() |
StreamComparator |
LeftOuterJoinStream.getStreamSort() |
StreamComparator |
ComplementStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
IntersectStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
SelectStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
SolrStream.getStreamSort()
There is no known sort applied to a SolrStream
|
StreamComparator |
StatsStream.getStreamSort() |
StreamComparator |
FacetStream.getStreamSort() |
StreamComparator |
ExceptionStream.getStreamSort() |
StreamComparator |
UniqueStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
ReducerStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
UpdateStream.getStreamSort() |
StreamComparator |
InnerJoinStream.getStreamSort() |
StreamComparator |
JDBCStream.getStreamSort() |
StreamComparator |
HashJoinStream.getStreamSort() |
StreamComparator |
RollupStream.getStreamSort() |
StreamComparator |
MergeStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
PushBackStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
This returns the streamSort of the substream
|
StreamComparator |
RankStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
DaemonStream.getStreamSort() |
StreamComparator |
CloudSolrStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
abstract StreamComparator |
TupleStream.getStreamSort() |
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).
|
Constructor and Description |
---|
JDBCStream(String connectionUrl,
String sqlQuery,
StreamComparator definedSort) |
JDBCStream(String connectionUrl,
String sqlQuery,
StreamComparator definedSort,
Properties connectionProperties,
String driverClassName) |
MergeStream(StreamComparator comp,
TupleStream... streams) |
MergeStream(TupleStream streamA,
TupleStream streamB,
StreamComparator comp) |
ParallelStream(String zkHost,
String collection,
String expressionString,
int workers,
StreamComparator comp) |
ParallelStream(String zkHost,
String collection,
TupleStream tupleStream,
int workers,
StreamComparator comp) |
RankStream(TupleStream tupleStream,
int size,
StreamComparator comp) |
ReducerStream(TupleStream stream,
StreamComparator comp,
ReduceOperation op) |
StreamOpener(SolrStream stream,
StreamComparator comp) |
TupleWrapper(SolrStream stream,
StreamComparator comp) |
Modifier and Type | Method and Description |
---|---|
StreamComparator |
StreamFactory.constructComparator(String comparatorString,
Class comparatorType) |
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.