org.apache.flink.statefun.sdk.java.handler

Interface RequestReplyHandler

All Known Implementing Classes:

ConcurrentRequestReplyHandler

public interface RequestReplyHandler

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<Slice>	handle(Slice input) Handles a Stateful Functions invocation.

Method Detail

handle

java.util.concurrent.CompletableFuture<Slice> handle(Slice input)

Handles a Stateful Functions invocation.

Parameters:

input - a Slice as received from the StateFun server.

Returns:

a serialized representation of the side-effects to preform by the StateFun server, as the result of this invocation.