public class DataStreamStateTTLTestProgram extends Object
The test pipeline does the following: - generates random keyed state updates for each state TTL verifier (state type) - performs update of created state with TTL for each verifier - keeps previous updates in other state - verifies expected result of last update against preserved history of updates
|Constructor and Description|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.