Re: What distinguishes a Windowing Bolt?

2016-12-21 Thread Arthur Maciejewicz
You must satisfy the IWindowedBolt and IComponent interfaces. BaseWindowedBolt is there for your convenience. When constructing the topology, there is a setBolt method on TopologyBuilder specifically for bolts satisfying the IWindowedBolt interface. It will be wrapped with a WindowedBoltExecutor by

Re: Explicit Topology Parallelism Shape

2016-11-07 Thread Arthur Maciejewicz
be found here: http://storm.apache.org/ > releases/1.0.2/Storm-Scheduler.html > > -Taylor > > On Nov 7, 2016, at 11:31 AM, Arthur Maciejewicz > wrote: > > Hello All, > > Is there a way to make the "shape" of topology parallelism explicit? > For example, a

Explicit Topology Parallelism Shape

2016-11-07 Thread Arthur Maciejewicz
Hello All, Is there a way to make the "shape" of topology parallelism explicit? For example, assume: * W workers on W nodes * 2 spouts with 1 executor each (total of 2 executors) * 1 "mapper" bolt with M executors * 1 "process" bolt with N executors. Is it currently possibly to co-locate th