| 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.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.metrics | Metrics package | 
| Modifier and Type | Method and Description | 
|---|---|
| Tuple | Tuple. clone() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Tuple. merge(Tuple other) | 
| Modifier and Type | Method and Description | 
|---|---|
| int | ComparatorLambda. compare(Tuple leftTuple,
       Tuple rightTuple) | 
| int | MultipleFieldComparator. compare(Tuple t1,
       Tuple t2) | 
| int | FieldComparator. compare(Tuple leftTuple,
       Tuple rightTuple) | 
| Modifier and Type | Method and Description | 
|---|---|
| boolean | FieldEqualitor. test(Tuple leftTuple,
    Tuple rightTuple) | 
| boolean | MultipleFieldEqualitor. test(Tuple t1,
    Tuple t2) | 
| Modifier and Type | Method and Description | 
|---|---|
| Tuple | GatherNodesStream. read() | 
| Tuple | ShortestPathStream. read() | 
| Tuple | Node. toTuple(String collection,
       String field,
       int level,
       Traversal traversal) | 
| Modifier and Type | Method and Description | 
|---|---|
| Iterator<Tuple> | Traversal. iterator() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Node. add(String ancestor,
   Tuple tuple) | 
| boolean | Traversal. visited(String nodeId,
       String ancestorId,
       Tuple tuple) | 
| Modifier and Type | Method and Description | 
|---|---|
| Tuple | DistinctOperation. reduce() | 
| Tuple | ReduceOperation. reduce() | 
| Tuple | GroupOperation. reduce() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ReplaceWithFieldOperation. operate(Tuple tuple) | 
| void | DistinctOperation. operate(Tuple tuple) | 
| void | ReplaceWithValueOperation. operate(Tuple tuple) | 
| void | ReplaceOperation. operate(Tuple tuple) | 
| void | StreamOperation. operate(Tuple tuple) | 
| void | ConcatOperation. operate(Tuple tuple) | 
| void | GroupOperation. operate(Tuple tuple) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected Tuple | HashJoinStream. workingFullTuple | 
| Modifier and Type | Field and Description | 
|---|---|
| protected Map<String,Tuple> | CloudSolrStream. eofTuples | 
| protected HashMap<Integer,List<Tuple>> | HashJoinStream. hashedTuples | 
| Modifier and Type | Method and Description | 
|---|---|
| protected Tuple | CloudSolrStream. _read() | 
| Tuple | DaemonStream. getInfo() | 
| Tuple | CloudSolrStream.TupleWrapper. getTuple() | 
| 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). | 
| Tuple | UpdateStream. read() | 
| Tuple | ReducerStream. read() | 
| Tuple | RandomStream. read() | 
| Tuple | HashJoinStream. read() | 
| Tuple | RollupStream. read() | 
| Tuple | SelectStream. read() | 
| Tuple | ComplementStream. read() | 
| Tuple | FacetStream. read() | 
| Tuple | TopicStream. read() | 
| Tuple | ParallelStream. read() | 
| Tuple | DaemonStream. read() | 
| Tuple | PushBackStream. read() | 
| Tuple | InnerJoinStream. read() | 
| Tuple | IntersectStream. read() | 
| Tuple | CloudSolrStream. read() | 
| Tuple | UniqueStream. read() | 
| Tuple | ExceptionStream. read() | 
| Tuple | RankStream. read() | 
| Tuple | MergeStream. read() | 
| Tuple | SolrStream. read()Reads a Tuple from the stream. | 
| Tuple | LeftOuterJoinStream. read() | 
| Tuple | StatsStream. read() | 
| Tuple | JDBCStream. read() | 
| Tuple | OuterHashJoinStream. read() | 
| Tuple | SortStream. read() | 
| abstract Tuple | TupleStream. read() | 
| Modifier and Type | Method and Description | 
|---|---|
| protected Integer | HashJoinStream. calculateHash(Tuple tuple,
             List<String> hashOn) | 
| void | PushBackStream. pushBack(Tuple tuple) | 
| 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 | 
|---|---|
| Object | Bucket. getBucketValue(Tuple tuple) | 
| void | CountMetric. update(Tuple tuple) | 
| abstract void | Metric. update(Tuple tuple) | 
| void | MeanMetric. update(Tuple tuple) | 
| void | SumMetric. update(Tuple tuple) | 
| void | MaxMetric. update(Tuple tuple) | 
| void | MinMetric. update(Tuple tuple) | 
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.