Uses of Class
org.apache.solr.client.solrj.io.stream.TupleStream

Packages that use TupleStream

Package	Description
org.apache.solr.client.solrj.io	Streaming Aggregation API
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

Uses of TupleStream in org.apache.solr.client.solrj.io

Subclasses of TupleStream in org.apache.solr.client.solrj.io

Modifier and Type	Class	Description
static class	Lang.LocalInputStream

Methods in org.apache.solr.client.solrj.io that return types with arguments of type TupleStream

Modifier and Type	Method	Description
List<TupleStream>	Lang.LocalInputStream.children()

Uses of TupleStream in org.apache.solr.client.solrj.io.graph

Subclasses of TupleStream in org.apache.solr.client.solrj.io.graph

Modifier and Type	Class	Description
class	GatherNodesStream
class	ShortestPathStream

Methods in org.apache.solr.client.solrj.io.graph that return types with arguments of type TupleStream

Modifier and Type	Method	Description
List<TupleStream>	GatherNodesStream.children()
List<TupleStream>	ShortestPathStream.children()

Constructors in org.apache.solr.client.solrj.io.graph with parameters of type TupleStream

Modifier	Constructor	Description
	GatherNodesStream(String zkHost, String collection, TupleStream tupleStream, String traverseFrom, String traverseTo, String gather, Map<String,String> queryParams, List<Metric> metrics, boolean trackTraversal, Set<Traversal.Scatter> scatter, int maxDocFreq)

Uses of TupleStream in org.apache.solr.client.solrj.io.stream

Subclasses of TupleStream in org.apache.solr.client.solrj.io.stream

Modifier and Type	Class	Description
class	BiJoinStream	Joins leftStream with rightStream based on an StreamEqualitor.
class	CalculatorStream
class	CartesianProductStream
class	CellStream
class	CloudSolrStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
class	CommitStream	Sends a commit message to a SolrCloud collection
class	ComplementStream	Emits tuples from streamA which do not exist in streamB.
class	CsvStream
class	DaemonStream
class	DeepRandomStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
final class	DeleteStream	Uses tuples to identify the uniqueKey values of documents to be deleted
class	DrillStream
class	EchoStream
class	EvalStream
class	ExceptionStream
class	ExecutorStream	The executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel.
class	Facet2DStream
class	FacetStream	The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.
class	FeaturesSelectionStream
class	FetchStream	Iterates over a stream and fetches additional fields from a specified collection.
class	FullOuterJoinStream	Joins leftStream with rightStream based on an Equalitor.
class	GetStream
class	HashJoinStream	Takes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.
class	HashRollupStream
class	HavingStream	The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.
class	InnerJoinStream	Joins leftStream with rightStream based on an Equalitor.
class	IntersectStream	Emits tuples from streamA which also exist in streamB.
class	JDBCStream	Connects to a datasource using a registered JDBC driver and execute a query.
class	JoinStream	Defines a JoinStream which can hold N streams, all joined with the same equalitor
class	KnnStream
class	LeftOuterJoinStream	Joins leftStream with rightStream based on an Equalitor.
class	LetStream
class	ListStream
class	MergeStream	Merges two or more streams together ordering the Tuples based on a Comparator.
class	ModelStream	The ModelStream retrieves a stored model from a Solr Cloud collection.
class	NoOpStream	A simple no-operation stream.
class	NullStream	The NullStream Iterates over a TupleStream and eats the tuples.
class	OuterHashJoinStream	Takes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.
class	ParallelListStream
class	ParallelStream	The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
class	PlotStream
class	PriorityStream	The priority function wraps two topics that represent high priority and low priority task queues.
class	PushBackStream	A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
class	RandomFacadeStream
class	RandomStream	The RandomStream emits a stream of pseudo random Tuples that match the query parameters.
class	RankStream	Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
class	ReducerStream	Iterates over a TupleStream and buffers Tuples that are equal based on a comparator.
class	RollupStream
class	ScoreNodesStream	Iterates over a gatherNodes() expression and scores the Tuples based on tf-idf.
class	SearchFacadeStream	Connects to Zookeeper to pick replicas from a specific collection to send the query to.
class	SearchStream
class	SelectStream	Selects fields from the incoming stream and applies optional field renaming.
class	ShuffleStream
class	SignificantTermsStream
class	SolrStream	Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
class	SortStream	The SortStream emits a stream of Tuples sorted by a Comparator.
class	SqlStream
class	StatsStream
class	TextLogitStream
protected static class	TextLogitStream.TermsStream
class	TimeSeriesStream
class	TopicStream
class	TsvStream
class	TupStream
class	UniqueStream	The UniqueStream emits a unique stream of Tuples based on a Comparator.
class	UpdateStream	Sends tuples emitted by a wrapped TupleStream as updates to a SolrCloud collection.
class	ZplotStream

Fields in org.apache.solr.client.solrj.io.stream declared as TupleStream

Modifier and Type	Field	Description
protected TupleStream	HashJoinStream.fullStream
protected TupleStream	HashJoinStream.hashStream
protected TupleStream	CsvStream.originalStream
protected TupleStream	FacetStream.parallelizedStream
protected TupleStream	StatsStream.parallelizedStream
protected TupleStream	TextLogitStream.termsStream
protected TupleStream	SqlStream.tupleStream

Fields in org.apache.solr.client.solrj.io.stream with type parameters of type TupleStream

Modifier and Type	Field	Description
protected List<TupleStream>	CloudSolrStream.solrStreams
protected List<TupleStream>	DeepRandomStream.solrStreams

Methods in org.apache.solr.client.solrj.io.stream that return TupleStream

Modifier and Type	Method	Description
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.
TupleStream	StatsStream.getSortedRollupStream(ParallelListStream plist, Metric[] rollupMetrics)
TupleStream	ParallelListStream.StreamIndex.getTupleStream()
TupleStream[]	FacetStream.parallelize(List<String> partitions)
TupleStream[]	ParallelMetricsRollup.parallelize(List<String> partitions)	Given a list of collections, return an array of TupleStream for each partition.
TupleStream[]	StatsStream.parallelize(List<String> partitions)

Methods in org.apache.solr.client.solrj.io.stream that return types with arguments of type TupleStream

Modifier and Type	Method	Description
List<TupleStream>	CalculatorStream.children()
List<TupleStream>	CartesianProductStream.children()
List<TupleStream>	CellStream.children()
List<TupleStream>	CloudSolrStream.children()
List<TupleStream>	CommitStream.children()
List<TupleStream>	ComplementStream.children()
List<TupleStream>	CsvStream.children()
List<TupleStream>	DaemonStream.children()
List<TupleStream>	DeepRandomStream.children()
List<TupleStream>	DrillStream.children()
List<TupleStream>	EchoStream.children()
List<TupleStream>	EvalStream.children()
List<TupleStream>	ExceptionStream.children()
List<TupleStream>	ExecutorStream.children()
List<TupleStream>	Facet2DStream.children()
List<TupleStream>	FacetStream.children()
List<TupleStream>	FeaturesSelectionStream.children()
List<TupleStream>	FetchStream.children()
List<TupleStream>	GetStream.children()
List<TupleStream>	HashJoinStream.children()
List<TupleStream>	HashRollupStream.children()
List<TupleStream>	HavingStream.children()
List<TupleStream>	IntersectStream.children()
List<TupleStream>	JDBCStream.children()
List<TupleStream>	JoinStream.children()
List<TupleStream>	KnnStream.children()
List<TupleStream>	LetStream.children()
List<TupleStream>	ListStream.children()
List<TupleStream>	MergeStream.children()
List<TupleStream>	ModelStream.children()
List<TupleStream>	NoOpStream.children()
List<TupleStream>	NullStream.children()
List<TupleStream>	ParallelListStream.children()
List<TupleStream>	ParallelStream.children()
List<TupleStream>	PlotStream.children()
List<TupleStream>	PriorityStream.children()
List<TupleStream>	PushBackStream.children()
List<TupleStream>	RandomFacadeStream.children()
List<TupleStream>	RandomStream.children()
List<TupleStream>	RankStream.children()
List<TupleStream>	ReducerStream.children()
List<TupleStream>	RollupStream.children()
List<TupleStream>	ScoreNodesStream.children()
List<TupleStream>	SearchFacadeStream.children()
List<TupleStream>	SearchStream.children()
List<TupleStream>	SelectStream.children()
List<TupleStream>	SignificantTermsStream.children()
List<TupleStream>	SolrStream.children()
List<TupleStream>	SortStream.children()
List<TupleStream>	SqlStream.children()
List<TupleStream>	StatsStream.children()
List<TupleStream>	TextLogitStream.children()
List<TupleStream>	TextLogitStream.TermsStream.children()
List<TupleStream>	TimeSeriesStream.children()
List<TupleStream>	TopicStream.children()
abstract List<TupleStream>	TupleStream.children()
List<TupleStream>	TupStream.children()
List<TupleStream>	UniqueStream.children()
List<TupleStream>	UpdateStream.children()
List<TupleStream>	ZplotStream.children()
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.

Methods in org.apache.solr.client.solrj.io.stream with parameters of type TupleStream

Modifier and Type	Method	Description
void	DaemonStream.init(TupleStream tupleStream, String id, long runInterval, int queueSize)
void	DaemonStream.init(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)

Constructors in org.apache.solr.client.solrj.io.stream with parameters of type TupleStream

Modifier	Constructor	Description
	BiJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)
	CellStream(String name, TupleStream stream)
	CommitStream(String collectionName, TupleStream tupleSource, String zkHost, int batchSize, boolean waitFlush, boolean waitSearcher, boolean softCommit)
	ComplementStream(TupleStream streamA, TupleStream streamB, StreamEqualitor eq)
	DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize)
	DaemonStream(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate)
	DrillStream(String zkHost, String collection, TupleStream tupleStream, StreamComparator comp, String sortParam, String flParam, String qParam)
	ExceptionStream(TupleStream stream)
	FetchStream(String zkHost, String collection, TupleStream tupleStream, String on, String fieldList, int batchSize)
	FullOuterJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)
	HashJoinStream(TupleStream fullStream, TupleStream hashStream, List<String> hashOn)
	HashRollupStream(TupleStream tupleStream, Bucket[] buckets, Metric[] metrics)
	HavingStream(TupleStream stream, RecursiveBooleanEvaluator evaluator)
	InnerJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)
	IntersectStream(TupleStream streamA, TupleStream streamB, StreamEqualitor eq)
	JoinStream(StreamEqualitor eq, TupleStream first, TupleStream second, TupleStream... others)
	LeftOuterJoinStream(TupleStream leftStream, TupleStream rightStream, StreamEqualitor eq)
	ListStream(TupleStream... streams)
	MergeStream(StreamComparator comp, TupleStream... streams)
	MergeStream(TupleStream streamA, TupleStream streamB, StreamComparator comp)
	NullStream(TupleStream tupleStream)
	OuterHashJoinStream(TupleStream fullStream, TupleStream hashStream, List<String> hashOn)
	ParallelListStream(TupleStream... streams)
	ParallelStream(String zkHost, String collection, TupleStream tupleStream, int workers, StreamComparator comp)
	PushBackStream(TupleStream stream)
	RankStream(TupleStream tupleStream, int size, StreamComparator comp)
	ReducerStream(TupleStream stream, StreamComparator comp, ReduceOperation op)
	ReducerStream(TupleStream stream, StreamEqualitor eq, ReduceOperation op)
	RollupStream(TupleStream tupleStream, Bucket[] buckets, Metric[] metrics)
	ScoreNodesStream(TupleStream tupleStream, String nodeFreqField)
	SelectStream(TupleStream stream, List<String> selectedFields)
	SelectStream(TupleStream stream, Map<String,String> selectedFields)
	SortStream(TupleStream stream, StreamComparator comp)
	StreamIndex(TupleStream tupleStream, int index)
	TextLogitStream(String zkHost, String collectionName, Map<String,String> params, String name, String field, TupleStream termsStream, List<Double> weights, String outcome, int positiveLabel, double threshold, int maxIterations)
	UniqueStream(TupleStream stream, StreamEqualitor eq)
	UpdateStream(String collectionName, TupleStream tupleSource, String zkHost, int updateBatchSize)

Uses of TupleStream in org.apache.solr.client.solrj.io.stream.expr

Methods in org.apache.solr.client.solrj.io.stream.expr that return TupleStream

Modifier and Type	Method	Description
TupleStream	StreamFactory.constructStream(String expressionClause)
TupleStream	StreamFactory.constructStream(StreamExpression expression)