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
