Package | Description |
---|---|
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 |
BiJoinStream
Joins leftStream with rightStream based on a Equalitor.
|
class |
CloudSolrStream
Connects to Zookeeper to pick replicas from a specific collection to send the query to.
|
class |
ComplementStream
Emits tuples from streamA which do not exist in streamB.
|
class |
DaemonStream |
class |
ExceptionStream |
class |
FacetStream
The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
|
class |
HashJoinStream
Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
|
class |
InnerJoinStream
Joins leftStream with rightStream based on a Equalitor.
|
class |
IntersectStream
Emits tuples from streamA which also exist in streamB.
|
class |
JDBCStream
Connects to a datasource using a registered JDBC driver and execute a query.
|
class |
JoinStream
Defines a JoinStream which can hold N streams, all joined with the same equalitor
|
class |
LeftOuterJoinStream
Joins leftStream with rightStream based on a Equalitor.
|
class |
MergeStream
Merges two or more streams together ordering the Tuples based on a Comparator.
|
class |
OuterHashJoinStream
Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
|
class |
ParallelStream
The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
|
class |
PushBackStream
A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
|
class |
RankStream
Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
|
class |
ReducerStream
Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
|
class |
RollupStream |
class |
SelectStream
Selects fields from the incoming stream and applies optional field renaming.
|
class |
SolrStream
Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
|
class |
StatsStream |
class |
TopicStream |
class |
UniqueStream
The UniqueStream emits a unique stream of Tuples based on a Comparator.
|
class |
UpdateStream
Sends tuples emitted by a wrapped
TupleStream as updates to a SolrCloud collection. |
Modifier and Type | Field and Description |
---|---|
protected TupleStream |
HashJoinStream.fullStream |
protected TupleStream |
HashJoinStream.hashStream |
Modifier and Type | Field and Description |
---|---|
protected List<TupleStream> |
CloudSolrStream.solrStreams |
Modifier and Type | Method and Description |
---|---|
void |
DaemonStream.init(TupleStream tupleStream,
String id,
long runInterval,
int queueSize) |
Modifier and Type | Method and Description |
---|---|
TupleStream |
StreamFactory.constructStream(StreamExpression expression) |
TupleStream |
StreamFactory.constructStream(String expressionClause) |
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.