Well, I'm using this code:
public EventsBatchBolt(TopologyConfig config, long emitFrequency, TimeUnit
unit) {
super(emitFrequency, unit);
topologyConfig = config;
}
And where I submitting topology, I have:
builder.setBolt("event_batch", new EventsBatchBolt(topologyConfig, 10,
TimeUnit.SECONDS), 1)
TopologyConfig is just generic class with my configuration
On 24 January 2015 at 18:59, clay teahouse <[email protected]> wrote:
> Any feedback on what the issue could be would be appreciated.
> I am getting an instance of Config and add my static objects to it and
> want to access these objects in bolt's prepare method.
> Config config = new Config();
> config.put("objectname", objectinstance);
>
> StormSubmitter.submitTopology(topologyname, config, builder.createTopology());
>
> And in bolt's prepare method, I try to extract the object.
>
> prepare(Map stormConfig,TopologyContext context) {
>
> ObjectType obj = (objectType) stormConfig.get("objectname");
>
> }
>
> Object type is either String or ArrayList or HashMap.
>
>
> On Sat, Jan 24, 2015 at 12:01 AM, clay teahouse <[email protected]>
> wrote:
>
>> Hi,
>>
>> I am trying to pass some objects to the bolts through config, but I am
>> not having much success. These objects are hashmap and arrarylists. I am
>> assuming these are serializable. Any idea what could be wrong?
>>
>> thanks,
>> Clay
>>
>>
>
--
With best regards, Irek Khasyanov.
