Package | Description |
---|---|
org.apache.flink.statefun.e2e.smoke.java | |
org.apache.flink.statefun.sdk.java | |
org.apache.flink.statefun.sdk.java.testing |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<java.lang.Void> |
CommandInterpreterFn.apply(Context context,
Message message) |
void |
CommandInterpreter.interpret(ValueSpec<java.lang.Long> state,
Context context,
Message message) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.CompletableFuture<java.lang.Void> |
StatefulFunction.apply(Context context,
Message argument)
Applies an input message to this function.
|
Modifier and Type | Class and Description |
---|---|
class |
TestContext
An implementation of
Context to to make it easier to test StatefulFunction s in isolation. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.