(I switched to use users@. I should've started so) Thank you Sanjeev for explaining. It is exciting. Is it true that pulsar cluster does some kind of resource management/scheduling? For example, when there are many functions registered and many messages come in, does each function gets certain resource (memory/cpu per node) allocations, dynamically, based on its tenant/namespace, similar way to what Spark does?
On Sat, May 5, 2018 at 12:04 AM, Sanjeev Kulkarni <sanjee...@gmail.com> wrote: > Hi, > While introducing stream native computing in Pulsar, we wanted to start > with the most basic primitives aka functions. Thus 2.0 added Pulsar > Functions. This > <https://pulsar.incubator.apache.org/docs/latest/functions/quickstart/> is > a good starting page to get started with functions. Advanced libraries > based on the functions primitive(like WindowFunction and streamlet apis) > are targetted for 2.1. > Thanks! > > On Fri, May 4, 2018 at 10:53 PM, jun aoki <ja...@apache.org> wrote: > > > I did a 10 min google search for pulsar stream API, something comparable > to > > kafka stream API. (https://kafka.apache.org/documentation/streams/) > > but I haven't been able to find any. Is there such thing exists? Or am I > > conceptually mistaken? > > > > -- > > -jun > > > -- -jun