Class | Description |
---|---|
ArtificalOperatorStateMapper<IN,OUT> |
A self-verifiable
RichMapFunction used to verify checkpointing and restore semantics for
various kinds of operator state. |
ArtificialKeyedStateMapper<IN,OUT> |
A generic, stateful
MapFunction that allows specifying what states to maintain based on a
provided list of ArtificialStateBuilder s. |
ComplexPayload |
A state type used in the
DataStreamAllroundTestProgram . |
ComplexPayload.InnerPayLoad |
Nested class in state type.
|
StatefulComplexPayloadSerializer |
A custom stateful serializer to test that serializers are not used concurrently.
|
StatefulComplexPayloadSerializer.Snapshot |
Snapshot for the
StatefulComplexPayloadSerializer . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.