storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rajeev <rajeev.dal...@gmail.com>
Subject addConfiguration in flux
Date Sun, 28 Jan 2018 04:35:56 GMT
Hi,

How can we specify the addConfiguration values that can be used in custom
scheduling under flux ?

For example:
I have a custom scheduler that implements IScheduler.
I have the below under my Topology.java:

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout( "Source_data_amqtest", new MessagingQueueSource()
).addConfiguration( "group", 4 );


How can i specify this addConfiguration( "group", 4 ) for a spout in Flux ?

Regards,
Rajeev.

Mime
View raw message