org.apache.beam.sdk.io.kinesis

Interface RateLimitPolicy

All Known Implementing Classes:

RateLimitPolicyFactory.DelayIntervalRateLimiter

public interface RateLimitPolicy

Method Summary

Modifier and Type	Method and Description
default void	onSuccess(java.util.List<KinesisRecord> records) Called after Kinesis records are successfully retrieved.
default void	onThrottle(KinesisClientThrottledException e) Called after the Kinesis client is throttled.

Method Detail

onSuccess

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

Called after Kinesis records are successfully retrieved.

Parameters:

records - The list of retrieved records.

Throws:

java.lang.InterruptedException

onThrottle

default void onThrottle(KinesisClientThrottledException e)
                 throws java.lang.InterruptedException

Called after the Kinesis client is throttled.

Parameters:

e - The KinesisClientThrottledException thrown by the client.

Throws:

java.lang.InterruptedException