org.apache.paimon.data.serializer

Class InternalMapSerializer

java.lang.Object

org.apache.paimon.data.serializer.InternalMapSerializer

All Implemented Interfaces:

Serializable, Serializer<InternalMap>

public class InternalMapSerializer
extends Object
implements Serializer<InternalMap>

Serializer for InternalMap.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
InternalMapSerializer(DataType keyType, DataType valueType)

Method Summary

Modifier and Type	Method and Description
static Map<Object,Object>	convertToJavaMap(InternalMap map, DataType keyType, DataType valueType) Converts a InternalMap into Java Map, the keys and values of the Java map still holds objects of internal data structures.
InternalMap	copy(InternalMap from) NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into a HashMap, problems maybe occur.
InternalMap	deserialize(DataInputView source) De-serializes a record from the given source input view.
Serializer<InternalMap>	duplicate() Creates a deep copy of this serializer if it is necessary, i.e.
boolean	equals(Object o)
int	hashCode()
void	serialize(InternalMap record, DataOutputView target) Serializes the given record to the given target output view.
BinaryMap	toBinaryMap(InternalMap from)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.data.serializer.Serializer

deserializeFromString, serializeToString

Constructor Detail

InternalMapSerializer

public InternalMapSerializer(DataType keyType,
                             DataType valueType)

Method Detail

duplicate

public Serializer<InternalMap> duplicate()

Description copied from interface: Serializer

Creates a deep copy of this serializer if it is necessary, i.e. if it is stateful. This can return itself if the serializer is not stateful.

We need this because Serializers might be used in several threads. Stateless serializers are inherently thread-safe while stateful serializers might not be thread-safe.

Specified by:

duplicate in interface Serializer<InternalMap>

copy

public InternalMap copy(InternalMap from)

NOTE: Map should be a HashMap, when we insert the key/value pairs of the TreeMap into a HashMap, problems maybe occur.

Specified by:

copy in interface Serializer<InternalMap>

Parameters:

from - The element reuse be copied.

Returns:

A deep copy of the element.

serialize

public void serialize(InternalMap record,
                      DataOutputView target)
               throws IOException

Description copied from interface: Serializer

Serializes the given record to the given target output view.

Specified by:

serialize in interface Serializer<InternalMap>

Parameters:

record - The record to serialize.

target - The output view to write the serialized data to.

Throws:

IOException - Thrown, if the serialization encountered an I/O related error. Typically raised by the output view, which may have an underlying I/O channel to which it delegates.

toBinaryMap

public BinaryMap toBinaryMap(InternalMap from)

deserialize

public InternalMap deserialize(DataInputView source)
                        throws IOException

Description copied from interface: Serializer

De-serializes a record from the given source input view.

Specified by:

deserialize in interface Serializer<InternalMap>

Parameters:

source - The input view from which to read the data.

Returns:

The deserialized element.

Throws:

IOException - Thrown, if the de-serialization encountered an I/O related error. Typically raised by the input view, which may have an underlying I/O channel from which it reads.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

convertToJavaMap

public static Map<Object,Object> convertToJavaMap(InternalMap map,
                                                  DataType keyType,
                                                  DataType valueType)

Converts a InternalMap into Java Map, the keys and values of the Java map still holds objects of internal data structures.