Hello Kobi,
I have spouts but I have not included them in my code. The problem is that
when I submit my topology, no tuples are sent around.
Thank you,
Nikos
2014-11-18 1:45 GMT-05:00 Kobi Salant <ko...@liveperson.com>:
> Hi Nikos,
>
> What about the spouts? you must have a spout to have data in the topology.
>
> What exactly is not working?
>
> Kobi
>
> On Mon, Nov 17, 2014 at 11:56 PM, Nick Katsipoulakis <
> nick.kat...@gmail.com> wrote:
>
>> Hello,
>>
>> I am currently creating an XML topology parser. Each bolt has its input
>> spout stored in a List, so I want to do something like the following:
>>
>> ...
>>
>> TopologyParser parser = new TopologyParser();
>> parser.parseTopology("some-file.xml");
>> components = parser.getComponents();
>> Iterator<Component> itr = components.iterator();
>> builder = new TopologyBuilder();
>> while(itr.hasNext()) {
>> Component comp = itr.next();
>> if(comp.getType().equals("Bolt")) {
>> BoltDeclarer declarer = builder.setBolt(comp.getName(), new
>> SampleBolt(comp.getName(), comp.getExecutors());
>> if(comp.getUpstreamTasks() != null && comp.getUpstreamTasks().size()
>> > 0) {
>> for(String upstream_task : comp.getUpstreamTasks()) {
>> declarer.directGrouping(upstream_task);
>> }
>> }
>> }
>> }
>>
>> Config conf = new Config();
>> conf.setDebug(true);
>> LocalCluster cluster = new LocalCluster();
>> cluster.submitTopology("test", conf, builder.createTopology());
>>
>> ...
>>
>> So, in the above code the TopologyParser parser parses the topology from
>> a file and the components variable is a list of all the Component objects
>> (the TopologyParser and the Component classes
>> are custom built by me). If a component is for type "Bolt" and has
>> upstream tasks, they have their output registered as directly grouped to
>> the bolt. Unfortunately, the above approach does not seem to work.
>> Any suggestions on how to make something the above work?
>>
>> Thank you,
>> Nikos
>>
>> --
>> Nikolaos Romanos Katsipoulakis,
>> University of Pittsburgh, PhD candidate
>>
>
>
> This message may contain confidential and/or privileged information.
> If you are not the addressee or authorized to receive this on behalf of
> the addressee you must not use, copy, disclose or take action based on this
> message or any information herein.
> If you have received this message in error, please advise the sender
> immediately by reply email and delete this message. Thank you.
>
--
Nikolaos Romanos Katsipoulakis,
University of Pittsburgh, PhD candidate
