public class SinkV1CommittableDeserializer
This class offers the possibility to deserialize committables that have been written with older
Flink releases (i.e. 1.13, 1.14).
|Modifier and Type
||Field and Description
It is important to keep this number consistent with the number used by the
StreamingCommitterStateSerializer in Flink 1.13 and 1.14.
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.