class Amazonite::Kinesis::RecordConfiguration

Overview

Specifies the format of records read from the source stream.

Included Modules

Defined in:

kinesis/record_configuration.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(pull : JSON::PullParser) #

[View source]
def self.new(record_format_type : RecordFormatType, gsr_schema_arn : String | Nil = nil) #

[View source]

Instance Method Detail

def ==(other : self) #
Description copied from class Reference

Returns true if this reference is the same as other. Invokes same?.


def gsr_schema_arn : String | Nil #

The Amazon Resource Name (ARN) of the Amazon Web Services Glue Schema Registry schema used to validate records. Required when the channel destination is a streaming table (Amazon S3 Tables), for both the JSON and GSR_JSON record formats.


[View source]
def gsr_schema_arn=(gsr_schema_arn : String | Nil) #

The Amazon Resource Name (ARN) of the Amazon Web Services Glue Schema Registry schema used to validate records. Required when the channel destination is a streaming table (Amazon S3 Tables), for both the JSON and GSR_JSON record formats.


[View source]
def hash(hasher) #
Description copied from class Reference

See Object#hash(hasher)


def record_format_type : RecordFormatType #

The format of records on the source stream. Valid values:

  • GSR_JSON - Supported only for streaming table (Amazon S3 Tables) destinations.

  • JSON - Supported for both general purpose Amazon S3 and streaming table destinations.

  • STRING - Supported only for general purpose Amazon S3 destinations.

  • BYTE_ARRAY - Supported only for general purpose Amazon S3 destinations.


[View source]
def record_format_type=(record_format_type : RecordFormatType) #

The format of records on the source stream. Valid values:

  • GSR_JSON - Supported only for streaming table (Amazon S3 Tables) destinations.

  • JSON - Supported for both general purpose Amazon S3 and streaming table destinations.

  • STRING - Supported only for general purpose Amazon S3 destinations.

  • BYTE_ARRAY - Supported only for general purpose Amazon S3 destinations.


[View source]
def validate! : Nil #

[View source]