public class WrapperCustomOutput
extends org.thales.punch.libraries.storm.api.BaseProcessingNode
Constructor and Description |
---|
WrapperCustomOutput(org.thales.punch.libraries.storm.api.NodeSettings config,
com.github.punch.api.storm.nodes.PunchProcessingNode node) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
Map<String,Object> |
getComponentConfiguration() |
void |
prepare(Map map,
org.apache.storm.task.TopologyContext topologyContext,
org.apache.storm.task.OutputCollector collector) |
void |
process(org.apache.storm.tuple.Tuple tuple) |
public static final String TYPE
public WrapperCustomOutput(org.thales.punch.libraries.storm.api.NodeSettings config, com.github.punch.api.storm.nodes.PunchProcessingNode node)
public void process(org.apache.storm.tuple.Tuple tuple)
process
in class org.thales.punch.libraries.storm.api.BaseProcessingNode
public void cleanup()
cleanup
in interface org.apache.storm.task.IBolt
cleanup
in class org.thales.punch.libraries.storm.api.BaseProcessingNode
public void prepare(Map map, org.apache.storm.task.TopologyContext topologyContext, org.apache.storm.task.OutputCollector collector)
prepare
in interface org.apache.storm.task.IBolt
prepare
in class org.thales.punch.libraries.storm.api.BaseProcessingNode
Copyright © 2023. All rights reserved.