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

Class KinesisTransformRegistrar.ReadDataBuilder.Configuration

java.lang.Object

org.apache.beam.sdk.io.aws2.kinesis.KinesisTransformRegistrar.ReadDataBuilder.Configuration

Enclosing class:

KinesisTransformRegistrar.ReadDataBuilder

public static class KinesisTransformRegistrar.ReadDataBuilder.Configuration
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Configuration()

Method Summary

Modifier and Type	Method and Description
void	setInitialPositionInStream(@Nullable java.lang.String initialPositionInStream)
void	setInitialTimestampInStream(@Nullable java.lang.Long initialTimestampInStream)
void	setMaxCapacityPerShard(@Nullable java.lang.Long maxCapacityPerShard)
void	setMaxNumRecords(@Nullable java.lang.Long maxNumRecords)
void	setMaxReadTime(@Nullable java.lang.Long maxReadTime)
void	setRateLimit(@Nullable java.lang.Long rateLimit)
void	setRequestRecordsLimit(@Nullable java.lang.Long requestRecordsLimit)
void	setUpToDateThreshold(@Nullable java.lang.Long upToDateThreshold)
void	setWatermarkIdleDurationThreshold(@Nullable java.lang.Long watermarkIdleDurationThreshold)
void	setWatermarkPolicy(@Nullable java.lang.String watermarkPolicy)

Methods inherited from class java.lang.Object

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

Constructor Detail

Configuration

public Configuration()

Method Detail

setMaxNumRecords

public void setMaxNumRecords(@Nullable java.lang.Long maxNumRecords)

setMaxReadTime

public void setMaxReadTime(@Nullable java.lang.Long maxReadTime)

setInitialPositionInStream

public void setInitialPositionInStream(@Nullable java.lang.String initialPositionInStream)

setInitialTimestampInStream

public void setInitialTimestampInStream(@Nullable java.lang.Long initialTimestampInStream)

setRequestRecordsLimit

public void setRequestRecordsLimit(@Nullable java.lang.Long requestRecordsLimit)

setUpToDateThreshold

public void setUpToDateThreshold(@Nullable java.lang.Long upToDateThreshold)

setMaxCapacityPerShard

public void setMaxCapacityPerShard(@Nullable java.lang.Long maxCapacityPerShard)

setWatermarkPolicy

public void setWatermarkPolicy(@Nullable java.lang.String watermarkPolicy)

setWatermarkIdleDurationThreshold

public void setWatermarkIdleDurationThreshold(@Nullable java.lang.Long watermarkIdleDurationThreshold)

setRateLimit

public void setRateLimit(@Nullable java.lang.Long rateLimit)