Tzu-Li (Gordon) Tai created FLINK-20268:
-------------------------------------------
Summary: Update Python SDK to implement new invocation protocol
Key: FLINK-20268
URL: https://issues.apache.org/jira/browse/FLINK-20268
Project: Flink
Issue Type: Sub-task
Components: Stateful Functions
Reporter: Tzu-Li (Gordon) Tai
Fix For: statefun-2.3.0
The Python SDK should be updated to implement the new protocol introduced by
FLINK-20265.
Users should be able to declare states the Python function uses, and with
information, the Python SDK {{RequestReplyHandler}} can then match on the
provided states values in invocation requests against the declared states of a
target function:
Proposed API:
{code}
@functions.bind(
typename="example/greeter",
states=[StateSpec("seen_count")])
def greet(context, greet_request: GreetRequest):
state = context.state("seen_count").unpack(SeenCount)
...
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
