![]() |
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.