public class ElasticSearchOutputFactory extends Object implements org.thales.punch.libraries.storm.api.IBoltFactory
Nothing complex, the ElasticSearchBolt is easy to configure. We only have to extract the elastic search http urls (i.e. the one usually on 9200 port) from the configuration and give them as expected by the ElasticSearchBolt.
Modifier and Type | Field and Description |
---|---|
static String |
TYPE
The key referencing the associated bolt.
|
Constructor and Description |
---|
ElasticSearchOutputFactory()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
org.apache.storm.topology.IRichBolt |
createBolt(org.thales.punch.platform.api.IPlatform platform,
org.thales.punch.libraries.storm.api.NodeSettings boltSettings,
org.thales.punch.libraries.storm.api.ITopologySettings topologySettings)
Create en ElasticSearch bolt.
|
public static final String TYPE
public ElasticSearchOutputFactory()
public org.apache.storm.topology.IRichBolt createBolt(org.thales.punch.platform.api.IPlatform platform, org.thales.punch.libraries.storm.api.NodeSettings boltSettings, org.thales.punch.libraries.storm.api.ITopologySettings topologySettings) throws org.thales.punch.exceptions.ConfigurationException
createBolt
in interface org.thales.punch.libraries.storm.api.IBoltFactory
boltSettings
- the bolt settings, from the topology json config filetopologySettings
- the topology configuration. It includes the global
punchlet resources, shared among all bolts and
spouts.platform
- the punchplatform properties, coming from the
punchplatform.properties file.org.thales.punch.exceptions.ConfigurationException
Copyright © 2023. All rights reserved.