public static class XaSinkStateSerializer.XaSinkStateSimpleXaTypeSerializerSnapshot extends SimpleTypeSerializerSnapshot<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState>
TypeSerializerSnapshot
for XaSinkStateSerializer
.Constructor and Description |
---|
XaSinkStateSimpleXaTypeSerializerSnapshot() |
Modifier and Type | Method and Description |
---|---|
void |
readSnapshot(int readVersion,
DataInputView in,
ClassLoader classLoader)
Reads the serializer snapshot from the provided
DataInputView . |
void |
writeSnapshot(DataOutputView out)
Writes the serializer snapshot to the provided
DataOutputView . |
equals, getCurrentVersion, hashCode, resolveSchemaCompatibility, restoreSerializer, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
readVersionedSnapshot, writeVersionedSnapshot
public XaSinkStateSimpleXaTypeSerializerSnapshot()
public void writeSnapshot(DataOutputView out) throws IOException
TypeSerializerSnapshot
DataOutputView
. The current version of
the written serializer snapshot's binary format is specified by the TypeSerializerSnapshot.getCurrentVersion()
method.writeSnapshot
in interface TypeSerializerSnapshot<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState>
writeSnapshot
in class SimpleTypeSerializerSnapshot<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState>
out
- the DataOutputView
to write the snapshot to.IOException
- Thrown if the snapshot data could not be written.TypeSerializerSnapshot.writeVersionedSnapshot(DataOutputView, TypeSerializerSnapshot)
public void readSnapshot(int readVersion, DataInputView in, ClassLoader classLoader) throws IOException
TypeSerializerSnapshot
DataInputView
. The version of the
binary format that the serializer snapshot was written with is provided. This version can be
used to determine how the serializer snapshot should be read.readSnapshot
in interface TypeSerializerSnapshot<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState>
readSnapshot
in class SimpleTypeSerializerSnapshot<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState>
readVersion
- version of the serializer snapshot's written binary formatin
- the DataInputView
to read the snapshot from.classLoader
- the user code classloaderIOException
- Thrown if the snapshot data could be read or parsed.TypeSerializerSnapshot.readVersionedSnapshot(DataInputView, ClassLoader)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.