Re: addConfiguration in flux

2018-02-08 Thread Rajeev
pout.java#L214 > > > > Can you give it a try and see if it works? > > > > *From: *Rajeev > *Reply-To: *"user@storm.apache.org" > *Date: *Monday, February 5, 2018 at 3:45 PM > *To: *"user@storm.apache.org" > *Subject: *Re: addConfiguration i

Re: addConfiguration in flux

2018-02-05 Thread Priyank Shah
3:45 PM To: "user@storm.apache.org" Subject: Re: addConfiguration in flux 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

Re: addConfiguration in flux

2018-02-05 Thread Rajeev
ng component > definition. > > > > *From: *Rajeev > *Reply-To: *"user@storm.apache.org" > *Date: *Saturday, January 27, 2018 at 8:36 PM > *To: *"user@storm.apache.org" > *Subject: *addConfiguration in flux > > > > Hi, > >

Re: addConfiguration in flux

2018-01-29 Thread Priyank Shah
: Rajeev Reply-To: "user@storm.apache.org" Date: Saturday, January 27, 2018 at 8:36 PM To: "user@storm.apache.org" 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 c

addConfiguration in flux

2018-01-27 Thread Rajeev
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_amqtes