| 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.eval | Evaluators 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() | 
| Tuple | ModelCache. getModel(String collection,
        String modelID,
        long checkMillis) | 
| Tuple | ModelCache. getModel(String zkHost,
        String collection,
        String modelID,
        long checkMillis) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Tuple. merge(Tuple other) | 
| Modifier and Type | Method and Description | 
|---|---|
| int | FieldComparator. compare(Tuple leftTuple,
       Tuple rightTuple) | 
| int | SingleValueComparator. compare(Tuple leftTuple,
       Tuple rightTuple) | 
| int | ComparatorLambda. compare(Tuple leftTuple,
       Tuple rightTuple) | 
| int | MultipleFieldComparator. compare(Tuple t1,
       Tuple t2) | 
| Modifier and Type | Method and Description | 
|---|---|
| boolean | MultipleFieldEqualitor. test(Tuple t1,
    Tuple t2) | 
| boolean | FieldEqualitor. test(Tuple leftTuple,
    Tuple rightTuple) | 
| Modifier and Type | Class and Description | 
|---|---|
| static class  | DbscanEvaluator.ClusterTuple | 
| static class  | KmeansEvaluator.ClusterTuple | 
| static class  | KnnRegressionEvaluator.KnnRegressionTuple | 
| static class  | LoessEvaluator.LoessRegressionTuple | 
| static class  | OLSRegressionEvaluator.MultipleRegressionTuple | 
| static class  | RegressionEvaluator.RegressionTuple | 
| Modifier and Type | Method and Description | 
|---|---|
| Object | EuclideanEvaluator. evaluate(Tuple tuple) | 
| Object | CosineDistanceEvaluator. evaluate(Tuple tuple) | 
| Object | UuidEvaluator. evaluate(Tuple tuple) | 
| Object | StreamEvaluator. evaluate(Tuple tuple) | 
| Object | RecursiveEvaluator. evaluate(Tuple tuple) | 
| Object | ColumnEvaluator. evaluate(Tuple tuple) | 
| Object | MemsetEvaluator. evaluate(Tuple tuple) | 
| Object | ChebyshevEvaluator. evaluate(Tuple tuple) | 
| Object | MonteCarloEvaluator. evaluate(Tuple tuple) | 
| Object | ManhattanEvaluator. evaluate(Tuple tuple) | 
| Object | CanberraEvaluator. evaluate(Tuple tuple) | 
| Object | EarthMoversEvaluator. evaluate(Tuple tuple) | 
| Object | RawValueEvaluator. evaluate(Tuple tuple) | 
| Object | RecNumEvaluator. evaluate(Tuple tuple) | 
| Object | FieldValueEvaluator. evaluate(Tuple tuple) | 
| List<Object> | RecursiveEvaluator. recursivelyEvaluate(Tuple tuple) | 
| 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 | GroupOperation. reduce() | 
| Tuple | DistinctOperation. reduce() | 
| Tuple | ReduceOperation. reduce() | 
| Modifier and Type | Method and Description | 
|---|---|
| void | ReplaceOperation. operate(Tuple tuple) | 
| void | GroupOperation. operate(Tuple tuple) | 
| void | ReplaceWithFieldOperation. operate(Tuple tuple) | 
| void | ConcatOperation. operate(Tuple tuple) | 
| void | StreamOperation. operate(Tuple tuple) | 
| void | DistinctOperation. operate(Tuple tuple) | 
| void | ReplaceWithValueOperation. operate(Tuple tuple) | 
| Modifier and Type | Field and Description | 
|---|---|
| protected Tuple | ModelStream. model | 
| protected Tuple | HashJoinStream. workingFullTuple | 
| Modifier and Type | Field and Description | 
|---|---|
| protected Map<String,Tuple> | CloudSolrStream. eofTuples | 
| protected Map<String,Tuple> | DeepRandomStream. eofTuples | 
| protected HashMap<String,List<Tuple>> | HashJoinStream. hashedTuples | 
| protected Iterator<Tuple> | FeaturesSelectionStream. tupleIterator | 
| protected Iterator<Tuple> | SignificantTermsStream. tupleIterator | 
| Modifier and Type | Method and Description | 
|---|---|
| protected Tuple | CloudSolrStream. _read() | 
| protected Tuple | DeepRandomStream. _read() | 
| Tuple | TextLogitStream.LogitCall. call() | 
| Tuple | DaemonStream. getInfo() | 
| Tuple | CloudSolrStream.TupleWrapper. getTuple() | 
| Tuple | DeepRandomStream.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 | CommitStream. read() | 
| Tuple | UniqueStream. read() | 
| Tuple | SortStream. read() | 
| Tuple | RankStream. read() | 
| Tuple | PlotStream. read() | 
| Tuple | RollupStream. read() | 
| Tuple | CsvStream. read() | 
| Tuple | StatsStream. read() | 
| Tuple | EchoStream. read() | 
| Tuple | RandomStream. read() | 
| Tuple | DaemonStream. read() | 
| Tuple | ParallelStream. read() | 
| Tuple | ComplementStream. read() | 
| Tuple | HavingStream. read() | 
| Tuple | ModelStream. read() | 
| Tuple | JDBCStream. read() | 
| Tuple | EvalStream. read() | 
| Tuple | FetchStream. read() | 
| Tuple | KnnStream. read() | 
| Tuple | TopicStream. read() | 
| Tuple | FacetStream. read() | 
| Tuple | MergeStream. read() | 
| Tuple | LeftOuterJoinStream. read() | 
| Tuple | GetStream. read() | 
| Tuple | CalculatorStream. read() | 
| Tuple | ScoreNodesStream. read() | 
| Tuple | TupStream. read() | 
| Tuple | FeaturesSelectionStream. read() | 
| Tuple | InnerJoinStream. read() | 
| Tuple | SelectStream. read() | 
| Tuple | HashJoinStream. read() | 
| Tuple | TextLogitStream. read() | 
| Tuple | TextLogitStream.TermsStream. read() | 
| Tuple | SearchFacadeStream. read() | 
| Tuple | PushBackStream. read() | 
| Tuple | ReducerStream. read() | 
| Tuple | LetStream. read() | 
| Tuple | OuterHashJoinStream. read() | 
| Tuple | PriorityStream. read() | 
| Tuple | ExecutorStream. read() | 
| Tuple | SignificantTermsStream. read() | 
| Tuple | ZplotStream. read() | 
| Tuple | SqlStream. read() | 
| Tuple | ParallelListStream. read() | 
| Tuple | SolrStream. read()Reads a Tuple from the stream. | 
| Tuple | NullStream. read() | 
| Tuple | HashRollupStream. read() | 
| Tuple | CloudSolrStream. read() | 
| Tuple | NoOpStream. read() | 
| Tuple | CellStream. read() | 
| Tuple | UpdateStream. read() | 
| Tuple | RandomFacadeStream. read() | 
| Tuple | CartesianProductStream. read() | 
| Tuple | ExceptionStream. read() | 
| Tuple | Facet2DStream. read() | 
| Tuple | ListStream. read() | 
| Tuple | TimeSeriesStream. read() | 
| Tuple | DeepRandomStream. read() | 
| abstract Tuple | TupleStream. read() | 
| Tuple | SearchStream. read() | 
| Tuple | IntersectStream. read() | 
| Modifier and Type | Method and Description | 
|---|---|
| protected String | HashJoinStream. computeHash(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) | 
| abstract void | Metric. update(Tuple tuple) | 
| void | SumMetric. update(Tuple tuple) | 
| void | MeanMetric. update(Tuple tuple) | 
| void | CountMetric. update(Tuple tuple) | 
| void | MinMetric. update(Tuple tuple) | 
| void | MaxMetric. update(Tuple tuple) | 
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.