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() |
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 |
MultipleFieldComparator.compare(Tuple t1,
Tuple t2) |
int |
FieldComparator.compare(Tuple leftTuple,
Tuple rightTuple) |
int |
ComparatorLambda.compare(Tuple leftTuple,
Tuple rightTuple) |
Modifier and Type | Method and Description |
---|---|
boolean |
MultipleFieldEqualitor.test(Tuple t1,
Tuple t2) |
boolean |
FieldEqualitor.test(Tuple leftTuple,
Tuple rightTuple) |
Modifier and Type | Method and Description |
---|---|
Tuple |
ShortestPathStream.read() |
Tuple |
GatherNodesStream.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 | Field and Description |
---|---|
protected Tuple |
LeafOperation.tuple |
Modifier and Type | Method and Description |
---|---|
Tuple |
ReduceOperation.reduce() |
Tuple |
GroupOperation.reduce() |
Tuple |
DistinctOperation.reduce() |
Modifier and Type | Method and Description |
---|---|
void |
StreamOperation.operate(Tuple tuple) |
void |
ReplaceWithValueOperation.operate(Tuple tuple) |
void |
ReplaceWithFieldOperation.operate(Tuple tuple) |
void |
ReplaceOperation.operate(Tuple tuple) |
void |
NotOperation.operate(Tuple tuple) |
void |
LessThanOperation.operate(Tuple tuple) |
void |
LessThanEqualToOperation.operate(Tuple tuple) |
void |
LeafOperation.operate(Tuple tuple) |
void |
GroupOperation.operate(Tuple tuple) |
void |
GreaterThanOperation.operate(Tuple tuple) |
void |
GreaterThanEqualToOperation.operate(Tuple tuple) |
void |
EqualsOperation.operate(Tuple tuple) |
void |
DistinctOperation.operate(Tuple tuple) |
void |
ConcatOperation.operate(Tuple tuple) |
void |
AndOperation.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 HashMap<Integer,List<Tuple>> |
HashJoinStream.hashedTuples |
protected Iterator<Tuple> |
FeaturesSelectionStream.tupleIterator |
Modifier and Type | Method and Description |
---|---|
protected Tuple |
CloudSolrStream._read() |
Tuple |
TextLogitStream.LogitCall.call() |
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 |
UniqueStream.read() |
abstract Tuple |
TupleStream.read() |
Tuple |
TopicStream.read() |
Tuple |
TextLogitStream.read() |
Tuple |
TextLogitStream.TermsStream.read() |
Tuple |
StatsStream.read() |
Tuple |
SortStream.read() |
Tuple |
SolrStream.read()
Reads a Tuple from the stream.
|
Tuple |
SelectStream.read() |
Tuple |
ScoreNodesStream.read() |
Tuple |
RollupStream.read() |
Tuple |
ReducerStream.read() |
Tuple |
RankStream.read() |
Tuple |
RandomStream.read() |
Tuple |
PushBackStream.read() |
Tuple |
PriorityStream.read() |
Tuple |
ParallelStream.read() |
Tuple |
OuterHashJoinStream.read() |
Tuple |
NullStream.read() |
Tuple |
ModelStream.read() |
Tuple |
MergeStream.read() |
Tuple |
LeftOuterJoinStream.read() |
Tuple |
JDBCStream.read() |
Tuple |
IntersectStream.read() |
Tuple |
InnerJoinStream.read() |
Tuple |
HavingStream.read() |
Tuple |
HashJoinStream.read() |
Tuple |
FetchStream.read() |
Tuple |
FeaturesSelectionStream.read() |
Tuple |
FacetStream.read() |
Tuple |
ExecutorStream.read() |
Tuple |
ExceptionStream.read() |
Tuple |
DaemonStream.read() |
Tuple |
ComplementStream.read() |
Tuple |
CommitStream.read() |
Tuple |
CloudSolrStream.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 |
SumMetric.update(Tuple tuple) |
void |
MinMetric.update(Tuple tuple) |
abstract void |
Metric.update(Tuple tuple) |
void |
MeanMetric.update(Tuple tuple) |
void |
MaxMetric.update(Tuple tuple) |
void |
CountMetric.update(Tuple tuple) |
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.