Package | Description |
---|---|
org.apache.flink.statefun.sdk.java.testing |
Class and Description |
---|
SideEffects.EgressSideEffect
A utility class that wraps a
EgressMessage thats was sent by a StatefulFunction . |
SideEffects.SendAfterSideEffect
A utility class that wraps a
Message and the Duration after which it was sent
by a StatefulFunction . |
SideEffects.SendSideEffect
A utility class that wraps a
Message that was sent by a StatefulFunction . |
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.