This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-statefun.git.
from c14d07a [FLINK-17963] [core] Revert execution environment patching in
StatefulFunctionsJob
new ac07854 [FLINK-17875] [core] Introduce JsonEntity and implementations
new 758076b [FLINK-17875] [core] Wire in JsonEntities into JsonModule
new 4a920f9 [FLINK-17875] [core] Move default function config values to
HttpFunctionSpec
new 1fa4664 [FLINK-17875] [core] Move JSON Pointers to individual entities
new 0023360 [FLINK-17875] [core] Introduce StateSpec for remote function
specs
new b852dcc [FLINK-17875] [core] Wire in StateSpec into
RequestReplyFunction
new 3c8e1f4 [FLINK-17875] [core] Add format version 2.0
new d8a2210 [FLINK-17875] [core] Update FunctionJsonEntity to recognize
V2 state format
new 44400f9 [FLINK-17875] [core] Parameterize JsonModuleTest to cover all
module format versions
new 4b96b43 [FLINK-17997] [legal] Revert manual merging of AWS KPL's
THIRD_PARTY_NOTICE content
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/core/httpfn/HttpFunctionSpec.java | 52 +++-
.../StateSpec.java} | 27 +-
.../flink/core/jsonmodule/EgressJsonEntity.java | 63 +++++
.../flink/core/jsonmodule/FormatVersion.java | 5 +-
.../flink/core/jsonmodule/FunctionJsonEntity.java | 232 ++++++++++++++++
.../flink/core/jsonmodule/IngressJsonEntity.java | 76 ++++++
.../{JsonModuleFactory.java => JsonEntity.java} | 37 ++-
.../statefun/flink/core/jsonmodule/JsonModule.java | 294 ++-------------------
.../flink/core/jsonmodule/JsonServiceLoader.java | 38 +--
.../statefun/flink/core/jsonmodule/Pointers.java | 87 ------
.../flink/core/jsonmodule/RouterJsonEntity.java | 120 +++++++++
.../flink/core/reqreply/RequestReplyFunction.java | 39 ++-
.../flink/core/jsonmodule/JsonModuleTest.java | 38 ++-
.../core/reqreply/RequestReplyFunctionTest.java | 3 +-
.../{bar-module => module-v1_0}/module.yaml | 0
.../{bar-module => module-v2_0}/module.yaml | 7 +-
statefun-flink/statefun-flink-distribution/pom.xml | 16 --
.../src/main/resources/META-INF/NOTICE | 197 --------------
18 files changed, 674 insertions(+), 657 deletions(-)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/{common/MailboxExecutorFacade.java
=> httpfn/StateSpec.java} (65%)
create mode 100644
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/EgressJsonEntity.java
create mode 100644
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FunctionJsonEntity.java
create mode 100644
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/IngressJsonEntity.java
rename
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/{JsonModuleFactory.java
=> JsonEntity.java} (54%)
delete mode 100644
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/Pointers.java
create mode 100644
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/RouterJsonEntity.java
copy statefun-flink/statefun-flink-core/src/test/resources/{bar-module =>
module-v1_0}/module.yaml (100%)
rename statefun-flink/statefun-flink-core/src/test/resources/{bar-module =>
module-v2_0}/module.yaml (95%)
