| commit | c7f98eb7598b90e7c9b311cea7ad6236ad41e91c | [log] [tgz] |
|---|---|---|
| author | Konstantin Knauf <knauf.konstantin@gmail.com> | Tue May 25 15:06:42 2021 +0200 |
| committer | Igal Shilman <igalshilman@gmail.com> | Fri Jul 16 17:32:03 2021 +0200 |
| tree | e5bb242bea591e034b8f616c79a86d0892f2e648 | |
| parent | b232879fa848f55332213f48662e95d3f8928e7d [diff] |
[FLINK-22771][java-sdk] Add testing utilities * add hashCode/equals to EgressMessageWrapper/MessageWrapper * add TestContext to Java SDK * add documentation for Java SDK TestContext * address review comments * Fix various code style warnings * Refactor Envelopes -> SideEffects * ValueSpec needs to be identified by name, as it does not support equality. * Support message cancellation This closes #236.