AWS SDK for Go (PILOT)
API Reference

PREVIEW DOCUMENTATION - This is a preview of a new format for the AWS SDK for Go API Reference documentation. For the current AWS SDK for Go API Reference, see https://docs.aws.amazon.com/sdk-for-go/api/.

We welcome your feedback on this new version of the documentation. Send your comments to aws-sdkdocs-feedback@amazon.com.

Input

import "github.com/aws/aws-sdk-go/service/kinesisanalytics"

type Input struct { InputParallelism *InputParallelism `type:"structure"` InputProcessingConfiguration *InputProcessingConfiguration `type:"structure"` InputSchema *SourceSchema `type:"structure" required:"true"` KinesisFirehoseInput *KinesisFirehoseInput `type:"structure"` KinesisStreamsInput *KinesisStreamsInput `type:"structure"` NamePrefix *string `min:"1" type:"string" required:"true"` }

When you configure the application input, you specify the streaming source, the in-application stream name that is created, and the mapping between the two. For more information, see Configuring Application Input (https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html).

InputParallelism

Describes the number of in-application streams to create for a given streaming source. For information about parallelism, see Configuring Application Input (https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-input.html).

InputProcessingConfiguration

Provides a description of a processor that is used to preprocess the records in the stream before being processed by your application code. Currently, the only input processor available is AWS Lambda (https://aws.amazon.com/documentation/lambda/).

InputSchema

Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.

KinesisFirehoseInput

Identifies an Amazon Kinesis Firehose delivery stream as the streaming source. You provide the delivery stream's Amazon Resource Name (ARN) and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.

KinesisStreamsInput

Identifies an Amazon Kinesis stream as the streaming source. You provide the stream's Amazon Resource Name (ARN) and an IAM role ARN that enables Amazon Kinesis Analytics to access the stream on your behalf.

NamePrefix

Type: *string

Name prefix to use when creating an in-application stream. Suppose that you specify a prefix "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.

NamePrefix is a required field

Method

GoString

func (s Input) GoString() string

GoString returns the string representation

SetInputParallelism

func (s *Input) SetInputParallelism(v *InputParallelism) *Input

SetInputParallelism sets the InputParallelism field's value.

SetInputProcessingConfiguration

func (s *Input) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *Input

SetInputProcessingConfiguration sets the InputProcessingConfiguration field's value.

SetInputSchema

func (s *Input) SetInputSchema(v *SourceSchema) *Input

SetInputSchema sets the InputSchema field's value.

SetKinesisFirehoseInput

func (s *Input) SetKinesisFirehoseInput(v *KinesisFirehoseInput) *Input

SetKinesisFirehoseInput sets the KinesisFirehoseInput field's value.

SetKinesisStreamsInput

func (s *Input) SetKinesisStreamsInput(v *KinesisStreamsInput) *Input

SetKinesisStreamsInput sets the KinesisStreamsInput field's value.

SetNamePrefix

func (s *Input) SetNamePrefix(v string) *Input

SetNamePrefix sets the NamePrefix field's value.

String

func (s Input) String() string

String returns the string representation

Validate

func (s *Input) Validate() error

Validate inspects the fields of the type to determine if they are valid.

On this page: