Package | Description |
---|---|
org.apache.paimon.data | |
org.apache.paimon.data.serializer | |
org.apache.paimon.lookup | |
org.apache.paimon.statistics | |
org.apache.paimon.utils |
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. |
Modifier and Type | Interface and Description |
---|---|
interface |
PagedTypeSerializer<T>
A type serializer which provides paged serialize and deserialize methods.
|
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 . |
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<InternalMap> |
InternalMapSerializer.duplicate() |
Serializer<Timestamp> |
TimestampSerializer.duplicate() |
Serializer<T> |
NullableSerializer.duplicate() |
Serializer<List<T>> |
ListSerializer.duplicate() |
Serializer<InternalRow> |
RowCompactedSerializer.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 . |
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 . |
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.
|
Modifier and Type | Field and Description |
---|---|
protected Serializer<K> |
RocksDBState.keySerializer |
protected Serializer<V> |
RocksDBState.valueSerializer |
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) |
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) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
PositiveIntIntSerializer
|
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) |
Constructor and Description |
---|
ParallelExecution(Serializer<T> serializer,
int pageSize,
int parallelism,
List<java.util.function.Supplier<Pair<RecordReader<T>,E>>> readers) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.