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.graph |
Streaming Graph Traversals
|
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.
|
class |
SingleValueComparator
An equality Comparator to be used when a stream will only ever return a single field,
ie, it has no sorted order
|
Modifier and Type | Method and Description |
---|---|
StreamComparator |
FieldComparator.append(StreamComparator other) |
StreamComparator |
StreamComparator.append(StreamComparator other) |
StreamComparator |
SingleValueComparator.append(StreamComparator other) |
StreamComparator |
MultipleFieldComparator.append(StreamComparator other) |
StreamComparator |
StreamComparator.copyAliased(Map<String,String> aliases) |
StreamComparator[] |
MultipleFieldComparator.getComps() |
Modifier and Type | Method and Description |
---|---|
StreamComparator |
FieldComparator.append(StreamComparator other) |
StreamComparator |
StreamComparator.append(StreamComparator other) |
StreamComparator |
SingleValueComparator.append(StreamComparator other) |
StreamComparator |
MultipleFieldComparator.append(StreamComparator other) |
boolean |
FieldComparator.isDerivedFrom(StreamComparator base) |
boolean |
StreamComparator.isDerivedFrom(StreamComparator base) |
boolean |
SingleValueComparator.isDerivedFrom(StreamComparator base) |
boolean |
MultipleFieldComparator.isDerivedFrom(StreamComparator base) |
Constructor and Description |
---|
MultipleFieldComparator(StreamComparator... comps) |
Modifier and Type | Method and Description |
---|---|
boolean |
MultipleFieldEqualitor.isDerivedFrom(StreamComparator base) |
boolean |
FieldEqualitor.isDerivedFrom(StreamComparator base) |
boolean |
StreamEqualitor.isDerivedFrom(StreamComparator base) |
Modifier and Type | Method and Description |
---|---|
StreamComparator |
GatherNodesStream.getStreamSort() |
StreamComparator |
ShortestPathStream.getStreamSort() |
Constructor and Description |
---|
GroupOperation(StreamComparator streamComparator,
int size) |
Modifier and Type | Field and Description |
---|---|
protected StreamComparator |
CloudSolrStream.comp |
protected StreamComparator |
DeepRandomStream.comp |
protected StreamComparator |
SearchStream.comp |
protected StreamComparator |
BiJoinStream.iterationComparator |
protected StreamComparator |
BiJoinStream.leftStreamComparator |
protected StreamComparator |
BiJoinStream.rightStreamComparator |
Modifier and Type | Method and Description |
---|---|
StreamComparator |
RankStream.getComparator() |
StreamComparator |
ScoreNodesStream.getComparator() |
StreamComparator |
CommitStream.getStreamSort() |
StreamComparator |
UniqueStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
SortStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
RankStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
PlotStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
RollupStream.getStreamSort() |
StreamComparator |
CsvStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
StatsStream.getStreamSort() |
StreamComparator |
EchoStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
RandomStream.getStreamSort() |
StreamComparator |
DaemonStream.getStreamSort() |
StreamComparator |
ComplementStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
HavingStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
ModelStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
JDBCStream.getStreamSort() |
StreamComparator |
EvalStream.getStreamSort() |
StreamComparator |
FetchStream.getStreamSort() |
StreamComparator |
KnnStream.getStreamSort() |
StreamComparator |
FacetStream.getStreamSort() |
StreamComparator |
MergeStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
LeftOuterJoinStream.getStreamSort() |
StreamComparator |
GetStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
CalculatorStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
ScoreNodesStream.getStreamSort() |
StreamComparator |
TupStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
FeaturesSelectionStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
InnerJoinStream.getStreamSort() |
StreamComparator |
SelectStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
HashJoinStream.getStreamSort() |
StreamComparator |
TextLogitStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
TextLogitStream.TermsStream.getStreamSort() |
StreamComparator |
SearchFacadeStream.getStreamSort() |
StreamComparator |
PushBackStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
This returns the streamSort of the substream
|
StreamComparator |
ReducerStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
LetStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
PriorityStream.getStreamSort() |
StreamComparator |
ExecutorStream.getStreamSort() |
StreamComparator |
SignificantTermsStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
ZplotStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
SqlStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
ParallelListStream.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 |
NullStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
HashRollupStream.getStreamSort() |
StreamComparator |
CloudSolrStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
NoOpStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
CellStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
UpdateStream.getStreamSort() |
StreamComparator |
RandomFacadeStream.getStreamSort() |
StreamComparator |
CartesianProductStream.getStreamSort()
Return the incoming sort + the sort applied to the generated tuples
|
StreamComparator |
ExceptionStream.getStreamSort() |
StreamComparator |
Facet2DStream.getStreamSort() |
StreamComparator |
ListStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
StreamComparator |
TimeSeriesStream.getStreamSort() |
StreamComparator |
DeepRandomStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
abstract StreamComparator |
TupleStream.getStreamSort() |
StreamComparator |
SearchStream.getStreamSort() |
StreamComparator |
IntersectStream.getStreamSort()
Return the stream sort - ie, the order in which records are returned
|
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).
|
Modifier and Type | Method and Description |
---|---|
StreamComparator |
StreamFactory.constructComparator(String comparatorString,
Class comparatorType) |
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.