Modifier and Type | Field and Description |
---|---|
static int |
MAGIC_NUMBER
It is important to keep this number consistent with the number used by the
StreamingCommitterStateSerializer in Flink 1.13 and 1.14. |
Constructor and Description |
---|
SinkV1CommittableDeserializer() |
Modifier and Type | Method and Description |
---|---|
static <T> List<T> |
readVersionAndDeserializeList(SimpleVersionedSerializer<T> serializer,
DataInputView in) |
@VisibleForTesting public static final int MAGIC_NUMBER
StreamingCommitterStateSerializer
in Flink 1.13 and 1.14.public static <T> List<T> readVersionAndDeserializeList(SimpleVersionedSerializer<T> serializer, DataInputView in) throws IOException
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.