The main function of the operator is to store a map in internal state, I want
to validate behavior / contents of that map following operator recovery and
during checkpointing.
- Ilya Ganelin
[id:image001.png@01D1F7A4.F3D42980]
From: Sanjay Pujare
Reply-To: "users@apex.apache.org"
Date: Friday
Is this an input/output/processing operator?
In the apex-malhar repo you can search for "testRecovery" (or
"testRecover") in all the *.java files and you'll find many examples. Hope
that helps
On Fri, Apr 28, 2017 at 3:13 PM, Ganelin, Ilya
wrote:
> Hi all, I’d like to explicitly test the behavi
Hi all, I’d like to explicitly test the behavior of one of my operators
following checkpoint window recovery. Is there an existing test you could point
me to that does something similar?
Thanks!
- Ilya Ganelin
[id:image001.png@01D1F7A4.F3D42980]
_
