/** * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ #pragma once #include #include #include namespace Aws { namespace Utils { namespace Json { class JsonValue; class JsonView; } // namespace Json } // namespace Utils namespace Pipes { namespace Model { /** *

The parameters for using a Kinesis stream as a source.

See * Also:

AWS * API Reference

*/ class PipeTargetKinesisStreamParameters { public: AWS_PIPES_API PipeTargetKinesisStreamParameters(); AWS_PIPES_API PipeTargetKinesisStreamParameters(Aws::Utils::Json::JsonView jsonValue); AWS_PIPES_API PipeTargetKinesisStreamParameters& operator=(Aws::Utils::Json::JsonView jsonValue); AWS_PIPES_API Aws::Utils::Json::JsonValue Jsonize() const; /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline const Aws::String& GetPartitionKey() const{ return m_partitionKey; } /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline bool PartitionKeyHasBeenSet() const { return m_partitionKeyHasBeenSet; } /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline void SetPartitionKey(const Aws::String& value) { m_partitionKeyHasBeenSet = true; m_partitionKey = value; } /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline void SetPartitionKey(Aws::String&& value) { m_partitionKeyHasBeenSet = true; m_partitionKey = std::move(value); } /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline void SetPartitionKey(const char* value) { m_partitionKeyHasBeenSet = true; m_partitionKey.assign(value); } /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline PipeTargetKinesisStreamParameters& WithPartitionKey(const Aws::String& value) { SetPartitionKey(value); return *this;} /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline PipeTargetKinesisStreamParameters& WithPartitionKey(Aws::String&& value) { SetPartitionKey(std::move(value)); return *this;} /** *

Determines which shard in the stream the data record is assigned to. * Partition keys are Unicode strings with a maximum length limit of 256 characters * for each key. Amazon Kinesis Data Streams uses the partition key as input to a * hash function that maps the partition key and associated data to a specific * shard. Specifically, an MD5 hash function is used to map partition keys to * 128-bit integer values and to map associated data records to shards. As a result * of this hashing mechanism, all data records with the same partition key map to * the same shard within the stream.

*/ inline PipeTargetKinesisStreamParameters& WithPartitionKey(const char* value) { SetPartitionKey(value); return *this;} private: Aws::String m_partitionKey; bool m_partitionKeyHasBeenSet = false; }; } // namespace Model } // namespace Pipes } // namespace Aws