org.apache.flink.statefun.e2e.smoke.java

Class CommandInterpreterFn

java.lang.Object

org.apache.flink.statefun.e2e.smoke.java.CommandInterpreterFn

All Implemented Interfaces:

StatefulFunction

public class CommandInterpreterFn
extends java.lang.Object
implements StatefulFunction

Field Summary

Fields

Modifier and Type	Field and Description
static ValueSpec<java.lang.Long>	STATE

Constructor Summary

Constructors

Constructor and Description
CommandInterpreterFn(CommandInterpreter interpreter)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<java.lang.Void>	apply(Context context, Message message) Applies an input message to this function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

STATE

public static final ValueSpec<java.lang.Long> STATE

Constructor Detail

CommandInterpreterFn

public CommandInterpreterFn(CommandInterpreter interpreter)

Method Detail

apply

public java.util.concurrent.CompletableFuture<java.lang.Void> apply(Context context,
                                                                    Message message)
                                                             throws java.lang.Throwable

Description copied from interface: StatefulFunction

Applies an input message to this function.

Specified by:

apply in interface StatefulFunction

Parameters:

context - the Context of the current invocation.

message - the input message.

Throws:

java.lang.Throwable