* The identifier of the event source mapping. *
*/ private String uUID; /** ** The name of the Lambda function. *
** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 * characters in length. *
*/ private String functionName; /** ** When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *
** Default: True *
*/ private Boolean enabled; /** ** The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your * function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit * for synchronous invocation (6 MB). *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max * is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *
*/ private FilterCriteria filterCriteria; /** *
* The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You
* can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in
* increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed
* Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because
* you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back
* to the 500 ms default batching window after you have changed it. To restore the default batching window, you must
* create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater
* than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
*
* (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *
*/ private DestinationConfig destinationConfig; /** ** (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *
*/ private Integer maximumRecordAgeInSeconds; /** ** (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *
*/ private Boolean bisectBatchOnFunctionError; /** ** (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *
*/ private Integer maximumRetryAttempts; /** ** (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *
*/ private Integer parallelizationFactor; /** ** An array of authentication protocols or VPC components required to secure your event source. *
*/ private com.amazonaws.internal.SdkInternalList* (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis * Streams event sources. A value of 0 seconds indicates no tumbling window. *
*/ private Integer tumblingWindowInSeconds; /** ** (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *
*/ private com.amazonaws.internal.SdkInternalList* (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *
*/ private ScalingConfig scalingConfig; /** ** Specific configuration settings for a DocumentDB event source. *
*/ private DocumentDBEventSourceConfig documentDBEventSourceConfig; /** ** The identifier of the event source mapping. *
* * @param uUID * The identifier of the event source mapping. */ public void setUUID(String uUID) { this.uUID = uUID; } /** ** The identifier of the event source mapping. *
* * @return The identifier of the event source mapping. */ public String getUUID() { return this.uUID; } /** ** The identifier of the event source mapping. *
* * @param uUID * The identifier of the event source mapping. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withUUID(String uUID) { setUUID(uUID); return this; } /** ** The name of the Lambda function. *
** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 * characters in length. *
* * @param functionName * The name of the Lambda function. ** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited to * 64 characters in length. */ public void setFunctionName(String functionName) { this.functionName = functionName; } /** *
* The name of the Lambda function. *
** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 * characters in length. *
* * @return The name of the Lambda function. ** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD
* .
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited * to 64 characters in length. */ public String getFunctionName() { return this.functionName; } /** *
* The name of the Lambda function. *
** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited to 64 * characters in length. *
* * @param functionName * The name of the Lambda function. ** Name formats *
*
* Function name – MyFunction.
*
* Function ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction.
*
* Version or Alias ARN – arn:aws:lambda:us-west-2:123456789012:function:MyFunction:PROD.
*
* Partial ARN – 123456789012:function:MyFunction.
*
* The length constraint applies only to the full ARN. If you specify only the function name, it's limited to * 64 characters in length. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withFunctionName(String functionName) { setFunctionName(functionName); return this; } /** *
* When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *
** Default: True *
* * @param enabled * When true, the event source mapping is active. When false, Lambda pauses polling and invocation. ** Default: True */ public void setEnabled(Boolean enabled) { this.enabled = enabled; } /** *
* When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *
** Default: True *
* * @return When true, the event source mapping is active. When false, Lambda pauses polling and invocation. ** Default: True */ public Boolean getEnabled() { return this.enabled; } /** *
* When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *
** Default: True *
* * @param enabled * When true, the event source mapping is active. When false, Lambda pauses polling and invocation. ** Default: True * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withEnabled(Boolean enabled) { setEnabled(enabled); return this; } /** *
* When true, the event source mapping is active. When false, Lambda pauses polling and invocation. *
** Default: True *
* * @return When true, the event source mapping is active. When false, Lambda pauses polling and invocation. ** Default: True */ public Boolean isEnabled() { return this.enabled; } /** *
* The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your * function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit * for synchronous invocation (6 MB). *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max * is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues * the max is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your * function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit * for synchronous invocation (6 MB). *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max * is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues * the max is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** The maximum number of records in each batch that Lambda pulls from your stream or queue and sends to your * function. Lambda passes all of the records in the batch to the function in a single call, up to the payload limit * for synchronous invocation (6 MB). *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues the max * is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** Amazon Kinesis – Default 100. Max 10,000. *
** Amazon DynamoDB Streams – Default 100. Max 10,000. *
** Amazon Simple Queue Service – Default 10. For standard queues the max is 10,000. For FIFO queues * the max is 10. *
** Amazon Managed Streaming for Apache Kafka – Default 100. Max 10,000. *
** Self-managed Apache Kafka – Default 100. Max 10,000. *
** Amazon MQ (ActiveMQ and RabbitMQ) – Default 100. Max 10,000. *
** DocumentDB – Default 100. Max 10,000. *
** An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *
* * @param filterCriteria * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda event * filtering. */ public void setFilterCriteria(FilterCriteria filterCriteria) { this.filterCriteria = filterCriteria; } /** ** An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *
* * @return An object that defines the filter criteria that determine whether Lambda should process an event. For * more information, see Lambda event * filtering. */ public FilterCriteria getFilterCriteria() { return this.filterCriteria; } /** ** An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda * event filtering. *
* * @param filterCriteria * An object that defines the filter criteria that determine whether Lambda should process an event. For more * information, see Lambda event * filtering. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withFilterCriteria(FilterCriteria filterCriteria) { setFilterCriteria(filterCriteria); return this; } /** *
* The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You
* can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in
* increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed
* Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because
* you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back
* to the 500 ms default batching window after you have changed it. To restore the default batching window, you must
* create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater
* than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
*
MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds
* in increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK,
* Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms.
* Note that because you can only change MaximumBatchingWindowInSeconds in increments of
* seconds, you cannot revert back to the 500 ms default batching window after you have changed it. To
* restore the default batching window, you must create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value
* greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
*/
public void setMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds) {
this.maximumBatchingWindowInSeconds = maximumBatchingWindowInSeconds;
}
/**
*
* The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You
* can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in
* increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed
* Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because
* you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back
* to the 500 ms default batching window after you have changed it. To restore the default batching window, you must
* create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater
* than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
*
MaximumBatchingWindowInSeconds to any value from 0 seconds to
* 300 seconds in increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK,
* Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500
* ms. Note that because you can only change MaximumBatchingWindowInSeconds in increments of
* seconds, you cannot revert back to the 500 ms default batching window after you have changed it. To
* restore the default batching window, you must create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value
* greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
*/
public Integer getMaximumBatchingWindowInSeconds() {
return this.maximumBatchingWindowInSeconds;
}
/**
*
* The maximum amount of time, in seconds, that Lambda spends gathering records before invoking the function. You
* can configure MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds in
* increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK, Self-managed
* Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms. Note that because
* you can only change MaximumBatchingWindowInSeconds in increments of seconds, you cannot revert back
* to the 500 ms default batching window after you have changed it. To restore the default batching window, you must
* create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value greater
* than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
*
MaximumBatchingWindowInSeconds to any value from 0 seconds to 300 seconds
* in increments of seconds.
*
* For streams and Amazon SQS event sources, the default batching window is 0 seconds. For Amazon MSK,
* Self-managed Apache Kafka, Amazon MQ, and DocumentDB event sources, the default batching window is 500 ms.
* Note that because you can only change MaximumBatchingWindowInSeconds in increments of
* seconds, you cannot revert back to the 500 ms default batching window after you have changed it. To
* restore the default batching window, you must create a new event source mapping.
*
* Related setting: For streams and Amazon SQS event sources, when you set BatchSize to a value
* greater than 10, you must set MaximumBatchingWindowInSeconds to at least 1.
* @return Returns a reference to this object so that method calls can be chained together.
*/
public UpdateEventSourceMappingRequest withMaximumBatchingWindowInSeconds(Integer maximumBatchingWindowInSeconds) {
setMaximumBatchingWindowInSeconds(maximumBatchingWindowInSeconds);
return this;
}
/**
*
* (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *
* * @param destinationConfig * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination * for discarded records. */ public void setDestinationConfig(DestinationConfig destinationConfig) { this.destinationConfig = destinationConfig; } /** ** (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *
* * @return (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination * for discarded records. */ public DestinationConfig getDestinationConfig() { return this.destinationConfig; } /** ** (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination for * discarded records. *
* * @param destinationConfig * (Kinesis and DynamoDB Streams only) A standard Amazon SQS queue or standard Amazon SNS topic destination * for discarded records. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withDestinationConfig(DestinationConfig destinationConfig) { setDestinationConfig(destinationConfig); return this; } /** ** (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *
* * @param maximumRecordAgeInSeconds * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is * infinite (-1). */ public void setMaximumRecordAgeInSeconds(Integer maximumRecordAgeInSeconds) { this.maximumRecordAgeInSeconds = maximumRecordAgeInSeconds; } /** ** (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *
* * @return (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is * infinite (-1). */ public Integer getMaximumRecordAgeInSeconds() { return this.maximumRecordAgeInSeconds; } /** ** (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is infinite * (-1). *
* * @param maximumRecordAgeInSeconds * (Kinesis and DynamoDB Streams only) Discard records older than the specified age. The default value is * infinite (-1). * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withMaximumRecordAgeInSeconds(Integer maximumRecordAgeInSeconds) { setMaximumRecordAgeInSeconds(maximumRecordAgeInSeconds); return this; } /** ** (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *
* * @param bisectBatchOnFunctionError * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. */ public void setBisectBatchOnFunctionError(Boolean bisectBatchOnFunctionError) { this.bisectBatchOnFunctionError = bisectBatchOnFunctionError; } /** ** (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *
* * @return (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. */ public Boolean getBisectBatchOnFunctionError() { return this.bisectBatchOnFunctionError; } /** ** (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *
* * @param bisectBatchOnFunctionError * (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withBisectBatchOnFunctionError(Boolean bisectBatchOnFunctionError) { setBisectBatchOnFunctionError(bisectBatchOnFunctionError); return this; } /** ** (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. *
* * @return (Kinesis and DynamoDB Streams only) If the function returns an error, split the batch in two and retry. */ public Boolean isBisectBatchOnFunctionError() { return this.bisectBatchOnFunctionError; } /** ** (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *
* * @param maximumRetryAttempts * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default * value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. */ public void setMaximumRetryAttempts(Integer maximumRetryAttempts) { this.maximumRetryAttempts = maximumRetryAttempts; } /** ** (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *
* * @return (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default * value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. */ public Integer getMaximumRetryAttempts() { return this.maximumRetryAttempts; } /** ** (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default value is * infinite (-1). When set to infinite (-1), failed records are retried until the record expires. *
* * @param maximumRetryAttempts * (Kinesis and DynamoDB Streams only) Discard records after the specified number of retries. The default * value is infinite (-1). When set to infinite (-1), failed records are retried until the record expires. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withMaximumRetryAttempts(Integer maximumRetryAttempts) { setMaximumRetryAttempts(maximumRetryAttempts); return this; } /** ** (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *
* * @param parallelizationFactor * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. */ public void setParallelizationFactor(Integer parallelizationFactor) { this.parallelizationFactor = parallelizationFactor; } /** ** (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *
* * @return (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. */ public Integer getParallelizationFactor() { return this.parallelizationFactor; } /** ** (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. *
* * @param parallelizationFactor * (Kinesis and DynamoDB Streams only) The number of batches to process from each shard concurrently. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withParallelizationFactor(Integer parallelizationFactor) { setParallelizationFactor(parallelizationFactor); return this; } /** ** An array of authentication protocols or VPC components required to secure your event source. *
* * @return An array of authentication protocols or VPC components required to secure your event source. */ public java.util.List* An array of authentication protocols or VPC components required to secure your event source. *
* * @param sourceAccessConfigurations * An array of authentication protocols or VPC components required to secure your event source. */ public void setSourceAccessConfigurations(java.util.Collection* An array of authentication protocols or VPC components required to secure your event source. *
** NOTE: This method appends the values to the existing list (if any). Use * {@link #setSourceAccessConfigurations(java.util.Collection)} or * {@link #withSourceAccessConfigurations(java.util.Collection)} if you want to override the existing values. *
* * @param sourceAccessConfigurations * An array of authentication protocols or VPC components required to secure your event source. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withSourceAccessConfigurations(SourceAccessConfiguration... sourceAccessConfigurations) { if (this.sourceAccessConfigurations == null) { setSourceAccessConfigurations(new com.amazonaws.internal.SdkInternalList* An array of authentication protocols or VPC components required to secure your event source. *
* * @param sourceAccessConfigurations * An array of authentication protocols or VPC components required to secure your event source. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withSourceAccessConfigurations(java.util.Collection* (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis * Streams event sources. A value of 0 seconds indicates no tumbling window. *
* * @param tumblingWindowInSeconds * (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and * Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window. */ public void setTumblingWindowInSeconds(Integer tumblingWindowInSeconds) { this.tumblingWindowInSeconds = tumblingWindowInSeconds; } /** ** (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis * Streams event sources. A value of 0 seconds indicates no tumbling window. *
* * @return (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and * Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window. */ public Integer getTumblingWindowInSeconds() { return this.tumblingWindowInSeconds; } /** ** (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and Kinesis * Streams event sources. A value of 0 seconds indicates no tumbling window. *
* * @param tumblingWindowInSeconds * (Kinesis and DynamoDB Streams only) The duration in seconds of a processing window for DynamoDB and * Kinesis Streams event sources. A value of 0 seconds indicates no tumbling window. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withTumblingWindowInSeconds(Integer tumblingWindowInSeconds) { setTumblingWindowInSeconds(tumblingWindowInSeconds); return this; } /** ** (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *
* * @return (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @see FunctionResponseType */ public java.util.List* (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *
* * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @see FunctionResponseType */ public void setFunctionResponseTypes(java.util.Collection* (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *
** NOTE: This method appends the values to the existing list (if any). Use * {@link #setFunctionResponseTypes(java.util.Collection)} or * {@link #withFunctionResponseTypes(java.util.Collection)} if you want to override the existing values. *
* * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @return Returns a reference to this object so that method calls can be chained together. * @see FunctionResponseType */ public UpdateEventSourceMappingRequest withFunctionResponseTypes(String... functionResponseTypes) { if (this.functionResponseTypes == null) { setFunctionResponseTypes(new com.amazonaws.internal.SdkInternalList* (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *
* * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @return Returns a reference to this object so that method calls can be chained together. * @see FunctionResponseType */ public UpdateEventSourceMappingRequest withFunctionResponseTypes(java.util.Collection* (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event source * mapping. *
* * @param functionResponseTypes * (Kinesis, DynamoDB Streams, and Amazon SQS) A list of current response type enums applied to the event * source mapping. * @return Returns a reference to this object so that method calls can be chained together. * @see FunctionResponseType */ public UpdateEventSourceMappingRequest withFunctionResponseTypes(FunctionResponseType... functionResponseTypes) { com.amazonaws.internal.SdkInternalList* (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *
* * @param scalingConfig * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring * maximum concurrency for Amazon SQS event sources. */ public void setScalingConfig(ScalingConfig scalingConfig) { this.scalingConfig = scalingConfig; } /** ** (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *
* * @return (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring * maximum concurrency for Amazon SQS event sources. */ public ScalingConfig getScalingConfig() { return this.scalingConfig; } /** ** (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring maximum * concurrency for Amazon SQS event sources. *
* * @param scalingConfig * (Amazon SQS only) The scaling configuration for the event source. For more information, see Configuring * maximum concurrency for Amazon SQS event sources. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withScalingConfig(ScalingConfig scalingConfig) { setScalingConfig(scalingConfig); return this; } /** ** Specific configuration settings for a DocumentDB event source. *
* * @param documentDBEventSourceConfig * Specific configuration settings for a DocumentDB event source. */ public void setDocumentDBEventSourceConfig(DocumentDBEventSourceConfig documentDBEventSourceConfig) { this.documentDBEventSourceConfig = documentDBEventSourceConfig; } /** ** Specific configuration settings for a DocumentDB event source. *
* * @return Specific configuration settings for a DocumentDB event source. */ public DocumentDBEventSourceConfig getDocumentDBEventSourceConfig() { return this.documentDBEventSourceConfig; } /** ** Specific configuration settings for a DocumentDB event source. *
* * @param documentDBEventSourceConfig * Specific configuration settings for a DocumentDB event source. * @return Returns a reference to this object so that method calls can be chained together. */ public UpdateEventSourceMappingRequest withDocumentDBEventSourceConfig(DocumentDBEventSourceConfig documentDBEventSourceConfig) { setDocumentDBEventSourceConfig(documentDBEventSourceConfig); return this; } /** * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be * redacted from this string using a placeholder value. * * @return A string representation of this object. * * @see java.lang.Object#toString() */ @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("{"); if (getUUID() != null) sb.append("UUID: ").append(getUUID()).append(","); if (getFunctionName() != null) sb.append("FunctionName: ").append(getFunctionName()).append(","); if (getEnabled() != null) sb.append("Enabled: ").append(getEnabled()).append(","); if (getBatchSize() != null) sb.append("BatchSize: ").append(getBatchSize()).append(","); if (getFilterCriteria() != null) sb.append("FilterCriteria: ").append(getFilterCriteria()).append(","); if (getMaximumBatchingWindowInSeconds() != null) sb.append("MaximumBatchingWindowInSeconds: ").append(getMaximumBatchingWindowInSeconds()).append(","); if (getDestinationConfig() != null) sb.append("DestinationConfig: ").append(getDestinationConfig()).append(","); if (getMaximumRecordAgeInSeconds() != null) sb.append("MaximumRecordAgeInSeconds: ").append(getMaximumRecordAgeInSeconds()).append(","); if (getBisectBatchOnFunctionError() != null) sb.append("BisectBatchOnFunctionError: ").append(getBisectBatchOnFunctionError()).append(","); if (getMaximumRetryAttempts() != null) sb.append("MaximumRetryAttempts: ").append(getMaximumRetryAttempts()).append(","); if (getParallelizationFactor() != null) sb.append("ParallelizationFactor: ").append(getParallelizationFactor()).append(","); if (getSourceAccessConfigurations() != null) sb.append("SourceAccessConfigurations: ").append(getSourceAccessConfigurations()).append(","); if (getTumblingWindowInSeconds() != null) sb.append("TumblingWindowInSeconds: ").append(getTumblingWindowInSeconds()).append(","); if (getFunctionResponseTypes() != null) sb.append("FunctionResponseTypes: ").append(getFunctionResponseTypes()).append(","); if (getScalingConfig() != null) sb.append("ScalingConfig: ").append(getScalingConfig()).append(","); if (getDocumentDBEventSourceConfig() != null) sb.append("DocumentDBEventSourceConfig: ").append(getDocumentDBEventSourceConfig()); sb.append("}"); return sb.toString(); } @Override public boolean equals(Object obj) { if (this == obj) return true; if (obj == null) return false; if (obj instanceof UpdateEventSourceMappingRequest == false) return false; UpdateEventSourceMappingRequest other = (UpdateEventSourceMappingRequest) obj; if (other.getUUID() == null ^ this.getUUID() == null) return false; if (other.getUUID() != null && other.getUUID().equals(this.getUUID()) == false) return false; if (other.getFunctionName() == null ^ this.getFunctionName() == null) return false; if (other.getFunctionName() != null && other.getFunctionName().equals(this.getFunctionName()) == false) return false; if (other.getEnabled() == null ^ this.getEnabled() == null) return false; if (other.getEnabled() != null && other.getEnabled().equals(this.getEnabled()) == false) return false; if (other.getBatchSize() == null ^ this.getBatchSize() == null) return false; if (other.getBatchSize() != null && other.getBatchSize().equals(this.getBatchSize()) == false) return false; if (other.getFilterCriteria() == null ^ this.getFilterCriteria() == null) return false; if (other.getFilterCriteria() != null && other.getFilterCriteria().equals(this.getFilterCriteria()) == false) return false; if (other.getMaximumBatchingWindowInSeconds() == null ^ this.getMaximumBatchingWindowInSeconds() == null) return false; if (other.getMaximumBatchingWindowInSeconds() != null && other.getMaximumBatchingWindowInSeconds().equals(this.getMaximumBatchingWindowInSeconds()) == false) return false; if (other.getDestinationConfig() == null ^ this.getDestinationConfig() == null) return false; if (other.getDestinationConfig() != null && other.getDestinationConfig().equals(this.getDestinationConfig()) == false) return false; if (other.getMaximumRecordAgeInSeconds() == null ^ this.getMaximumRecordAgeInSeconds() == null) return false; if (other.getMaximumRecordAgeInSeconds() != null && other.getMaximumRecordAgeInSeconds().equals(this.getMaximumRecordAgeInSeconds()) == false) return false; if (other.getBisectBatchOnFunctionError() == null ^ this.getBisectBatchOnFunctionError() == null) return false; if (other.getBisectBatchOnFunctionError() != null && other.getBisectBatchOnFunctionError().equals(this.getBisectBatchOnFunctionError()) == false) return false; if (other.getMaximumRetryAttempts() == null ^ this.getMaximumRetryAttempts() == null) return false; if (other.getMaximumRetryAttempts() != null && other.getMaximumRetryAttempts().equals(this.getMaximumRetryAttempts()) == false) return false; if (other.getParallelizationFactor() == null ^ this.getParallelizationFactor() == null) return false; if (other.getParallelizationFactor() != null && other.getParallelizationFactor().equals(this.getParallelizationFactor()) == false) return false; if (other.getSourceAccessConfigurations() == null ^ this.getSourceAccessConfigurations() == null) return false; if (other.getSourceAccessConfigurations() != null && other.getSourceAccessConfigurations().equals(this.getSourceAccessConfigurations()) == false) return false; if (other.getTumblingWindowInSeconds() == null ^ this.getTumblingWindowInSeconds() == null) return false; if (other.getTumblingWindowInSeconds() != null && other.getTumblingWindowInSeconds().equals(this.getTumblingWindowInSeconds()) == false) return false; if (other.getFunctionResponseTypes() == null ^ this.getFunctionResponseTypes() == null) return false; if (other.getFunctionResponseTypes() != null && other.getFunctionResponseTypes().equals(this.getFunctionResponseTypes()) == false) return false; if (other.getScalingConfig() == null ^ this.getScalingConfig() == null) return false; if (other.getScalingConfig() != null && other.getScalingConfig().equals(this.getScalingConfig()) == false) return false; if (other.getDocumentDBEventSourceConfig() == null ^ this.getDocumentDBEventSourceConfig() == null) return false; if (other.getDocumentDBEventSourceConfig() != null && other.getDocumentDBEventSourceConfig().equals(this.getDocumentDBEventSourceConfig()) == false) return false; return true; } @Override public int hashCode() { final int prime = 31; int hashCode = 1; hashCode = prime * hashCode + ((getUUID() == null) ? 0 : getUUID().hashCode()); hashCode = prime * hashCode + ((getFunctionName() == null) ? 0 : getFunctionName().hashCode()); hashCode = prime * hashCode + ((getEnabled() == null) ? 0 : getEnabled().hashCode()); hashCode = prime * hashCode + ((getBatchSize() == null) ? 0 : getBatchSize().hashCode()); hashCode = prime * hashCode + ((getFilterCriteria() == null) ? 0 : getFilterCriteria().hashCode()); hashCode = prime * hashCode + ((getMaximumBatchingWindowInSeconds() == null) ? 0 : getMaximumBatchingWindowInSeconds().hashCode()); hashCode = prime * hashCode + ((getDestinationConfig() == null) ? 0 : getDestinationConfig().hashCode()); hashCode = prime * hashCode + ((getMaximumRecordAgeInSeconds() == null) ? 0 : getMaximumRecordAgeInSeconds().hashCode()); hashCode = prime * hashCode + ((getBisectBatchOnFunctionError() == null) ? 0 : getBisectBatchOnFunctionError().hashCode()); hashCode = prime * hashCode + ((getMaximumRetryAttempts() == null) ? 0 : getMaximumRetryAttempts().hashCode()); hashCode = prime * hashCode + ((getParallelizationFactor() == null) ? 0 : getParallelizationFactor().hashCode()); hashCode = prime * hashCode + ((getSourceAccessConfigurations() == null) ? 0 : getSourceAccessConfigurations().hashCode()); hashCode = prime * hashCode + ((getTumblingWindowInSeconds() == null) ? 0 : getTumblingWindowInSeconds().hashCode()); hashCode = prime * hashCode + ((getFunctionResponseTypes() == null) ? 0 : getFunctionResponseTypes().hashCode()); hashCode = prime * hashCode + ((getScalingConfig() == null) ? 0 : getScalingConfig().hashCode()); hashCode = prime * hashCode + ((getDocumentDBEventSourceConfig() == null) ? 0 : getDocumentDBEventSourceConfig().hashCode()); return hashCode; } @Override public UpdateEventSourceMappingRequest clone() { return (UpdateEventSourceMappingRequest) super.clone(); } }