You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2015/05/12 23:15:25 UTC
[3/3] camel git commit: Elasticsearch component docs
Elasticsearch component docs
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/746e4263
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/746e4263
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/746e4263
Branch: refs/heads/master
Commit: 746e4263438f9094add5c4328960074dd773ed4f
Parents: e085ef2
Author: Andrea Cosentino <an...@gmail.com>
Authored: Tue May 12 23:14:11 2015 +0200
Committer: Andrea Cosentino <an...@gmail.com>
Committed: Tue May 12 23:14:11 2015 +0200
----------------------------------------------------------------------
.../ElasticsearchConfiguration.java | 65 +++++++++++++++-----
1 file changed, 48 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/746e4263/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java
index 3888ed2..b71b925 100644
--- a/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java
+++ b/components/camel-elasticsearch/src/main/java/org/apache/camel/component/elasticsearch/ElasticsearchConfiguration.java
@@ -61,23 +61,10 @@ public class ElasticsearchConfiguration {
private String transportAddresses;
@UriParam(defaultValue = "9300")
private int port = ElasticsearchConstants.DEFAULT_PORT;
-
- public boolean isLocal() {
- return local;
- }
-
- public void setLocal(boolean local) {
- this.local = local;
- }
-
- public List<InetSocketTransportAddress> getTransportAddressesList() {
- return transportAddressesList;
- }
-
- public void setTransportAddressesList(List<InetSocketTransportAddress> transportAddressesList) {
- this.transportAddressesList = transportAddressesList;
- }
+ /**
+ * Name of cluster or use local for local mode
+ */
public String getClusterName() {
return clusterName;
}
@@ -86,6 +73,9 @@ public class ElasticsearchConfiguration {
this.clusterName = clusterName;
}
+ /**
+ * What operation to perform
+ */
public String getOperation() {
return operation;
}
@@ -94,6 +84,9 @@ public class ElasticsearchConfiguration {
this.operation = operation;
}
+ /**
+ * The name of the index to act against
+ */
public String getIndexName() {
return indexName;
}
@@ -102,6 +95,9 @@ public class ElasticsearchConfiguration {
this.indexName = indexName;
}
+ /**
+ * The type of the index to act against
+ */
public String getIndexType() {
return indexType;
}
@@ -110,6 +106,9 @@ public class ElasticsearchConfiguration {
this.indexType = indexType;
}
+ /**
+ * The write consistency level to use with INDEX and BULK operations (can be any of ONE, QUORUM, ALL or DEFAULT)
+ */
public WriteConsistencyLevel getConsistencyLevel() {
return consistencyLevel;
}
@@ -118,6 +117,9 @@ public class ElasticsearchConfiguration {
this.consistencyLevel = consistencyLevel;
}
+ /**
+ * The replication type to use with INDEX and BULK operations (can be any of SYNC, ASYNC or DEFAULT)
+ */
public ReplicationType getReplicationType() {
return replicationType;
}
@@ -125,7 +127,10 @@ public class ElasticsearchConfiguration {
public void setReplicationType(ReplicationType replicationType) {
this.replicationType = replicationType;
}
-
+
+ /**
+ * Is the node going to be allowed to allocate data (shards) to it or not. This setting map to the <tt>node.data</tt> setting.
+ */
public Boolean getData() {
return data;
}
@@ -134,6 +139,9 @@ public class ElasticsearchConfiguration {
this.data = data;
}
+ /**
+ * The TransportClient remote host ip to use
+ */
public String getIp() {
return ip;
}
@@ -142,6 +150,10 @@ public class ElasticsearchConfiguration {
this.ip = ip;
}
+ /**
+ * Comma separated list with ip:port formatted remote transport addresses to use.
+ * The ip and port options must be left blank for transportAddresses to be considered instead.
+ */
public String getTransportAddresses() {
return transportAddresses;
}
@@ -150,6 +162,9 @@ public class ElasticsearchConfiguration {
this.transportAddresses = transportAddresses;
}
+ /**
+ * The TransportClient remote port to use (defaults to 9300)
+ */
public int getPort() {
return port;
}
@@ -157,4 +172,20 @@ public class ElasticsearchConfiguration {
public void setPort(int port) {
this.port = port;
}
+
+ public boolean isLocal() {
+ return local;
+ }
+
+ public void setLocal(boolean local) {
+ this.local = local;
+ }
+
+ public List<InetSocketTransportAddress> getTransportAddressesList() {
+ return transportAddressesList;
+ }
+
+ public void setTransportAddressesList(List<InetSocketTransportAddress> transportAddressesList) {
+ this.transportAddressesList = transportAddressesList;
+ }
}
\ No newline at end of file