You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by cp...@apache.org on 2017/05/04 17:10:07 UTC
[13/50] lucene-solr:jira/solr-8668: SOLR-10559: Fixed compilation
error
SOLR-10559: Fixed compilation error
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/e4d4e582
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/e4d4e582
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/e4d4e582
Branch: refs/heads/jira/solr-8668
Commit: e4d4e582a0049de34990fcff3df5fb220f14ee4b
Parents: e57fab1
Author: Joel Bernstein <jb...@apache.org>
Authored: Thu Apr 27 16:40:24 2017 -0400
Committer: Joel Bernstein <jb...@apache.org>
Committed: Thu Apr 27 17:03:29 2017 -0400
----------------------------------------------------------------------
.../apache/solr/client/solrj/io/stream/GetStream.java | 14 +++++++++++---
1 file changed, 11 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/e4d4e582/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/GetStream.java
----------------------------------------------------------------------
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 5a89f0f..a9c8478 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
@@ -101,9 +101,17 @@ public class GetStream extends TupleStream implements Expressible {
}
public void open() throws IOException {
- Map<String, List<Tuple>> lets = streamContext.getLets();
- List<Tuple> tuples = lets.get(name);
- tupleIterator = tuples.iterator();
+ Map<String, Object> lets = streamContext.getLets();
+ Object o = lets.get(name);
+ List l = null;
+ if(o instanceof List) {
+ l = (List)o;
+ if(l.get(0) instanceof Tuple) {
+ tupleIterator = l.iterator();
+ } else {
+ throw new IOException("Get was not passed a list of tuples:"+o.getClass());
+ }
+ }
}
/** Return the stream sort - ie, the order in which records are returned */