org.apache.paimon.flink.source

Class RecordLimiter

java.lang.Object

org.apache.paimon.flink.source.RecordLimiter

public class RecordLimiter
extends Object

A limiter to limit record reading.

Constructor Summary

Constructors

Constructor and Description
RecordLimiter(long limit)

Method Summary

Modifier and Type	Method and Description
void	add(long delta)
static RecordLimiter	create(Long limit)
void	increment()
boolean	reachLimit()

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordLimiter

public RecordLimiter(long limit)

Method Detail

reachLimit

public boolean reachLimit()

increment

public void increment()

add

public void add(long delta)

create

@Nullable
public static RecordLimiter create(@Nullable
                                             Long limit)