public class SavepointSerializers extends Object
SavepointSerializer
for a specific savepoint version.Modifier and Type | Method and Description |
---|---|
static SavepointSerializer<?> |
getSerializer(int version)
Returns the
SavepointSerializer for the given savepoint version. |
static <T extends Savepoint> |
getSerializer(T savepoint)
Returns the
SavepointSerializer for the given savepoint. |
static void |
setFailWhenLegacyStateDetected(boolean fail)
This is only visible as a temporary solution to keep the stateful job migration it cases working from binary
savepoints that still contain legacy state (<= Flink 1.1).
|
public static <T extends Savepoint> SavepointSerializer<T> getSerializer(T savepoint)
SavepointSerializer
for the given savepoint.T
- Type of savepointsavepoint
- Savepoint to get serializer forIllegalArgumentException
- If unknown savepoint versionpublic static SavepointSerializer<?> getSerializer(int version)
SavepointSerializer
for the given savepoint version.version
- Savepoint version to get serializer forIllegalArgumentException
- If unknown savepoint version@VisibleForTesting public static void setFailWhenLegacyStateDetected(boolean fail)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.