You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by jb...@apache.org on 2017/05/03 17:49:11 UTC
[33/36] lucene-solr:branch_6x: SOLR-10559: Fix TupStream to respect
field order
SOLR-10559: Fix TupStream to respect field order
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/3fdbbb7c
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/3fdbbb7c
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/3fdbbb7c
Branch: refs/heads/branch_6x
Commit: 3fdbbb7c6f95b64b73903a0372cae4c339678709
Parents: 5269fce
Author: Joel Bernstein <jb...@apache.org>
Authored: Mon May 1 12:32:37 2017 -0400
Committer: Joel Bernstein <jb...@apache.org>
Committed: Wed May 3 13:10:26 2017 -0400
----------------------------------------------------------------------
.../org/apache/solr/client/solrj/io/stream/TupStream.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/3fdbbb7c/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/TupStream.java
----------------------------------------------------------------------
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 8a71ae6..f099e31 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
@@ -46,6 +46,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 boolean finished;
@@ -55,6 +57,8 @@ public class TupStream extends TupleStream implements Expressible {
//Get all the named params
for(StreamExpressionNamedParameter np : namedParams) {
String name = np.getName();
+ fieldNames.add(name);
+ fieldLabels.put(name, name);
StreamExpressionParameter param = np.getParameter();
// we're going to split these up here so we only make the choice once
@@ -186,7 +190,10 @@ public class TupStream extends TupleStream implements Expressible {
}
}
- return new Tuple(values);
+ Tuple tup = new Tuple(values);
+ tup.fieldNames = fieldNames;
+ tup.fieldLabels = fieldLabels;
+ return tup;
}
}