org.apache.paimon.utils

Class ObjectsCache<K,V>

java.lang.Object

org.apache.paimon.utils.ObjectsCache<K,V>

@ThreadSafe
public class ObjectsCache<K,V>
extends Object

Cache records to SegmentsCache by compacted serializer.

Constructor Summary

Constructors

Constructor and Description
ObjectsCache(SegmentsCache<K> cache, ObjectSerializer<V> projectedSerializer, RowType formatSchema, FunctionWithIOException<K,Long> fileSizeFunction, BiFunctionWithIOE<K,Long,CloseableIterator<InternalRow>> reader)

Method Summary

Modifier and Type	Method and Description
List<V>	read(K key, Long fileSize, Filter<InternalRow> loadFilter, Filter<InternalRow> readFilter, Filter<V> readVFilter)
void	withCacheMetrics(CacheMetrics cacheMetrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectsCache

public ObjectsCache(SegmentsCache<K> cache,
                    ObjectSerializer<V> projectedSerializer,
                    RowType formatSchema,
                    FunctionWithIOException<K,Long> fileSizeFunction,
                    BiFunctionWithIOE<K,Long,CloseableIterator<InternalRow>> reader)

Method Detail

withCacheMetrics

public void withCacheMetrics(@Nullable
                             CacheMetrics cacheMetrics)

read

public List<V> read(K key,
                    @Nullable
                    Long fileSize,
                    Filter<InternalRow> loadFilter,
                    Filter<InternalRow> readFilter,
                    Filter<V> readVFilter)
             throws IOException

Throws:

IOException