![]() |
Open Kilda Java Documentation
|
Public Member Functions | |
RouteBolt (String topology) | |
String | registerEndpoint (String boltId) throws StreamNameCollisionException |
void | prepare (Map stormConf, TopologyContext context, OutputCollector collector) |
void | execute (Tuple input) |
void | declareOutputFields (OutputFieldsDeclarer declarer) |
TopologyContext | getContext () |
OutputCollector | getOutput () |
Public Attributes | |
final String | STREAM_ID_ERROR = PREFIX_STREAM_ID + "_error" |
Definition at line 15 of file RouteBolt.java.
org.openkilda.wfm.ctrl.RouteBolt.RouteBolt | ( | String | topology | ) |
Definition at line 25 of file RouteBolt.java.
void org.openkilda.wfm.ctrl.RouteBolt.declareOutputFields | ( | OutputFieldsDeclarer | declarer | ) |
Definition at line 56 of file RouteBolt.java.
void org.openkilda.wfm.ctrl.RouteBolt.execute | ( | Tuple | input | ) |
Definition at line 49 of file RouteBolt.java.
TopologyContext org.openkilda.wfm.ctrl.RouteBolt.getContext | ( | ) |
Implements org.openkilda.wfm.IKildaBolt.
Definition at line 64 of file RouteBolt.java.
OutputCollector org.openkilda.wfm.ctrl.RouteBolt.getOutput | ( | ) |
Implements org.openkilda.wfm.IKildaBolt.
Definition at line 69 of file RouteBolt.java.
void org.openkilda.wfm.ctrl.RouteBolt.prepare | ( | Map | stormConf, |
TopologyContext | context, | ||
OutputCollector | collector | ||
) |
Definition at line 43 of file RouteBolt.java.
String org.openkilda.wfm.ctrl.RouteBolt.registerEndpoint | ( | String | boltId | ) | throws StreamNameCollisionException |
Definition at line 31 of file RouteBolt.java.
final String org.openkilda.wfm.ctrl.RouteBolt.STREAM_ID_ERROR = PREFIX_STREAM_ID + "_error" |
Definition at line 17 of file RouteBolt.java.