org.apache.beam.sdk.io.kinesis

Class RateLimitPolicyFactory.DelayIntervalRateLimiter

java.lang.Object

org.apache.beam.sdk.io.kinesis.RateLimitPolicyFactory.DelayIntervalRateLimiter

All Implemented Interfaces:

RateLimitPolicy

Enclosing interface:

RateLimitPolicyFactory

public static class RateLimitPolicyFactory.DelayIntervalRateLimiter
extends java.lang.Object
implements RateLimitPolicy

Constructor Summary

Constructors

Constructor and Description
DelayIntervalRateLimiter()
DelayIntervalRateLimiter(java.util.function.Supplier<Duration> delay)

Method Summary

Modifier and Type	Method and Description
void	onSuccess(java.util.List<KinesisRecord> records) Called after Kinesis records are successfully retrieved.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.io.kinesis.RateLimitPolicy

onThrottle

Constructor Detail

DelayIntervalRateLimiter

public DelayIntervalRateLimiter()

DelayIntervalRateLimiter

public DelayIntervalRateLimiter(java.util.function.Supplier<Duration> delay)

Method Detail

onSuccess

public void onSuccess(java.util.List<KinesisRecord> records)
               throws java.lang.InterruptedException

Description copied from interface: RateLimitPolicy

Called after Kinesis records are successfully retrieved.

Specified by:

onSuccess in interface RateLimitPolicy

Parameters:

records - The list of retrieved records.

Throws:

java.lang.InterruptedException