public class FacetStream extends TupleStream implements Expressible, ParallelMetricsRollup
TupleStream.IgnoreException
MapWriter.EntryWriter
Modifier and Type | Field and Description |
---|---|
protected SolrClientCache |
cache |
protected CloudSolrClient |
cloudSolrClient |
protected StreamContext |
context |
protected TupleStream |
parallelizedStream |
Constructor and Description |
---|
FacetStream(StreamExpression expression,
StreamFactory factory) |
FacetStream(String zkHost,
String collection,
SolrParams params,
Bucket[] buckets,
Metric[] metrics,
FieldComparator[] bucketSorts,
int bucketSizeLimit) |
Modifier and Type | Method and Description |
---|---|
List<TupleStream> |
children() |
void |
close() |
Bucket[] |
getBuckets() |
int |
getBucketSizeLimit() |
String |
getCollection() |
int |
getCost() |
int |
getOffset() |
int |
getOverfetch() |
protected Map<String,String> |
getRollupSelectFields(Metric[] rollupMetrics)
The projection of dimensions and metrics from the rollup stream.
|
int |
getRows() |
TupleStream |
getSortedRollupStream(ParallelListStream plist,
Metric[] rollupMetrics)
Get the rollup for the parallelized streams that is sorted based on the original (non-parallel) sort order.
|
StreamComparator |
getStreamSort() |
void |
open() |
TupleStream[] |
parallelize(List<String> partitions)
Given a list of collections, return an array of TupleStream for each partition.
|
Tuple |
read() |
void |
setStreamContext(StreamContext context) |
Explanation |
toExplanation(StreamFactory factory)
Returns an explanation about the stream object
|
StreamExpressionParameter |
toExpression(StreamFactory factory) |
getShards, getShards, getStreamNodeId, writeMap
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRollupMetrics, openParallelStream
_forEachEntry, _forEachEntry, _forEachEntry, _get, _get, _getStr, _getStr, _size
protected transient SolrClientCache cache
protected transient CloudSolrClient cloudSolrClient
protected transient TupleStream parallelizedStream
protected transient StreamContext context
public FacetStream(String zkHost, String collection, SolrParams params, Bucket[] buckets, Metric[] metrics, FieldComparator[] bucketSorts, int bucketSizeLimit) throws IOException
IOException
public FacetStream(StreamExpression expression, StreamFactory factory) throws IOException
IOException
public int getBucketSizeLimit()
public int getRows()
public int getOffset()
public int getOverfetch()
public Bucket[] getBuckets()
public String getCollection()
public StreamExpressionParameter toExpression(StreamFactory factory) throws IOException
toExpression
in interface Expressible
IOException
public Explanation toExplanation(StreamFactory factory) throws IOException
Expressible
toExplanation
in interface Expressible
toExplanation
in class TupleStream
factory
- Stream factory for this, contains information about the function nameIOException
- throw on any errorpublic void setStreamContext(StreamContext context)
setStreamContext
in class TupleStream
public List<TupleStream> children()
children
in class TupleStream
public void open() throws IOException
open
in class TupleStream
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class TupleStream
IOException
public Tuple read() throws IOException
read
in class TupleStream
IOException
public int getCost()
getCost
in class TupleStream
public StreamComparator getStreamSort()
getStreamSort
in class TupleStream
public TupleStream[] parallelize(List<String> partitions) throws IOException
ParallelMetricsRollup
parallelize
in interface ParallelMetricsRollup
partitions
- A list of collections to parallelize metrics computation across.IOException
- if an error occurs while constructing the underlying TupleStream for a partition.public TupleStream getSortedRollupStream(ParallelListStream plist, Metric[] rollupMetrics) throws IOException
ParallelMetricsRollup
getSortedRollupStream
in interface ParallelMetricsRollup
plist
- A parallel list stream to fetch metrics from each partition concurrentlyrollupMetrics
- An array of metrics to rollupIOException
- if an error occurs while reading from the sorted streamCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.