Hi everyone, Can someone help me with the two questions?
Thanks in advance, Casey On Thu, Feb 6, 2014 at 4:30 PM, Anh Thu Vu <[email protected]> wrote: > Hi everyone, > > I've just started using Samza, so pardon me if my questions are obvious. > > I've looked through the example hello-samza. So here are some questions I > have when trying to write an application on Samza: > 1) I can't seem to figure out how to define the number of partitions for a > stream. > > 2) Will a StreamTask stop? (when its input streams are all exhausted). How > to trigger this and stop the task when all messages are processed? > > Thanks a lot, guys! > > Casey >
