Uses of Interface
org.apache.paimon.data.serializer.Serializer

Packages that use Serializer

Package	Description
org.apache.paimon.data
org.apache.paimon.data.serializer
org.apache.paimon.lookup
org.apache.paimon.statistics
org.apache.paimon.utils

Uses of Serializer in org.apache.paimon.data

Methods in org.apache.paimon.data with parameters of type Serializer

Modifier and Type	Method and Description
static BinaryWriter.ValueSetter	BinaryWriter.createValueSetter(DataType elementType, Serializer<?> serializer)
static void	BinaryWriter.write(BinaryWriter writer, int pos, Object o, DataType type, Serializer<?> serializer) Deprecated. Use #createValueSetter(DataType) for avoiding logical types during runtime.

Uses of Serializer in org.apache.paimon.data.serializer

Subinterfaces of Serializer in org.apache.paimon.data.serializer

Modifier and Type	Interface and Description
interface	PagedTypeSerializer<T> A type serializer which provides paged serialize and deserialize methods.

Classes in org.apache.paimon.data.serializer that implement Serializer

Modifier and Type	Class and Description
class	AbstractRowDataSerializer<T extends InternalRow> Row serializer, provided paged serialize paged method.
class	BinaryRowSerializer Serializer for BinaryRow.
class	BinarySerializer Type serializer for byte[].
class	BinaryStringSerializer Serializer for BinaryString.
class	BooleanSerializer Type serializer for Boolean (and bool, via auto-boxing).
class	ByteSerializer Type serializer for Byte (and byte, via auto-boxing).
class	DecimalSerializer Serializer for Decimal.
class	DoubleSerializer Type serializer for Double (and double, via auto-boxing).
class	FloatSerializer Type serializer for Float (and float, via auto-boxing).
class	InternalArraySerializer Serializer for InternalArray.
class	InternalMapSerializer Serializer for InternalMap.
class	InternalRowSerializer Serializer for InternalRow.
class	IntSerializer Type serializer for Integer (and int, via auto-boxing).
class	ListSerializer<T> A serializer for Lists.
class	LongSerializer Type serializer for Integer (and int, via auto-boxing).
class	NullableSerializer<T> Serializer wrapper to add support of null value serialization.
class	RowCompactedSerializer A Serializer for InternalRow using compacted binary.
class	SerializerSingleton<T> Singleton Serializer.
class	ShortSerializer Type serializer for Short (and short, via auto-boxing).
class	TimestampSerializer Serializer for Timestamp.

Methods in org.apache.paimon.data.serializer that return Serializer

Modifier and Type	Method and Description
static <T> Serializer<T>	InternalSerializers.create(DataType type) Creates a Serializer for internal data structures of the given DataType.
Serializer<T>	Serializer.duplicate() Creates a deep copy of this serializer if it is necessary, i.e.
Serializer<InternalRow>	RowCompactedSerializer.duplicate()
Serializer<Timestamp>	TimestampSerializer.duplicate()
Serializer<InternalMap>	InternalMapSerializer.duplicate()
Serializer<List<T>>	ListSerializer.duplicate()
Serializer<T>	NullableSerializer.duplicate()
Serializer<T>	ListSerializer.getElementSerializer() Gets the serializer for the elements of the list.
static <T> Serializer<T>	NullableSerializer.wrap(Serializer<T> originalSerializer) This method wraps the originalSerializer with the NullableSerializer if not already wrapped.
static <T> Serializer<T>	NullableSerializer.wrapIfNullIsNotSupported(Serializer<T> originalSerializer) This method tries to serialize null value with the originalSerializer and wraps it in case of NullPointerException, otherwise it returns the originalSerializer.

Methods in org.apache.paimon.data.serializer with parameters of type Serializer

Modifier and Type	Method and Description
static <T> boolean	NullableSerializer.checkIfNullSupported(Serializer<T> serializer) This method checks if serializer supports null value.
static <T> Serializer<T>	NullableSerializer.wrap(Serializer<T> originalSerializer) This method wraps the originalSerializer with the NullableSerializer if not already wrapped.
static <T> Serializer<T>	NullableSerializer.wrapIfNullIsNotSupported(Serializer<T> originalSerializer) This method tries to serialize null value with the originalSerializer and wraps it in case of NullPointerException, otherwise it returns the originalSerializer.

Constructors in org.apache.paimon.data.serializer with parameters of type Serializer

Constructor and Description
InternalRowSerializer(DataType[] types, Serializer<?>[] fieldSerializers)
ListSerializer(Serializer<T> elementSerializer) Creates a list serializer that uses the given serializer to serialize the list's elements.

Uses of Serializer in org.apache.paimon.lookup

Fields in org.apache.paimon.lookup declared as Serializer

Modifier and Type	Field and Description
protected Serializer<K>	RocksDBState.keySerializer
protected Serializer<V>	RocksDBState.valueSerializer

Methods in org.apache.paimon.lookup with parameters of type Serializer

Modifier and Type	Method and Description
<K,V> RocksDBListState<K,V>	RocksDBStateFactory.listState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
<K,V> RocksDBListState<K,V>	RocksDBStateFactory.listState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
<K,V> RocksDBSetState<K,V>	RocksDBStateFactory.setState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
<K,V> RocksDBSetState<K,V>	RocksDBStateFactory.setState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
<K,V> RocksDBValueState<K,V>	RocksDBStateFactory.valueState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
<K,V> RocksDBValueState<K,V>	RocksDBStateFactory.valueState(String name, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)

Constructors in org.apache.paimon.lookup with parameters of type Serializer

Constructor and Description
RocksDBListState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBListState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBSetState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBSetState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBValueState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)
RocksDBValueState(RocksDBStateFactory stateFactory, org.rocksdb.ColumnFamilyHandle columnFamily, Serializer<K> keySerializer, Serializer<V> valueSerializer, long lruCacheSize)

Uses of Serializer in org.apache.paimon.statistics

Methods in org.apache.paimon.statistics with parameters of type Serializer

Modifier and Type	Method and Description
void	NoneSimpleColStatsCollector.collect(Object field, Serializer<Object> fieldSerializer)
void	FullSimpleColStatsCollector.collect(Object field, Serializer<Object> fieldSerializer)
void	CountsSimpleColStatsCollector.collect(Object field, Serializer<Object> serializer)
void	SimpleColStatsCollector.collect(Object field, Serializer<Object> fieldSerializer) collect stats from the field.
void	TruncateSimpleColStatsCollector.collect(Object field, Serializer<Object> fieldSerializer)

Uses of Serializer in org.apache.paimon.utils

Classes in org.apache.paimon.utils that implement Serializer

Modifier and Type	Class and Description
class	PositiveIntIntSerializer A SerializerSingleton for PositiveIntInt.

Methods in org.apache.paimon.utils with parameters of type Serializer

Modifier and Type	Method and Description
<T> List<T>	ListDelimitedSerializer.deserializeList(byte[] valueBytes, Serializer<T> elementSerializer)
static <T> T	ListDelimitedSerializer.deserializeNextElement(DataInputDeserializer in, Serializer<T> elementSerializer) Deserializes a single element from a serialized list.
<T> byte[]	ListDelimitedSerializer.serializeList(List<T> valueList, Serializer<T> elementSerializer)

Constructors in org.apache.paimon.utils with parameters of type Serializer

Constructor and Description
ParallelExecution(Serializer<T> serializer, int pageSize, int parallelism, List<java.util.function.Supplier<Pair<RecordReader<T>,E>>> readers)