Package | Description |
---|---|
org.apache.flink.statefun.sdk.java | |
org.apache.flink.statefun.sdk.java.handler |
Modifier and Type | Method and Description |
---|---|
RequestReplyHandler |
StatefulFunctions.requestReplyHandler()
Creates a
RequestReplyHandler that understands how to dispatch invocation requests to
the registered functions as well as encode side-effects (e.g., sending messages to other
functions or updating values in storage) as the response. |
Modifier and Type | Class and Description |
---|---|
class |
ConcurrentRequestReplyHandler
A threadsafe RequestReplyHandler.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.