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 classLang.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 interfaceStreamComparatorDefines a comparator we can use with TupleStreamsClasses in org.apache.solr.client.solrj.io.comp that implement Expressible Modifier and Type Class Description classFieldComparatorAn equality field Comparator which compares a field of two Tuples and determines sort order.classMultipleFieldComparatorWraps multiple Comparators to provide sub-sorting.classSingleValueComparatorAn 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 interfaceStreamEqualitorDefines a comparator we can use with TupleStreamsClasses in org.apache.solr.client.solrj.io.eq that implement Expressible Modifier and Type Class Description classFieldEqualitorAn equality field Equalitor which compares a field of two Tuples and determines if they are equal.classMultipleFieldEqualitorWraps 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 interfaceStreamEvaluator -
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 classGatherNodesStreamclassShortestPathStream -
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 interfaceReduceOperationinterfaceStreamOperationInterface 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 classConcatOperationConcatenates fields and adds them to the tuple.classDistinctOperationclassGroupOperationclassReplaceOperationReplaces some tuple value with another.classReplaceWithFieldOperationImplementation of replace(...., withField=fieldName) See ReplaceOperation for description.classReplaceWithValueOperationImplementation 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 classBiJoinStreamJoins leftStream with rightStream based on anStreamEqualitor.classCalculatorStreamclassCartesianProductStreamclassCellStreamclassCloudSolrStreamConnects to Zookeeper to pick replicas from a specific collection to send the query to.classCommitStreamSends a commit message to a SolrCloud collectionclassComplementStreamEmits tuples from streamA which do not exist in streamB.classCsvStreamclassDaemonStreamclassDeepRandomStreamConnects to Zookeeper to pick replicas from a specific collection to send the query to.classDeleteStreamUses tuples to identify the uniqueKey values of documents to be deletedclassDrillStreamclassEchoStreamclassEvalStreamclassExecutorStreamThe executor function wraps a stream with Tuples containing Streaming Expressions and executes them in parallel.classFacet2DStreamclassFacetStreamThe FacetStream abstracts the output from the JSON facet API as a Stream of Tuples.classFeaturesSelectionStreamclassFetchStreamIterates over a stream and fetches additional fields from a specified collection.classGetStreamclassHashJoinStreamTakes two streams (fullStream and hashStream) and joins them similar to an InnerJoinStream.classHashRollupStreamclassHavingStreamThe HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple.classInnerJoinStreamJoins leftStream with rightStream based on an Equalitor.classIntersectStreamEmits tuples from streamA which also exist in streamB.classJDBCStreamConnects to a datasource using a registered JDBC driver and execute a query.classJoinStreamDefines a JoinStream which can hold N streams, all joined with the same equalitorclassKnnStreamclassLeftOuterJoinStreamJoins leftStream with rightStream based on an Equalitor.classLetStreamclassListStreamclassMergeStreamMerges two or more streams together ordering the Tuples based on a Comparator.classModelStreamThe ModelStream retrieves a stored model from a Solr Cloud collection.classNoOpStreamA simple no-operation stream.classNullStreamThe NullStream Iterates over a TupleStream and eats the tuples.classOuterHashJoinStreamTakes two streams (fullStream and hashStream) and joins them similar to an LeftOuterJoinStream.classParallelListStreamclassParallelStreamThe ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.classPlotStreamclassPriorityStreamThe priority function wraps two topics that represent high priority and low priority task queues.classPushBackStreamA TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.classRandomFacadeStreamclassRandomStreamThe RandomStream emits a stream of pseudo random Tuples that match the query parameters.classRankStreamIterates over a TupleStream and Ranks the topN tuples based on a Comparator.classReducerStreamIterates over a TupleStream and buffers Tuples that are equal based on a comparator.classRollupStreamclassScoreNodesStreamIterates over a gatherNodes() expression and scores the Tuples based on tf-idf.classSearchFacadeStreamConnects to Zookeeper to pick replicas from a specific collection to send the query to.classSearchStreamclassSelectStreamSelects fields from the incoming stream and applies optional field renaming.classShuffleStreamclassSignificantTermsStreamclassSortStreamThe SortStream emits a stream of Tuples sorted by a Comparator.classSqlStreamclassStatsStreamclassTextLogitStreamclassTimeSeriesStreamclassTopicStreamclassTsvStreamclassTupStreamclassUniqueStreamThe UniqueStream emits a unique stream of Tuples based on a Comparator.classUpdateStreamSends tuples emitted by a wrappedTupleStreamas updates to a SolrCloud collection.classZplotStream -
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 StringStreamFactory. getFunctionName(Class<? extends Expressible> clazz)StreamFactoryStreamFactory. withFunctionName(String functionName, Class<? extends Expressible> clazz)StreamFactoryStreamFactory. 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 classCountDistinctMetricclassCountMetricclassMaxMetricclassMeanMetricclassMetricclassMinMetricclassPercentileMetricclassStdMetricclassSumMetricclassWeightedSumMetric
-