public class EsIndexBolt extends AbstractEsBolt
Basic bolt for storing tuple to ES document.
client, collector, objectMapper| Constructor and Description |
|---|
EsIndexBolt(EsConfig esConfig)
EsIndexBolt constructor.
|
EsIndexBolt(EsConfig esConfig,
EsTupleMapper tupleMapper)
EsIndexBolt constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
Declare the output schema for all the streams of this topology.
|
void |
prepare(Map<String,Object> map,
TopologyContext topologyContext,
OutputCollector outputCollector)
Called when a task for this component is initialized within a worker on the cluster.
|
void |
process(Tuple tuple)
Process a single non-tick tuple of input.
|
execute, onTickTuplecleanupgetComponentConfigurationclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetComponentConfigurationpublic EsIndexBolt(EsConfig esConfig)
EsIndexBolt constructor.
esConfig - Elasticsearch configuration containing node addresses EsConfigpublic EsIndexBolt(EsConfig esConfig, EsTupleMapper tupleMapper)
EsIndexBolt constructor.
esConfig - Elasticsearch configuration containing node addresses EsConfigtupleMapper - Tuple to ES document mapper EsTupleMapperpublic void prepare(Map<String,Object> map, TopologyContext topologyContext, OutputCollector outputCollector)
IBoltCalled when a task for this component is initialized within a worker on the cluster. It provides the bolt with the environment in which the bolt executes.
This includes the:
prepare in interface IBoltprepare in class AbstractEsBoltmap - The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this machine.topologyContext - This object can be used to get information about this task’s place within the topology, including the task id and component id of this task, input and output information, etc.outputCollector - The collector is used to emit tuples from this bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The collector is thread-safe and should be saved as an instance variable of this bolt object.public void process(Tuple tuple)
Process a single non-tick tuple of input. Implementation needs to handle ack manually. More details on IBolt.execute(Tuple).
process in class BaseTickTupleAwareRichBolttuple - The input tuple to be processed.public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer)
IComponentDeclare the output schema for all the streams of this topology.
declareOutputFields in interface IComponentdeclareOutputFields in class AbstractEsBoltoutputFieldsDeclarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streamCopyright © 2021 The Apache Software Foundation. All rights reserved.