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–2020 The Apache Software Foundation. All rights reserved.