Uses of Package
org.apache.solr.client.solrj.io.stream
-
Packages that use org.apache.solr.client.solrj.io.stream Package Description org.apache.solr.client.solrj.io Streaming Aggregation APIorg.apache.solr.client.solrj.io.eval Evaluators for the Streaming Aggregation APIorg.apache.solr.client.solrj.io.graph Streaming Graph Traversalsorg.apache.solr.client.solrj.io.stream Stream implementations for the Streaming Aggregation APIorg.apache.solr.client.solrj.io.stream.expr Expression language for the Streaming Aggregation API -
Classes in org.apache.solr.client.solrj.io.stream used by org.apache.solr.client.solrj.io Class Description StreamContext The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.TupleStream -
Classes in org.apache.solr.client.solrj.io.stream used by org.apache.solr.client.solrj.io.eval Class Description StreamContext The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method. -
Classes in org.apache.solr.client.solrj.io.stream used by org.apache.solr.client.solrj.io.graph Class Description StreamContext The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.TupleStream -
Classes in org.apache.solr.client.solrj.io.stream used by org.apache.solr.client.solrj.io.stream Class Description BiJoinStream Joins leftStream with rightStream based on a Equalitor.CloudSolrStream Connects to Zookeeper to pick replicas from a specific collection to send the query to.CloudSolrStream.TupleWrapper CsvStream DaemonStream DeepRandomStream.TupleWrapper HashJoinStream Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.JDBCStream.ResultSetValueSelector JoinStream Defines a JoinStream which can hold N streams, all joined with the same equalitorJSONTupleStream ParallelListStream ParallelListStream.StreamIndex ParallelMetricsRollup Indicates the underlying stream source supports parallelizing metrics computation across collections using a rollup of metrics from each collection.PushBackStream A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.SolrStream Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.StreamContext The StreamContext is passed to TupleStreams using the TupleStream.setStreamContext() method.TupleStream TupleStreamParser UpdateStream Sends tuples emitted by a wrappedTupleStream
as updates to a SolrCloud collection. -
Classes in org.apache.solr.client.solrj.io.stream used by org.apache.solr.client.solrj.io.stream.expr Class Description TupleStream