Passing array values to PostgreSQL using storm bolts.

Hai., I want to insert Array values of type long into the PostgreSQL using storm bolts and from the schema class(Spout) i am returning the array values.Can anyone help me in rectifying my error. *My simplejdbcMapper class:* public class SimpleJdbcMapper implements JdbcMapper { p

How to emit the values in a for-each loop

I'm having the a string values which are appended so i used the for each loop and sliptted them and emit them with in the for each loop.if I'm getting id string v="1,2,3"; I'm using for each and emitting the id in for loop itself. next when I Tried to emit the value of other string which is a appen

ExclamationTopology workers executors vs tasks

Hi, I am new to Storm. I am running the storm starter example ExclamationTopology on storm cluster (version 0.10). The code snippet is below: TopologyBuilder builder =new TopologyBuilder(); builder.setSpout("word",new TestWordSpout(),10); builder.setBolt("exclaim1",new ExclamationBolt(),3).s

Re: Storm 0.10.x defining log file for topology.

So is there no topologly level conf option to alter the target filename? It seems like the default log4j2 config looks at a system property to determine it. Looking at source code where workers are launched, it looks like that property is passed in on the command line here, but my clojure isn't gr

Re: ExclamationTopology workers executors vs tasks

Each worker process has an ack bolt. On Mar 1, 2016 6:34 AM, "patcharee" wrote: > Hi, > > I am new to Storm. I am running the storm starter example > ExclamationTopology on storm cluster (version 0.10). The code snippet is > below: > > TopologyBuilder builder = new TopologyBuilder(); > > builder.