public class RemoteValueSerializerSnapshot
extends java.lang.Object
implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<byte[]>
Constructor and Description |
---|
RemoteValueSerializerSnapshot() |
Modifier and Type | Method and Description |
---|---|
int |
getCurrentVersion() |
void |
readSnapshot(int i,
org.apache.flink.core.memory.DataInputView dataInputView,
java.lang.ClassLoader classLoader) |
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<byte[]> |
resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<byte[]> otherSerializer) |
org.apache.flink.api.common.typeutils.TypeSerializer<byte[]> |
restoreSerializer() |
TypeName |
type() |
void |
writeSnapshot(org.apache.flink.core.memory.DataOutputView dataOutputView) |
public TypeName type()
public int getCurrentVersion()
getCurrentVersion
in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<byte[]>
public void writeSnapshot(org.apache.flink.core.memory.DataOutputView dataOutputView) throws java.io.IOException
writeSnapshot
in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<byte[]>
java.io.IOException
public void readSnapshot(int i, org.apache.flink.core.memory.DataInputView dataInputView, java.lang.ClassLoader classLoader) throws java.io.IOException
readSnapshot
in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<byte[]>
java.io.IOException
public org.apache.flink.api.common.typeutils.TypeSerializer<byte[]> restoreSerializer()
restoreSerializer
in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<byte[]>
public org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility<byte[]> resolveSchemaCompatibility(org.apache.flink.api.common.typeutils.TypeSerializer<byte[]> otherSerializer)
resolveSchemaCompatibility
in interface org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<byte[]>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.