2020-10-10 | Kai Moritz | Added an endpoint to query the watermarks by partition |
commit | commitdiff | tree |
2020-10-10 | Kai Moritz | Moved the building of the topology into a static method |
commit | commitdiff | tree |
2020-10-10 | Kai Moritz | Implemented an unit-test for the transformer |
commit | commitdiff | tree |
2020-10-10 | Kai Moritz | Offsets are not needed by the test |
commit | commitdiff | tree |
2020-10-10 | Kai Moritz | Implemented an integration-test for the transformer |
commit | commitdiff | tree |
2020-10-10 | Kai Moritz | Simplified example |
commit | commitdiff | tree |
2020-10-10 | Kai Moritz | A deduplicator, that assumes steadily increasing global... |
commit | commitdiff | tree |