c7f98eb7598b90e7c9b311cea7ad6236ad41e91c - flink-statefun

commit: c7f98eb7598b90e7c9b311cea7ad6236ad41e91c
[log]
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.

docs/content/docs/sdk/java.md[diff]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/EgressMessageWrapper.java[diff]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/message/MessageWrapper.java[diff]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/SideEffects.java[Added - diff]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestAddressScopedStorage.java[Added - diff]
statefun-sdk-java/src/main/java/org/apache/flink/statefun/sdk/java/testing/TestContext.java[Added - diff]
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/testing/TestContextIntegrationTest.java[Added - diff]
statefun-sdk-java/src/test/java/org/apache/flink/statefun/sdk/java/testing/TestContextTest.java[Added - diff]

8 files changed