You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by er...@apache.org on 2020/06/09 23:22:42 UTC
[lucene-solr] branch branch_8x updated: SOLR-14547: Fix or suppress
warnings in solr/client/solrj/io/stream
This is an automated email from the ASF dual-hosted git repository.
erick pushed a commit to branch branch_8x
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git
The following commit(s) were added to refs/heads/branch_8x by this push:
new d9ed829 SOLR-14547: Fix or suppress warnings in solr/client/solrj/io/stream
d9ed829 is described below
commit d9ed82912a9220dd9da7da909bbfeae7288ff145
Author: Erick Erickson <Er...@gmail.com>
AuthorDate: Tue Jun 9 19:21:16 2020 -0400
SOLR-14547: Fix or suppress warnings in solr/client/solrj/io/stream
---
solr/CHANGES.txt | 2 ++
.../solrj/io/stream/CartesianProductStream.java | 1 +
.../solr/client/solrj/io/stream/CellStream.java | 2 +-
.../client/solrj/io/stream/CloudSolrStream.java | 15 +++++++------
.../solr/client/solrj/io/stream/DaemonStream.java | 3 ++-
.../client/solrj/io/stream/DeepRandomStream.java | 11 +++++-----
.../solr/client/solrj/io/stream/EvalStream.java | 2 +-
.../client/solrj/io/stream/ExecutorStream.java | 6 ++++--
.../solr/client/solrj/io/stream/Facet2DStream.java | 15 ++++++++++---
.../solr/client/solrj/io/stream/FacetStream.java | 13 +++++++----
.../solrj/io/stream/FeaturesSelectionStream.java | 13 ++++++++---
.../solr/client/solrj/io/stream/FetchStream.java | 3 ++-
.../solr/client/solrj/io/stream/GetStream.java | 4 +++-
.../client/solrj/io/stream/HashRollupStream.java | 4 +++-
.../client/solrj/io/stream/JSONTupleStream.java | 1 +
.../solrj/io/stream/JavabinTupleStreamParser.java | 3 +++
.../solr/client/solrj/io/stream/KnnStream.java | 2 +-
.../solr/client/solrj/io/stream/LetStream.java | 6 +++++-
.../solr/client/solrj/io/stream/ModelStream.java | 2 +-
.../client/solrj/io/stream/ParallelListStream.java | 2 +-
.../client/solrj/io/stream/ParallelStream.java | 2 +-
.../solr/client/solrj/io/stream/PlotStream.java | 11 +++++-----
.../client/solrj/io/stream/PriorityStream.java | 2 +-
.../solr/client/solrj/io/stream/RandomStream.java | 2 +-
.../client/solrj/io/stream/ScoreNodesStream.java | 7 ++++--
.../solr/client/solrj/io/stream/SearchStream.java | 3 ++-
.../solr/client/solrj/io/stream/SelectStream.java | 9 ++++----
.../solrj/io/stream/SignificantTermsStream.java | 23 ++++++++++++++------
.../solr/client/solrj/io/stream/SolrStream.java | 5 ++++-
.../solr/client/solrj/io/stream/StatsStream.java | 10 ++++++---
.../solr/client/solrj/io/stream/StreamContext.java | 11 ++++++++--
.../client/solrj/io/stream/TextLogitStream.java | 23 +++++++++++++-------
.../client/solrj/io/stream/TimeSeriesStream.java | 13 +++++++----
.../solr/client/solrj/io/stream/TopicStream.java | 11 +++++-----
.../solr/client/solrj/io/stream/TupStream.java | 8 ++++---
.../solr/client/solrj/io/stream/TupleStream.java | 3 ++-
.../solr/client/solrj/io/stream/UpdateStream.java | 3 ++-
.../solr/client/solrj/io/stream/ZplotStream.java | 9 +++++---
.../client/solrj/io/stream/expr/Explanation.java | 1 +
.../solrj/io/stream/expr/StreamExplanation.java | 1 +
.../solrj/io/stream/expr/StreamExpression.java | 1 +
.../expr/StreamExpressionNamedParameter.java | 1 +
.../io/stream/expr/StreamExpressionValue.java | 1 +
.../client/solrj/io/stream/expr/StreamFactory.java | 25 ++++++++++++++++------
44 files changed, 203 insertions(+), 92 deletions(-)
diff --git a/solr/CHANGES.txt b/solr/CHANGES.txt
index 8c2275f..5230eb6 100644
--- a/solr/CHANGES.txt
+++ b/solr/CHANGES.txt
@@ -246,6 +246,8 @@ Other Changes
* SOLR-14548: Address warning: static member should be qualified by type name (Mike Drob)
+* SOLR-14547: Fix or suppress warnings in solr/client/solrj/io/stream
+
================== 8.5.2 ==================
Consult the LUCENE_CHANGES.txt file for additional, low level, changes in this release.
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CartesianProductStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CartesianProductStream.java
index 24bf31b..4e4563e 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CartesianProductStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CartesianProductStream.java
@@ -199,6 +199,7 @@ public class CartesianProductStream extends TupleStream implements Expressible {
return generatedTuples.pop();
}
+ @SuppressWarnings({"unchecked"})
private LinkedList<Tuple> generateTupleList(Tuple original) throws IOException{
Map<String, Object> evaluatedValues = new HashMap<>();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CellStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CellStream.java
index fac8ca8..6eccac0 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CellStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CellStream.java
@@ -121,7 +121,7 @@ public class CellStream extends TupleStream implements Expressible {
public void open() throws IOException {
try {
stream.open();
- List<Tuple> list = new ArrayList();
+ List<Tuple> list = new ArrayList<>();
while(true) {
Tuple tuple = stream.read();
if(tuple.EOF) {
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
index 270a5b4..0721077 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/CloudSolrStream.java
@@ -272,15 +272,15 @@ public class CloudSolrStream extends TupleStream implements Expressible {
*
***/
public void open() throws IOException {
- this.tuples = new TreeSet();
- this.solrStreams = new ArrayList();
- this.eofTuples = Collections.synchronizedMap(new HashMap());
+ this.tuples = new TreeSet<>();
+ this.solrStreams = new ArrayList<>();
+ this.eofTuples = Collections.synchronizedMap(new HashMap<>());
constructStreams();
openStreams();
}
- public Map getEofTuples() {
+ public Map<String, Tuple> getEofTuples() {
return this.eofTuples;
}
@@ -288,9 +288,11 @@ public class CloudSolrStream extends TupleStream implements Expressible {
return solrStreams;
}
+ @SuppressWarnings({"unchecked"})
private StreamComparator parseComp(String sort, String fl) throws IOException {
String[] fls = fl.split(",");
+ @SuppressWarnings({"rawtypes"})
HashSet fieldSet = new HashSet();
for(String f : fls) {
fieldSet.add(f.trim()); //Handle spaces in the field list.
@@ -339,7 +341,7 @@ public class CloudSolrStream extends TupleStream implements Expressible {
// check for alias or collection
- List<String> allCollections = new ArrayList();
+ List<String> allCollections = new ArrayList<>();
String[] collectionNames = collectionName.split(",");
for(String col : collectionNames) {
List<String> collections = checkAlias
@@ -394,7 +396,7 @@ public class CloudSolrStream extends TupleStream implements Expressible {
private void openStreams() throws IOException {
ExecutorService service = ExecutorUtil.newMDCAwareCachedThreadPool(new SolrNamedThreadFactory("CloudSolrStream"));
try {
- List<Future<TupleWrapper>> futures = new ArrayList();
+ List<Future<TupleWrapper>> futures = new ArrayList<>();
for (TupleStream solrStream : solrStreams) {
StreamOpener so = new StreamOpener((SolrStream) solrStream, comp);
Future<TupleWrapper> future = service.submit(so);
@@ -458,6 +460,7 @@ public class CloudSolrStream extends TupleStream implements Expressible {
}
}
+ @SuppressWarnings({"overrides"})
protected class TupleWrapper implements Comparable<TupleWrapper> {
private Tuple tuple;
private SolrStream stream;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
index 962b61a..2a2bc4a 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
@@ -168,6 +168,7 @@ public class DaemonStream extends TupleStream implements Expressible {
init(tupleStream, id, runInterval, queueSize, false);
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
public void init(TupleStream tupleStream, String id, long runInterval, int queueSize, boolean terminate) {
this.tupleStream = tupleStream;
this.id = id;
@@ -245,7 +246,7 @@ public class DaemonStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> children = new ArrayList();
+ List<TupleStream> children = new ArrayList<>();
children.add(tupleStream);
return children;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DeepRandomStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DeepRandomStream.java
index 1d53604..00b3d3c 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DeepRandomStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DeepRandomStream.java
@@ -257,9 +257,9 @@ public class DeepRandomStream extends TupleStream implements Expressible {
}
public void open() throws IOException {
- this.tuples = new LinkedList();
- this.solrStreams = new ArrayList();
- this.eofTuples = Collections.synchronizedMap(new HashMap());
+ this.tuples = new LinkedList<>();
+ this.solrStreams = new ArrayList<>();
+ this.eofTuples = Collections.synchronizedMap(new HashMap<>());
constructStreams();
openStreams();
}
@@ -278,7 +278,7 @@ public class DeepRandomStream extends TupleStream implements Expressible {
// check for alias or collection
- List<String> allCollections = new ArrayList();
+ List<String> allCollections = new ArrayList<>();
String[] collectionNames = collectionName.split(",");
for(String col : collectionNames) {
List<String> collections = checkAlias
@@ -349,7 +349,7 @@ public class DeepRandomStream extends TupleStream implements Expressible {
private void openStreams() throws IOException {
ExecutorService service = ExecutorUtil.newMDCAwareCachedThreadPool(new SolrNamedThreadFactory("DeepRandomStream"));
try {
- List<Future<TupleWrapper>> futures = new ArrayList();
+ List<Future<TupleWrapper>> futures = new ArrayList<>();
for (TupleStream solrStream : solrStreams) {
StreamOpener so = new StreamOpener((SolrStream) solrStream, comp);
Future<TupleWrapper> future = service.submit(so);
@@ -411,6 +411,7 @@ public class DeepRandomStream extends TupleStream implements Expressible {
}
}
+ @SuppressWarnings({"overrides"})
protected class TupleWrapper implements Comparable<TupleWrapper> {
private Tuple tuple;
private SolrStream stream;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/EvalStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/EvalStream.java
index 957f5b4..cbab9b0 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/EvalStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/EvalStream.java
@@ -100,7 +100,7 @@ public class EvalStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(stream);
return l;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ExecutorStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ExecutorStream.java
index 29581fe..85be58f 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ExecutorStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ExecutorStream.java
@@ -132,7 +132,7 @@ public class ExecutorStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(stream);
return l;
}
@@ -153,6 +153,7 @@ public class ExecutorStream extends TupleStream implements Expressible {
}
public Tuple read() throws IOException {
+ @SuppressWarnings({"unchecked", "rawtypes"})
ArrayBlockingQueue<Tuple> queue = new ArrayBlockingQueue(10000);
while(true) {
Tuple tuple = stream.read();
@@ -183,7 +184,8 @@ public class ExecutorStream extends TupleStream implements Expressible {
private StreamFactory streamFactory;
private StreamContext streamContext;
- public StreamTask(ArrayBlockingQueue queue, StreamFactory streamFactory, StreamContext streamContext) {
+ @SuppressWarnings({"unchecked"})
+ public StreamTask(@SuppressWarnings({"rawtypes"})ArrayBlockingQueue queue, StreamFactory streamFactory, StreamContext streamContext) {
this.queue = queue;
this.streamFactory = streamFactory;
this.streamContext = new StreamContext();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/Facet2DStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/Facet2DStream.java
index 7f3d635..cb19b90 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/Facet2DStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/Facet2DStream.java
@@ -271,7 +271,7 @@ public class Facet2DStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- return new ArrayList();
+ return new ArrayList<>();
}
public void open() throws IOException {
@@ -293,6 +293,7 @@ public class Facet2DStream extends TupleStream implements Expressible {
QueryRequest request = new QueryRequest(paramsLoc, SolrRequest.METHOD.POST);
try {
+ @SuppressWarnings({"rawtypes"})
NamedList response = cloudSolrClient.request(request, collection);
getTuples(response, x, y, metric);
this.out = tuples.iterator();
@@ -389,21 +390,26 @@ public class Facet2DStream extends TupleStream implements Expressible {
return null;
}
- private void getTuples(NamedList response, Bucket x, Bucket y, Metric metric) {
+ private void getTuples(@SuppressWarnings({"rawtypes"})NamedList response, Bucket x, Bucket y, Metric metric) {
Tuple tuple = new Tuple();
+ @SuppressWarnings({"rawtypes"})
NamedList facets = (NamedList) response.get("facets");
fillTuples(0, tuples, tuple, facets, x, y, metric);
}
- private void fillTuples(int level, List<Tuple> tuples, Tuple currentTuple, NamedList facets, Bucket x, Bucket y, Metric metric) {
+ private void fillTuples(int level, List<Tuple> tuples, Tuple currentTuple,
+ @SuppressWarnings({"rawtypes"})NamedList facets, Bucket x, Bucket y, Metric metric) {
String bucketXName = x.toString();
String bucketYName = y.toString();
+ @SuppressWarnings({"rawtypes"})
NamedList allXBuckets = (NamedList) facets.get("x");
for (int b = 0; b < allXBuckets.size(); b++) {
+ @SuppressWarnings({"rawtypes"})
List buckets = (List) allXBuckets.get("buckets");
for(int s=0; s<buckets.size(); s++) {
+ @SuppressWarnings({"rawtypes"})
NamedList bucket = (NamedList)buckets.get(s);
Object val = bucket.get("val");
if (val instanceof Integer) {
@@ -412,10 +418,13 @@ public class Facet2DStream extends TupleStream implements Expressible {
Tuple tx = currentTuple.clone();
tx.put(bucketXName, val);
+ @SuppressWarnings({"rawtypes"})
NamedList allYBuckets = (NamedList) bucket.get("y");
+ @SuppressWarnings({"rawtypes"})
List ybuckets = (List)allYBuckets.get("buckets");
for (int d = 0; d < ybuckets.size(); d++) {
+ @SuppressWarnings({"rawtypes"})
NamedList bucketY = (NamedList) ybuckets.get(d);
Object valY = bucketY.get("val");
if (valY instanceof Integer) {
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FacetStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FacetStream.java
index 29c48ae..638550f 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FacetStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FacetStream.java
@@ -373,7 +373,7 @@ public class FacetStream extends TupleStream implements Expressible {
}
private String[] parseSorts(String sortString) {
- List<String> sorts = new ArrayList();
+ List<String> sorts = new ArrayList<>();
boolean inParam = false;
StringBuilder buff = new StringBuilder();
for(int i=0; i<sortString.length(); i++) {
@@ -533,7 +533,7 @@ public class FacetStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- return new ArrayList();
+ return new ArrayList<>();
}
public void open() throws IOException {
@@ -556,6 +556,7 @@ public class FacetStream extends TupleStream implements Expressible {
QueryRequest request = new QueryRequest(paramsLoc, SolrRequest.METHOD.POST);
try {
+ @SuppressWarnings({"rawtypes"})
NamedList response = cloudSolrClient.request(request, collection);
getTuples(response, buckets, metrics);
@@ -761,11 +762,12 @@ public class FacetStream extends TupleStream implements Expressible {
return "index";
}
- private void getTuples(NamedList response,
+ private void getTuples(@SuppressWarnings({"rawtypes"})NamedList response,
Bucket[] buckets,
Metric[] metrics) {
Tuple tuple = new Tuple();
+ @SuppressWarnings({"rawtypes"})
NamedList facets = (NamedList)response.get("facets");
fillTuples(0,
tuples,
@@ -779,17 +781,20 @@ public class FacetStream extends TupleStream implements Expressible {
private void fillTuples(int level,
List<Tuple> tuples,
Tuple currentTuple,
- NamedList facets,
+ @SuppressWarnings({"rawtypes"}) NamedList facets,
Bucket[] _buckets,
Metric[] _metrics) {
String bucketName = _buckets[level].toString();
+ @SuppressWarnings({"rawtypes"})
NamedList nl = (NamedList)facets.get(bucketName);
if(nl == null) {
return;
}
+ @SuppressWarnings({"rawtypes"})
List allBuckets = (List)nl.get("buckets");
for(int b=0; b<allBuckets.size(); b++) {
+ @SuppressWarnings({"rawtypes"})
NamedList bucket = (NamedList)allBuckets.get(b);
Object val = bucket.get("val");
if (val instanceof Integer) {
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FeaturesSelectionStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FeaturesSelectionStream.java
index 041e7c3..9ed805c 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FeaturesSelectionStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FeaturesSelectionStream.java
@@ -91,7 +91,7 @@ public class FeaturesSelectionStream extends TupleStream implements Expressible{
public FeaturesSelectionStream(String zkHost,
String collectionName,
- Map params,
+ @SuppressWarnings({"rawtypes"})Map params,
String field,
String outcome,
String featureSet,
@@ -213,9 +213,10 @@ public class FeaturesSelectionStream extends TupleStream implements Expressible{
return expression;
}
+ @SuppressWarnings({"unchecked"})
private void init(String collectionName,
String zkHost,
- Map params,
+ @SuppressWarnings({"rawtypes"})Map params,
String field,
String outcome,
String featureSet,
@@ -288,6 +289,7 @@ public class FeaturesSelectionStream extends TupleStream implements Expressible{
}
}
+ @SuppressWarnings({"rawtypes"})
private List<Future<NamedList>> callShards(List<String> baseUrls) throws IOException {
List<Future<NamedList>> futures = new ArrayList<>();
@@ -336,10 +338,13 @@ public class FeaturesSelectionStream extends TupleStream implements Expressible{
long numDocs = 0;
- for (Future<NamedList> getTopTermsCall : callShards(getShardUrls())) {
+ for (@SuppressWarnings({"rawtypes"})Future<NamedList> getTopTermsCall : callShards(getShardUrls())) {
+ @SuppressWarnings({"rawtypes"})
NamedList resp = getTopTermsCall.get();
+ @SuppressWarnings({"unchecked"})
NamedList<Double> shardTopTerms = (NamedList<Double>)resp.get("featuredTerms");
+ @SuppressWarnings({"unchecked"})
NamedList<Integer> shardDocFreqs = (NamedList<Integer>)resp.get("docFreq");
numDocs += (Integer)resp.get("numDocs");
@@ -397,6 +402,7 @@ public class FeaturesSelectionStream extends TupleStream implements Expressible{
return result;
}
+ @SuppressWarnings({"rawtypes"})
protected class FeaturesSelectionCall implements Callable<NamedList> {
private String baseUrl;
@@ -415,6 +421,7 @@ public class FeaturesSelectionStream extends TupleStream implements Expressible{
this.paramsMap = paramsMap;
}
+ @SuppressWarnings({"unchecked"})
public NamedList<Double> call() throws Exception {
ModifiableSolrParams params = new ModifiableSolrParams();
HttpSolrClient solrClient = cache.getHttpSolrClient(baseUrl);
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FetchStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FetchStream.java
index e587ff2..2a0e49c 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FetchStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/FetchStream.java
@@ -199,11 +199,12 @@ public class FetchStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(stream);
return l;
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
public void open() throws IOException {
tuples = new ArrayList().iterator();
stream.open();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/GetStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/GetStream.java
index 8b82761..2088b35 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/GetStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/GetStream.java
@@ -83,7 +83,7 @@ public class GetStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
return l;
}
@@ -99,9 +99,11 @@ public class GetStream extends TupleStream implements Expressible {
public void close() throws IOException {
}
+ @SuppressWarnings({"unchecked"})
public void open() throws IOException {
Map<String, Object> lets = streamContext.getLets();
Object o = lets.get(name);
+ @SuppressWarnings({"rawtypes"})
List l = null;
if(o instanceof List) {
l = (List)o;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/HashRollupStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/HashRollupStream.java
index 0754692..30bc59e 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/HashRollupStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/HashRollupStream.java
@@ -190,13 +190,15 @@ public class HashRollupStream extends TupleStream implements Expressible {
tupleIterator = null;
}
+ @SuppressWarnings({"unchecked"})
public Tuple read() throws IOException {
//On the first call to read build the tupleIterator.
if(tupleIterator == null) {
- Map<HashKey, Metric[]> metricMap = new HashMap();
+ Map<HashKey, Metric[]> metricMap = new HashMap<>();
while (true) {
Tuple tuple = tupleStream.read();
if (tuple.EOF) {
+ @SuppressWarnings({"rawtypes"})
List tuples = new ArrayList();
for(Map.Entry<HashKey, Metric[]> entry : metricMap.entrySet()) {
Tuple t = new Tuple();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JSONTupleStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JSONTupleStream.java
index 335b174..b2321e6 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JSONTupleStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JSONTupleStream.java
@@ -73,6 +73,7 @@ public class JSONTupleStream implements TupleStreamParser {
/** returns the next Tuple or null */
@Override
+ @SuppressWarnings({"unchecked"})
public Map<String,Object> next() throws IOException {
if (!atDocs) {
boolean found = advanceToDocs();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JavabinTupleStreamParser.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JavabinTupleStreamParser.java
index dfe8cc7..f9f1790 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JavabinTupleStreamParser.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/JavabinTupleStreamParser.java
@@ -96,6 +96,7 @@ public class JavabinTupleStreamParser extends JavaBinCodec implements TupleStrea
return tagByte == SOLRDOCLST;
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
private Map readAsMap(DataInputInputStream dis) throws IOException {
int sz = readSize(dis);
Map m = new LinkedHashMap<>();
@@ -107,6 +108,7 @@ public class JavabinTupleStreamParser extends JavaBinCodec implements TupleStrea
return m;
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
private Map readSolrDocumentAsMap(DataInputInputStream dis) throws IOException {
tagByte = dis.readByte();
int size = readSize(dis);
@@ -174,6 +176,7 @@ public class JavabinTupleStreamParser extends JavaBinCodec implements TupleStrea
@Override
+ @SuppressWarnings({"unchecked"})
public Map<String, Object> next() throws IOException {
if (arraySize == 0) return null;
Object o = readVal(fis);
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/KnnStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/KnnStream.java
index 39c9cd6..78d2470 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/KnnStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/KnnStream.java
@@ -183,7 +183,7 @@ public class KnnStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
return l;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/LetStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/LetStream.java
index 23881c3..79cdcbf 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/LetStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/LetStream.java
@@ -47,8 +47,10 @@ public class LetStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
private TupleStream stream;
private StreamContext streamContext;
+ @SuppressWarnings({"rawtypes"})
private Map letParams = new LinkedHashMap();
+ @SuppressWarnings({"unchecked", "rawtypes"})
public LetStream(StreamExpression expression, StreamFactory factory) throws IOException {
List<StreamExpression> streamExpressions = factory.getExpressionOperandsRepresentingTypes(expression, Expressible.class, TupleStream.class);
@@ -160,6 +162,7 @@ public class LetStream extends TupleStream implements Expressible {
stream.close();
}
+ @SuppressWarnings({"unchecked"})
public void open() throws IOException {
Map<String, Object> lets = streamContext.getLets();
Set<Map.Entry<String, Object>> entries = letParams.entrySet();
@@ -169,7 +172,7 @@ public class LetStream extends TupleStream implements Expressible {
String name = entry.getKey();
Object o = entry.getValue();
if(o instanceof TupleStream) {
- List<Tuple> tuples = new ArrayList();
+ List<Tuple> tuples = new ArrayList<>();
TupleStream tStream = (TupleStream)o;
tStream.setStreamContext(streamContext);
try {
@@ -196,6 +199,7 @@ public class LetStream extends TupleStream implements Expressible {
evaluator.setStreamContext(streamContext);
Object eo = evaluator.evaluate(eTuple);
if(evaluator instanceof MemsetEvaluator) {
+ @SuppressWarnings({"rawtypes"})
Map mem = (Map)eo;
lets.putAll(mem);
} else {
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ModelStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ModelStream.java
index f13e736..77c5090 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ModelStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ModelStream.java
@@ -162,7 +162,7 @@ public class ModelStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
return l;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelListStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelListStream.java
index dbf2901..591a4ef 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelListStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelListStream.java
@@ -136,7 +136,7 @@ public class ParallelListStream extends TupleStream implements Expressible {
private void openStreams() throws IOException {
ExecutorService service = ExecutorUtil.newMDCAwareCachedThreadPool(new SolrNamedThreadFactory("ParallelListStream"));
try {
- List<Future<StreamIndex>> futures = new ArrayList();
+ List<Future<StreamIndex>> futures = new ArrayList<>();
int i=0;
for (TupleStream tupleStream : streams) {
StreamOpener so = new StreamOpener(new StreamIndex(tupleStream, i++));
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
index 141411e..0d48b0b 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ParallelStream.java
@@ -206,7 +206,7 @@ public class ParallelStream extends CloudSolrStream implements Expressible {
}
public List<TupleStream> children() {
- List l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(tupleStream);
return l;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PlotStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PlotStream.java
index 142e3d0..f281536 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PlotStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PlotStream.java
@@ -49,8 +49,8 @@ public class PlotStream extends TupleStream implements Expressible {
private Map<String,String> stringParams = new HashMap<>();
private Map<String,StreamEvaluator> evaluatorParams = new HashMap<>();
private Map<String,TupleStream> streamParams = new HashMap<>();
- private List<String> fieldNames = new ArrayList();
- private Map<String, String> fieldLabels = new HashMap();
+ private List<String> fieldNames = new ArrayList<>();
+ private Map<String, String> fieldLabels = new HashMap<>();
private boolean finished;
@@ -148,6 +148,7 @@ public class PlotStream extends TupleStream implements Expressible {
return l;
}
+ @SuppressWarnings({"unchecked"})
public Tuple read() throws IOException {
if (finished) {
@@ -177,15 +178,15 @@ public class PlotStream extends TupleStream implements Expressible {
if(x == null) {
//x is null so add a sequence
- x = new ArrayList();
+ x = new ArrayList<>();
for(int i=0; i<y.size(); i++) {
x.add(i+1);
}
}
- List<List<Number>> xy = new ArrayList();
+ List<List<Number>> xy = new ArrayList<>();
for(int i=0; i<x.size(); i++) {
- List<Number> pair = new ArrayList();
+ List<Number> pair = new ArrayList<>();
pair.add(x.get(i));
pair.add(y.get(i));
xy.add(pair);
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PriorityStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PriorityStream.java
index edb3455..5a10d65 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PriorityStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/PriorityStream.java
@@ -120,7 +120,7 @@ public class PriorityStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(highPriorityTasks);
l.add(tasks);
return l;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RandomStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RandomStream.java
index 20a055c..ba2a799 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RandomStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/RandomStream.java
@@ -193,7 +193,7 @@ public class RandomStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
return l;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ScoreNodesStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ScoreNodesStream.java
index 95aa700..e4f9ebb 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ScoreNodesStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ScoreNodesStream.java
@@ -65,7 +65,7 @@ public class ScoreNodesStream extends TupleStream implements Expressible
protected String zkHost;
private TupleStream stream;
private transient SolrClientCache clientCache;
- private Map<String, Tuple> nodes = new HashMap();
+ private Map<String, Tuple> nodes = new HashMap<>();
private Iterator<Tuple> tuples;
private String termFreq;
private boolean facet;
@@ -165,7 +165,7 @@ public class ScoreNodesStream extends TupleStream implements Expressible
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(stream);
return l;
}
@@ -222,9 +222,12 @@ public class ScoreNodesStream extends TupleStream implements Expressible
try {
//Get the response from the terms component
+ @SuppressWarnings({"rawtypes"})
NamedList response = client.request(request, collection);
+ @SuppressWarnings({"unchecked"})
NamedList<Number> stats = (NamedList<Number>)response.get("indexstats");
long numDocs = stats.get("numDocs").longValue();
+ @SuppressWarnings({"unchecked"})
NamedList<NamedList<Number>> fields = (NamedList<NamedList<Number>>)response.get("terms");
int size = fields.size();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SearchStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SearchStream.java
index 2d96d60..6067783 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SearchStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SearchStream.java
@@ -174,7 +174,7 @@ public class SearchStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
return l;
}
@@ -227,6 +227,7 @@ public class SearchStream extends TupleStream implements Expressible {
return comp;
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
private StreamComparator parseComp(String sort, String fl) throws IOException {
HashSet fieldSet = null;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SelectStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SelectStream.java
index aee9c4c..62e490a 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SelectStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SelectStream.java
@@ -64,16 +64,17 @@ public class SelectStream extends TupleStream implements Expressible {
this.selectedFields.put(selectedField, selectedField);
}
operations = new ArrayList<>();
- selectedEvaluators = new LinkedHashMap();
+ selectedEvaluators = new LinkedHashMap<>();
}
public SelectStream(TupleStream stream, Map<String,String> selectedFields) throws IOException {
this.stream = stream;
this.selectedFields = selectedFields;
operations = new ArrayList<>();
- selectedEvaluators = new LinkedHashMap();
+ selectedEvaluators = new LinkedHashMap<>();
}
+ @SuppressWarnings({"unchecked"})
public SelectStream(StreamExpression expression,StreamFactory factory) throws IOException {
// grab all parameters out
List<StreamExpression> streamExpressions = factory.getExpressionOperandsRepresentingTypes(expression, Expressible.class, TupleStream.class);
@@ -101,7 +102,7 @@ public class SelectStream extends TupleStream implements Expressible {
stream = factory.constructStream(streamExpressions.get(0));
selectedFields = new HashMap<String,String>();
- selectedEvaluators = new LinkedHashMap();
+ selectedEvaluators = new LinkedHashMap<>();
for(StreamExpressionParameter parameter : selectAsFieldsExpressions){
StreamExpressionValue selectField = (StreamExpressionValue)parameter;
String value = selectField.getValue().trim();
@@ -236,7 +237,7 @@ public class SelectStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(stream);
return l;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SignificantTermsStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SignificantTermsStream.java
index a1c1b3d..e1b7f8f 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SignificantTermsStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SignificantTermsStream.java
@@ -77,7 +77,7 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
public SignificantTermsStream(String zkHost,
String collectionName,
- Map params,
+ @SuppressWarnings({"rawtypes"})Map params,
String field,
float minDocFreq,
float maxDocFreq,
@@ -202,9 +202,10 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
return expression;
}
+ @SuppressWarnings({"unchecked"})
private void init(String collectionName,
String zkHost,
- Map params,
+ @SuppressWarnings({"rawtypes"})Map params,
String field,
float minDocFreq,
float maxDocFreq,
@@ -240,6 +241,7 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
return null;
}
+ @SuppressWarnings({"rawtypes"})
private List<Future<NamedList>> callShards(List<String> baseUrls) throws IOException {
List<Future<NamedList>> futures = new ArrayList<>();
@@ -252,6 +254,7 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
this.minTermLength,
this.numTerms);
+ @SuppressWarnings({"rawtypes"})
Future<NamedList> future = executorService.submit(lc);
futures.add(future);
}
@@ -281,14 +284,17 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
.withExpression(toExpression(factory).toString());
}
+ @SuppressWarnings({"unchecked"})
public Tuple read() throws IOException {
try {
if (tupleIterator == null) {
Map<String, int[]> mergeFreqs = new HashMap<>();
long numDocs = 0;
long resultCount = 0;
- for (Future<NamedList> getTopTermsCall : callShards(getShards(zkHost, collection, streamContext))) {
+ for (@SuppressWarnings({"rawtypes"})Future<NamedList> getTopTermsCall : callShards(getShards(zkHost, collection, streamContext))) {
+ @SuppressWarnings({"rawtypes"})
NamedList fullResp = getTopTermsCall.get();
+ @SuppressWarnings({"rawtypes"})
Map stResp = (Map)fullResp.get("significantTerms");
List<String> terms = (List<String>)stResp.get("sterms");
@@ -313,10 +319,12 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
}
}
- List<Map> maps = new ArrayList();
+ @SuppressWarnings({"rawtypes"})
+ List<Map> maps = new ArrayList<>();
for(Map.Entry<String, int[]> entry : mergeFreqs.entrySet()) {
int[] freqs = entry.getValue();
+ @SuppressWarnings({"rawtypes"})
Map map = new HashMap();
map.put("term", entry.getKey());
map.put("background", freqs[0]);
@@ -329,8 +337,8 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
}
Collections.sort(maps, new ScoreComp());
- List<Tuple> tuples = new ArrayList();
- for (Map map : maps) {
+ List<Tuple> tuples = new ArrayList<>();
+ for (@SuppressWarnings({"rawtypes"})Map map : maps) {
if (tuples.size() == numTerms) break;
tuples.add(new Tuple(map));
}
@@ -345,6 +353,7 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
}
}
+ @SuppressWarnings({"rawtypes"})
private static class ScoreComp implements Comparator<Map> {
public int compare(Map a, Map b) {
Float scorea = (Float)a.get("score");
@@ -353,6 +362,7 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
}
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
protected class SignificantTermsCall implements Callable<NamedList> {
private String baseUrl;
@@ -380,6 +390,7 @@ public class SignificantTermsStream extends TupleStream implements Expressible{
this.minTermLength = minTermLength;
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
public NamedList<Double> call() throws Exception {
ModifiableSolrParams params = new ModifiableSolrParams();
HttpSolrClient solrClient = cache.getHttpSolrClient(baseUrl);
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SolrStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SolrStream.java
index 9286cfa..d4987b5 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SolrStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/SolrStream.java
@@ -85,7 +85,7 @@ public class SolrStream extends TupleStream {
}
public List<TupleStream> children() {
- return new ArrayList();
+ return new ArrayList<>();
}
public String getBaseUrl() {
@@ -191,8 +191,10 @@ public class SolrStream extends TupleStream {
* Reads a Tuple from the stream. The Stream is completed when Tuple.EOF == true.
**/
+ @SuppressWarnings({"unchecked"})
public Tuple read() throws IOException {
try {
+ @SuppressWarnings({"rawtypes"})
Map fields = tupleStreamParser.next();
if (fields == null) {
@@ -237,6 +239,7 @@ public class SolrStream extends TupleStream {
return null;
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
private Map mapFields(Map fields, Map<String,String> mappings) {
Iterator<Map.Entry<String,String>> it = mappings.entrySet().iterator();
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StatsStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StatsStream.java
index 1a31873..3403ae6 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StatsStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StatsStream.java
@@ -208,7 +208,7 @@ public class StatsStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- return new ArrayList();
+ return new ArrayList<>();
}
public void open() throws IOException {
@@ -219,11 +219,13 @@ public class StatsStream extends TupleStream implements Expressible {
paramsLoc.set("json.facet", json);
paramsLoc.set("rows", "0");
+ @SuppressWarnings({"unchecked"})
Map<String, List<String>> shardsMap = (Map<String, List<String>>)context.get("shards");
if(shardsMap == null) {
QueryRequest request = new QueryRequest(paramsLoc, SolrRequest.METHOD.POST);
cloudSolrClient = cache.getCloudSolrClient(zkHost);
try {
+ @SuppressWarnings({"rawtypes"})
NamedList response = cloudSolrClient.request(request, collection);
getTuples(response, metrics);
} catch (Exception e) {
@@ -241,6 +243,7 @@ public class StatsStream extends TupleStream implements Expressible {
QueryRequest request = new QueryRequest(paramsLoc, SolrRequest.METHOD.POST);
try {
+ @SuppressWarnings({"rawtypes"})
NamedList response = client.request(request);
getTuples(response, metrics);
} catch (Exception e) {
@@ -301,16 +304,17 @@ public class StatsStream extends TupleStream implements Expressible {
}
}
- private void getTuples(NamedList response,
+ private void getTuples(@SuppressWarnings({"rawtypes"})NamedList response,
Metric[] metrics) {
this.tuple = new Tuple();
+ @SuppressWarnings({"rawtypes"})
NamedList facets = (NamedList)response.get("facets");
fillTuple(tuple, facets, metrics);
}
private void fillTuple(Tuple t,
- NamedList nl,
+ @SuppressWarnings({"rawtypes"})NamedList nl,
Metric[] _metrics) {
if(nl == null) {
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StreamContext.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StreamContext.java
index 8243b2a..2a0c5b0 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StreamContext.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/StreamContext.java
@@ -38,9 +38,12 @@ import org.apache.solr.common.params.SolrParams;
public class StreamContext implements Serializable{
+ @SuppressWarnings({"rawtypes"})
private Map entries = new HashMap();
+ @SuppressWarnings({"rawtypes"})
private Map tupleContext = new HashMap();
- private Map<String, Object> lets = new HashMap();
+ private Map<String, Object> lets = new HashMap<>();
+ @SuppressWarnings({"rawtypes"})
private ConcurrentMap objectCache;
public int workerID;
public int numWorkers;
@@ -50,11 +53,12 @@ public class StreamContext implements Serializable{
private SolrParams requestParams;
private RequestReplicaListTransformerGenerator requestReplicaListTransformerGenerator;
+ @SuppressWarnings({"rawtypes"})
public ConcurrentMap getObjectCache() {
return this.objectCache;
}
- public void setObjectCache(ConcurrentMap objectCache) {
+ public void setObjectCache(@SuppressWarnings({"rawtypes"})ConcurrentMap objectCache) {
this.objectCache = objectCache;
}
@@ -66,6 +70,7 @@ public class StreamContext implements Serializable{
return entries.get(key);
}
+ @SuppressWarnings({"unchecked"})
public void put(Object key, Object value) {
this.entries.put(key, value);
}
@@ -74,6 +79,7 @@ public class StreamContext implements Serializable{
return entries.containsKey(key);
}
+ @SuppressWarnings({"rawtypes"})
public Map getEntries() {
return this.entries;
}
@@ -98,6 +104,7 @@ public class StreamContext implements Serializable{
this.streamFactory = streamFactory;
}
+ @SuppressWarnings({"rawtypes"})
public Map getTupleContext() {
return tupleContext;
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TextLogitStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TextLogitStream.java
index 3e6666d..6949d80 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TextLogitStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TextLogitStream.java
@@ -99,7 +99,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
public TextLogitStream(String zkHost,
String collectionName,
- Map params,
+ @SuppressWarnings({"rawtypes"})Map params,
String name,
String field,
TupleStream termsStream,
@@ -283,9 +283,10 @@ public class TextLogitStream extends TupleStream implements Expressible {
return expression;
}
+ @SuppressWarnings({"unchecked"})
private void init(String collectionName,
String zkHost,
- Map params,
+ @SuppressWarnings({"rawtypes"})Map params,
String name,
String feature,
TupleStream termsStream,
@@ -332,7 +333,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
l.add(termsStream);
return l;
}
@@ -371,7 +372,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
private List<Future<Tuple>> callShards(List<String> baseUrls) throws IOException {
- List<Future<Tuple>> futures = new ArrayList();
+ List<Future<Tuple>> futures = new ArrayList<>();
for (String baseUrl : baseUrls) {
LogitCall lc = new LogitCall(baseUrl,
this.params,
@@ -423,7 +424,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
if (this.terms == null) {
termsStream.open();
this.terms = new ArrayList<>();
- this.idfs = new ArrayList();
+ this.idfs = new ArrayList<>();
while (true) {
Tuple termTuple = termsStream.read();
@@ -438,6 +439,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
}
}
+ @SuppressWarnings({"unchecked"})
public Tuple read() throws IOException {
try {
@@ -453,7 +455,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
}
}
- List<List<Double>> allWeights = new ArrayList();
+ List<List<Double>> allWeights = new ArrayList<>();
this.evaluation = new ClassificationEvaluation();
this.error = 0;
@@ -463,11 +465,13 @@ public class TextLogitStream extends TupleStream implements Expressible {
List<Double> shardWeights = (List<Double>) tuple.get("weights");
allWeights.add(shardWeights);
this.error += tuple.getDouble("error");
+ @SuppressWarnings({"rawtypes"})
Map shardEvaluation = (Map) tuple.get("evaluation");
this.evaluation.addEvaluation(shardEvaluation);
}
this.weights = averageWeights(allWeights);
+ @SuppressWarnings({"rawtypes"})
Map map = new HashMap();
map.put(ID, name+"_"+iteration);
map.put("name_s", name);
@@ -514,7 +518,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
working[i] = working[i] / allWeights.size();
}
- List<Double> ave = new ArrayList();
+ List<Double> ave = new ArrayList<>();
for(double d : working) {
ave.add(d);
}
@@ -522,7 +526,7 @@ public class TextLogitStream extends TupleStream implements Expressible {
return ave;
}
- static String toString(List items) {
+ static String toString(@SuppressWarnings({"rawtypes"})List items) {
StringBuilder buf = new StringBuilder();
for(Object item : items) {
if(buf.length() > 0) {
@@ -640,10 +644,13 @@ public class TextLogitStream extends TupleStream implements Expressible {
QueryRequest request= new QueryRequest(params, SolrRequest.METHOD.POST);
QueryResponse response = request.process(solrClient);
+ @SuppressWarnings({"rawtypes"})
NamedList res = response.getResponse();
+ @SuppressWarnings({"rawtypes"})
NamedList logit = (NamedList)res.get("logit");
+ @SuppressWarnings({"unchecked"})
List<Double> shardWeights = (List<Double>)logit.get("weights");
double shardError = (double)logit.get("error");
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TimeSeriesStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TimeSeriesStream.java
index e9d7e7a..a7cbee7 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TimeSeriesStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TimeSeriesStream.java
@@ -65,7 +65,7 @@ public class TimeSeriesStream extends TupleStream implements Expressible {
private DateTimeFormatter formatter;
private Metric[] metrics;
- private List<Tuple> tuples = new ArrayList();
+ private List<Tuple> tuples = new ArrayList<>();
private int index;
private String zkHost;
private SolrParams params;
@@ -287,7 +287,7 @@ public class TimeSeriesStream extends TupleStream implements Expressible {
}
public List<TupleStream> children() {
- return new ArrayList();
+ return new ArrayList<>();
}
public void open() throws IOException {
@@ -307,6 +307,7 @@ public class TimeSeriesStream extends TupleStream implements Expressible {
QueryRequest request = new QueryRequest(paramsLoc, SolrRequest.METHOD.POST);
try {
+ @SuppressWarnings({"rawtypes"})
NamedList response = cloudSolrClient.request(request, collection);
getTuples(response, field, metrics);
} catch (Exception e) {
@@ -374,28 +375,32 @@ public class TimeSeriesStream extends TupleStream implements Expressible {
buf.append("}}");
}
- private void getTuples(NamedList response,
+ private void getTuples(@SuppressWarnings({"rawtypes"})NamedList response,
String field,
Metric[] metrics) {
Tuple tuple = new Tuple();
+ @SuppressWarnings({"rawtypes"})
NamedList facets = (NamedList)response.get("facets");
fillTuples(tuples, tuple, facets, field, metrics);
}
private void fillTuples(List<Tuple> tuples,
Tuple currentTuple,
- NamedList facets,
+ @SuppressWarnings({"rawtypes"})NamedList facets,
String field,
Metric[] _metrics) {
+ @SuppressWarnings({"rawtypes"})
NamedList nl = (NamedList)facets.get("timeseries");
if(nl == null) {
return;
}
+ @SuppressWarnings({"rawtypes"})
List allBuckets = (List)nl.get("buckets");
for(int b=0; b<allBuckets.size(); b++) {
+ @SuppressWarnings({"rawtypes"})
NamedList bucket = (NamedList)allBuckets.get(b);
Object val = bucket.get("val");
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TopicStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TopicStream.java
index 26cbff3..b1769a6 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TopicStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TopicStream.java
@@ -273,14 +273,14 @@ public class TopicStream extends CloudSolrStream implements Expressible {
}
public List<TupleStream> children() {
- List<TupleStream> l = new ArrayList();
+ List<TupleStream> l = new ArrayList<>();
return l;
}
public void open() throws IOException {
- this.tuples = new TreeSet();
- this.solrStreams = new ArrayList();
- this.eofTuples = Collections.synchronizedMap(new HashMap());
+ this.tuples = new TreeSet<>();
+ this.solrStreams = new ArrayList<>();
+ this.eofTuples = Collections.synchronizedMap(new HashMap<>());
if(checkpoints.size() == 0 && streamContext.numWorkers > 1) {
//Each worker must maintain its own checkpoints
@@ -313,7 +313,7 @@ public class TopicStream extends CloudSolrStream implements Expressible {
ExecutorService service = ExecutorUtil.newMDCAwareCachedThreadPool(new SolrNamedThreadFactory("TopicStream"));
try {
- List<Future<TupleWrapper>> futures = new ArrayList();
+ List<Future<TupleWrapper>> futures = new ArrayList<>();
for (TupleStream solrStream : solrStreams) {
StreamOpener so = new StreamOpener((SolrStream) solrStream, comp);
Future<TupleWrapper> future = service.submit(so);
@@ -489,6 +489,7 @@ public class TopicStream extends CloudSolrStream implements Expressible {
try {
SolrDocument doc = httpClient.getById(id);
if(doc != null) {
+ @SuppressWarnings({"unchecked"})
List<String> checkpoints = (List<String>)doc.getFieldValue("checkpoint_ss");
for (String checkpoint : checkpoints) {
String[] pair = checkpoint.split("~");
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupStream.java
index 7dd6204..769b696 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupStream.java
@@ -50,8 +50,8 @@ public class TupStream extends TupleStream implements Expressible {
private Map<String,String> stringParams = new HashMap<>();
private Map<String,StreamEvaluator> evaluatorParams = new HashMap<>();
private Map<String,TupleStream> streamParams = new HashMap<>();
- private List<String> fieldNames = new ArrayList();
- private Map<String, String> fieldLabels = new HashMap();
+ private List<String> fieldNames = new ArrayList<>();
+ private Map<String, String> fieldLabels = new HashMap<>();
private Tuple tup = null;
private Tuple unnestedTuple = null;
private Iterator<Tuple> unnestedTuples = null;
@@ -174,6 +174,7 @@ public class TupStream extends TupleStream implements Expressible {
// Nothing to do here
}
+ @SuppressWarnings({"unchecked"})
public void open() throws IOException {
Map<String, Object> values = new HashMap<>();
@@ -197,7 +198,7 @@ public class TupStream extends TupleStream implements Expressible {
for(Entry<String,TupleStream> param : streamParams.entrySet()){
try{
- List<Tuple> streamTuples = new ArrayList();
+ List<Tuple> streamTuples = new ArrayList<>();
// open the stream, closed in finally block
param.getValue().open();
@@ -221,6 +222,7 @@ public class TupStream extends TupleStream implements Expressible {
if(o instanceof Tuple) {
unnestedTuple = (Tuple)o;
} else if(o instanceof List) {
+ @SuppressWarnings({"rawtypes"})
List l = (List)o;
if(l.size() > 0 && l.get(0) instanceof Tuple) {
List<Tuple> tl = (List<Tuple>)l;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupleStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupleStream.java
index c2957bc..f3d8079 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupleStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupleStream.java
@@ -123,13 +123,14 @@ public abstract class TupleStream implements Closeable, Serializable, MapWriter
return getShards(zkHost, collection, streamContext, new ModifiableSolrParams());
}
+ @SuppressWarnings({"unchecked"})
public static List<String> getShards(String zkHost,
String collection,
StreamContext streamContext,
SolrParams requestParams)
throws IOException {
Map<String, List<String>> shardsMap = null;
- List<String> shards = new ArrayList();
+ List<String> shards = new ArrayList<>();
if(streamContext != null) {
shardsMap = (Map<String, List<String>>)streamContext.get("shards");
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/UpdateStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/UpdateStream.java
index 453f842..f309f19 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/UpdateStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/UpdateStream.java
@@ -66,7 +66,7 @@ public class UpdateStream extends TupleStream implements Expressible {
private PushBackStream tupleSource;
private transient SolrClientCache cache;
private transient CloudSolrClient cloudSolrClient;
- private List<SolrInputDocument> documentBatch = new ArrayList();
+ private List<SolrInputDocument> documentBatch = new ArrayList<>();
private String coreName;
public UpdateStream(StreamExpression expression, StreamFactory factory) throws IOException {
@@ -294,6 +294,7 @@ public class UpdateStream extends TupleStream implements Expressible {
}
}
+ @SuppressWarnings({"unchecked"})
private SolrInputDocument convertTupleToSolrDocument(Tuple tuple) {
SolrInputDocument doc = new SolrInputDocument();
for (Object field : tuple.getFields().keySet()) {
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ZplotStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ZplotStream.java
index e6f0222..d9854e6 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ZplotStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/ZplotStream.java
@@ -53,9 +53,11 @@ public class ZplotStream extends TupleStream implements Expressible {
private static final long serialVersionUID = 1;
private StreamContext streamContext;
+ @SuppressWarnings({"rawtypes"})
private Map letParams = new LinkedHashMap();
private Iterator<Tuple> out;
+ @SuppressWarnings({"unchecked"})
public ZplotStream(StreamExpression expression, StreamFactory factory) throws IOException {
List<StreamExpressionNamedParameter> namedParams = factory.getNamedOperands(expression);
@@ -118,10 +120,11 @@ public class ZplotStream extends TupleStream implements Expressible {
public void close() throws IOException {
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
public void open() throws IOException {
Map<String, Object> lets = streamContext.getLets();
Set<Map.Entry<String, Object>> entries = letParams.entrySet();
- Map<String, Object> evaluated = new HashMap();
+ Map<String, Object> evaluated = new HashMap<>();
//Load up the StreamContext with the data created by the letParams.
int numTuples = -1;
@@ -191,7 +194,7 @@ public class ZplotStream extends TupleStream implements Expressible {
}
//Load the values into tuples
- List<Tuple> outTuples = new ArrayList();
+ List<Tuple> outTuples = new ArrayList<>();
if(!table && !distribution && !clusters && !heat) {
//Handle the vectors
for (int i = 0; i < numTuples; i++) {
@@ -287,7 +290,7 @@ public class ZplotStream extends TupleStream implements Expressible {
}
Iterator it = frequency.valuesIterator();
- List<Long> values = new ArrayList();
+ List<Long> values = new ArrayList<>();
while(it.hasNext()) {
values.add((Long)it.next());
}
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/Explanation.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/Explanation.java
index acaefbf..b62777f 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/Explanation.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/Explanation.java
@@ -128,6 +128,7 @@ public class Explanation implements MapSerializable {
}
@Override
+ @SuppressWarnings({"unchecked", "rawtypes"})
public Map toMap(Map<String, Object> map) {
if(null != expressionNodeId){ map.put("expressionNodeId",expressionNodeId); }
if(null != expressionType){ map.put("expressionType",expressionType); }
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExplanation.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExplanation.java
index bfe6651..d6e61c4 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExplanation.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExplanation.java
@@ -55,6 +55,7 @@ public class StreamExplanation extends Explanation {
children.add(child);
}
+ @SuppressWarnings({"unchecked"})
public Map<String,Object> toMap(Map<String,Object> map){
map = super.toMap(map);
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpression.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpression.java
index 35d9f52..4d80a4d 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpression.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpression.java
@@ -22,6 +22,7 @@ import java.util.List;
/**
* Expression containing a function and set of parameters
*/
+@SuppressWarnings({"overrides"})
public class StreamExpression implements StreamExpressionParameter {
private String functionName;
private List<StreamExpressionParameter> parameters;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionNamedParameter.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionNamedParameter.java
index 5c9f53c..ccfc243 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionNamedParameter.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionNamedParameter.java
@@ -20,6 +20,7 @@ package org.apache.solr.client.solrj.io.stream.expr;
/**
* Provides a named parameter
*/
+@SuppressWarnings({"overrides"})
public class StreamExpressionNamedParameter implements StreamExpressionParameter {
private String name;
private StreamExpressionParameter parameter;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionValue.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionValue.java
index 20a3f95..433559b 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionValue.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamExpressionValue.java
@@ -19,6 +19,7 @@ package org.apache.solr.client.solrj.io.stream.expr;
/**
* Basic string stream expression
*/
+@SuppressWarnings({"overrides"})
public class StreamExpressionValue implements StreamExpressionParameter {
private String value;
diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamFactory.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamFactory.java
index 451add8..f3443e9 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamFactory.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/expr/StreamFactory.java
@@ -182,12 +182,14 @@ public class StreamFactory implements Serializable {
return namedParameters;
}
- public List<StreamExpressionParameter> getOperandsOfType(StreamExpression expression, Class ... clazzes) {
+ @SuppressWarnings({"unchecked"})
+ public List<StreamExpressionParameter> getOperandsOfType(StreamExpression expression,
+ @SuppressWarnings({"rawtypes"})Class ... clazzes) {
List<StreamExpressionParameter> parameters = new ArrayList<>();
parameterLoop:
for (StreamExpressionParameter parameter : expression.getParameters()) {
- for (Class clazz : clazzes) {
+ for (@SuppressWarnings({"rawtypes"})Class clazz : clazzes) {
if (!clazz.isAssignableFrom(parameter.getClass())) {
continue parameterLoop; // go to the next parameter since this parameter cannot be assigned to at least one of the classes
}
@@ -197,7 +199,9 @@ public class StreamFactory implements Serializable {
return parameters;
}
- public List<StreamExpression> getExpressionOperandsRepresentingTypes(StreamExpression expression, Class ... clazzes) {
+ @SuppressWarnings({"unchecked"})
+ public List<StreamExpression> getExpressionOperandsRepresentingTypes(StreamExpression expression,
+ @SuppressWarnings({"rawtypes"})Class ... clazzes) {
List<StreamExpression> matchingStreamExpressions = new ArrayList<>();
List<StreamExpression> allStreamExpressions = getExpressionOperands(expression);
@@ -205,7 +209,7 @@ public class StreamFactory implements Serializable {
for (StreamExpression streamExpression : allStreamExpressions) {
Supplier<Class<? extends Expressible>> classSupplier = functionNames.get(streamExpression.getFunctionName());
if (classSupplier != null) {
- for (Class clazz : clazzes) {
+ for (@SuppressWarnings({"rawtypes"})Class clazz : clazzes) {
if (!clazz.isAssignableFrom(classSupplier.get())) {
continue parameterLoop;
}
@@ -216,10 +220,11 @@ public class StreamFactory implements Serializable {
return matchingStreamExpressions;
}
- public boolean doesRepresentTypes(StreamExpression expression, Class ... clazzes) {
+ @SuppressWarnings({"unchecked"})
+ public boolean doesRepresentTypes(StreamExpression expression, @SuppressWarnings({"rawtypes"})Class ... clazzes) {
Supplier<Class<? extends Expressible>> classSupplier = functionNames.get(expression.getFunctionName());
if (classSupplier != null) {
- for (Class clazz : clazzes) {
+ for (@SuppressWarnings({"rawtypes"})Class clazz : clazzes) {
if (!clazz.isAssignableFrom(classSupplier.get())) {
return false;
}
@@ -265,6 +270,7 @@ public class StreamFactory implements Serializable {
public TupleStream constructStream(String expressionClause) throws IOException {
return constructStream(StreamExpressionParser.parse(expressionClause));
}
+ @SuppressWarnings({"rawtypes"})
public TupleStream constructStream(StreamExpression expression) throws IOException {
String function = expression.getFunctionName();
Supplier<Class<? extends Expressible>> classSupplier = functionNames.get(function);
@@ -283,6 +289,7 @@ public class StreamFactory implements Serializable {
return constructMetric(StreamExpressionParser.parse(expressionClause));
}
+ @SuppressWarnings({"rawtypes"})
public Metric constructMetric(StreamExpression expression) throws IOException {
String function = expression.getFunctionName();
Supplier<Class<? extends Expressible>> classSupplier = functionNames.get(function);
@@ -296,7 +303,8 @@ public class StreamFactory implements Serializable {
throw new IOException(String.format(Locale.ROOT, "Invalid metric expression %s - function '%s' is unknown (not mapped to a valid Metric)", expression, expression.getFunctionName()));
}
- public StreamComparator constructComparator(String comparatorString, Class comparatorType) throws IOException {
+ @SuppressWarnings({"unchecked", "rawtypes"})
+ public StreamComparator constructComparator(String comparatorString, @SuppressWarnings({"rawtypes"})Class comparatorType) throws IOException {
if (comparatorString.contains(",")) {
String[] parts = comparatorString.split(",");
StreamComparator[] comps = new StreamComparator[parts.length];
@@ -349,6 +357,7 @@ public class StreamFactory implements Serializable {
}
}
+ @SuppressWarnings({"unchecked", "rawtypes"})
public StreamEqualitor constructEqualitor(String equalitorString, Class equalitorType) throws IOException {
if (equalitorString.contains(",")) {
String[] parts = equalitorString.split(",");
@@ -381,6 +390,7 @@ public class StreamFactory implements Serializable {
return constructMetric(StreamExpressionParser.parse(expressionClause));
}
+ @SuppressWarnings({"rawtypes"})
public StreamOperation constructOperation(StreamExpression expression) throws IOException {
String function = expression.getFunctionName();
Supplier<Class<? extends Expressible>> classSupplier = functionNames.get(function);
@@ -398,6 +408,7 @@ public class StreamFactory implements Serializable {
return constructEvaluator(StreamExpressionParser.parse(expressionClause));
}
+ @SuppressWarnings({"rawtypes"})
public org.apache.solr.client.solrj.io.eval.StreamEvaluator constructEvaluator(StreamExpression expression) throws IOException {
String function = expression.getFunctionName();
Supplier<Class<? extends Expressible>> classSupplier = functionNames.get(function);