69c658ec361682fb3bef50bd810f0646d7332a0c - flink-statefun

commit	69c658ec361682fb3bef50bd810f0646d7332a0c	[log] [tgz]
author	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Thu Jan 28 16:40:16 2021 +0800
committer	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Mon Feb 01 13:49:01 2021 +0800
tree	cbf6ce9122571f82e8db751fae28b9262fdb5854
parent	36973beb8081c1005964dc2c082ebe41d0064b43 [diff]

[FLINK-21171] Wire in TypedValue throughout the runtime as state values and message payloads

This closes #195.

statefun-e2e-tests/statefun-smoke-e2e/pom.xml[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandFlinkSource.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreter.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/CommandRouter.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/Constants.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/Module.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/main/java/org/apache/flink/statefun/e2e/smoke/ProtobufUtils.java[Deleted - diff]
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/CommandInterpreterTest.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/HarnessTest.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/SmokeRunner.java[diff]
statefun-e2e-tests/statefun-smoke-e2e/src/test/java/org/apache/flink/statefun/e2e/smoke/Utils.java[diff]
statefun-examples/statefun-python-walkthrough-example/run-example.py[diff]
statefun-flink/statefun-flink-common/pom.xml[diff]
statefun-flink/statefun-flink-common/src/main/java/org/apache/flink/statefun/flink/common/types/TypedValueUtil.java[Added - diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/EgressJsonEntity.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/protorouter/AutoRoutableProtobufRouter.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValues.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunction.java[diff]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonModuleTest.java[diff]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/PersistedRemoteFunctionValuesTest.java[diff]
statefun-flink/statefun-flink-core/src/test/java/org/apache/flink/statefun/flink/core/reqreply/RequestReplyFunctionTest.java[diff]
statefun-flink/statefun-flink-io-bundle/pom.xml[diff]
statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaEgressSerializer.java[diff]
statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaSinkProvider.java[diff]
statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/polyglot/GenericKinesisEgressSerializer.java[diff]
statefun-flink/statefun-flink-io-bundle/src/main/java/org/apache/flink/statefun/flink/io/kinesis/polyglot/GenericKinesisSinkProvider.java[diff]
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kafka/GenericKafkaSinkProviderTest.java[diff]
statefun-flink/statefun-flink-io-bundle/src/test/java/org/apache/flink/statefun/flink/io/kinesis/GenericKinesisSinkProviderTest.java[diff]
statefun-python-sdk/statefun/core.py[diff]
statefun-python-sdk/statefun/request_reply.py[diff]
statefun-python-sdk/statefun/typed_value_utils.py[Added - diff]
statefun-python-sdk/tests/request_reply_test.py[diff]
statefun-sdk-protos/src/main/protobuf/sdk/request-reply.proto[diff]

33 files changed