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
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
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
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
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.