Hi, Chad,
The following code will let you find the stream name:
{code}
envelope.getSystemStreamPartition().getSystemStream().getStream();
{code}
Thanks!
-Yi
On Tue, Feb 23, 2016 at 8:14 AM, Chad Scribner <chad.scrib...@xls.xerox.com>
wrote:
> Hi All,
>
> First time emailing the list. I just had a question about doing a
> Stream-Stream join in Samza.
>
> What I'm attempting to do is have a Load stream which contains events of
> when an object was loaded and an Action stream which contains events that
> are taken on the objects in the Load stream. Both streams have a single
> partition at the moment. The defined job listens to both of these streams
> and round robin's the messages from each stream.
>
> And now my question. Is determining the source of each message as simple
> as the below?
>
> # Pseudo code -- body of myJob.process()
> if (job.stream == Load) {
> // do loading code
> } else if (job.stream == Action) {
> // do action code
> }
>
> Chad Scribner
> Senior Software Engineer (OmniX)
> Xerox Litigation Services
> 80 State Street
> Suite 300
> Albany, NY 12207
> 518-328-1335
>
