Hi Priyank, Thanks for the reply. I think the configMethods can be used within the spout or bolt codes.. but i need to use the configuration for my custom scheduler like how we can do it from java topology builder. Can we do the same in flux ?
Regards, Rajeev. On Tue, 30 Jan 2018 at 03:32, Priyank Shah <[email protected]> wrote: > Check out http://storm.apache.org/releases/2.0.0-SNAPSHOT/flux.html and > search for configMethods on that page. It has an example for how to call a > withFoo method on the bolt instance. You can do the same on > MessagingQueueSource instance that you can create using component > definition. > > > > *From: *Rajeev <[email protected]> > *Reply-To: *"[email protected]" <[email protected]> > *Date: *Saturday, January 27, 2018 at 8:36 PM > *To: *"[email protected]" <[email protected]> > *Subject: *addConfiguration in flux > > > > 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. >
