SqsReadConfiguration (Apache Beam 2.68.0)

java.lang.Object

org.apache.beam.sdk.io.aws2.sqs.providers.SqsReadConfiguration

@DefaultSchema(AutoValueSchema.class) public abstract class SqsReadConfiguration extends Object

Configuration class for reading data from an AWS SQS queue.

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static class

SqsReadConfiguration.Builder
Constructor Summary

Constructors

Constructor

Description

SqsReadConfiguration()
Method Summary

Modifier and Type

Method

Description

static SqsReadConfiguration.Builder

builder()

abstract Long

getMaxNumRecords()

abstract Long

getMaxReadTimeSecs()

abstract String

getQueueUrl()

long

maxNumRecords()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- SqsReadConfiguration
  
  public SqsReadConfiguration()
Method Details
- builder
  
  public static SqsReadConfiguration.Builder builder()
- getQueueUrl
  
  public abstract String getQueueUrl()
- getMaxReadTimeSecs
  
  @Nullable public abstract Long getMaxReadTimeSecs()
- getMaxNumRecords
  
  @Nullable public abstract Long getMaxNumRecords()
- maxNumRecords
  
  public long maxNumRecords()