public class StateUtils extends Object
Modifier and Type | Method and Description |
---|---|
static <T extends StateHandle<?>> |
setOperatorState(StatefulTask<?> op,
StateHandle<?> state,
long recoveryTimestamp)
Utility method to define a common generic bound to be used for setting a
generic state handle on a generic state carrier.
|
public static <T extends StateHandle<?>> void setOperatorState(StatefulTask<?> op, StateHandle<?> state, long recoveryTimestamp) throws Exception
T
- Type bound for theop
- The state carrier operator.state
- The state handle.recoveryTimestamp
- Global recovery timestampException
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.