[flink-statefun] branch master updated (1bfd242 -> 3cfae08)

[tz...@apache.org]

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 1bfd242  [FLINK-16396] [kafka] Add Protobuf message for YAML-ized Kafka egress
     add 397d6ad  [FLINK-16391] [http] Add delayed and egress messages to request-reply protocol
     add 1814e4e  [FLINK-16396] [kafka] Rename KafkaSpecJsonParser to KafkaIngressSpecJsonParser
     add fcbd346  [FLINK-16396] Support binding JSON egress specs in JsonModule
     add 615b373  [hotfix] Remove unused foo-module test resource
     add 5b7703c  [FLINK-16396] [minor] Support longAt in Selectors
     add b342227  [FLINK-16396] [kafka] Add GenericKafkaSinkProvider
     add 6620bd5  [FLINK-16396] [kafka] Bind GenericKafkaSinkProvider in KafkaFlinkIoModule
     add 3cfae08  [hotfix] Refactor YAML loading utility method as test utils

No new revisions were added by this update.

Summary of changes:
 .../statefun/flink/common/json/Selectors.java      |   8 ++
 .../statefun/flink/common/json/SelectorsTest.java  |  10 ++
 .../statefun/flink/core/jsonmodule/JsonModule.java |  30 ++++++
 .../statefun/flink/core/jsonmodule/Pointers.java   |   6 ++
 .../flink/core/reqreply/RequestReplyFunction.java  |  34 ++++++-
 .../src/main/protobuf/http-function.proto          |  25 +++++
 .../flink/core/jsonmodule/JsonModuleTest.java      |  13 +++
 .../core/reqreply/RequestReplyFunctionTest.java    |  62 ++++++++++++-
 .../src/test/resources/bar-module/module.yaml      |  12 +++
 .../io/kafka/GenericKafkaEgressSerializer.java     |  65 +++++++++++++
 .../flink/io/kafka/GenericKafkaSinkProvider.java   | 102 +++++++++++++++++++++
 .../flink/io/kafka/KafkaEgressSpecJsonParser.java  |  83 +++++++++++++++++
 .../flink/io/kafka/KafkaFlinkIoModule.java         |   2 +
 ...Parser.java => KafkaIngressSpecJsonParser.java} |   4 +-
 .../io/kafka/ProtobufKafkaSourceProvider.java      |  14 +--
 .../kafka/RoutableProtobufKafkaSourceProvider.java |  12 +--
 .../io/kafka/GenericKafkaSinkProviderTest.java     |  49 ++++++++++
 .../io/kafka/ProtobufKafkaSourceProviderTest.java  |  18 +---
 .../RoutableProtobufKafkaSourceProviderTest.java   |  19 +---
 .../statefun/flink/io/testutils/YamlUtils.java}    |  43 +++------
 .../src/test/resources/generic-kafka-egress.yaml}  |  18 ++--
 .../statefun/flink/io/kafka/KafkaEgressTypes.java  |  18 ++--
 .../{JsonIngressSpec.java => JsonEgressSpec.java}  |  19 ++--
 .../statefun/sdk/kafka/KafkaEgressBuilder.java     |   2 +-
 24 files changed, 557 insertions(+), 111 deletions(-)
 create mode 100644 statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaEgressSerializer.java
 create mode 100644 statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaSinkProvider.java
 create mode 100644 statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaEgressSpecJsonParser.java
 rename statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/{KafkaSpecJsonParser.java => KafkaIngressSpecJsonParser.java} (99%)
 create mode 100644 statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaSinkProviderTest.java
 copy statefun-flink/{statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkValueAccessor.java => statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/testutils/YamlUtils.java} (55%)
 rename statefun-flink/{statefun-flink-core/src/test/resources/foo-module/module.yaml => statefun-flink-io-bundle/src/test/resources/generic-kafka-egress.yaml} (75%)
 copy statefun-examples/statefun-greeter-example/src/main/protobuf/greeter.proto => statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/kafka/KafkaEgressTypes.java (72%)
 copy statefun-flink/statefun-flink-io/src/main/java/org/apache/flink/statefun/flink/io/spi/{JsonIngressSpec.java => JsonEgressSpec.java} (73%)