September 2017
Beginner to intermediate
360 pages
8h 13m
English
This bolt is a persistence bolt. real-time sensor data or generated alerts are persisted into Elasticsearch for further analysis in Kibana:
package com.book.processing;import java.net.InetSocketAddress;import java.util.Date;import java.util.HashMap;import java.util.Map;import org.apache.storm.task.TopologyContext;import org.apache.storm.topology.BasicOutputCollector;import org.apache.storm.topology.OutputFieldsDeclarer;import org.apache.storm.topology.base.BaseBasicBolt;import org.apache.storm.tuple.Tuple;import org.elasticsearch.action.index.IndexResponse;import org.elasticsearch.client.Client;import org.elasticsearch.common.settings.Settings;import org.elasticsearch.common.transport.InetSocketTransportAddress;import org.elasticsearch.transport.client.PreBuiltTransportClient; ...
Read now
Unlock full access