Uses of Class
org.apache.solr.client.solrj.io.stream.expr.StreamFactory

Packages that use StreamFactory

Package	Description
org.apache.solr.client.solrj.io.comp	Comparators for the Streaming Aggregation API
org.apache.solr.client.solrj.io.eq	Equalitors for the Streaming Aggregation API
org.apache.solr.client.solrj.io.eval	Evaluators for the Streaming Aggregation API
org.apache.solr.client.solrj.io.graph	Streaming Graph Traversals
org.apache.solr.client.solrj.io.ops	Operations for the Streaming Aggregation API
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

Uses of StreamFactory in org.apache.solr.client.solrj.io.comp

Methods in org.apache.solr.client.solrj.io.comp with parameters of type StreamFactory

Modifier and Type	Method and Description
Explanation	MultipleFieldComparator.toExplanation(StreamFactory factory)
Explanation	SingleValueComparator.toExplanation(StreamFactory factory)
Explanation	FieldComparator.toExplanation(StreamFactory factory)
StreamExpressionParameter	MultipleFieldComparator.toExpression(StreamFactory factory)
StreamExpressionParameter	SingleValueComparator.toExpression(StreamFactory factory)
StreamExpressionParameter	FieldComparator.toExpression(StreamFactory factory)

Uses of StreamFactory in org.apache.solr.client.solrj.io.eq

Methods in org.apache.solr.client.solrj.io.eq with parameters of type StreamFactory

Modifier and Type	Method and Description
Explanation	FieldEqualitor.toExplanation(StreamFactory factory)
Explanation	MultipleFieldEqualitor.toExplanation(StreamFactory factory)
StreamExpressionParameter	FieldEqualitor.toExpression(StreamFactory factory)
StreamExpressionParameter	MultipleFieldEqualitor.toExpression(StreamFactory factory)

Uses of StreamFactory in org.apache.solr.client.solrj.io.eval

Fields in org.apache.solr.client.solrj.io.eval declared as StreamFactory

Modifier and Type	Field and Description
protected StreamFactory	ComplexEvaluator.constructingFactory

Methods in org.apache.solr.client.solrj.io.eval with parameters of type StreamFactory

Modifier and Type	Method and Description
Explanation	ConversionEvaluator.toExplanation(StreamFactory factory)
Explanation	TemporalEvaluator.toExplanation(StreamFactory factory)
Explanation	FieldEvaluator.toExplanation(StreamFactory factory)
Explanation	RawValueEvaluator.toExplanation(StreamFactory factory)
Explanation	UuidEvaluator.toExplanation(StreamFactory factory)
Explanation	ComplexEvaluator.toExplanation(StreamFactory factory)
StreamExpressionParameter	ConversionEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	TemporalEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	FieldEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	RawValueEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	UuidEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	ComplexEvaluator.toExpression(StreamFactory factory)

Constructors in org.apache.solr.client.solrj.io.eval with parameters of type StreamFactory

Constructor and Description
AbsoluteValueEvaluator(StreamExpression expression, StreamFactory factory)
AddEvaluator(StreamExpression expression, StreamFactory factory)
AndEvaluator(StreamExpression expression, StreamFactory factory)
ArcCosineEvaluator(StreamExpression expression, StreamFactory factory)
ArcSineEvaluator(StreamExpression expression, StreamFactory factory)
ArcTangentEvaluator(StreamExpression expression, StreamFactory factory)
BooleanEvaluator(StreamExpression expression, StreamFactory factory)
CeilingEvaluator(StreamExpression expression, StreamFactory factory)
CoalesceEvaluator(StreamExpression expression, StreamFactory factory)
ComplexEvaluator(StreamExpression expression, StreamFactory factory)
ConditionalEvaluator(StreamExpression expression, StreamFactory factory)
ConversionEvaluator(StreamExpression expression, StreamFactory factory)
CosineEvaluator(StreamExpression expression, StreamFactory factory)
CubedRootEvaluator(StreamExpression expression, StreamFactory factory)
DivideEvaluator(StreamExpression expression, StreamFactory factory)
EqualsEvaluator(StreamExpression expression, StreamFactory factory)
ExclusiveOrEvaluator(StreamExpression expression, StreamFactory factory)
FloorEvaluator(StreamExpression expression, StreamFactory factory)
GreaterThanEqualToEvaluator(StreamExpression expression, StreamFactory factory)
GreaterThanEvaluator(StreamExpression expression, StreamFactory factory)
HyperbolicCosineEvaluator(StreamExpression expression, StreamFactory factory)
HyperbolicSineEvaluator(StreamExpression expression, StreamFactory factory)
HyperbolicTangentEvaluator(StreamExpression expression, StreamFactory factory)
IfThenElseEvaluator(StreamExpression expression, StreamFactory factory)
LessThanEqualToEvaluator(StreamExpression expression, StreamFactory factory)
LessThanEvaluator(StreamExpression expression, StreamFactory factory)
ModuloEvaluator(StreamExpression expression, StreamFactory factory)
MultiplyEvaluator(StreamExpression expression, StreamFactory factory)
NaturalLogEvaluator(StreamExpression expression, StreamFactory factory)
NotEvaluator(StreamExpression expression, StreamFactory factory)
NumberEvaluator(StreamExpression expression, StreamFactory factory)
OrEvaluator(StreamExpression expression, StreamFactory factory)
PowerEvaluator(StreamExpression expression, StreamFactory factory)
RawValueEvaluator(StreamExpression expression, StreamFactory factory)
RoundEvaluator(StreamExpression expression, StreamFactory factory)
SineEvaluator(StreamExpression expression, StreamFactory factory)
SquareRootEvaluator(StreamExpression expression, StreamFactory factory)
SubtractEvaluator(StreamExpression expression, StreamFactory factory)
TangentEvaluator(StreamExpression expression, StreamFactory factory)
TemporalEvaluator(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorDay(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorDayOfQuarter(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorDayOfYear(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorEpoch(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorHour(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorMinute(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorMonth(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorQuarter(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorSecond(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorWeek(StreamExpression expression, StreamFactory factory)
TemporalEvaluatorYear(StreamExpression expression, StreamFactory factory)
UuidEvaluator(StreamExpression expression, StreamFactory factory)

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

Methods in org.apache.solr.client.solrj.io.graph with parameters of type StreamFactory

Modifier and Type	Method and Description
Explanation	GatherNodesStream.toExplanation(StreamFactory factory)
Explanation	ShortestPathStream.toExplanation(StreamFactory factory)
StreamExpression	GatherNodesStream.toExpression(StreamFactory factory)
StreamExpressionParameter	ShortestPathStream.toExpression(StreamFactory factory)

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

Constructor and Description
GatherNodesStream(StreamExpression expression, StreamFactory factory)
ShortestPathStream(StreamExpression expression, StreamFactory factory)

Uses of StreamFactory in org.apache.solr.client.solrj.io.ops

Methods in org.apache.solr.client.solrj.io.ops with parameters of type StreamFactory

Modifier and Type	Method and Description
Explanation	ReplaceWithValueOperation.toExplanation(StreamFactory factory)
Explanation	ConcatOperation.toExplanation(StreamFactory factory)
Explanation	GroupOperation.toExplanation(StreamFactory factory)
Explanation	ReplaceWithFieldOperation.toExplanation(StreamFactory factory)
Explanation	ReplaceOperation.toExplanation(StreamFactory factory)
Explanation	DistinctOperation.toExplanation(StreamFactory factory)
StreamExpressionParameter	ReplaceWithValueOperation.toExpression(StreamFactory factory)
StreamExpressionParameter	ConcatOperation.toExpression(StreamFactory factory)
StreamExpressionParameter	GroupOperation.toExpression(StreamFactory factory)
StreamExpressionParameter	ReplaceWithFieldOperation.toExpression(StreamFactory factory)
StreamExpressionParameter	ReplaceOperation.toExpression(StreamFactory factory)
StreamExpressionParameter	DistinctOperation.toExpression(StreamFactory factory)

Constructors in org.apache.solr.client.solrj.io.ops with parameters of type StreamFactory

Constructor and Description
ConcatOperation(StreamExpression expression, StreamFactory factory)
DistinctOperation(StreamExpression expression, StreamFactory factory)
GroupOperation(StreamExpression expression, StreamFactory factory)
ReplaceOperation(StreamExpression expression, StreamFactory factory)
ReplaceOperation(String forField, StreamExpression expression, StreamFactory factory)
ReplaceWithFieldOperation(String forField, StreamExpression expression, StreamFactory factory)
ReplaceWithValueOperation(String forField, StreamExpression expression, StreamFactory factory)

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

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

Modifier and Type	Method and Description
StreamFactory	StreamContext.getStreamFactory()

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

Modifier and Type	Method and Description
void	StreamContext.setStreamFactory(StreamFactory streamFactory)
void	ParallelStream.setStreamFactory(StreamFactory streamFactory)
Explanation	ColumnEvaluator.toExplanation(StreamFactory factory)
Explanation	PushBackStream.toExplanation(StreamFactory factory)
Explanation	JoinStream.toExplanation(StreamFactory factory)
Explanation	RollupStream.toExplanation(StreamFactory factory)
Explanation	UniqueStream.toExplanation(StreamFactory factory)
Explanation	RankStream.toExplanation(StreamFactory factory)
Explanation	NullStream.toExplanation(StreamFactory factory)
Explanation	CartesianProductStream.toExplanation(StreamFactory factory)
Explanation	PriorityStream.toExplanation(StreamFactory factory)
Explanation	JDBCStream.toExplanation(StreamFactory factory)
Explanation	FacetStream.toExplanation(StreamFactory factory)
Explanation	GetStream.toExplanation(StreamFactory factory)
Explanation	HashJoinStream.toExplanation(StreamFactory factory)
Explanation	ScoreNodesStream.toExplanation(StreamFactory factory)
Explanation	SolrStream.toExplanation(StreamFactory factory)
Explanation	TextLogitStream.toExplanation(StreamFactory factory)
Explanation	TextLogitStream.TermsStream.toExplanation(StreamFactory factory)
Explanation	ExceptionStream.toExplanation(StreamFactory factory)
Explanation	MergeStream.toExplanation(StreamFactory factory)
Explanation	ComplementStream.toExplanation(StreamFactory factory)
Explanation	CloudSolrStream.toExplanation(StreamFactory factory)
Explanation	TopicStream.toExplanation(StreamFactory factory)
Explanation	UpdateStream.toExplanation(StreamFactory factory)
Explanation	PredictEvaluator.toExplanation(StreamFactory factory)
Explanation	SelectStream.toExplanation(StreamFactory factory)
Explanation	EvalStream.toExplanation(StreamFactory factory)
Explanation	FeaturesSelectionStream.toExplanation(StreamFactory factory)
Explanation	CellStream.toExplanation(StreamFactory factory)
Explanation	EchoStream.toExplanation(StreamFactory factory)
Explanation	FetchStream.toExplanation(StreamFactory factory)
Explanation	ExecutorStream.toExplanation(StreamFactory factory)
Explanation	ParallelStream.toExplanation(StreamFactory factory)
Explanation	RegressionEvaluator.toExplanation(StreamFactory factory)
Explanation	ListStream.toExplanation(StreamFactory factory)
Explanation	LetStream.toExplanation(StreamFactory factory)
Explanation	HavingStream.toExplanation(StreamFactory factory)
Explanation	ConvolutionEvaluator.toExplanation(StreamFactory factory)
Explanation	SignificantTermsStream.toExplanation(StreamFactory factory)
Explanation	CovarianceEvaluator.toExplanation(StreamFactory factory)
Explanation	RandomStream.toExplanation(StreamFactory factory)
Explanation	CalculatorStream.toExplanation(StreamFactory factory)
Explanation	TimeSeriesStream.toExplanation(StreamFactory factory)
Explanation	CommitStream.toExplanation(StreamFactory factory)
abstract Explanation	TupleStream.toExplanation(StreamFactory factory)
Explanation	StatsStream.toExplanation(StreamFactory factory)
Explanation	IntersectStream.toExplanation(StreamFactory factory)
Explanation	TupStream.toExplanation(StreamFactory factory)
Explanation	NormalizeEvaluator.toExplanation(StreamFactory factory)
Explanation	CorrelationEvaluator.toExplanation(StreamFactory factory)
Explanation	DaemonStream.toExplanation(StreamFactory factory)
Explanation	ReducerStream.toExplanation(StreamFactory factory)
Explanation	SortStream.toExplanation(StreamFactory factory)
Explanation	ModelStream.toExplanation(StreamFactory factory)
StreamExpressionParameter	ColumnEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	PushBackStream.toExpression(StreamFactory factory)
StreamExpression	JoinStream.toExpression(StreamFactory factory)
StreamExpression	RollupStream.toExpression(StreamFactory factory)
StreamExpression	UniqueStream.toExpression(StreamFactory factory)
StreamExpression	RankStream.toExpression(StreamFactory factory)
StreamExpression	NullStream.toExpression(StreamFactory factory)
StreamExpression	CartesianProductStream.toExpression(StreamFactory factory)
StreamExpression	PriorityStream.toExpression(StreamFactory factory)
StreamExpressionParameter	JDBCStream.toExpression(StreamFactory factory)
StreamExpressionParameter	FacetStream.toExpression(StreamFactory factory)
StreamExpression	GetStream.toExpression(StreamFactory factory)
StreamExpression	HashJoinStream.toExpression(StreamFactory factory)
StreamExpression	ScoreNodesStream.toExpression(StreamFactory factory)
StreamExpressionParameter	TextLogitStream.toExpression(StreamFactory factory)
StreamExpression	MergeStream.toExpression(StreamFactory factory)
StreamExpression	ComplementStream.toExpression(StreamFactory factory)
StreamExpression	CloudSolrStream.toExpression(StreamFactory factory)
StreamExpression	TopicStream.toExpression(StreamFactory factory)
StreamExpression	UpdateStream.toExpression(StreamFactory factory)
StreamExpressionParameter	PredictEvaluator.toExpression(StreamFactory factory)
StreamExpression	SelectStream.toExpression(StreamFactory factory)
StreamExpression	EvalStream.toExpression(StreamFactory factory)
StreamExpressionParameter	FeaturesSelectionStream.toExpression(StreamFactory factory)
StreamExpression	CellStream.toExpression(StreamFactory factory)
StreamExpression	EchoStream.toExpression(StreamFactory factory)
StreamExpression	FetchStream.toExpression(StreamFactory factory)
StreamExpression	ExecutorStream.toExpression(StreamFactory factory)
StreamExpression	ParallelStream.toExpression(StreamFactory factory)
StreamExpressionParameter	RegressionEvaluator.toExpression(StreamFactory factory)
StreamExpression	ListStream.toExpression(StreamFactory factory)
StreamExpression	LetStream.toExpression(StreamFactory factory)
StreamExpression	HavingStream.toExpression(StreamFactory factory)
StreamExpression	OuterHashJoinStream.toExpression(StreamFactory factory)
StreamExpressionParameter	ConvolutionEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	SignificantTermsStream.toExpression(StreamFactory factory)
StreamExpressionParameter	CovarianceEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	RandomStream.toExpression(StreamFactory factory)
StreamExpression	CalculatorStream.toExpression(StreamFactory factory)
StreamExpressionParameter	TimeSeriesStream.toExpression(StreamFactory factory)
StreamExpression	CommitStream.toExpression(StreamFactory factory)
StreamExpressionParameter	StatsStream.toExpression(StreamFactory factory)
StreamExpression	IntersectStream.toExpression(StreamFactory factory)
StreamExpression	TupStream.toExpression(StreamFactory factory)
StreamExpressionParameter	NormalizeEvaluator.toExpression(StreamFactory factory)
StreamExpressionParameter	CorrelationEvaluator.toExpression(StreamFactory factory)
StreamExpression	DaemonStream.toExpression(StreamFactory factory)
StreamExpression	ReducerStream.toExpression(StreamFactory factory)
StreamExpression	SortStream.toExpression(StreamFactory factory)
StreamExpressionParameter	ModelStream.toExpression(StreamFactory factory)

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

Constructor and Description
BiJoinStream(StreamExpression expression, StreamFactory factory)
CalculatorStream(StreamExpression expression, StreamFactory factory)
CartesianProductStream(StreamExpression expression, StreamFactory factory)
CellStream(StreamExpression expression, StreamFactory factory)
CloudSolrStream(StreamExpression expression, StreamFactory factory)
ColumnEvaluator(StreamExpression expression, StreamFactory factory)
CommitStream(StreamExpression expression, StreamFactory factory)
ComplementStream(StreamExpression expression, StreamFactory factory)
ConvolutionEvaluator(StreamExpression expression, StreamFactory factory)
CorrelationEvaluator(StreamExpression expression, StreamFactory factory)
CovarianceEvaluator(StreamExpression expression, StreamFactory factory)
DaemonStream(StreamExpression expression, StreamFactory factory)
EchoStream(StreamExpression expression, StreamFactory factory)
EvalStream(StreamExpression expression, StreamFactory factory)
ExecutorStream(StreamExpression expression, StreamFactory factory)
FacetStream(StreamExpression expression, StreamFactory factory)
FeaturesSelectionStream(StreamExpression expression, StreamFactory factory) logit(collection, zkHost="", features="a,b,c,d,e,f,g", outcome="y", maxIteration="20")
FetchStream(StreamExpression expression, StreamFactory factory)
GetStream(StreamExpression expression, StreamFactory factory)
HashJoinStream(StreamExpression expression, StreamFactory factory)
HavingStream(StreamExpression expression, StreamFactory factory)
InnerJoinStream(StreamExpression expression, StreamFactory factory)
IntersectStream(StreamExpression expression, StreamFactory factory)
JDBCStream(StreamExpression expression, StreamFactory factory)
JoinStream(StreamExpression expression, StreamFactory factory)
LeftOuterJoinStream(StreamExpression expression, StreamFactory factory)
LetStream(StreamExpression expression, StreamFactory factory)
ListStream(StreamExpression expression, StreamFactory factory)
MergeStream(StreamExpression expression, StreamFactory factory)
ModelStream(StreamExpression expression, StreamFactory factory)
NormalizeEvaluator(StreamExpression expression, StreamFactory factory)
NullStream(StreamExpression expression, StreamFactory factory)
OuterHashJoinStream(StreamExpression expression, StreamFactory factory)
ParallelStream(StreamExpression expression, StreamFactory factory)
PredictEvaluator(StreamExpression expression, StreamFactory factory)
PriorityStream(StreamExpression expression, StreamFactory factory)
RandomStream(StreamExpression expression, StreamFactory factory)
RankStream(StreamExpression expression, StreamFactory factory)
ReducerStream(StreamExpression expression, StreamFactory factory)
RegressionEvaluator(StreamExpression expression, StreamFactory factory)
RollupStream(StreamExpression expression, StreamFactory factory)
ScoreNodesStream(StreamExpression expression, StreamFactory factory)
SelectStream(StreamExpression expression, StreamFactory factory)
ShuffleStream(StreamExpression expression, StreamFactory factory)
SignificantTermsStream(StreamExpression expression, StreamFactory factory)
SortStream(StreamExpression expression, StreamFactory factory)
StatsStream(StreamExpression expression, StreamFactory factory)
StreamTask(ArrayBlockingQueue queue, StreamFactory streamFactory, StreamContext streamContext)
TextLogitStream(StreamExpression expression, StreamFactory factory) logit(collection, zkHost="", features="a,b,c,d,e,f,g", outcome="y", maxIteration="20")
TimeSeriesStream(StreamExpression expression, StreamFactory factory)
TopicStream(StreamExpression expression, StreamFactory factory)
TupStream(StreamExpression expression, StreamFactory factory)
UniqueStream(StreamExpression expression, StreamFactory factory)
UpdateStream(StreamExpression expression, StreamFactory factory)

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

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

Modifier and Type	Method and Description
StreamFactory	StreamFactory.withCollectionZkHost(String collectionName, String zkHost)
StreamFactory	StreamFactory.withDefaultZkHost(String zkHost)
StreamFactory	StreamFactory.withFunctionName(String functionName, Class<? extends Expressible> clazz)

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

Modifier and Type	Method and Description
Explanation	Expressible.toExplanation(StreamFactory factory) Returns an explanation about the stream object
StreamExpressionParameter	Expressible.toExpression(StreamFactory factory)

Uses of StreamFactory in org.apache.solr.client.solrj.io.stream.metrics

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

Modifier and Type	Method and Description
Explanation	Metric.toExplanation(StreamFactory factory)
StreamExpressionParameter	CountMetric.toExpression(StreamFactory factory)
StreamExpressionParameter	SumMetric.toExpression(StreamFactory factory)
StreamExpressionParameter	MeanMetric.toExpression(StreamFactory factory)
StreamExpressionParameter	MaxMetric.toExpression(StreamFactory factory)
StreamExpressionParameter	MinMetric.toExpression(StreamFactory factory)

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

Constructor and Description
CountMetric(StreamExpression expression, StreamFactory factory)
MaxMetric(StreamExpression expression, StreamFactory factory)
MeanMetric(StreamExpression expression, StreamFactory factory)
MinMetric(StreamExpression expression, StreamFactory factory)
SumMetric(StreamExpression expression, StreamFactory factory)