You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/08/28 00:12:52 UTC
[08/13] storm git commit: Weaken the ES get request extractor
dependency to ITuple
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 <al...@teradata.com>
Authored: Thu Aug 20 17:53:52 2015 +0200
Committer: Alex Panov <al...@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();
}
}