igalshilman opened a new pull request #218:
URL: https://github.com/apache/flink-statefun/pull/218
The following PR is the result of doing a pre-release sweep, and removing
small inconsistent leftovers.
This PR covers the following:
FLINK-21956] Improve error message when key is missing
[FLINK-21955] Remove outdated examples
[FLINK-21957] Rename statefun-python-sdk => statefun-sdk-python
[FLINK-21958] Rename statefun-sdk -> statefun-sdk-embedded
[FLINK-21959] Rename statefun.kafka.io/routable-protobuf-ingress =>
io.statefun.kafka/ingress
[FLINK-21959] Rename Kafka generic-egress to egress =>
io.statefun.kafka/egress
[FLINK-21959] Shorten kinesis egress/ingress => io.statefun.kinesis/ingress
(egress)
[FLINK-21960] Rename typename.namespace -> targetFunctions:
instead of:
```
endpoint:
spec:
typename:
namespace: foo.bar
```
You can simply write:
```
endpoint:
spec:
functions: foo.bar/baz
```
or
```
endpoint:
spec:
functions: foo.bar/*
```
[FLINK-21960] Rename ingress typeUrl -> valueType
[FLINK-21961] Add JSON type to the Python SDK
```
USER_LOGIN_TYPE = make_json_type("foo.bar/UserLogic")
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
