samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chris Riccomini <>
Subject Re: Process of adding a new integration test
Date Wed, 18 Feb 2015 17:04:40 GMT
Hey Milinda,

Use the negate-numbers test in samza-test as an example. Adding a new test
involves adding some code to samza-test/src/main/python, and
samza-test/src/main/java (if you want to write a new StreamTask).

Have a look at:

I think these docs might be insufficient. If so, could you update
with documentation describing how you added your new test? If you get stuck
at all, please ask for help. There's a bit of a learning curve to Zopkio,
and without better docs in Samza, I'm afraid it's going to be some trial
and error. It'd be good to use your experience to better document stuff, so
those in the future can add integration tests easily.


On Wed, Feb 18, 2015 at 8:35 AM, Milinda Pathirage <>

> Hi,
> What is the process I need to follow to add a new integration test to the
> samza-test? Is there a easy way, if I just need to initialize a task and
> send some messages to it?
> Thanks
> Milinda
> --
> Milinda Pathirage
> PhD Student | Research Assistant
> School of Informatics and Computing | Data to Insight Center
> Indiana University
> twitter: milindalakmal
> skype: milinda.pathirage
> blog:

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message