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 3edff61 [hotfix][sdk] Correct spelling of wrong words.
new 8482d94 [FLINK-20334] [sdk] Support binding function providers per
namespace
new ee051dd [FLINK-20334] [core] Implement V3 module YAML with function
endpoint templating
new 914dc11 [hotfix] [e2e] Add timeout to ExactlyOnceWithRemoteFnE2E
The 3 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:
.../e2e/remote/ExactlyOnceWithRemoteFnE2E.java | 2 +-
.../src/test/resources/remote-module/module.yaml | 18 +-
.../statefun/module.yaml | 15 +-
.../statefun-python-greeter-example/module.yaml | 15 +-
.../statefun-python-k8s-example/module.yaml | 13 +-
.../flink/core/StatefulFunctionsUniverse.java | 21 ++-
.../core/StatefulFunctionsUniverseValidator.java | 3 +-
.../core/functions/PredefinedFunctionLoader.java | 25 ++-
.../statefun/flink/core/functions/Reductions.java | 2 +
...tionSpec.java => HttpFunctionEndpointSpec.java} | 92 ++++-----
.../flink/core/httpfn/HttpFunctionProvider.java | 2 +-
.../flink/core/httpfn/HttpFunctionSpec.java | 5 -
...der.java => TemplatedHttpFunctionProvider.java} | 56 ++++--
.../flink/core/httpfn/UnixDomainHttpEndpoint.java | 8 +
.../flink/core/jsonmodule/FormatVersion.java | 5 +-
.../jsonmodule/FunctionEndpointJsonEntity.java | 206 +++++++++++++++++++++
...FunctionSpec.java => FunctionEndpointSpec.java} | 24 ++-
.../statefun/flink/core/jsonmodule/JsonModule.java | 13 +-
.../functions/PredefinedFunctionLoaderTest.java | 118 ++++++++++++
.../core/httpfn/UnixDomainHttpEndpointTest.java | 11 ++
.../{JsonModuleTest.java => JsonModuleV3Test.java} | 33 ++--
.../{module-v1_0 => module-v3_0}/module.yaml | 44 +++--
.../statefun/sdk/FunctionTypeNamespaceMatcher.java | 46 ++---
.../statefun/sdk/spi/StatefulFunctionModule.java | 17 +-
24 files changed, 606 insertions(+), 188 deletions(-)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/{HttpFunctionSpec.java
=> HttpFunctionEndpointSpec.java} (68%)
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/{HttpFunctionProvider.java
=> TemplatedHttpFunctionProvider.java} (59%)
create mode 100644
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/FunctionEndpointJsonEntity.java
copy
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/{FunctionSpec.java
=> FunctionEndpointSpec.java} (58%)
create mode 100644
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/functions/PredefinedFunctionLoaderTest.java
copy
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/jsonmodule/{JsonModuleTest.java
=> JsonModuleV3Test.java} (80%)
copy statefun-flink/statefun-flink-core/src/test/resources/{module-v1_0 =>
module-v3_0}/module.yaml (73%)
copy
statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-simulator/src/main/java/org/apache/flink/statefun/examples/ridesharing/simulator/model/SimulationStartedEvent.java
=>
statefun-sdk/src/main/java/org/apache/flink/statefun/sdk/FunctionTypeNamespaceMatcher.java
(51%)
