Copies documents from hdfs to elasticsearch.
HdfsElasticsearch.dot.svg
{ "source": { "scheme": "file", "host": "localhost", "user": "cloudera", "path": "/tmp", "writerPath": "activity" }, "destination": { "hosts": [ "localhost" ], "port": 9300, "clusterName": "elasticsearch", "index": "activity2", "type": "activity", "forceUseConfig": true } }
docker run elasticsearch-hdfs:0.2-incubating-SNAPSHOT.jar java -cp elasticsearch-hdfs-0.2-incubating-SNAPSHOT.jar -Dconfig.file=file://<location_of_config_file>.json org.apache.streams.elasticsearch.example.HdfsElasticsearch