ElasticsearchLoader¶

The ElasticsearchLoader writes processed rows into a given Elasticsearch index and returns the rows.

Configuration¶

XPath	Type	Description
`elasticsearch/@index`	Attribute	Name of the Elasticsearch index where the documents are stored.
`elasticsearch/@idField`	Attribute	Name of the field in the row that is used as the Elasticsearch document ID (`_id`).

The Elasticsearch hosts are configured via the project configuration (e.g. SpringbokCommonConfig::getElasticsearchLoaderHosts()) and are not provided in the pipeline XML.

Example¶

Input data¶

Row	code	name	symbol
1	String: `EUR`	String: `Euro`	String: `€`
2	String: `USD`	String: `US Dollar`	String: `$`

Pipeline configuration¶

<elasticsearch
    index="currency"
    idField="code"
/>

Elasticsearch output¶

Documents stored in the currency index:

_id	code	name	symbol
`EUR`	`EUR`	`Euro`	`€`
`USD`	`USD`	`US Dollar`	`$`

Pipeline output¶

The ElasticsearchLoader returns the input rows unchanged.

Row	code	name	symbol
1	String: `EUR`	String: `Euro`	String: `€`
2	String: `USD`	String: `US Dollar`	String: `$`