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 and 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 and 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 and 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 and Description
List<TupleStream>	GatherNodesStream.children()
List<TupleStream>	ShortestPathStream.children()

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

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)

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 and Description
class	BiJoinStream Joins leftStream with rightStream based on a Equalitor.
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.
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	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 a 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 a 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 psuedo 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 and Description
protected TupleStream	HashJoinStream.fullStream
protected TupleStream	HashJoinStream.hashStream
protected TupleStream	CsvStream.originalStream
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 and Description
protected List<TupleStream>	DeepRandomStream.solrStreams
protected List<TupleStream>	CloudSolrStream.solrStreams

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

Modifier and Type	Method and Description
TupleStream	ParallelListStream.StreamIndex.getTupleStream()

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

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

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

Modifier and Type	Method and 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

Constructor and 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)
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)
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 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 and Description
TupleStream	StreamFactory.constructStream(StreamExpression expression)
TupleStream	StreamFactory.constructStream(String expressionClause)