Uses of Interface
org.apache.solr.client.solrj.io.stream.expr.Expressible
-
Packages that use Expressible Package Description org.apache.solr.client.solrj.io Streaming Aggregation APIorg.apache.solr.client.solrj.io.comp Comparators for the Streaming Aggregation APIorg.apache.solr.client.solrj.io.eq Equalitors for the 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.ops Operations for the Streaming Aggregation APIorg.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 APIorg.apache.solr.client.solrj.io.stream.metrics Metrics package -
-
Uses of Expressible in org.apache.solr.client.solrj.io
Classes in org.apache.solr.client.solrj.io that implement Expressible Modifier and Type Class Description static class
Lang.LocalInputStream
-
Uses of Expressible in org.apache.solr.client.solrj.io.comp
Subinterfaces of Expressible in org.apache.solr.client.solrj.io.comp Modifier and Type Interface Description interface
StreamComparator
Defines a comparator we can use with TupleStreamsClasses in org.apache.solr.client.solrj.io.comp that implement Expressible Modifier and Type Class Description class
FieldComparator
An equality field Comparator which compares a field of two Tuples and determines sort order.class
MultipleFieldComparator
Wraps multiple Comparators to provide sub-sorting.class
SingleValueComparator
An equality Comparator to be used when a stream will only ever return a single field, ie, it has no sorted order -
Uses of Expressible in org.apache.solr.client.solrj.io.eq
Subinterfaces of Expressible in org.apache.solr.client.solrj.io.eq Modifier and Type Interface Description interface
StreamEqualitor
Defines a comparator we can use with TupleStreamsClasses in org.apache.solr.client.solrj.io.eq that implement Expressible Modifier and Type Class Description class
FieldEqualitor
An equality field Equalitor which compares a field of two Tuples and determines if they are equal.class
MultipleFieldEqualitor
Wraps multiple Equalitors. -
Uses of Expressible in org.apache.solr.client.solrj.io.eval
Subinterfaces of Expressible in org.apache.solr.client.solrj.io.eval Modifier and Type Interface Description interface
StreamEvaluator
-
Uses of Expressible in org.apache.solr.client.solrj.io.graph
Classes in org.apache.solr.client.solrj.io.graph that implement Expressible Modifier and Type Class Description class
GatherNodesStream
class
ShortestPathStream
-
Uses of Expressible in org.apache.solr.client.solrj.io.ops
Subinterfaces of Expressible in org.apache.solr.client.solrj.io.ops Modifier and Type Interface Description interface
ReduceOperation
interface
StreamOperation
Interface for any operation one can perform on a tuple in a TupleStreamClasses in org.apache.solr.client.solrj.io.ops that implement Expressible Modifier and Type Class Description class
ConcatOperation
Concatenates fields and adds them to the tuple.class
DistinctOperation
class
GroupOperation
class
ReplaceOperation
Replaces some tuple value with another.class
ReplaceWithFieldOperation
Implementation of replace(...., withField=fieldName) See ReplaceOperation for description.class
ReplaceWithValueOperation
Implementation of replace(...., withValue="some value") See ReplaceOperation for description. -
Uses of Expressible in org.apache.solr.client.solrj.io.stream
Classes in org.apache.solr.client.solrj.io.stream that implement Expressible Modifier and Type Class 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 collectionclass
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 deletedclass
DrillStream
class
EchoStream
class
EvalStream
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 equalitorclass
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 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
SortStream
The SortStream emits a stream of Tuples sorted by a Comparator.class
SqlStream
class
StatsStream
class
TextLogitStream
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 wrappedTupleStream
as updates to a SolrCloud collection.class
ZplotStream
-
Uses of Expressible in org.apache.solr.client.solrj.io.stream.expr
Methods in org.apache.solr.client.solrj.io.stream.expr that return types with arguments of type Expressible Modifier and Type Method Description Map<String,Supplier<Class<? extends Expressible>>>
StreamFactory. getFunctionNames()
Method parameters in org.apache.solr.client.solrj.io.stream.expr with type arguments of type Expressible Modifier and Type Method Description String
StreamFactory. getFunctionName(Class<? extends Expressible> clazz)
StreamFactory
StreamFactory. withFunctionName(String functionName, Class<? extends Expressible> clazz)
StreamFactory
StreamFactory. withFunctionName(String functionName, Supplier<Class<? extends Expressible>> clazz)
Constructor parameters in org.apache.solr.client.solrj.io.stream.expr with type arguments of type Expressible Constructor Description StreamFactory(HashMap<String,Supplier<Class<? extends Expressible>>> functionNames)
-
Uses of Expressible in org.apache.solr.client.solrj.io.stream.metrics
Classes in org.apache.solr.client.solrj.io.stream.metrics that implement Expressible Modifier and Type Class Description class
CountDistinctMetric
class
CountMetric
class
MaxMetric
class
MeanMetric
class
Metric
class
MinMetric
class
PercentileMetric
class
StdMetric
class
SumMetric
class
WeightedSumMetric
-