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, RowType rowType)
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,
                                                 RowType rowType)

wrap

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