diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehose.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehose.java
index c6962f8e86..9571c70742 100644
--- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehose.java
+++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehose.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License").
* You may not use this file except in compliance with the License.
@@ -20,13 +20,17 @@
import com.amazonaws.services.kinesisfirehose.model.*;
/**
- * Interface for accessing Amazon Kinesis Firehose
- * Amazon Kinesis Data Firehose is a fully managed service that delivers
- * real-time streaming data to destinations such as Amazon Simple Storage
- * Service (Amazon S3), Amazon OpenSearch Service, Amazon Redshift, Splunk, and
- * various other supportd destinations.
+ * Amazon Data Firehose was previously known as Amazon Kinesis Data Firehose.
+ *
+ * Amazon Data Firehose is a fully managed service that delivers real-time + * streaming data to destinations such as Amazon Simple Storage Service (Amazon + * S3), Amazon OpenSearch Service, Amazon Redshift, Splunk, and various other + * supported destinations. *
**/ public interface AmazonKinesisFirehose { @@ -98,9 +102,16 @@ public interface AmazonKinesisFirehose { * producers. * *+ * Firehose accumulates and publishes a particular metric for a customer + * account in one minute intervals. It is possible that the bursts of + * incoming bytes/records ingested to a delivery stream last only for a few + * seconds. Due to this, the actual spikes in the traffic might not be fully + * visible in the customer's 1 minute CloudWatch metrics. + *
+ ** For information about service quota, see Amazon - * Kinesis Data Firehose Quota. + * Firehose Quota. *
** Each PutRecordBatch request supports up to 500 records. Each @@ -116,12 +127,12 @@ public interface AmazonKinesisFirehose { * data, and so on. *
*
- * Kinesis Data Firehose buffers records before delivering them to the
- * destination. To disambiguate the data blobs at the destination, a common
- * solution is to use delimiters in the data, such as a newline (
- * \n
) or some other character unique within the data. This
- * allows the consumer application to parse individual data items when
- * reading the data from the destination.
+ * Firehose buffers records before delivering them to the destination. To
+ * disambiguate the data blobs at the destination, a common solution is to
+ * use delimiters in the data, such as a newline (\n
) or some
+ * other character unique within the data. This allows the consumer
+ * application to parse individual data items when reading the data from the
+ * destination.
*
* The PutRecordBatch response includes a count of failed records,
@@ -134,9 +145,9 @@ public interface AmazonKinesisFirehose {
* record in the request array using the same ordering, from the top to the
* bottom. The response array always includes the same number of records as
* the request array. RequestResponses
includes both
- * successfully and unsuccessfully processed records. Kinesis Data Firehose
- * tries to process all records in each PutRecordBatch request. A
- * single record failure does not stop the processing of subsequent records.
+ * successfully and unsuccessfully processed records. Firehose tries to
+ * process all records in each PutRecordBatch request. A single
+ * record failure does not stop the processing of subsequent records.
*
* A successfully processed record includes a RecordId
value,
@@ -157,14 +168,20 @@ public interface AmazonKinesisFirehose {
*
* If PutRecordBatch throws ServiceUnavailableException
,
- * back off and retry. If the exception persists, it is possible that the
- * throughput limits have been exceeded for the delivery stream.
+ * the API is automatically reinvoked (retried) 3 times. If the exception
+ * persists, it is possible that the throughput limits have been exceeded
+ * for the delivery stream.
+ *
+ * Re-invoking the Put API operations (for example, PutRecord and + * PutRecordBatch) can result in data duplicates. For larger data assets, + * allow for a longer time out before retrying Put API operations. *
*- * Data records sent to Kinesis Data Firehose are stored for 24 hours from - * the time they are added to a delivery stream as it attempts to send the - * records to the destination. If the destination is unreachable for more - * than 24 hours, the data is no longer available. + * Data records sent to Firehose are stored for 24 hours from the time they + * are added to a delivery stream as it attempts to send the records to the + * destination. If the destination is unreachable for more than 24 hours, + * the data is no longer available. *
*@@ -180,6 +197,7 @@ public interface AmazonKinesisFirehose { * @throws ResourceNotFoundException * @throws InvalidArgumentException * @throws InvalidKMSResourceException + * @throws InvalidSourceException * @throws ServiceUnavailableException * @throws AmazonClientException If any internal errors are encountered * inside the client while attempting to make the request or diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehoseClient.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehoseClient.java index 50fa5e92cd..c0f5a56c39 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehoseClient.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/AmazonKinesisFirehoseClient.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. @@ -35,12 +35,16 @@ * this client are blocking, and will not return until the service call * completes. *
- *
- * Amazon Kinesis Data Firehose is a fully managed service that delivers
- * real-time streaming data to destinations such as Amazon Simple Storage
- * Service (Amazon S3), Amazon OpenSearch Service, Amazon Redshift, Splunk, and
- * various other supportd destinations.
+ * Amazon Data Firehose was previously known as Amazon Kinesis Data Firehose.
+ *
+ * Amazon Data Firehose is a fully managed service that delivers real-time + * streaming data to destinations such as Amazon Simple Storage Service (Amazon + * S3), Amazon OpenSearch Service, Amazon Redshift, Splunk, and various other + * supported destinations. *
*/ public class AmazonKinesisFirehoseClient extends AmazonWebServiceClient implements @@ -339,6 +343,7 @@ private void init() { jsonErrorUnmarshallers = new ArrayList+ * Firehose accumulates and publishes a particular metric for a customer + * account in one minute intervals. It is possible that the bursts of + * incoming bytes/records ingested to a delivery stream last only for a few + * seconds. Due to this, the actual spikes in the traffic might not be fully + * visible in the customer's 1 minute CloudWatch metrics. + *
+ ** For information about service quota, see Amazon - * Kinesis Data Firehose Quota. + * Firehose Quota. *
** Each PutRecordBatch request supports up to 500 records. Each @@ -387,12 +399,12 @@ private static ClientConfiguration adjustClientConfiguration(ClientConfiguration * data, and so on. *
*
- * Kinesis Data Firehose buffers records before delivering them to the
- * destination. To disambiguate the data blobs at the destination, a common
- * solution is to use delimiters in the data, such as a newline (
- * \n
) or some other character unique within the data. This
- * allows the consumer application to parse individual data items when
- * reading the data from the destination.
+ * Firehose buffers records before delivering them to the destination. To
+ * disambiguate the data blobs at the destination, a common solution is to
+ * use delimiters in the data, such as a newline (\n
) or some
+ * other character unique within the data. This allows the consumer
+ * application to parse individual data items when reading the data from the
+ * destination.
*
* The PutRecordBatch response includes a count of failed records,
@@ -405,9 +417,9 @@ private static ClientConfiguration adjustClientConfiguration(ClientConfiguration
* record in the request array using the same ordering, from the top to the
* bottom. The response array always includes the same number of records as
* the request array. RequestResponses
includes both
- * successfully and unsuccessfully processed records. Kinesis Data Firehose
- * tries to process all records in each PutRecordBatch request. A
- * single record failure does not stop the processing of subsequent records.
+ * successfully and unsuccessfully processed records. Firehose tries to
+ * process all records in each PutRecordBatch request. A single
+ * record failure does not stop the processing of subsequent records.
*
* A successfully processed record includes a RecordId
value,
@@ -428,14 +440,20 @@ private static ClientConfiguration adjustClientConfiguration(ClientConfiguration
*
* If PutRecordBatch throws ServiceUnavailableException
,
- * back off and retry. If the exception persists, it is possible that the
- * throughput limits have been exceeded for the delivery stream.
+ * the API is automatically reinvoked (retried) 3 times. If the exception
+ * persists, it is possible that the throughput limits have been exceeded
+ * for the delivery stream.
+ *
+ * Re-invoking the Put API operations (for example, PutRecord and + * PutRecordBatch) can result in data duplicates. For larger data assets, + * allow for a longer time out before retrying Put API operations. *
*- * Data records sent to Kinesis Data Firehose are stored for 24 hours from - * the time they are added to a delivery stream as it attempts to send the - * records to the destination. If the destination is unreachable for more - * than 24 hours, the data is no longer available. + * Data records sent to Firehose are stored for 24 hours from the time they + * are added to a delivery stream as it attempts to send the records to the + * destination. If the destination is unreachable for more than 24 hours, + * the data is no longer available. *
*@@ -451,6 +469,7 @@ private static ClientConfiguration adjustClientConfiguration(ClientConfiguration * @throws ResourceNotFoundException * @throws InvalidArgumentException * @throws InvalidKMSResourceException + * @throws InvalidSourceException * @throws ServiceUnavailableException * @throws AmazonClientException If any internal errors are encountered * inside the client while attempting to make the request or diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidArgumentException.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidArgumentException.java index 7e3c8959f6..41af881d27 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidArgumentException.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidArgumentException.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidKMSResourceException.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidKMSResourceException.java index 548e52a186..b63ce7e35c 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidKMSResourceException.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/InvalidKMSResourceException.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. @@ -19,9 +19,9 @@ /** *
- * Kinesis Data Firehose throws this exception when an attempt to put records or
- * to start or stop delivery stream encryption fails. This happens when the KMS
- * service throws one of the following exception types:
+ * Firehose throws this exception when an attempt to put records or to start or
+ * stop delivery stream encryption fails. This happens when the KMS service
+ * throws one of the following exception types:
* AccessDeniedException
, InvalidStateException
,
* DisabledException
, or NotFoundException
.
*
+ * Only requests from CloudWatch Logs are supported when CloudWatch Logs + * decompression is enabled. + *
+ */ +public class InvalidSourceException extends AmazonServiceException { + private static final long serialVersionUID = 1L; + + private String code; + + /** + * Constructs a new InvalidSourceException with the specified error message. + * + * @param message Describes the error encountered. + */ + public InvalidSourceException(String message) { + super(message); + } + + /** + * Returns the value of the code property for this object. + * + * @return The value of the code property for this object. + */ + public String getCode() { + return code; + } + + /** + * Sets the value of code + * + * @param code The new value for the code property for this object. + */ + public void setCode(String code) { + this.code = code; + } +} diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchRequest.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchRequest.java index 9e48d63331..4239cec5d9 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchRequest.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchRequest.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. @@ -27,9 +27,16 @@ * Applications using these operations are referred to as producers. * *+ * Firehose accumulates and publishes a particular metric for a customer account + * in one minute intervals. It is possible that the bursts of incoming + * bytes/records ingested to a delivery stream last only for a few seconds. Due + * to this, the actual spikes in the traffic might not be fully visible in the + * customer's 1 minute CloudWatch metrics. + *
+ ** For information about service quota, see Amazon - * Kinesis Data Firehose Quota. + * Firehose Quota. *
** Each PutRecordBatch request supports up to 500 records. Each record in @@ -44,12 +51,11 @@ * and so on. *
*
- * Kinesis Data Firehose buffers records before delivering them to the
- * destination. To disambiguate the data blobs at the destination, a common
- * solution is to use delimiters in the data, such as a newline (\n
- * ) or some other character unique within the data. This allows the consumer
- * application to parse individual data items when reading the data from the
- * destination.
+ * Firehose buffers records before delivering them to the destination. To
+ * disambiguate the data blobs at the destination, a common solution is to use
+ * delimiters in the data, such as a newline (\n
) or some other
+ * character unique within the data. This allows the consumer application to
+ * parse individual data items when reading the data from the destination.
*
* The PutRecordBatch response includes a count of failed records,
@@ -62,9 +68,9 @@
* in the request array using the same ordering, from the top to the bottom. The
* response array always includes the same number of records as the request
* array. RequestResponses
includes both successfully and
- * unsuccessfully processed records. Kinesis Data Firehose tries to process all
- * records in each PutRecordBatch request. A single record failure does
- * not stop the processing of subsequent records.
+ * unsuccessfully processed records. Firehose tries to process all records in
+ * each PutRecordBatch request. A single record failure does not stop the
+ * processing of subsequent records.
*
* A successfully processed record includes a RecordId
value, which
@@ -84,15 +90,21 @@
* you handle any duplicates at the destination.
*
- * If PutRecordBatch throws ServiceUnavailableException
,
- * back off and retry. If the exception persists, it is possible that the
- * throughput limits have been exceeded for the delivery stream.
+ * If PutRecordBatch throws ServiceUnavailableException
, the
+ * API is automatically reinvoked (retried) 3 times. If the exception persists,
+ * it is possible that the throughput limits have been exceeded for the delivery
+ * stream.
+ *
+ * Re-invoking the Put API operations (for example, PutRecord and + * PutRecordBatch) can result in data duplicates. For larger data assets, allow + * for a longer time out before retrying Put API operations. *
*- * Data records sent to Kinesis Data Firehose are stored for 24 hours from the - * time they are added to a delivery stream as it attempts to send the records - * to the destination. If the destination is unreachable for more than 24 hours, - * the data is no longer available. + * Data records sent to Firehose are stored for 24 hours from the time they are + * added to a delivery stream as it attempts to send the records to the + * destination. If the destination is unreachable for more than 24 hours, the + * data is no longer available. *
*diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResponseEntry.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResponseEntry.java index 206d6f2546..e967903e09 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResponseEntry.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResponseEntry.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResult.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResult.java index 2859b69711..1c5c518cd1 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResult.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/PutRecordBatchResult.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/Record.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/Record.java index 9d2b0a47f3..61290cbba2 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/Record.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/Record.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ResourceNotFoundException.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ResourceNotFoundException.java index 87dfcd5935..93e2664010 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ResourceNotFoundException.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ResourceNotFoundException.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ServiceUnavailableException.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ServiceUnavailableException.java index d40050bdce..b1f6d5d2ba 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ServiceUnavailableException.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/ServiceUnavailableException.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. @@ -24,7 +24,7 @@ * exceeded. For more information about limits and how to request an increase, * see Amazon - * Kinesis Data Firehose Limits. + * Firehose Limits. *
*/ public class ServiceUnavailableException extends AmazonServiceException { diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidArgumentExceptionUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidArgumentExceptionUnmarshaller.java index a66d6998b6..6210f09b41 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidArgumentExceptionUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidArgumentExceptionUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidKMSResourceExceptionUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidKMSResourceExceptionUnmarshaller.java index 6f60b6e14c..ba568309f8 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidKMSResourceExceptionUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidKMSResourceExceptionUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidSourceExceptionUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidSourceExceptionUnmarshaller.java new file mode 100644 index 0000000000..c6d0ca3a3f --- /dev/null +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/InvalidSourceExceptionUnmarshaller.java @@ -0,0 +1,43 @@ +/* + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"). + * You may not use this file except in compliance with the License. + * A copy of the License is located at + * + * http://aws.amazon.com/apache2.0 + * + * or in the "license" file accompanying this file. This file is distributed + * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either + * express or implied. See the License for the specific language governing + * permissions and limitations under the License. + */ + +package com.amazonaws.services.kinesisfirehose.model.transform; + +import com.amazonaws.AmazonServiceException; +import com.amazonaws.http.JsonErrorResponseHandler.JsonErrorResponse; +import com.amazonaws.transform.JsonErrorUnmarshaller; +import com.amazonaws.services.kinesisfirehose.model.InvalidSourceException; + +public class InvalidSourceExceptionUnmarshaller extends JsonErrorUnmarshaller { + + public InvalidSourceExceptionUnmarshaller() { + super(InvalidSourceException.class); + } + + @Override + public boolean match(JsonErrorResponse error) throws Exception { + return error.getErrorCode().equals("InvalidSourceException"); + } + + @Override + public AmazonServiceException unmarshall(JsonErrorResponse error) throws Exception { + + InvalidSourceException e = (InvalidSourceException) super.unmarshall(error); + e.setErrorCode("InvalidSourceException"); + e.setCode(String.valueOf(error.get("code"))); + + return e; + } +} diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonMarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonMarshaller.java index e204065e36..9782ec0aa1 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonMarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonMarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonUnmarshaller.java index 2b1d4e44a5..a35081a50e 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResponseEntryJsonUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResultJsonUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResultJsonUnmarshaller.java index 60ac84e361..0d82074d64 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResultJsonUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/PutRecordBatchResultJsonUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonMarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonMarshaller.java index 683edf7ec0..7c2b14ed45 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonMarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonMarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonUnmarshaller.java index 9065848677..a8ff7c9ecb 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/RecordJsonUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ResourceNotFoundExceptionUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ResourceNotFoundExceptionUnmarshaller.java index fbb1d2db86..859882692d 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ResourceNotFoundExceptionUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ResourceNotFoundExceptionUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ServiceUnavailableExceptionUnmarshaller.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ServiceUnavailableExceptionUnmarshaller.java index 249caa5464..90bc0a764c 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ServiceUnavailableExceptionUnmarshaller.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/model/transform/ServiceUnavailableExceptionUnmarshaller.java @@ -1,5 +1,5 @@ /* - * Copyright 2010-2022 Amazon.com, Inc. or its affiliates. All Rights Reserved. + * Copyright 2010-2024 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). * You may not use this file except in compliance with the License. diff --git a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/package-info.java b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/package-info.java index 6fb690c030..6162146399 100644 --- a/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/package-info.java +++ b/aws-android-sdk-kinesis/src/main/java/com/amazonaws/services/kinesisfirehose/package-info.java @@ -1,5 +1,5 @@ /** - *Amazon Kinesis Data Firehose is a fully managed service that delivers real-time streaming data to destinations such as Amazon Simple Storage Service (Amazon S3), Amazon OpenSearch Service, Amazon Redshift, Splunk, and various other supportd destinations.
+ *Amazon Data Firehose was previously known as Amazon Kinesis Data Firehose.
Amazon Data Firehose is a fully managed service that delivers real-time streaming data to destinations such as Amazon Simple Storage Service (Amazon S3), Amazon OpenSearch Service, Amazon Redshift, Splunk, and various other supported destinations.
*/ package com.amazonaws.services.kinesisfirehose;