org.apache.paimon.io

Class RecordLevelExpire

java.lang.Object

org.apache.paimon.io.RecordLevelExpire

public class RecordLevelExpire
extends Object

A factory to create RecordReader expires records by time.

Method Summary

Modifier and Type	Method and Description
static RecordLevelExpire	create(CoreOptions options, TableSchema schema, SchemaManager schemaManager)
static java.util.function.Function<InternalRow,Optional<Long>>	createFieldGetterAndConvertToSecond(DataType dataType, int fieldIndex)
boolean	isExpireFile(DataFileMeta file)
FileReaderFactory<KeyValue>	wrap(FileReaderFactory<KeyValue> readerFactory)

Methods inherited from class java.lang.Object

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

Method Detail

create

@Nullable
public static RecordLevelExpire create(CoreOptions options,
                                                 TableSchema schema,
                                                 SchemaManager schemaManager)

isExpireFile

public boolean isExpireFile(DataFileMeta file)

wrap

public FileReaderFactory<KeyValue> wrap(FileReaderFactory<KeyValue> readerFactory)

createFieldGetterAndConvertToSecond

@VisibleForTesting
public static java.util.function.Function<InternalRow,Optional<Long>> createFieldGetterAndConvertToSecond(DataType dataType,
                                                                                                                             int fieldIndex)