storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [08/13] storm git commit: Weaken the ES get request extractor dependency to ITuple
Date Thu, 27 Aug 2015 22:12:52 GMT
Weaken the ES get request extractor dependency to ITuple


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a2db49f1
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a2db49f1
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a2db49f1

Branch: refs/heads/master
Commit: a2db49f1b476c5cbd0253a6cba4a29c0e3c5584e
Parents: 7b52754
Author: Alex Panov <alex.panov@teradata.com>
Authored: Thu Aug 20 17:53:52 2015 +0200
Committer: Alex Panov <alex.panov@teradata.com>
Committed: Thu Aug 20 17:53:52 2015 +0200

----------------------------------------------------------------------
 .../org/apache/storm/elasticsearch/ElasticsearchGetRequest.java  | 4 ++--
 .../storm/elasticsearch/bolt/EsLookupBoltIntegrationTest.java    | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/a2db49f1/external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/ElasticsearchGetRequest.java
----------------------------------------------------------------------
diff --git a/external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/ElasticsearchGetRequest.java
b/external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/ElasticsearchGetRequest.java
index 2fcbbf1..098c993 100644
--- a/external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/ElasticsearchGetRequest.java
+++ b/external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/ElasticsearchGetRequest.java
@@ -19,9 +19,9 @@ package org.apache.storm.elasticsearch;
 
 import org.elasticsearch.action.get.GetRequest;
 
-import backtype.storm.tuple.Tuple;
+import backtype.storm.tuple.ITuple;
 
 public interface ElasticsearchGetRequest {
 
-    GetRequest extractFrom(Tuple tuple);
+    GetRequest extractFrom(ITuple tuple);
 }

http://git-wip-us.apache.org/repos/asf/storm/blob/a2db49f1/external/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsLookupBoltIntegrationTest.java
----------------------------------------------------------------------
diff --git a/external/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsLookupBoltIntegrationTest.java
b/external/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsLookupBoltIntegrationTest.java
index 2a544f9..a869281 100644
--- a/external/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsLookupBoltIntegrationTest.java
+++ b/external/storm-elasticsearch/src/test/java/org/apache/storm/elasticsearch/bolt/EsLookupBoltIntegrationTest.java
@@ -35,6 +35,7 @@ import org.mockito.Mock;
 import org.mockito.runners.MockitoJUnitRunner;
 
 import backtype.storm.tuple.Fields;
+import backtype.storm.tuple.ITuple;
 import backtype.storm.tuple.Tuple;
 import backtype.storm.tuple.Values;
 
@@ -110,7 +111,7 @@ public class EsLookupBoltIntegrationTest extends AbstractEsBoltIntegrationTest<E
     private class TestElasticsearchGetRequest implements ElasticsearchGetRequest {
 
         @Override
-        public GetRequest extractFrom(Tuple tuple) {
+        public GetRequest extractFrom(ITuple tuple) {
             return node.client().prepareGet().setId(documentId).setIndex(indexName).setType(typeName).request();
         }
     }


Mime
View raw message