Add Application Input

kinesisanalyticsv2_add_application_input

R Documentation

Adds a streaming source to your SQL-based Kinesis Data Analytics application

Description

Adds a streaming source to your SQL-based Kinesis Data Analytics application.

You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see create_application.

Any configuration update, including adding a streaming source using this operation, results in a new version of the application. You can use the describe_application operation to find the current application version.

Usage

kinesisanalyticsv2_add_application_input(ApplicationName,
  CurrentApplicationVersionId, Input)

Arguments

ApplicationName

[required] The name of your existing application to which you want to add the streaming source.

CurrentApplicationVersionId

[required] The current version of your application. You must provide the ApplicationVersionID or the ConditionalToken.You can use the describe_application operation to find the current application version.

Input

[required] The Input to add.

Value

A list with the following syntax:

list(
  ApplicationARN = "string",
  ApplicationVersionId = 123,
  InputDescriptions = list(
    list(
      InputId = "string",
      NamePrefix = "string",
      InAppStreamNames = list(
        "string"
      ),
      InputProcessingConfigurationDescription = list(
        InputLambdaProcessorDescription = list(
          ResourceARN = "string",
          RoleARN = "string"
        )
      ),
      KinesisStreamsInputDescription = list(
        ResourceARN = "string",
        RoleARN = "string"
      ),
      KinesisFirehoseInputDescription = list(
        ResourceARN = "string",
        RoleARN = "string"
      ),
      InputSchema = list(
        RecordFormat = list(
          RecordFormatType = "JSON"|"CSV",
          MappingParameters = list(
            JSONMappingParameters = list(
              RecordRowPath = "string"
            ),
            CSVMappingParameters = list(
              RecordRowDelimiter = "string",
              RecordColumnDelimiter = "string"
            )
          )
        ),
        RecordEncoding = "string",
        RecordColumns = list(
          list(
            Name = "string",
            Mapping = "string",
            SqlType = "string"
          )
        )
      ),
      InputParallelism = list(
        Count = 123
      ),
      InputStartingPositionConfiguration = list(
        InputStartingPosition = "NOW"|"TRIM_HORIZON"|"LAST_STOPPED_POINT"
      )
    )
  )
)

Request syntax

svc$add_application_input(
  ApplicationName = "string",
  CurrentApplicationVersionId = 123,
  Input = list(
    NamePrefix = "string",
    InputProcessingConfiguration = list(
      InputLambdaProcessor = list(
        ResourceARN = "string"
      )
    ),
    KinesisStreamsInput = list(
      ResourceARN = "string"
    ),
    KinesisFirehoseInput = list(
      ResourceARN = "string"
    ),
    InputParallelism = list(
      Count = 123
    ),
    InputSchema = list(
      RecordFormat = list(
        RecordFormatType = "JSON"|"CSV",
        MappingParameters = list(
          JSONMappingParameters = list(
            RecordRowPath = "string"
          ),
          CSVMappingParameters = list(
            RecordRowDelimiter = "string",
            RecordColumnDelimiter = "string"
          )
        )
      ),
      RecordEncoding = "string",
      RecordColumns = list(
        list(
          Name = "string",
          Mapping = "string",
          SqlType = "string"
        )
      )
    )
  )
)