Class: Aws::Kinesis::Types::CreateStreamInput

Inherits:
Struct
  • Object
show all
Defined in:
gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb

Overview

Represents the input for CreateStream.

Constant Summary collapse

SENSITIVE =
[]

Instance Attribute Summary collapse

Instance Attribute Details

#max_record_size_in_ki_b ⇒ Integer

The maximum record size of a single record in kibibyte (KiB) that you can write to, and read from a stream.

Returns:

  • (Integer)


608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end

#record_distribution_strategy ⇒ String

The record distribution strategy for the stream, which determines how Amazon Kinesis Data Streams distributes records across shards. Specify one of the following values:

  • AUTO – Amazon Kinesis Data Streams distributes records evenly across shards and ignores any partition key and ExplicitHashKey that producers supply. Use this value for stateless workloads that do not require partition-key ordering.

  • USER_PARTITION_KEY – Producers must supply a partition key, which Amazon Kinesis Data Streams uses to determine shard placement. This is the default.

The record distribution strategy is only supported for streams that use the on-demand capacity mode. If you do not specify this parameter, the stream uses USER_PARTITION_KEY.

Returns:

  • (String)


608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end

#shard_count ⇒ Integer

The number of shards that the stream will use. The throughput of the stream is a function of the number of shards; more shards are required for greater provisioned throughput.

Returns:

  • (Integer)


608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end

#stream_mode_details ⇒ Types::StreamModeDetails

Indicates the capacity mode of the data stream. Currently, in Kinesis Data Streams, you can choose between an on-demand capacity mode and a provisioned capacity mode for your data streams.



608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end

#stream_name ⇒ String

A name to identify the stream. The stream name is scoped to the Amazon Web Services account used by the application that creates the stream. It is also scoped by Amazon Web Services Region. That is, two streams in two different Amazon Web Services accounts can have the same name. Two streams in the same Amazon Web Services account but in two different Regions can also have the same name.

Returns:

  • (String)


608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end

#tags ⇒ Hash<String,String>

A set of up to 50 key-value pairs to use to create the tags. A tag consists of a required key and an optional value.

Returns:

  • (Hash<String,String>)


608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end

#warm_throughput_mi_bps ⇒ Integer

The target warm throughput in MB/s that the stream should be scaled to handle. This represents the throughput capacity that will be immediately available for write operations.

Returns:

  • (Integer)


608
609
610
611
612
613
614
615
616
617
618
# File 'gems/aws-sdk-kinesis/lib/aws-sdk-kinesis/types.rb', line 608

class CreateStreamInput < Struct.new(
  :stream_name,
  :shard_count,
  :stream_mode_details,
  :tags,
  :warm_throughput_mi_bps,
  :max_record_size_in_ki_b,
  :record_distribution_strategy)
  SENSITIVE = []
  include Aws::Structure
end