[
https://issues.apache.org/jira/browse/STORM-845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14595376#comment-14595376
]
ASF GitHub Bot commented on STORM-845:
--------------------------------------
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/573#discussion_r32905722
--- Diff: external/storm-elasticsearch/README.md ---
@@ -0,0 +1,71 @@
+# Storm ElasticSearch Bolt & Trident State
+
+ EsIndexBolt, EsPercolateBolt and EsState allows users to stream data
from storm into ElasticSearch directly.
+ For detailed description, please refer to the following.
+
+## EsIndexBolt (org.apache.storm.elasticsearch.bolt.EsIndexBolt)
+
+EsIndexBolt streams tuples directly into ElasticSearch. Tuples are indexed
in specified index & type combination.
+User should make sure that there are "index","type", and "source" fields
declared in preceding bolts or spout.
+"index" and "type" fields are used for identifying target index and type.
+"source" is a document in JSON format string that will be indexed in
elastic search.
+
+```java
+EsConfig esConfig = new EsConfig();
+esConfig.setClusterName(clusterName);
+esConfig.setHost(new String[]{"localhost"});
+esConfig.setPort(9300);
+EsIndexBolt indexBolt = new IndexBolt(esConfig);
+```
+
+## EsPercolateBolt (org.apache.storm.elasticsearch.bolt.EsPercolateBolt)
+
+EsPercolateBolt streams tuples directly into ElasticSearch. Tuples are
used to send percolate request to specified index & type combination.
+User should make sure that there are "index","type", and "source" fields
declared in preceding bolts or spout.
+"index" and "type" fields are used for identifying target index and type.
+"source" is a document in JSON format string that will be sent in
percolate request to elastic search.
+
+```java
+EsConfig esConfig = new EsConfig();
+esConfig.setClusterName(clusterName);
+esConfig.setHost(new String[]{"localhost"});
+esConfig.setPort(9300);
+EsPercolateBolt percolateBolt = new EsPercolateBolt(esConfig);
+```
+
+### EsConfig (org.apache.storm.elasticsearch.common.EsConfig)
+
+Two bolts above takes in EsConfig as a constructor arg.
+
+ ```java
+ EsConfig esConfig = new EsConfig();
+ esConfig.setClusterName(clusterName);
+ esConfig.setHost(new String[]{"localhost"});
+ esConfig.setPort(9300);
+ ```
+
+EsConfig params
+
+|Arg |Description | Type
+|--- |--- |---
+|clusterName | ElasticSearch cluster name | String (required) |
+|host | ElasticSearch host | String array (required) |
--- End diff --
+1 on @harshach opinion.
> Storm ElasticSearch connector
> -----------------------------
>
> Key: STORM-845
> URL: https://issues.apache.org/jira/browse/STORM-845
> Project: Apache Storm
> Issue Type: New Feature
> Reporter: Adrian Seungjin Lee
>
> It would be nice to provide storm driver for elasticsearch, just like it does
> for hive, redis and so on.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
