Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Flume >> mail # dev >> Review Request 24500: FLUME-2444 ElasticSearchSink: Support for document id and version


Copy link to this message
-
Review Request 24500: FLUME-2444 ElasticSearchSink: Support for document id and version

This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/24500/

Review request for Flume.
Repository: flume-git
Description

This patch adds support for document id and version so that you do not have to rely on elasticsearch generating them for you. The only existing extra document parameter is TTL. The two additional document parameters were added in the same way. They are added to both client implementations. There are tests for this feature and also documentation is updated.
Diffs

  flume-ng-doc/sphinx/FlumeUserGuide.rst daf6e72
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java 1d9dfce
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSinkConstants.java da88def
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClient.java 655e00a
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchRestClient.java 0d1c37f
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchTransportClient.java d44c8ad
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/client/TestElasticSearchRestClient.java b7d8822
  flume-ng-sinks/flume-ng-elasticsearch-sink/src/test/java/org/apache/flume/sink/elasticsearch/client/TestElasticSearchTransportClient.java b7b8e74

Diff: https://reviews.apache.org/r/24500/diff/
Testing
Thanks,

Bastian Germann