Package | Description |
---|---|
org.apache.solr.client.solrj.io.graph |
Streaming Graph Traversals
|
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
|
org.apache.solr.client.solrj.io.stream.metrics |
Metrics package
|
Modifier and Type | Method and Description |
---|---|
void |
Node.setMetrics(List<Metric> metrics) |
Constructor and Description |
---|
GatherNodesStream(String zkHost,
String collection,
TupleStream tupleStream,
String traverseFrom,
String traverseTo,
String gather,
Map queryParams,
List<Metric> metrics,
boolean trackTraversal,
Set<Traversal.Scatter> scatter,
int maxDocFreq) |
Modifier and Type | Method and Description |
---|---|
default Optional<Metric[]> |
ParallelMetricsRollup.getRollupMetrics(Metric[] metrics)
Either an array of metrics that can be parallelized and rolled up or empty.
|
protected Map<String,String> |
FacetStream.getRollupSelectFields(Metric[] rollupMetrics)
The projection of dimensions and metrics from the rollup stream.
|
TupleStream |
FacetStream.getSortedRollupStream(ParallelListStream plist,
Metric[] rollupMetrics) |
TupleStream |
ParallelMetricsRollup.getSortedRollupStream(ParallelListStream plistStream,
Metric[] rollupMetrics)
Get the rollup for the parallelized streams that is sorted based on the original (non-parallel) sort order.
|
default Optional<TupleStream> |
ParallelMetricsRollup.openParallelStream(StreamContext context,
List<String> partitions,
Metric[] metrics)
Given a list of partitions (collections), open a select stream that projects the dimensions and
metrics produced by rolling up over a parallelized group of streams.
|
Constructor and Description |
---|
Facet2DStream(String zkHost,
String collection,
ModifiableSolrParams params,
Bucket x,
Bucket y,
String dimensions,
Metric metric) |
FacetStream(String zkHost,
String collection,
SolrParams params,
Bucket[] buckets,
Metric[] metrics,
FieldComparator[] bucketSorts,
int bucketSizeLimit) |
HashRollupStream(TupleStream tupleStream,
Bucket[] buckets,
Metric[] metrics) |
RollupStream(TupleStream tupleStream,
Bucket[] buckets,
Metric[] metrics) |
StatsStream(String zkHost,
String collection,
SolrParams params,
Metric[] metrics) |
TimeSeriesStream(String zkHost,
String collection,
SolrParams params,
Metric[] metrics,
String field,
String start,
String end,
String gap,
String format) |
Modifier and Type | Method and Description |
---|---|
Metric |
StreamFactory.constructMetric(StreamExpression expression) |
Metric |
StreamFactory.constructMetric(String expressionClause) |
Metric |
StreamFactory.constructOperation(String expressionClause) |
Modifier and Type | Class and Description |
---|---|
class |
CountMetric |
class |
MaxMetric |
class |
MeanMetric |
class |
MinMetric |
class |
PercentileMetric |
class |
StdMetric |
class |
SumMetric |
class |
WeightedSumMetric |
Modifier and Type | Method and Description |
---|---|
Metric |
MeanMetric.newInstance() |
Metric |
WeightedSumMetric.newInstance() |
Metric |
StdMetric.newInstance() |
Metric |
PercentileMetric.newInstance() |
Metric |
MaxMetric.newInstance() |
Metric |
SumMetric.newInstance() |
Metric |
CountMetric.newInstance() |
abstract Metric |
Metric.newInstance() |
Metric |
MinMetric.newInstance() |
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.