Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-11490: Add missing @since tags 

To all descendants of TupleStream
This commit is contained in:
Alexandre Rafalovitch 2017-10-18 21:38:51 -04:00
parent 18c8091da5
commit 70784f4561
59 changed files with 145 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
solr/core/src/java/org/apache/solr/handler/CalciteJDBCStream.java
View File

@ -30,6 +30,7 @@ import org.apache.solr.client.solrj.io.stream.JDBCStream;
* Used with o.a.s.Handler.SQLHandler.
*
* @lucene.internal
* @since 7.0.0
*/
public class CalciteJDBCStream extends JDBCStream {
private static final long serialVersionUID = 1L;

3
solr/core/src/java/org/apache/solr/handler/ClassifyStream.java
View File

@ -43,6 +43,7 @@ import org.apache.lucene.analysis.*;
* The classify expression retrieves a model trained by the train expression and uses it to classify documents from a stream
* Syntax:
* classif(model(...), anyStream(...), field="body")
* @since 6.3.0
**/
public class ClassifyStream extends TupleStream implements Expressible {
@ -225,4 +226,4 @@ public class ClassifyStream extends TupleStream implements Expressible {
return explanation;
}
}
}

3
solr/core/src/java/org/apache/solr/handler/GraphHandler.java
View File

@ -59,6 +59,9 @@ import org.slf4j.LoggerFactory;
import static org.apache.solr.common.params.CommonParams.SORT;
/**
* @since 6.1.0
*/
public class GraphHandler extends RequestHandlerBase implements SolrCoreAware, PermissionNameProvider {
private StreamFactory streamFactory = new StreamFactory();

3
solr/core/src/java/org/apache/solr/handler/StreamHandler.java
View File

@ -70,6 +70,9 @@ import org.slf4j.LoggerFactory;
import static org.apache.solr.common.params.CommonParams.ID;
import static org.apache.solr.common.params.CommonParams.SORT;
/**
* @since 5.1.0
*/
public class StreamHandler extends RequestHandlerBase implements SolrCoreAware, PermissionNameProvider {
static SolrClientCache clientCache = new SolrClientCache();

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/graph/GatherNodesStream.java
View File

@ -53,6 +53,9 @@ import org.apache.solr.common.util.SolrjNamedThreadFactory;
import static org.apache.solr.common.params.CommonParams.SORT;
/**
* @since 6.1.0
*/
public class GatherNodesStream extends TupleStream implements Expressible {
private String zkHost;
@ -674,4 +677,4 @@ public class GatherNodesStream extends TupleStream implements Expressible {
.withExpression("non-expressible");
}
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/graph/ShortestPathStream.java
View File

@ -53,6 +53,9 @@ import org.apache.solr.common.util.SolrjNamedThreadFactory;
import static org.apache.solr.common.params.CommonParams.SORT;
/**
* @since 6.1.0
*/
public class ShortestPathStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/BiJoinStream.java
View File

@ -30,6 +30,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Joins leftStream with rightStream based on a Equalitor. Both streams must be sorted by the fields being joined on.
* Resulting stream is sorted by the equalitor.
* @since 6.0.0
**/
public abstract class BiJoinStream extends JoinStream implements Expressible {

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CalculatorStream.java
View File

@ -30,6 +30,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExplanation;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpression;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class CalculatorStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -106,4 +109,4 @@ public class CalculatorStream extends TupleStream implements Expressible {
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CartesianProductStream.java
View File

@ -41,6 +41,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParser;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionValue;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class CartesianProductStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -304,4 +307,4 @@ public class CartesianProductStream extends TupleStream implements Expressible {
return evaluator;
}
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CellStream.java
View File

@ -32,6 +32,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExplanation;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpression;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class CellStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -149,4 +152,4 @@ public class CellStream extends TupleStream implements Expressible {
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
View File

@ -65,6 +65,7 @@ import static org.apache.solr.common.params.CommonParams.SORT;
* Under the covers the SolrStream instances send the query to the replicas.
* SolrStreams are opened using a thread pool, but a single thread is used
* to iterate and merge Tuples from each SolrStream.
* @since 5.1.0
**/
public class CloudSolrStream extends TupleStream implements Expressible {

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CommitStream.java
View File

@ -39,6 +39,7 @@ import org.slf4j.LoggerFactory;
/**
* Sends a commit message to a SolrCloud collection
* @since 6.3.0
*/
public class CommitStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1L;

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ComplementStream.java
View File

@ -37,6 +37,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Emits tuples from streamA which do not exist in streamB. Resulting tuples are ordered
* the same as they were in streamA. Both streams must be sorted by the fields being compared.
* @since 6.0.0
**/
public class ComplementStream extends TupleStream implements Expressible {

6
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
View File

@ -41,7 +41,9 @@ import org.slf4j.LoggerFactory;
import static org.apache.solr.common.params.CommonParams.ID;
/**
* @since 6.0.0
*/
public class DaemonStream extends TupleStream implements Expressible {
private TupleStream tupleStream;
@ -372,4 +374,4 @@ public class DaemonStream extends TupleStream implements Expressible {
setStopTime(new Date().getTime());
}
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/EchoStream.java
View File

@ -30,6 +30,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExplanation;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpression;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class EchoStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -116,4 +119,4 @@ public class EchoStream extends TupleStream implements Expressible {
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/EvalStream.java
View File

@ -34,6 +34,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @since 6.6.0
*/
public class EvalStream extends TupleStream implements Expressible {
private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
@ -140,4 +143,4 @@ public class EvalStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ExceptionStream.java
View File

@ -32,6 +32,9 @@ import org.apache.solr.common.SolrException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @since 6.0.0
*/
public class ExceptionStream extends TupleStream {
private TupleStream stream;

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ExecutorStream.java
View File

@ -50,6 +50,7 @@ import static org.apache.solr.common.params.CommonParams.ID;
* executor(thread=10, topic(storedExpressions, q="*:*", fl="expr_s, id", id="topic1"))
*
* The Streaming Expression to execute is taken from the expr field in the Tuples.
* @since 6.3.0
*/
public class ExecutorStream extends TupleStream implements Expressible {
@ -223,4 +224,4 @@ public class ExecutorStream extends TupleStream implements Expressible {
}
}
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FacetStream.java
View File

@ -53,6 +53,7 @@ import org.apache.solr.common.util.NamedList;
/**
* The FacetStream abstracts the output from the JSON facet API as a Stream of Tuples. This provides an alternative to the
* RollupStream which uses Map/Reduce to perform aggregations.
* @since 6.0.0
**/
public class FacetStream extends TupleStream implements Expressible {

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FeaturesSelectionStream.java
View File

@ -62,6 +62,9 @@ import org.apache.solr.common.util.SolrjNamedThreadFactory;
import static org.apache.solr.common.params.CommonParams.DISTRIB;
import static org.apache.solr.common.params.CommonParams.ID;
/**
* @since 6.2.0
*/
public class FeaturesSelectionStream extends TupleStream implements Expressible{
private static final long serialVersionUID = 1;

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FetchStream.java
View File

@ -49,6 +49,7 @@ import static org.apache.solr.common.params.CommonParams.VERSION_FIELD;
*
* fetch(collection, stream, on="a=b", fl="c,d,e", batchSize="50")
*
* @since 6.3.0
**/
public class FetchStream extends TupleStream implements Expressible {

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/GetStream.java
View File

@ -32,6 +32,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExplanation;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpression;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class GetStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -118,4 +121,4 @@ public class GetStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/HashJoinStream.java
View File

@ -40,6 +40,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
* You are expected to provide a set of fields for which the hash will be calculated from. If a tuple does
* not contain a value (ie, null) for one of the fields the hash is being computed on then that tuple will
* not be considered a match to anything. Ie, all fields which are part of the hash must have a non-null value.
* @since 6.0.0
**/
public class HashJoinStream extends TupleStream implements Expressible {
@ -283,4 +284,4 @@ public class HashJoinStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/HavingStream.java
View File

@ -35,6 +35,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* The HavingStream iterates over an internal stream and applies a BooleanOperation to each tuple. If the BooleanOperation
* evaluates to true then the HavingStream emits the tuple, if it returns false the tuple is not emitted.
* @since 6.4.0
**/
public class HavingStream extends TupleStream implements Expressible {
@ -169,4 +170,4 @@ public class HavingStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/InnerJoinStream.java
View File

@ -29,6 +29,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Joins leftStream with rightStream based on a Equalitor. Both streams must be sorted by the fields being joined on.
* Resulting stream is sorted by the equalitor.
* @since 6.0.0
**/
public class InnerJoinStream extends BiJoinStream implements Expressible {

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/IntersectStream.java
View File

@ -37,6 +37,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Emits tuples from streamA which also exist in streamB. Resulting tuples are ordered
* the same as they were in streamA. Both streams must be sorted by the fields being compared.
* @since 6.0.0
**/
public class IntersectStream extends TupleStream implements Expressible {

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JDBCStream.java
View File

@ -115,6 +115,7 @@ import static org.apache.solr.common.params.CommonParams.SORT;
* </tr>
* </table>
*
* @since 6.0.0
**/
public class JDBCStream extends TupleStream implements Expressible {

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JoinStream.java
View File

@ -35,7 +35,10 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionNamedParamete
import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionValue;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/** Defines a JoinStream which can hold N streams, all joined with the same equalitor */
/**
* Defines a JoinStream which can hold N streams, all joined with the same equalitor
* @since 6.0.0
*/
public abstract class JoinStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/KnnStream.java
View File

@ -50,6 +50,9 @@ import static org.apache.solr.common.params.CommonParams.Q;
import static org.apache.solr.common.params.CommonParams.ROWS;
/**
* @since 7.0.0
*/
public class KnnStream extends TupleStream implements Expressible {
private static String[] mltParams = {"qf", "mintf", "mindf", "maxdf", "minwl", "maxwl", "maxqt", "maxntp", "boost"};
@ -253,4 +256,4 @@ public class KnnStream extends TupleStream implements Expressible {
public StreamComparator getStreamSort() {
return null;
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/LeftOuterJoinStream.java
View File

@ -29,6 +29,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Joins leftStream with rightStream based on a Equalitor. Both streams must be sorted by the fields being joined on.
* Resulting stream is sorted by the equalitor.
* @since 6.0.0
**/
public class LeftOuterJoinStream extends BiJoinStream implements Expressible {

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/LetStream.java
View File

@ -35,6 +35,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionNamedParamete
import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class LetStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -181,4 +184,4 @@ public class LetStream extends TupleStream implements Expressible {
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ListStream.java
View File

@ -30,6 +30,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExplanation;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpression;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class ListStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -142,4 +145,4 @@ public class ListStream extends TupleStream implements Expressible {
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/MergeStream.java
View File

@ -36,6 +36,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Merges two or more streams together ordering the Tuples based on a Comparator.
* All streams must be sorted by the fields being compared - this will be validated on construction.
* @since 5.1.0
**/
public class MergeStream extends TupleStream implements Expressible {
@ -246,4 +247,4 @@ public class MergeStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ModelStream.java
View File

@ -43,6 +43,7 @@ import static org.apache.solr.common.params.CommonParams.ID;
* The ModelStream retrieves a stored model from a Solr Cloud collection.
*
* Syntax: model(collection, id="modelID")
* @since 6.3.0
**/
public class ModelStream extends TupleStream implements Expressible {

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/NullStream.java
View File

@ -36,6 +36,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
* The NullStream Iterates over a TupleStream and eats the tuples. It returns the tuple count in the EOF tuple.
* Because the NullStreaam eats all the Tuples it see's it can be used as a simple tool for performance analysis of
* underlying streams.
* @since 6.4.0
**/
public class NullStream extends TupleStream implements Expressible {
@ -152,4 +153,4 @@ public class NullStream extends TupleStream implements Expressible {
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/OuterHashJoinStream.java
View File

@ -36,6 +36,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
* tuple will not be considered a match to anything. If a tuple from the fullStream does not contain a value (ie, null)
* for one of the fields the hash is being computed on then that tuple will be returned without any joined tuples
* from the hashStream
* @since 6.0.0
**/
public class OuterHashJoinStream extends HashJoinStream implements Expressible {
@ -129,4 +130,4 @@ public class OuterHashJoinStream extends HashJoinStream implements Expressible {
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
View File

@ -43,9 +43,8 @@ import static org.apache.solr.common.params.CommonParams.SORT;
* The ParallelStream decorates a TupleStream implementation and pushes it to N workers for parallel execution.
* Workers are chosen from a SolrCloud collection.
* Tuples that are streamed back from the workers are ordered by a Comparator.
* @since 5.1.0
**/
public class ParallelStream extends CloudSolrStream implements Expressible {
private TupleStream tupleStream;

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PlotStream.java
View File

@ -38,6 +38,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionValue;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 7.1.0
*/
public class PlotStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -218,4 +221,4 @@ public class PlotStream extends TupleStream implements Expressible {
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PriorityStream.java
View File

@ -43,6 +43,7 @@ import org.slf4j.LoggerFactory;
* returned.
*
* The scheduler is designed to be wrapped by the executor function and a daemon function can be used to call the executor iteratively.
* @since 6.4.0
**/
public class PriorityStream extends TupleStream implements Expressible {
@ -158,4 +159,4 @@ public class PriorityStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PushBackStream.java
View File

@ -31,6 +31,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
* A TupleStream that allows a single Tuple to be pushed back onto the stream after it's been read.
* This is a useful class when building streams that maintain the order of Tuples between multiple
* substreams.
* @since 5.1.0
**/
public class PushBackStream extends TupleStream implements Expressible {
@ -98,4 +99,4 @@ public class PushBackStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RandomStream.java
View File

@ -52,6 +52,7 @@ import static org.apache.solr.common.params.CommonParams.SORT;
/**
* The RandomStream emits a stream of psuedo random Tuples that match the query parameters. Sample expression syntax:
* random(collection, q="Hello word", rows="50", fl="title, body")
* @since 6.1.0
**/
public class RandomStream extends TupleStream implements Expressible {

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RankStream.java
View File

@ -42,6 +42,7 @@ import static org.apache.solr.common.params.CommonParams.SORT;
/**
* Iterates over a TupleStream and Ranks the topN tuples based on a Comparator.
* @since 5.1.0
**/
public class RankStream extends TupleStream implements Expressible {
@ -228,4 +229,4 @@ public class RankStream extends TupleStream implements Expressible {
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ReducerStream.java
View File

@ -52,6 +52,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
* Note: The ReducerStream requires that it's underlying stream be sorted and partitioned by the same
* fields as it's comparator.
*
* @since 5.1.0
**/
public class ReducerStream extends TupleStream implements Expressible {
@ -244,4 +245,4 @@ public class ReducerStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RollupStream.java
View File

@ -40,6 +40,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
import org.apache.solr.client.solrj.io.stream.metrics.Bucket;
import org.apache.solr.client.solrj.io.stream.metrics.Metric;
/**
* @since 6.0.0
*/
public class RollupStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -270,4 +273,4 @@ public class RollupStream extends TupleStream implements Expressible {
public StreamComparator getStreamSort() {
return tupleStream.getStreamSort();
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ScoreNodesStream.java
View File

@ -54,6 +54,7 @@ import static org.apache.solr.common.params.CommonParams.DISTRIB;
* You can use a different value for termFreq by providing the termFreq param
* scoreNodes(gatherNodes(...), termFreq="min(weight)")
*
* @since 6.2.0
**/
public class ScoreNodesStream extends TupleStream implements Expressible

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SelectStream.java
View File

@ -42,6 +42,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* Selects fields from the incoming stream and applies optional field renaming.
* Does not reorder the outgoing stream.
* @since 6.0.0
**/
@ -295,4 +296,4 @@ public class SelectStream extends TupleStream implements Expressible {
public int getCost() {
return 0;
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ShuffleStream.java
View File

@ -31,6 +31,9 @@ import org.apache.solr.common.params.CommonParams;
import org.apache.solr.common.params.ModifiableSolrParams;
/**
* @since 6.6.0
*/
public class ShuffleStream extends CloudSolrStream implements Expressible {
public ShuffleStream(StreamExpression expression, StreamFactory factory) throws IOException {

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SignificantTermsStream.java
View File

@ -51,6 +51,9 @@ import org.apache.solr.common.util.SolrjNamedThreadFactory;
import static org.apache.solr.common.params.CommonParams.DISTRIB;
/**
* @since 6.5.0
*/
public class SignificantTermsStream extends TupleStream implements Expressible{
private static final long serialVersionUID = 1;

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SolrStream.java
View File

@ -49,6 +49,7 @@ import org.slf4j.LoggerFactory;
/**
* Queries a single Solr instance and maps SolrDocs to a Stream of Tuples.
* @since 5.1.0
**/
public class SolrStream extends TupleStream {

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SortStream.java
View File

@ -37,6 +37,7 @@ import org.apache.solr.client.solrj.io.stream.expr.Explanation.ExpressionType;
/**
* The SortStream emits a stream of Tuples sorted by a Comparator.
* @since 6.1.0
**/
public class SortStream extends TupleStream implements Expressible {
@ -196,4 +197,4 @@ public class SortStream extends TupleStream implements Expressible {
public Tuple read();
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SqlStream.java
View File

@ -39,6 +39,9 @@ import org.apache.solr.common.params.CommonParams;
import org.apache.solr.common.params.ModifiableSolrParams;
import org.apache.solr.common.params.SolrParams;
/**
* @since 7.0.0
*/
public class SqlStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StatsStream.java
View File

@ -46,6 +46,9 @@ import org.apache.solr.common.params.ModifiableSolrParams;
import org.apache.solr.common.params.SolrParams;
import org.apache.solr.common.util.NamedList;
/**
* @since 6.0.0
*/
public class StatsStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TextLogitStream.java
View File

@ -63,6 +63,9 @@ import org.apache.solr.common.util.SolrjNamedThreadFactory;
import static org.apache.solr.common.params.CommonParams.DISTRIB;
import static org.apache.solr.common.params.CommonParams.ID;
/**
* @since 6.2.0
*/
public class TextLogitStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TimeSeriesStream.java
View File

@ -48,6 +48,9 @@ import org.apache.solr.common.params.ModifiableSolrParams;
import org.apache.solr.common.params.SolrParams;
import org.apache.solr.common.util.NamedList;
/**
* @since 6.6.0
*/
public class TimeSeriesStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TopicStream.java
View File

@ -67,6 +67,9 @@ import static org.apache.solr.common.params.CommonParams.ID;
import static org.apache.solr.common.params.CommonParams.SORT;
import static org.apache.solr.common.params.CommonParams.VERSION_FIELD;
/**
* @since 6.0.0
*/
public class TopicStream extends CloudSolrStream implements Expressible {
private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupStream.java
View File

@ -38,6 +38,9 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionParameter;
import org.apache.solr.client.solrj.io.stream.expr.StreamExpressionValue;
import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
/**
* @since 6.6.0
*/
public class TupStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
@ -214,4 +217,4 @@ public class TupStream extends TupleStream implements Expressible {
}
}
}

5
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupleStream.java
View File

@ -49,6 +49,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @since 5.1.0
*/
public abstract class TupleStream implements Closeable, Serializable, MapWriter {
private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
@ -207,4 +210,4 @@ public abstract class TupleStream implements Closeable, Serializable, MapWriter
return "Early Client Disconnect";
}
}
}
}

3
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/UniqueStream.java
View File

@ -40,6 +40,7 @@ import org.apache.solr.client.solrj.io.stream.expr.StreamFactory;
* The UniqueStream emits a unique stream of Tuples based on a Comparator.
*
* Note: The sort order of the underlying stream must match the Comparator.
* @since 5.1.0
**/
public class UniqueStream extends TupleStream implements Expressible {
@ -169,4 +170,4 @@ public class UniqueStream extends TupleStream implements Expressible {
return 0;
}
}
}

1
solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/UpdateStream.java
View File

@ -46,6 +46,7 @@ import static org.apache.solr.common.params.CommonParams.VERSION_FIELD;
/**
* Sends tuples emitted by a wrapped {@link TupleStream} as updates to a SolrCloud collection.
* @since 6.0.0
*/
public class UpdateStream extends TupleStream implements Expressible {
private static final Logger LOG = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());