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() |
static Tuple |
Tuple.EOF()
Create a new empty tuple marked as EOF.
|
static Tuple |
Tuple.EXCEPTION(String msg,
boolean eof)
Create a new empty tuple marked as EXCEPTION, and optionally EOF.
|
static Tuple |
Tuple.EXCEPTION(Throwable t,
boolean eof)
Create a new empty tuple marked as EXCEPTION and optionally EOF.
|
Tuple |
ModelCache.getModel(String collection,
String modelID,
long checkMillis) |
Tuple |
ModelCache.getModel(String zkHost,
String collection,
String modelID,
long checkMillis) |
Tuple |
Lang.LocalInputStream.read() |
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 |
FieldComparator.compare(Tuple leftTuple,
Tuple rightTuple) |
int |
MultipleFieldComparator.compare(Tuple t1,
Tuple t2) |
int |
SingleValueComparator.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 | 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 |
ColumnEvaluator.evaluate(Tuple tuple) |
Object |
EarthMoversEvaluator.evaluate(Tuple tuple) |
Object |
RawValueEvaluator.evaluate(Tuple tuple) |
Object |
MonteCarloEvaluator.evaluate(Tuple tuple) |
Object |
RecNumEvaluator.evaluate(Tuple tuple) |
Object |
MemsetEvaluator.evaluate(Tuple tuple) |
Object |
CanberraEvaluator.evaluate(Tuple tuple) |
Object |
FieldValueEvaluator.evaluate(Tuple tuple) |
Object |
ManhattanEvaluator.evaluate(Tuple tuple) |
Object |
StreamEvaluator.evaluate(Tuple tuple) |
Object |
UuidEvaluator.evaluate(Tuple tuple) |
Object |
EuclideanEvaluator.evaluate(Tuple tuple) |
Object |
CosineDistanceEvaluator.evaluate(Tuple tuple) |
Object |
ChebyshevEvaluator.evaluate(Tuple tuple) |
Object |
RecursiveEvaluator.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 |
DistinctOperation.reduce() |
Tuple |
ReduceOperation.reduce() |
Tuple |
GroupOperation.reduce() |
Modifier and Type | Method and Description |
---|---|
void |
ConcatOperation.operate(Tuple tuple) |
void |
DistinctOperation.operate(Tuple tuple) |
void |
ReplaceWithValueOperation.operate(Tuple tuple) |
void |
ReplaceOperation.operate(Tuple tuple) |
void |
StreamOperation.operate(Tuple tuple) |
void |
ReplaceWithFieldOperation.operate(Tuple tuple) |
void |
GroupOperation.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> |
DeepRandomStream.eofTuples |
protected Map<String,Tuple> |
CloudSolrStream.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 |
DeepRandomStream._read() |
protected Tuple |
CloudSolrStream._read() |
Tuple |
TextLogitStream.LogitCall.call() |
Tuple |
DaemonStream.getInfo() |
Tuple |
DeepRandomStream.TupleWrapper.getTuple() |
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 |
ZplotStream.read() |
Tuple |
CartesianProductStream.read() |
Tuple |
Facet2DStream.read() |
Tuple |
FacetStream.read() |
Tuple |
DrillStream.read() |
abstract Tuple |
TupleStream.read() |
Tuple |
HavingStream.read() |
Tuple |
RankStream.read() |
Tuple |
TupStream.read() |
Tuple |
SelectStream.read() |
Tuple |
ListStream.read() |
Tuple |
UpdateStream.read() |
Tuple |
SearchFacadeStream.read() |
Tuple |
OuterHashJoinStream.read() |
Tuple |
EvalStream.read() |
Tuple |
NoOpStream.read() |
Tuple |
CellStream.read() |
Tuple |
TopicStream.read() |
Tuple |
CsvStream.read() |
Tuple |
MergeStream.read() |
Tuple |
RollupStream.read() |
Tuple |
PriorityStream.read() |
Tuple |
FeaturesSelectionStream.read() |
Tuple |
JDBCStream.read() |
Tuple |
HashRollupStream.read() |
Tuple |
TextLogitStream.read() |
Tuple |
TextLogitStream.TermsStream.read() |
Tuple |
PlotStream.read() |
Tuple |
SqlStream.read() |
Tuple |
NullStream.read() |
Tuple |
RandomFacadeStream.read() |
Tuple |
ParallelStream.read() |
Tuple |
LetStream.read() |
Tuple |
FetchStream.read() |
Tuple |
IntersectStream.read() |
Tuple |
ReducerStream.read() |
Tuple |
ParallelListStream.read() |
Tuple |
CalculatorStream.read() |
Tuple |
DaemonStream.read() |
Tuple |
UniqueStream.read() |
Tuple |
SortStream.read() |
Tuple |
StatsStream.read() |
Tuple |
ComplementStream.read() |
Tuple |
InnerJoinStream.read() |
Tuple |
GetStream.read() |
Tuple |
EchoStream.read() |
Tuple |
HashJoinStream.read() |
Tuple |
SearchStream.read() |
Tuple |
DeepRandomStream.read() |
Tuple |
TimeSeriesStream.read() |
Tuple |
SolrStream.read()
Reads a Tuple from the stream.
|
Tuple |
ScoreNodesStream.read() |
Tuple |
ExceptionStream.read() |
Tuple |
KnnStream.read() |
Tuple |
CommitStream.read() |
Tuple |
RandomStream.read() |
Tuple |
LeftOuterJoinStream.read() |
Tuple |
CloudSolrStream.read() |
Tuple |
SignificantTermsStream.read() |
Tuple |
ExecutorStream.read() |
Tuple |
PushBackStream.read() |
Tuple |
ModelStream.read() |
Modifier and Type | Method and Description |
---|---|
Map<String,Tuple> |
CloudSolrStream.getEofTuples() |
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) |
void |
MeanMetric.update(Tuple tuple) |
void |
StdMetric.update(Tuple tuple) |
void |
PercentileMetric.update(Tuple tuple) |
void |
MaxMetric.update(Tuple tuple) |
void |
SumMetric.update(Tuple tuple) |
void |
CountMetric.update(Tuple tuple) |
abstract void |
Metric.update(Tuple tuple) |
void |
MinMetric.update(Tuple tuple) |
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.