Package org.apache.beam.sdk.io.aws2.kinesis

Interface RateLimitPolicy

All Known Implementing Classes:

RateLimitPolicyFactory.DefaultRateLimiter, RateLimitPolicyFactory.DelayIntervalRateLimiter

public interface RateLimitPolicy

Method Summary

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

Method Details

onSuccess

default void onSuccess(List<KinesisRecord> records)
                throws InterruptedException

Called after Kinesis records are successfully retrieved.

Parameters:

records - The list of retrieved records.

Throws:

InterruptedException

onThrottle

default void onThrottle(KinesisClientThrottledException e)
                 throws InterruptedException

Called after the Kinesis client is throttled.

Parameters:

e - The KinesisClientThrottledException thrown by the client.

Throws:

InterruptedException