Input class

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.

Constructors

Input({required SourceSchema inputSchema, required String namePrefix, InputParallelism? inputParallelism, InputProcessingConfiguration? inputProcessingConfiguration, KinesisFirehoseInput? kinesisFirehoseInput, KinesisStreamsInput? kinesisStreamsInput})

Properties

hashCode → int
The hash code for this object.
no setterinherited
inputParallelism → InputParallelism?
Describes the number of in-application streams to create.
final
inputProcessingConfiguration → InputProcessingConfiguration?
The InputProcessingConfiguration for the input. An input processor transforms records as they are received from the stream, before the application's SQL code executes. Currently, the only input processing configuration available is InputLambdaProcessor.
final
inputSchema → SourceSchema
Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
final
kinesisFirehoseInput → KinesisFirehoseInput?
If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
final
kinesisStreamsInput → KinesisStreamsInput?
If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf.
final
namePrefix → 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.
final
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toJson() → Map<String, dynamic>
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited