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 24da73b [FLINK-21154] Move shared request-reply protobuf files to
statefun-sdk-protos
new 3a124bb [FLINK-21154] Move *-egress.proto to the sdk protos
new 36973be [FLINK-21154] Rename packages for request-reply protocol
Proto messages
new 69c658e [FLINK-21171] Wire in TypedValue throughout the runtime as
state values and message payloads
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:
statefun-e2e-tests/statefun-smoke-e2e/pom.xml | 59 ++++++++++
.../statefun/e2e/smoke/CommandFlinkSource.java | 15 +--
.../statefun/e2e/smoke/CommandInterpreter.java | 28 ++---
.../flink/statefun/e2e/smoke/CommandRouter.java | 12 ++-
.../apache/flink/statefun/e2e/smoke/Constants.java | 12 ++-
.../apache/flink/statefun/e2e/smoke/Module.java | 9 +-
.../flink/statefun/e2e/smoke/ProtobufUtils.java | 34 ------
.../statefun/e2e/smoke/CommandInterpreterTest.java | 4 +-
.../flink/statefun/e2e/smoke/HarnessTest.java | 4 +-
.../flink/statefun/e2e/smoke/SmokeRunner.java | 4 +-
.../org/apache/flink/statefun/e2e/smoke/Utils.java | 15 +--
.../run-example.py | 26 ++++-
statefun-flink/statefun-flink-common/pom.xml | 57 ++++++++++
.../flink/common/types/TypedValueUtil.java | 55 ++++++++++
statefun-flink/statefun-flink-core/pom.xml | 2 +-
.../statefun/flink/core/common/PolyglotUtil.java | 2 +-
.../flink/core/httpfn/HttpRequestReplyClient.java | 4 +-
.../flink/core/jsonmodule/EgressJsonEntity.java | 6 +-
.../protorouter/AutoRoutableProtobufRouter.java | 15 ++-
.../reqreply/PersistedRemoteFunctionValues.java | 47 ++++----
.../flink/core/reqreply/RequestReplyClient.java | 4 +-
.../flink/core/reqreply/RequestReplyFunction.java | 30 +++---
.../flink/core/jsonmodule/JsonModuleTest.java | 5 +-
.../PersistedRemoteFunctionValuesTest.java | 59 +++++++---
.../core/reqreply/RequestReplyFunctionTest.java | 119 ++++++++++++---------
statefun-flink/statefun-flink-io-bundle/pom.xml | 10 ++
.../io/kafka/GenericKafkaEgressSerializer.java | 17 +--
.../flink/io/kafka/GenericKafkaSinkProvider.java | 6 +-
.../polyglot/GenericKinesisEgressSerializer.java | 15 +--
.../polyglot/GenericKinesisSinkProvider.java | 6 +-
.../io/kafka/GenericKafkaSinkProviderTest.java | 4 +-
.../io/kinesis/GenericKinesisSinkProviderTest.java | 4 +-
statefun-flink/statefun-flink-io/pom.xml | 63 +++++++++++
statefun-python-sdk/build-distribution.sh | 6 +-
statefun-python-sdk/statefun/core.py | 7 ++
statefun-python-sdk/statefun/kafka_egress_pb2.py | 100 -----------------
statefun-python-sdk/statefun/kinesis_egress_pb2.py | 107 ------------------
statefun-python-sdk/statefun/request_reply.py | 27 +++--
statefun-python-sdk/statefun/typed_value_utils.py | 49 +++++++++
statefun-python-sdk/tests/request_reply_test.py | 34 ++++--
.../src/main/protobuf/io}/kafka-egress.proto | 5 +-
.../src/main/protobuf/io}/kinesis-egress.proto | 5 +-
.../main/protobuf/{ => sdk}/request-reply.proto | 36 ++++---
43 files changed, 651 insertions(+), 477 deletions(-)
delete mode 100644
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/ProtobufUtils.java
create mode 100644
statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/types/TypedValueUtil.java
delete mode 100644 statefun-python-sdk/statefun/kafka_egress_pb2.py
delete mode 100644 statefun-python-sdk/statefun/kinesis_egress_pb2.py
create mode 100644 statefun-python-sdk/statefun/typed_value_utils.py
rename {statefun-flink/statefun-flink-io/src/main/protobuf =>
statefun-sdk-protos/src/main/protobuf/io}/kafka-egress.proto (89%)
rename {statefun-flink/statefun-flink-io/src/main/protobuf =>
statefun-sdk-protos/src/main/protobuf/io}/kinesis-egress.proto (89%)
rename statefun-sdk-protos/src/main/protobuf/{ => sdk}/request-reply.proto
(86%)
