Package 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 Object

  • Constructor Details

    • Configuration

      public Configuration()

  • Method Details

    • setMaxNumRecords

      public void setMaxNumRecords(@Nullable Long maxNumRecords)

    • setMaxReadTime

      public void setMaxReadTime(@Nullable Long maxReadTime)

    • setInitialPositionInStream

      public void setInitialPositionInStream(@Nullable String initialPositionInStream)

    • setInitialTimestampInStream

      public void setInitialTimestampInStream(@Nullable Long initialTimestampInStream)

    • setRequestRecordsLimit

      public void setRequestRecordsLimit(@Nullable Long requestRecordsLimit)

    • setUpToDateThreshold

      public void setUpToDateThreshold(@Nullable Long upToDateThreshold)

    • setMaxCapacityPerShard

      public void setMaxCapacityPerShard(@Nullable Long maxCapacityPerShard)

    • setWatermarkPolicy

      public void setWatermarkPolicy(@Nullable String watermarkPolicy)

    • setWatermarkIdleDurationThreshold

      public void setWatermarkIdleDurationThreshold(@Nullable Long watermarkIdleDurationThreshold)

    • setRateLimit

      public void setRateLimit(@Nullable Long rateLimit)

    • setStreamName

      public void setStreamName(String streamName)

    • setAwsAccessKey

      public void setAwsAccessKey(String awsAccessKey)

    • setAwsSecretKey

      public void setAwsSecretKey(String awsSecretKey)

    • setRegion

      public void setRegion(String region)

    • setServiceEndpoint

      public void setServiceEndpoint(@Nullable String serviceEndpoint)

    • setVerifyCertificate

      public void setVerifyCertificate(@Nullable Boolean verifyCertificate)

    • setAggregationEnabled

      public void setAggregationEnabled(@Nullable Boolean aggregationEnabled)

    • setAggregationMaxBytes

      public void setAggregationMaxBytes(Long aggregationMaxBytes)

    • setAggregationMaxBufferedTime

      public void setAggregationMaxBufferedTime(Long aggregationMaxBufferedTime)

    • setAggregationShardRefreshInterval

      public void setAggregationShardRefreshInterval(Long aggregationShardRefreshInterval)