org.rocksdb

Interface FlinkCompactionFilter.ListElementFilter

Enclosing class:

FlinkCompactionFilter

public static interface FlinkCompactionFilter.ListElementFilter

Method Summary

Modifier and Type	Method and Description
int	nextUnexpiredOffset(byte[] list, long ttl, long currentTimestamp) Gets offset of the first unexpired element in the list.

Method Detail

nextUnexpiredOffset

int nextUnexpiredOffset(byte[] list,
                        long ttl,
                        long currentTimestamp)

Gets offset of the first unexpired element in the list.

Native code wraps this java object and calls it for list state for which element byte length is unknown and Flink custom type serializer has to be used to compute offset of the next element in serialized form.

Parameters:

list - serialised list of elements with timestamp

ttl - time-to-live of the list elements

currentTimestamp - current timestamp to check expiration against

Returns:

offset of the first unexpired element in the list