

API Docs - v1.1.0

Store

elasticsearch (Store)

Elasticsearch store implementation uses Elasticsearch indexing document for underlying data storage. The events are converted to Elasticsearch index documents when the events are inserted into the elasticsearch store. Elasticsearch indexing documents are converted to events when the documents are read from Elasticsearch indexes. The internal store is connected to the Elastisearch server via the Elasticsearch Java High Level REST Client library.

Syntax

@Store(type="elasticsearch", host="<STRING>", port="<INT>", scheme="<STRING>", username="<STRING>", password="<STRING>", index.name="<STRING>", index.alias="<STRING>", index.number.of.shards="<INT>", index.number.of.replicas="<INT>")
@PrimaryKey("PRIMARY_KEY")
@Index("INDEX")

QUERY PARAMETERS

Name	Description	Default Value	Possible Data Types	Optional	Dynamic
host	The host of the Elasticsearch server.	localhost	STRING	Yes	No
port	The port of the Elasticsearch server.	9200	INT	Yes	No
scheme	The scheme type of the Elasticsearch server connection.	http	STRING	Yes	No
username	The username for the Elasticsearch server connection.	elastic	STRING	Yes	No
password	The password for the Elasticsearch server connection.	changeme	STRING	Yes	No
index.name	The name of the Elasticsearch index.	The table name defined in the Siddhi App query.	STRING	Yes	No
index.alias	The alias of the Elasticsearch index.	null	STRING	Yes	No
index.number.of.shards	The number of shards allocated for the index in the Elasticsearch server.	3	INT	Yes	No
index.number.of.replicas	The number of replicas for the index in the Elasticsearch server.	2	INT	Yes	No

Examples EXAMPLE 1

@Store(type="elasticsearch", host="localhost", username="elastic", password="changeme" , index.name="MyStockTable",field.length="symbol:100")
@PrimaryKey("symbol")define table StockTable (symbol string, price float, volume long);

This example creates an index named 'MyStockTable' in the Elasticsearch server if it does not already exist (with three attributes named 'symbol', 'price', and 'volume' of the types 'string', 'float' and 'long' respectively). The connection is made as specified by the parameters configured for the '@Store' annotation. The 'symbol' attribute is considered a unique field and an Elasticsearch index document ID is generated for it.