Input class

When you configure the application input for a SQL-based Kinesis Data Analytics application, you specify the streaming source, the in-application stream name that is created, and the mapping between the two.

Constructors

Input.new({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 Data Firehose delivery stream, identifies the delivery stream's ARN.
final
kinesisStreamsInput → KinesisStreamsInput?
If the streaming source is an Amazon Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
final
namePrefix → String
The name prefix to use when creating an in-application stream. Suppose that you specify a prefix "MyInApplicationStream." Kinesis Data Analytics then creates one or more (as per the InputParallelism count you specified) in-application streams with the 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