5.0.0 • Published 5 years ago

@datafire/amazonaws_kinesisanalyticsv2 v5.0.0

Weekly downloads
1
License
MIT
Repository
github
Last release
5 years ago

@datafire/amazonaws_kinesisanalyticsv2

Client library for Amazon Kinesis Analytics

Installation and Usage

npm install --save @datafire/amazonaws_kinesisanalyticsv2
let amazonaws_kinesisanalyticsv2 = require('@datafire/amazonaws_kinesisanalyticsv2').create({
  accessKeyId: "",
  secretAccessKey: "",
  region: ""
});

.then(data => {
  console.log(data);
});

Description

Amazon Kinesis Data Analytics is a fully managed service that you can use to process and analyze streaming data using Java, SQL, or Scala. The service enables you to quickly author and run Java, SQL, or Scala code against streaming sources to perform time series analytics, feed real-time dashboards, and create real-time metrics.

Actions

AddApplicationCloudWatchLoggingOption

amazonaws_kinesisanalyticsv2.AddApplicationCloudWatchLoggingOption({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "CloudWatchLoggingOption": null
}, context)

Input

  • input object
    • ApplicationName required
    • CloudWatchLoggingOption required
      • LogStreamARN required
    • CurrentApplicationVersionId required

Output

AddApplicationInput

amazonaws_kinesisanalyticsv2.AddApplicationInput({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "Input": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • Input required
      • InputParallelism
        • Count
      • InputProcessingConfiguration
        • InputLambdaProcessor required
          • ResourceARN required
      • InputSchema required
        • RecordColumns required
        • RecordEncoding
        • RecordFormat required
          • MappingParameters
            • CSVMappingParameters
            • JSONMappingParameters
          • RecordFormatType required
      • KinesisFirehoseInput
        • ResourceARN required
      • KinesisStreamsInput
        • ResourceARN required
      • NamePrefix required

Output

AddApplicationInputProcessingConfiguration

amazonaws_kinesisanalyticsv2.AddApplicationInputProcessingConfiguration({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "InputId": null,
  "InputProcessingConfiguration": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • InputId required
    • InputProcessingConfiguration required
      • InputLambdaProcessor required
        • ResourceARN required

Output

AddApplicationOutput

amazonaws_kinesisanalyticsv2.AddApplicationOutput({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "Output": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • Output required
      • DestinationSchema required
        • RecordFormatType required
      • KinesisFirehoseOutput
        • ResourceARN required
      • KinesisStreamsOutput
        • ResourceARN required
      • LambdaOutput
        • ResourceARN required
      • Name required

Output

AddApplicationReferenceDataSource

amazonaws_kinesisanalyticsv2.AddApplicationReferenceDataSource({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "ReferenceDataSource": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • ReferenceDataSource required
      • ReferenceSchema required
        • RecordColumns required
        • RecordEncoding
        • RecordFormat required
          • MappingParameters
            • CSVMappingParameters
            • JSONMappingParameters
          • RecordFormatType required
      • S3ReferenceDataSource
        • BucketARN
        • FileKey
      • TableName required

Output

AddApplicationVpcConfiguration

amazonaws_kinesisanalyticsv2.AddApplicationVpcConfiguration({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "VpcConfiguration": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • VpcConfiguration required

Output

CreateApplication

amazonaws_kinesisanalyticsv2.CreateApplication({
  "ApplicationName": null,
  "RuntimeEnvironment": null,
  "ServiceExecutionRole": null
}, context)

Input

  • input object
    • ApplicationConfiguration
      • ApplicationCodeConfiguration required
        • CodeContent
          • S3ContentLocation
            • BucketARN required
            • FileKey required
            • ObjectVersion
          • TextContent
          • ZipFileContent
        • CodeContentType required
      • ApplicationSnapshotConfiguration
        • SnapshotsEnabled required
      • EnvironmentProperties
      • FlinkApplicationConfiguration
        • CheckpointConfiguration
          • CheckpointInterval
          • CheckpointingEnabled
          • ConfigurationType required
          • MinPauseBetweenCheckpoints
        • MonitoringConfiguration
          • ConfigurationType required
          • LogLevel
          • MetricsLevel
        • ParallelismConfiguration
          • AutoScalingEnabled
          • ConfigurationType required
          • Parallelism
          • ParallelismPerKPU
      • SqlApplicationConfiguration
      • VpcConfigurations
    • ApplicationDescription
    • ApplicationName required
    • CloudWatchLoggingOptions
    • RuntimeEnvironment required
    • ServiceExecutionRole required
    • Tags

Output

CreateApplicationPresignedUrl

amazonaws_kinesisanalyticsv2.CreateApplicationPresignedUrl({
  "ApplicationName": null,
  "UrlType": null
}, context)

Input

  • input object
    • ApplicationName required
    • SessionExpirationDurationInSeconds
    • UrlType required

Output

CreateApplicationSnapshot

amazonaws_kinesisanalyticsv2.CreateApplicationSnapshot({
  "ApplicationName": null,
  "SnapshotName": null
}, context)

Input

  • input object
    • ApplicationName required
    • SnapshotName required

Output

DeleteApplication

amazonaws_kinesisanalyticsv2.DeleteApplication({
  "ApplicationName": null,
  "CreateTimestamp": null
}, context)

Input

  • input object
    • ApplicationName required
    • CreateTimestamp required

Output

DeleteApplicationCloudWatchLoggingOption

amazonaws_kinesisanalyticsv2.DeleteApplicationCloudWatchLoggingOption({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "CloudWatchLoggingOptionId": null
}, context)

Input

  • input object
    • ApplicationName required
    • CloudWatchLoggingOptionId required
    • CurrentApplicationVersionId required

Output

DeleteApplicationInputProcessingConfiguration

amazonaws_kinesisanalyticsv2.DeleteApplicationInputProcessingConfiguration({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "InputId": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • InputId required

Output

DeleteApplicationOutput

amazonaws_kinesisanalyticsv2.DeleteApplicationOutput({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "OutputId": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • OutputId required

Output

DeleteApplicationReferenceDataSource

amazonaws_kinesisanalyticsv2.DeleteApplicationReferenceDataSource({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "ReferenceId": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • ReferenceId required

Output

DeleteApplicationSnapshot

amazonaws_kinesisanalyticsv2.DeleteApplicationSnapshot({
  "ApplicationName": null,
  "SnapshotName": null,
  "SnapshotCreationTimestamp": null
}, context)

Input

  • input object
    • ApplicationName required
    • SnapshotCreationTimestamp required
    • SnapshotName required

Output

DeleteApplicationVpcConfiguration

amazonaws_kinesisanalyticsv2.DeleteApplicationVpcConfiguration({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null,
  "VpcConfigurationId": null
}, context)

Input

  • input object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • VpcConfigurationId required

Output

DescribeApplication

amazonaws_kinesisanalyticsv2.DescribeApplication({
  "ApplicationName": null
}, context)

Input

  • input object
    • ApplicationName required
    • IncludeAdditionalDetails

Output

DescribeApplicationSnapshot

amazonaws_kinesisanalyticsv2.DescribeApplicationSnapshot({
  "ApplicationName": null,
  "SnapshotName": null
}, context)

Input

  • input object
    • ApplicationName required
    • SnapshotName required

Output

DiscoverInputSchema

amazonaws_kinesisanalyticsv2.DiscoverInputSchema({
  "ServiceExecutionRole": null
}, context)

Input

  • input object
    • InputProcessingConfiguration
      • InputLambdaProcessor required
        • ResourceARN required
    • InputStartingPositionConfiguration
      • InputStartingPosition
    • ResourceARN
    • S3Configuration
      • BucketARN required
      • FileKey required
    • ServiceExecutionRole required

Output

ListApplicationSnapshots

amazonaws_kinesisanalyticsv2.ListApplicationSnapshots({
  "ApplicationName": null
}, context)

Input

  • input object
    • ApplicationName required
    • Limit
    • NextToken

Output

ListApplications

amazonaws_kinesisanalyticsv2.ListApplications({}, context)

Input

  • input object
    • Limit
    • NextToken

Output

ListTagsForResource

amazonaws_kinesisanalyticsv2.ListTagsForResource({
  "ResourceARN": null
}, context)

Input

  • input object
    • ResourceARN required

Output

StartApplication

amazonaws_kinesisanalyticsv2.StartApplication({
  "ApplicationName": null,
  "RunConfiguration": null
}, context)

Input

  • input object
    • ApplicationName required
    • RunConfiguration required
      • ApplicationRestoreConfiguration
        • ApplicationRestoreType required
        • SnapshotName
      • FlinkRunConfiguration
        • AllowNonRestoredState
      • SqlRunConfigurations

Output

StopApplication

amazonaws_kinesisanalyticsv2.StopApplication({
  "ApplicationName": null
}, context)

Input

  • input object
    • ApplicationName required
    • Force

Output

TagResource

amazonaws_kinesisanalyticsv2.TagResource({
  "ResourceARN": null,
  "Tags": null
}, context)

Input

  • input object
    • ResourceARN required
    • Tags required

Output

UntagResource

amazonaws_kinesisanalyticsv2.UntagResource({
  "ResourceARN": null,
  "TagKeys": null
}, context)

Input

  • input object
    • ResourceARN required
    • TagKeys required

Output

UpdateApplication

amazonaws_kinesisanalyticsv2.UpdateApplication({
  "ApplicationName": null,
  "CurrentApplicationVersionId": null
}, context)

Input

  • input object
    • ApplicationConfigurationUpdate
      • ApplicationCodeConfigurationUpdate
        • CodeContentTypeUpdate
        • CodeContentUpdate
          • S3ContentLocationUpdate
            • BucketARNUpdate
            • FileKeyUpdate
            • ObjectVersionUpdate
          • TextContentUpdate
          • ZipFileContentUpdate
      • ApplicationSnapshotConfigurationUpdate
        • SnapshotsEnabledUpdate required
      • EnvironmentPropertyUpdates
      • FlinkApplicationConfigurationUpdate
        • CheckpointConfigurationUpdate
          • CheckpointIntervalUpdate
          • CheckpointingEnabledUpdate
          • ConfigurationTypeUpdate
          • MinPauseBetweenCheckpointsUpdate
        • MonitoringConfigurationUpdate
          • ConfigurationTypeUpdate
          • LogLevelUpdate
          • MetricsLevelUpdate
        • ParallelismConfigurationUpdate
          • AutoScalingEnabledUpdate
          • ConfigurationTypeUpdate
          • ParallelismPerKPUUpdate
          • ParallelismUpdate
      • SqlApplicationConfigurationUpdate
      • VpcConfigurationUpdates
    • ApplicationName required
    • CloudWatchLoggingOptionUpdates
    • CurrentApplicationVersionId required
    • RunConfigurationUpdate
      • ApplicationRestoreConfiguration
        • ApplicationRestoreType required
        • SnapshotName
      • FlinkRunConfiguration
        • AllowNonRestoredState
    • ServiceExecutionRoleUpdate

Output

Definitions

AddApplicationCloudWatchLoggingOptionRequest

  • AddApplicationCloudWatchLoggingOptionRequest object
    • ApplicationName required
    • CloudWatchLoggingOption required
      • LogStreamARN required
    • CurrentApplicationVersionId required

AddApplicationCloudWatchLoggingOptionResponse

AddApplicationInputProcessingConfigurationRequest

  • AddApplicationInputProcessingConfigurationRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • InputId required
    • InputProcessingConfiguration required
      • InputLambdaProcessor required
        • ResourceARN required

AddApplicationInputProcessingConfigurationResponse

  • AddApplicationInputProcessingConfigurationResponse object
    • ApplicationARN
    • ApplicationVersionId
    • InputId
    • InputProcessingConfigurationDescription
      • InputLambdaProcessorDescription
        • ResourceARN required
        • RoleARN

AddApplicationInputRequest

  • AddApplicationInputRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • Input required
      • InputParallelism
        • Count
      • InputProcessingConfiguration
        • InputLambdaProcessor required
          • ResourceARN required
      • InputSchema required
        • RecordColumns required
        • RecordEncoding
        • RecordFormat required
          • MappingParameters
            • CSVMappingParameters
            • JSONMappingParameters
          • RecordFormatType required
      • KinesisFirehoseInput
        • ResourceARN required
      • KinesisStreamsInput
        • ResourceARN required
      • NamePrefix required

AddApplicationInputResponse

  • AddApplicationInputResponse object

AddApplicationOutputRequest

  • AddApplicationOutputRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • Output required
      • DestinationSchema required
        • RecordFormatType required
      • KinesisFirehoseOutput
        • ResourceARN required
      • KinesisStreamsOutput
        • ResourceARN required
      • LambdaOutput
        • ResourceARN required
      • Name required

AddApplicationOutputResponse

  • AddApplicationOutputResponse object

AddApplicationReferenceDataSourceRequest

  • AddApplicationReferenceDataSourceRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • ReferenceDataSource required
      • ReferenceSchema required
        • RecordColumns required
        • RecordEncoding
        • RecordFormat required
          • MappingParameters
            • CSVMappingParameters
            • JSONMappingParameters
          • RecordFormatType required
      • S3ReferenceDataSource
        • BucketARN
        • FileKey
      • TableName required

AddApplicationReferenceDataSourceResponse

AddApplicationVpcConfigurationRequest

  • AddApplicationVpcConfigurationRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • VpcConfiguration required

AddApplicationVpcConfigurationResponse

  • AddApplicationVpcConfigurationResponse object
    • ApplicationARN
    • ApplicationVersionId
    • VpcConfigurationDescription
      • SecurityGroupIds required
      • SubnetIds required
      • VpcConfigurationId required
      • VpcId required

ApplicationCodeConfiguration

  • ApplicationCodeConfiguration object: Describes code configuration for a Flink-based Kinesis Data Analytics application.
    • CodeContent
      • S3ContentLocation
        • BucketARN required
        • FileKey required
        • ObjectVersion
      • TextContent
      • ZipFileContent
    • CodeContentType required

ApplicationCodeConfigurationDescription

  • ApplicationCodeConfigurationDescription object: Describes code configuration for a Flink-based Kinesis Data Analytics application.
    • CodeContentDescription
      • CodeMD5
      • CodeSize
      • S3ApplicationCodeLocationDescription
        • BucketARN required
        • FileKey required
        • ObjectVersion
      • TextContent
    • CodeContentType required

ApplicationCodeConfigurationUpdate

  • ApplicationCodeConfigurationUpdate object: Describes code configuration updates to a Flink-based Kinesis Data Analytics application.
    • CodeContentTypeUpdate
    • CodeContentUpdate
      • S3ContentLocationUpdate
        • BucketARNUpdate
        • FileKeyUpdate
        • ObjectVersionUpdate
      • TextContentUpdate
      • ZipFileContentUpdate

ApplicationConfiguration

  • ApplicationConfiguration object: Specifies the creation parameters for a Kinesis Data Analytics application.
    • ApplicationCodeConfiguration required
      • CodeContent
        • S3ContentLocation
          • BucketARN required
          • FileKey required
          • ObjectVersion
        • TextContent
        • ZipFileContent
      • CodeContentType required
    • ApplicationSnapshotConfiguration
      • SnapshotsEnabled required
    • EnvironmentProperties
    • FlinkApplicationConfiguration
      • CheckpointConfiguration
        • CheckpointInterval
        • CheckpointingEnabled
        • ConfigurationType required
        • MinPauseBetweenCheckpoints
      • MonitoringConfiguration
        • ConfigurationType required
        • LogLevel
        • MetricsLevel
      • ParallelismConfiguration
        • AutoScalingEnabled
        • ConfigurationType required
        • Parallelism
        • ParallelismPerKPU
    • SqlApplicationConfiguration
    • VpcConfigurations

ApplicationConfigurationDescription

  • ApplicationConfigurationDescription object: Describes details about the application code and starting parameters for a Kinesis Data Analytics application.
    • ApplicationCodeConfigurationDescription
      • CodeContentDescription
        • CodeMD5
        • CodeSize
        • S3ApplicationCodeLocationDescription
          • BucketARN required
          • FileKey required
          • ObjectVersion
        • TextContent
      • CodeContentType required
    • ApplicationSnapshotConfigurationDescription
      • SnapshotsEnabled required
    • EnvironmentPropertyDescriptions
    • FlinkApplicationConfigurationDescription
      • CheckpointConfigurationDescription
        • CheckpointInterval
        • CheckpointingEnabled
        • ConfigurationType
        • MinPauseBetweenCheckpoints
      • JobPlanDescription
      • MonitoringConfigurationDescription
        • ConfigurationType
        • LogLevel
        • MetricsLevel
      • ParallelismConfigurationDescription
        • AutoScalingEnabled
        • ConfigurationType
        • CurrentParallelism
        • Parallelism
        • ParallelismPerKPU
    • RunConfigurationDescription
      • ApplicationRestoreConfigurationDescription
        • ApplicationRestoreType required
        • SnapshotName
      • FlinkRunConfigurationDescription FlinkRunConfiguration
    • SqlApplicationConfigurationDescription
    • VpcConfigurationDescriptions

ApplicationConfigurationUpdate

  • ApplicationConfigurationUpdate object: Describes updates to an application's configuration.
    • ApplicationCodeConfigurationUpdate
      • CodeContentTypeUpdate
      • CodeContentUpdate
        • S3ContentLocationUpdate
          • BucketARNUpdate
          • FileKeyUpdate
          • ObjectVersionUpdate
        • TextContentUpdate
        • ZipFileContentUpdate
    • ApplicationSnapshotConfigurationUpdate
      • SnapshotsEnabledUpdate required
    • EnvironmentPropertyUpdates
    • FlinkApplicationConfigurationUpdate
      • CheckpointConfigurationUpdate
        • CheckpointIntervalUpdate
        • CheckpointingEnabledUpdate
        • ConfigurationTypeUpdate
        • MinPauseBetweenCheckpointsUpdate
      • MonitoringConfigurationUpdate
        • ConfigurationTypeUpdate
        • LogLevelUpdate
        • MetricsLevelUpdate
      • ParallelismConfigurationUpdate
        • AutoScalingEnabledUpdate
        • ConfigurationTypeUpdate
        • ParallelismPerKPUUpdate
        • ParallelismUpdate
    • SqlApplicationConfigurationUpdate
    • VpcConfigurationUpdates

ApplicationDescription

  • ApplicationDescription string

ApplicationDetail

  • ApplicationDetail object: Describes the application, including the application Amazon Resource Name (ARN), status, latest version, and input and output configurations.
    • ApplicationARN required
    • ApplicationConfigurationDescription
      • ApplicationCodeConfigurationDescription
        • CodeContentDescription
          • CodeMD5
          • CodeSize
          • S3ApplicationCodeLocationDescription
            • BucketARN required
            • FileKey required
            • ObjectVersion
          • TextContent
        • CodeContentType required
      • ApplicationSnapshotConfigurationDescription
        • SnapshotsEnabled required
      • EnvironmentPropertyDescriptions
      • FlinkApplicationConfigurationDescription
        • CheckpointConfigurationDescription
          • CheckpointInterval
          • CheckpointingEnabled
          • ConfigurationType
          • MinPauseBetweenCheckpoints
        • JobPlanDescription
        • MonitoringConfigurationDescription
          • ConfigurationType
          • LogLevel
          • MetricsLevel
        • ParallelismConfigurationDescription
          • AutoScalingEnabled
          • ConfigurationType
          • CurrentParallelism
          • Parallelism
          • ParallelismPerKPU
      • RunConfigurationDescription
        • ApplicationRestoreConfigurationDescription
          • ApplicationRestoreType required
          • SnapshotName
        • FlinkRunConfigurationDescription FlinkRunConfiguration
      • SqlApplicationConfigurationDescription
      • VpcConfigurationDescriptions
    • ApplicationDescription
    • ApplicationName required
    • ApplicationStatus required
    • ApplicationVersionId required
    • CloudWatchLoggingOptionDescriptions
    • CreateTimestamp
    • LastUpdateTimestamp
    • RuntimeEnvironment required
    • ServiceExecutionRole

ApplicationName

  • ApplicationName string

ApplicationRestoreConfiguration

  • ApplicationRestoreConfiguration object: Specifies the method and snapshot to use when restarting an application using previously saved application state.
    • ApplicationRestoreType required
    • SnapshotName

ApplicationRestoreType

  • ApplicationRestoreType string (values: SKIP_RESTORE_FROM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, RESTORE_FROM_CUSTOM_SNAPSHOT)

ApplicationSnapshotConfiguration

  • ApplicationSnapshotConfiguration object: Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    • SnapshotsEnabled required

ApplicationSnapshotConfigurationDescription

  • ApplicationSnapshotConfigurationDescription object: Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    • SnapshotsEnabled required

ApplicationSnapshotConfigurationUpdate

  • ApplicationSnapshotConfigurationUpdate object: Describes updates to whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
    • SnapshotsEnabledUpdate required

ApplicationStatus

  • ApplicationStatus string (values: DELETING, STARTING, STOPPING, READY, RUNNING, UPDATING, AUTOSCALING, FORCE_STOPPING)

ApplicationSummaries

ApplicationSummary

  • ApplicationSummary object: Provides application summary information, including the application Amazon Resource Name (ARN), name, and status.
    • ApplicationARN required
    • ApplicationName required
    • ApplicationStatus required
    • ApplicationVersionId required
    • RuntimeEnvironment required

ApplicationVersionId

  • ApplicationVersionId integer

AuthorizedUrl

  • AuthorizedUrl string

BooleanObject

  • BooleanObject boolean

BucketARN

  • BucketARN string

CSVMappingParameters

  • CSVMappingParameters object: For a SQL-based Kinesis Data Analytics application, provides additional mapping information when the record format uses delimiters, such as CSV. For example, the following sample records use CSV format, where the records use the '\n' as the row delimiter and a comma (",") as the column delimiter: "name1", "address1" "name2", "address2"
    • RecordColumnDelimiter required
    • RecordRowDelimiter required

CheckpointConfiguration

  • CheckpointConfiguration object: Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.
    • CheckpointInterval
    • CheckpointingEnabled
    • ConfigurationType required
    • MinPauseBetweenCheckpoints

CheckpointConfigurationDescription

  • CheckpointConfigurationDescription object: Describes checkpointing parameters for a Flink-based Kinesis Data Analytics application.
    • CheckpointInterval
    • CheckpointingEnabled
    • ConfigurationType
    • MinPauseBetweenCheckpoints

CheckpointConfigurationUpdate

  • CheckpointConfigurationUpdate object: Describes updates to the checkpointing parameters for a Flink-based Kinesis Data Analytics application.
    • CheckpointIntervalUpdate
    • CheckpointingEnabledUpdate
    • ConfigurationTypeUpdate
    • MinPauseBetweenCheckpointsUpdate

CheckpointInterval

  • CheckpointInterval integer

CloudWatchLoggingOption

  • CloudWatchLoggingOption object: Provides a description of Amazon CloudWatch logging options, including the log stream Amazon Resource Name (ARN).
    • LogStreamARN required

CloudWatchLoggingOptionDescription

  • CloudWatchLoggingOptionDescription object: Describes the Amazon CloudWatch logging option.
    • CloudWatchLoggingOptionId
    • LogStreamARN required
    • RoleARN

CloudWatchLoggingOptionDescriptions

CloudWatchLoggingOptionUpdate

  • CloudWatchLoggingOptionUpdate object: Describes the Amazon CloudWatch logging option updates.
    • CloudWatchLoggingOptionId required
    • LogStreamARNUpdate

CloudWatchLoggingOptionUpdates

CloudWatchLoggingOptions

CodeContent

  • CodeContent object: Specifies either the application code, or the location of the application code, for a Flink-based Kinesis Data Analytics application.
    • S3ContentLocation
      • BucketARN required
      • FileKey required
      • ObjectVersion
    • TextContent
    • ZipFileContent

CodeContentDescription

  • CodeContentDescription object: Describes details about the application code for a Flink-based Kinesis Data Analytics application.
    • CodeMD5
    • CodeSize
    • S3ApplicationCodeLocationDescription
      • BucketARN required
      • FileKey required
      • ObjectVersion
    • TextContent

CodeContentType

  • CodeContentType string (values: PLAINTEXT, ZIPFILE)

CodeContentUpdate

  • CodeContentUpdate object: Describes an update to the code of a Flink-based Kinesis Data Analytics application.
    • S3ContentLocationUpdate
      • BucketARNUpdate
      • FileKeyUpdate
      • ObjectVersionUpdate
    • TextContentUpdate
    • ZipFileContentUpdate

CodeMD5

  • CodeMD5 string

CodeSize

  • CodeSize integer

CodeValidationException

ConcurrentModificationException

ConfigurationType

  • ConfigurationType string (values: DEFAULT, CUSTOM)

CreateApplicationPresignedUrlRequest

  • CreateApplicationPresignedUrlRequest object
    • ApplicationName required
    • SessionExpirationDurationInSeconds
    • UrlType required

CreateApplicationPresignedUrlResponse

  • CreateApplicationPresignedUrlResponse object
    • AuthorizedUrl

CreateApplicationRequest

  • CreateApplicationRequest object
    • ApplicationConfiguration
      • ApplicationCodeConfiguration required
        • CodeContent
          • S3ContentLocation
            • BucketARN required
            • FileKey required
            • ObjectVersion
          • TextContent
          • ZipFileContent
        • CodeContentType required
      • ApplicationSnapshotConfiguration
        • SnapshotsEnabled required
      • EnvironmentProperties
      • FlinkApplicationConfiguration
        • CheckpointConfiguration
          • CheckpointInterval
          • CheckpointingEnabled
          • ConfigurationType required
          • MinPauseBetweenCheckpoints
        • MonitoringConfiguration
          • ConfigurationType required
          • LogLevel
          • MetricsLevel
        • ParallelismConfiguration
          • AutoScalingEnabled
          • ConfigurationType required
          • Parallelism
          • ParallelismPerKPU
      • SqlApplicationConfiguration
      • VpcConfigurations
    • ApplicationDescription
    • ApplicationName required
    • CloudWatchLoggingOptions
    • RuntimeEnvironment required
    • ServiceExecutionRole required
    • Tags

CreateApplicationResponse

  • CreateApplicationResponse object
    • ApplicationDetail required
      • ApplicationARN required
      • ApplicationConfigurationDescription
        • ApplicationCodeConfigurationDescription
          • CodeContentDescription
            • CodeMD5
            • CodeSize
            • S3ApplicationCodeLocationDescription
            • TextContent
          • CodeContentType required
        • ApplicationSnapshotConfigurationDescription
          • SnapshotsEnabled required
        • EnvironmentPropertyDescriptions
        • FlinkApplicationConfigurationDescription
          • CheckpointConfigurationDescription
            • CheckpointInterval
            • CheckpointingEnabled
            • ConfigurationType
            • MinPauseBetweenCheckpoints
          • JobPlanDescription
          • MonitoringConfigurationDescription
            • ConfigurationType
            • LogLevel
            • MetricsLevel
          • ParallelismConfigurationDescription
            • AutoScalingEnabled
            • ConfigurationType
            • CurrentParallelism
            • Parallelism
            • ParallelismPerKPU
        • RunConfigurationDescription
          • ApplicationRestoreConfigurationDescription
            • ApplicationRestoreType required
            • SnapshotName
          • FlinkRunConfigurationDescription FlinkRunConfiguration
        • SqlApplicationConfigurationDescription
        • VpcConfigurationDescriptions
      • ApplicationDescription
      • ApplicationName required
      • ApplicationStatus required
      • ApplicationVersionId required
      • CloudWatchLoggingOptionDescriptions
      • CreateTimestamp
      • LastUpdateTimestamp
      • RuntimeEnvironment required
      • ServiceExecutionRole

CreateApplicationSnapshotRequest

  • CreateApplicationSnapshotRequest object
    • ApplicationName required
    • SnapshotName required

CreateApplicationSnapshotResponse

  • CreateApplicationSnapshotResponse object

DeleteApplicationCloudWatchLoggingOptionRequest

  • DeleteApplicationCloudWatchLoggingOptionRequest object
    • ApplicationName required
    • CloudWatchLoggingOptionId required
    • CurrentApplicationVersionId required

DeleteApplicationCloudWatchLoggingOptionResponse

DeleteApplicationInputProcessingConfigurationRequest

  • DeleteApplicationInputProcessingConfigurationRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • InputId required

DeleteApplicationInputProcessingConfigurationResponse

  • DeleteApplicationInputProcessingConfigurationResponse object
    • ApplicationARN
    • ApplicationVersionId

DeleteApplicationOutputRequest

  • DeleteApplicationOutputRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • OutputId required

DeleteApplicationOutputResponse

  • DeleteApplicationOutputResponse object
    • ApplicationARN
    • ApplicationVersionId

DeleteApplicationReferenceDataSourceRequest

  • DeleteApplicationReferenceDataSourceRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • ReferenceId required

DeleteApplicationReferenceDataSourceResponse

  • DeleteApplicationReferenceDataSourceResponse object
    • ApplicationARN
    • ApplicationVersionId

DeleteApplicationRequest

  • DeleteApplicationRequest object
    • ApplicationName required
    • CreateTimestamp required

DeleteApplicationResponse

  • DeleteApplicationResponse object

DeleteApplicationSnapshotRequest

  • DeleteApplicationSnapshotRequest object
    • ApplicationName required
    • SnapshotCreationTimestamp required
    • SnapshotName required

DeleteApplicationSnapshotResponse

  • DeleteApplicationSnapshotResponse object

DeleteApplicationVpcConfigurationRequest

  • DeleteApplicationVpcConfigurationRequest object
    • ApplicationName required
    • CurrentApplicationVersionId required
    • VpcConfigurationId required

DeleteApplicationVpcConfigurationResponse

  • DeleteApplicationVpcConfigurationResponse object
    • ApplicationARN
    • ApplicationVersionId

DescribeApplicationRequest

  • DescribeApplicationRequest object
    • ApplicationName required
    • IncludeAdditionalDetails

DescribeApplicationResponse

  • DescribeApplicationResponse object
    • ApplicationDetail required
      • ApplicationARN required
      • ApplicationConfigurationDescription
        • ApplicationCodeConfigurationDescription
          • CodeContentDescription
            • CodeMD5
            • CodeSize
            • S3ApplicationCodeLocationDescription
            • TextContent
          • CodeContentType required
        • ApplicationSnapshotConfigurationDescription
          • SnapshotsEnabled required
        • EnvironmentPropertyDescriptions
        • FlinkApplicationConfigurationDescription
          • CheckpointConfigurationDescription
            • CheckpointInterval
            • CheckpointingEnabled
            • ConfigurationType
            • MinPauseBetweenCheckpoints
          • JobPlanDescription
          • MonitoringConfigurationDescription
            • ConfigurationType
            • LogLevel
            • MetricsLevel
          • ParallelismConfigurationDescription
            • AutoScalingEnabled
            • ConfigurationType
            • CurrentParallelism
            • Parallelism
            • ParallelismPerKPU
        • RunConfigurationDescription
          • ApplicationRestoreConfigurationDescription
            • ApplicationRestoreType required
            • SnapshotName
          • FlinkRunConfigurationDescription FlinkRunConfiguration
        • SqlApplicationConfigurationDescription
        • VpcConfigurationDescriptions
      • ApplicationDescription
      • ApplicationName required
      • ApplicationStatus required
      • ApplicationVersionId required
      • CloudWatchLoggingOptionDescriptions
      • CreateTimestamp
      • LastUpdateTimestamp
      • RuntimeEnvironment required
      • ServiceExecutionRole

DescribeApplicationSnapshotRequest

  • DescribeApplicationSnapshotRequest object
    • ApplicationName required
    • SnapshotName required

DescribeApplicationSnapshotResponse

  • DescribeApplicationSnapshotResponse object
    • SnapshotDetails required
      • ApplicationVersionId required
      • SnapshotCreationTimestamp
      • SnapshotName required
      • SnapshotStatus required

DestinationSchema

  • DestinationSchema object: Describes the data format when records are written to the destination in a SQL-based Kinesis Data Analytics application.
    • RecordFormatType required

DiscoverInputSchemaRequest

  • DiscoverInputSchemaRequest object
    • InputProcessingConfiguration
      • InputLambdaProcessor required
        • ResourceARN required
    • InputStartingPositionConfiguration
      • InputStartingPosition
    • ResourceARN
    • S3Configuration
      • BucketARN required
      • FileKey required
    • ServiceExecutionRole required

DiscoverInputSchemaResponse

  • DiscoverInputSchemaResponse object
    • InputSchema
      • RecordColumns required
      • RecordEncoding
      • RecordFormat required
        • MappingParameters
          • CSVMappingParameters
            • RecordColumnDelimiter required
            • RecordRowDelimiter required
          • JSONMappingParameters
            • RecordRowPath required
        • RecordFormatType required
    • ParsedInputRecords
    • ProcessedInputRecords
    • RawInputRecords

EnvironmentProperties

  • EnvironmentProperties object: Describes execution properties for a Flink-based Kinesis Data Analytics application.

EnvironmentPropertyDescriptions

  • EnvironmentPropertyDescriptions object: Describes the execution properties for a Flink-based Kinesis Data Analytics application.

EnvironmentPropertyUpdates

  • EnvironmentPropertyUpdates object: Describes updates to the execution property groups for a Flink-based Kinesis Data Analytics application.

FileKey

  • FileKey string

FlinkApplicationConfiguration

  • FlinkApplicationConfiguration object: Describes configuration parameters for a Flink-based Kinesis Data Analytics application.
    • CheckpointConfiguration
      • CheckpointInterval
      • CheckpointingEnabled
      • ConfigurationType required
      • MinPauseBetweenCheckpoints
    • MonitoringConfiguration
      • ConfigurationType required
      • LogLevel
      • MetricsLevel
    • ParallelismConfiguration
      • AutoScalingEnabled
      • ConfigurationType required
      • Parallelism
      • ParallelismPerKPU

FlinkApplicationConfigurationDescription

  • FlinkApplicationConfigurationDescription object: Describes configuration parameters for a Flink-based Kinesis Data Analytics application.
    • CheckpointConfigurationDescription
      • CheckpointInterval
      • CheckpointingEnabled
      • ConfigurationType
      • MinPauseBetweenCheckpoints
    • JobPlanDescription
    • MonitoringConfigurationDescription
      • ConfigurationType
      • LogLevel
      • MetricsLevel
    • ParallelismConfigurationDescription
      • AutoScalingEnabled
      • ConfigurationType
      • CurrentParallelism
      • Parallelism
      • ParallelismPerKPU

FlinkApplicationConfigurationUpdate

  • FlinkApplicationConfigurationUpdate object: Describes updates to the configuration parameters for a Flink-based Kinesis Data Analytics application.
    • CheckpointConfigurationUpdate
      • CheckpointIntervalUpdate
      • CheckpointingEnabledUpdate
      • ConfigurationTypeUpdate
      • MinPauseBetweenCheckpointsUpdate
    • MonitoringConfigurationUpdate
      • ConfigurationTypeUpdate
      • LogLevelUpdate
      • MetricsLevelUpdate
    • ParallelismConfigurationUpdate
      • AutoScalingEnabledUpdate
      • ConfigurationTypeUpdate
      • ParallelismPerKPUUpdate
      • ParallelismUpdate

FlinkRunConfiguration

  • FlinkRunConfiguration object: Describes the starting parameters for a Flink-based Kinesis Data Analytics application.
    • AllowNonRestoredState

Id

  • Id string

InAppStreamName

  • InAppStreamName string

InAppStreamNames

InAppTableName

  • InAppTableName string

Input

  • Input object: 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.
    • InputParallelism
      • Count
    • InputProcessingConfiguration
      • InputLambdaProcessor required
        • ResourceARN required
    • InputSchema required
      • RecordColumns required
      • RecordEncoding
      • RecordFormat required
        • MappingParameters
          • CSVMappingParameters
            • RecordColumnDelimiter required
            • RecordRowDelimiter required
          • JSONMappingParameters
            • RecordRowPath required
        • RecordFormatType required
    • KinesisFirehoseInput
      • ResourceARN required
    • KinesisStreamsInput
      • ResourceARN required
    • NamePrefix required

InputDescription

  • InputDescription object: Describes the application input configuration for a SQL-based Kinesis Data Analytics application.
    • InAppStreamNames
    • InputId
    • InputParallelism
      • Count
    • InputProcessingConfigurationDescription
      • InputLambdaProcessorDescription
        • ResourceARN required
        • RoleARN
    • InputSchema
      • RecordColumns required
      • RecordEncoding
      • RecordFormat required
        • MappingParameters
          • CSVMappingParameters
            • RecordColumnDelimiter required
            • RecordRowDelimiter required
          • JSONMappingParameters
            • RecordRowPath required
        • RecordFormatType required
    • InputStartingPositionConfiguration
      • InputStartingPosition
    • KinesisFirehoseInputDescription
      • ResourceARN required
      • RoleARN
    • KinesisStreamsInputDescription
      • ResourceARN required
      • RoleARN
    • NamePrefix

InputDescriptions

InputLambdaProcessor

  • InputLambdaProcessor object: An object that contains the Amazon Resource Name (ARN) of the AWS Lambda function that is used to preprocess records in the stream in a SQL-based Kinesis Data Analytics application.
    • ResourceARN required

InputLambdaProcessorDescription

  • InputLambdaProcessorDescription object: For a SQL-based Kinesis Data Analytics application, an object that contains the Amazon Resource Name (ARN) of the AWS Lambda function that is used to preprocess records in the stream.
    • ResourceARN required
    • RoleARN

InputLambdaProcessorUpdate

  • InputLambdaProcessorUpdate object: For a SQL-based Kinesis Data Analytics application, represents an update to the InputLambdaProcessor that is used to preprocess the records in the stream.
    • ResourceARNUpdate required

InputParallelism

  • InputParallelism object: For a SQL-based Kinesis Data Analytics application, describes the number of in-application streams to create for a given streaming source.
    • Count

InputParallelismCount

  • InputParallelismCount integer

InputParallelismUpdate

  • InputParallelismUpdate object: For a SQL-based Kinesis Data Analytics application, provides updates to the parallelism count.
    • CountUpdate required

InputProcessingConfiguration

  • InputProcessingConfiguration object: For a SQL-based Kinesis Data Analytics application, describes 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.
    • InputLambdaProcessor required
      • ResourceARN required

InputProcessingConfigurationDescription

  • InputProcessingConfigurationDescription object: For a SQL-based Kinesis Data Analytics application, provides the configuration information about an input processor. Currently, the only input processor available is AWS Lambda.
    • InputLambdaProcessorDescription
      • ResourceARN required
      • RoleARN

InputProcessingConfigurationUpdate

  • InputProcessingConfigurationUpdate object: For a SQL-based Kinesis Data Analytics application, describes updates to an InputProcessingConfiguration.
    • InputLambdaProcessorUpdate required
      • ResourceARNUpdate required

InputSchemaUpdate

  • InputSchemaUpdate object: Describes updates for an SQL-based Kinesis Data Analytics application's input schema.
    • RecordColumnUpdates
    • RecordEncodingUpdate
    • RecordFormatUpdate
      • MappingParameters
        • CSVMappingParameters
          • RecordColumnDelimiter required
          • RecordRowDelimiter required
        • JSONMappingParameters
          • RecordRowPath required
      • RecordFormatType required

InputStartingPosition

  • InputStartingPosition string (values: NOW, TRIM_HORIZON, LAST_STOPPED_POINT)

InputStartingPositionConfiguration

  • InputStartingPositionConfiguration object: Describes the point at which the application reads from the streaming source.
    • InputStartingPosition

InputUpdate

  • InputUpdate object: For a SQL-based Kinesis Data Analytics application, describes updates to a specific input configuration (identified by the InputId of an application).
    • InputId required
    • InputParallelismUpdate
      • CountUpdate required
    • InputProcessingConfigurationUpdate
      • InputLambdaProcessorUpdate required
        • ResourceARNUpdate required
    • InputSchemaUpdate
      • RecordColumnUpdates
      • RecordEncodingUpdate
      • RecordFormatUpdate
        • MappingParameters
          • CSVMappingParameters
            • RecordColumnDelimiter required
            • RecordRowDelimiter required
          • JSONMappingParameters
            • RecordRowPath required
        • RecordFormatType required
    • KinesisFirehoseInputUpdate
      • ResourceARNUpdate required
    • KinesisStreamsInputUpdate
      • ResourceARNUpdate required
    • NamePrefixUpdate

InputUpdates

Inputs

InvalidApplicationConfigurationException

InvalidArgumentException

InvalidRequestException

JSONMappingParameters

  • JSONMappingParameters object: For a SQL-based Kinesis Data Analytics application, provides additional mapping information when JSON is the record format on the streaming source.
    • RecordRowPath required

JobPlanDescription

  • JobPlanDescription string

KinesisAnalyticsARN

  • KinesisAnalyticsARN string

KinesisFirehoseInput

  • KinesisFirehoseInput object: For a SQL-based Kinesis Data Analytics application, identifies a Kinesis Data Firehose delivery stream as the streaming source. You provide the delivery stream's Amazon Resource Name (ARN).
    • ResourceARN required

KinesisFirehoseInputDescription

  • KinesisFirehoseInputDescription object: Describes the Amazon Kinesis Data Firehose delivery stream that is configured as the streaming source in the application input configuration.
    • ResourceARN required
    • RoleARN

KinesisFirehoseInputUpdate

  • KinesisFirehoseInputUpdate object: For a SQL-based Kinesis Data Analytics application, when updating application input configuration, provides information about a Kinesis Data Firehose delivery stream as the streaming source.
    • ResourceARNUpdate required

KinesisFirehoseOutput

  • KinesisFirehoseOutput object: For a SQL-based Kinesis Data Analytics application, when configuring application output, identifies a Kinesis Data Firehose delivery stream as the destination. You provide the stream Amazon Resource Name (ARN) of the delivery stream.
    • ResourceARN required

KinesisFirehoseOutputDescription

  • KinesisFirehoseOutputDescription object: For a SQL-based Kinesis Data Analytics application's output, describes the Kinesis Data Firehose delivery stream that is configured as its destination.
    • ResourceARN required
    • RoleARN

KinesisFirehoseOutputUpdate

  • KinesisFirehoseOutputUpdate object: For a SQL-based Kinesis Data Analytics application, when updating an output configuration using the UpdateApplication operation, provides information about a Kinesis Data Firehose delivery stream that is configured as the destination.
    • ResourceARNUpdate required

KinesisStreamsInput

  • KinesisStreamsInput object: Identifies a Kinesis data stream as the streaming source. You provide the stream's Amazon Resource Name (ARN).
    • ResourceARN required

KinesisStreamsInputDescription

  • KinesisStreamsInputDescription object: For a SQL-based Kinesis Data Analytics application, describes the Kinesis data stream that is configured as the streaming source in the application input configuration.
    • ResourceARN required
    • RoleARN

KinesisStreamsInputUpdate

  • KinesisStreamsInputUpdate object: When you update the input configuration for a SQL-based Kinesis Data Analytics application, provides information about a Kinesis stream as the streaming source.
    • ResourceARNUpdate required

KinesisStreamsOutput

  • KinesisStreamsOutput object: When you configure a SQL-based Kinesis Data Analytics application's output, identifies a Kinesis data stream as the destination. You provide the stream Amazon Resource Name (ARN).
    • ResourceARN required

KinesisStreamsOutputDescription

  • KinesisStreamsOutputDescription object: For an SQL-based Kinesis Data Analytics application's output, describes the Kinesis data stream that is configured as its destination.
    • ResourceARN required
    • RoleARN

KinesisStreamsOutputUpdate

  • KinesisStreamsOutputUpdate object: When you update a SQL-based Kinesis Data Analytics application's output configuration using the UpdateApplication operation, provides information about a Kinesis data stream that is configured as the destination.
    • ResourceARNUpdate required

LambdaOutput

  • LambdaOutput object: When you configure a SQL-based Kinesis Data Analytics application's output, identifies an AWS Lambda function as the destination. You provide the function Amazon Resource Name (ARN) of the Lambda function.
    • ResourceARN required

LambdaOutputDescription

  • LambdaOutputDescription object: For a SQL-based Kinesis Data Analytics application's output, describes the AWS Lambda function that is configured as its destination.
    • ResourceARN required
    • RoleARN

LambdaOutputUpdate

  • LambdaOutputUpdate object: When you update an SQL-based Kinesis Data Analytics application's output configuration using the UpdateApplication operation, provides information about an AWS Lambda function that is configured as the destination.
    • ResourceARNUpdate required

LimitExceededException

ListApplicationSnapshotsRequest

  • ListApplicationSnapshotsRequest object
    • ApplicationName required
    • Limit
    • NextToken

ListApplicationSnapshotsResponse

  • ListApplicationSnapshotsResponse object

ListApplicationsInputLimit

  • ListApplicationsInputLimit integer

ListApplicationsRequest

  • ListApplicationsRequest object
    • Limit
    • NextToken

ListApplicationsResponse

  • ListApplicationsResponse object

ListSnapshotsInputLimit

  • ListSnapshotsInputLimit integer

ListTagsForResourceRequest

  • ListTagsForResourceRequest object
    • ResourceARN required

ListTagsForResourceResponse

  • ListTagsForResourceResponse object

LogLevel

  • LogLevel string (values: INFO, WARN, ERROR, DEBUG)

LogStreamARN

  • LogStreamARN string

MappingParameters

  • MappingParameters object: When you configure a SQL-based Kinesis Data Analytics application's input at the time of creating or updating an application, provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
    • CSVMappingParameters
      • RecordColumnDelimiter required
      • RecordRowDelimiter required
    • JSONMappingParameters
      • RecordRowPath required

MetricsLevel

  • MetricsLevel string (values: APPLICATION, TASK, OPERATOR, PARALLELISM)

MinPauseBetweenCheckpoints

  • MinPauseBetweenCheckpoints integer

MonitoringConfiguration

  • MonitoringConfiguration object: Describes configuration parameters for Amazon CloudWatch logging for a Flink-based Kinesis Data Analytics application. For more information about CloudWatch logging, see Monitoring.
    • ConfigurationType required
    • LogLevel
    • MetricsLevel

MonitoringConfigurationDescription

  • MonitoringConfigurationDescription object: Describes configuration parameters for CloudWatch logging for a Flink-based Kinesis Data Analytics application.
    • ConfigurationType
    • LogLevel
    • MetricsLevel

MonitoringConfigurationUpdate

  • MonitoringConfigurationUpdate object: Describes updates to configuration parameters for Amazon CloudWatch logging for a Flink-based Kinesis Data Analytics application.
    • ConfigurationTypeUpdate
    • LogLevelUpdate
    • MetricsLevelUpdate

NextToken

  • NextToken string

ObjectVersion

  • ObjectVersion string

Output

  • Output object: Describes a SQL-based Kinesis Data Analytics application's output configuration, in which you identify an in-application stream and a destination where you want the in-application stream data to be written. The destination can be a Kinesis data stream or a Kinesis Data Firehose delivery stream.
    • DestinationSchema required
      • RecordFormatType required
    • KinesisFirehoseOutput
      • ResourceARN required
    • KinesisStreamsOutput
      • ResourceARN required
    • LambdaOutput
      • ResourceARN required
    • Name required

OutputDescription

  • OutputDescription object: For a SQL-based Kinesis Data Analytics application, describes the application output configuration, which includes the in-application stream name and the destination where the stream data is written. The destination can be a Kinesis data stream or a Kinesis Data Firehose delivery stream.
    • DestinationSchema
      • RecordFormatType required
    • KinesisFirehoseOutputDescription
      • ResourceARN required
      • RoleARN
    • KinesisStreamsOutputDescription
      • ResourceARN required
      • RoleARN
    • LambdaOutputDescription
      • ResourceARN required
      • RoleARN
    • Name
    • OutputId

OutputDescriptions

OutputUpdate

  • OutputUpdate object: For a SQL-based Kinesis Data Analytics application, describes updates to the output configuration identified by the OutputId.
    • DestinationSchemaUpdate
      • RecordFormatType required
    • KinesisFirehoseOutputUpdate
      • ResourceARNUpdate required
    • KinesisStreamsOutputUpdate
      • ResourceARNUpdate required
    • LambdaOutputUpdate
      • ResourceARNUpdate required
    • NameUpdate
    • OutputId required

OutputUpdates

Outputs

Parallelism

  • Parallelism integer

ParallelismConfiguration

  • ParallelismConfiguration object: Describes parameters for how a Flink-based Kinesis Data Analytics application application executes multiple tasks simultaneously. For more information about parallelism, see Parallel Execution in the Apache Flink Documentation.
    • AutoScalingEnabled
    • ConfigurationType required
    • Parallelism
    • ParallelismPerKPU

ParallelismConfigurationDescription

  • ParallelismConfigurationDescription object: Describes parameters for how a Flink-based Kinesis Data Analytics application executes multiple tasks simultaneously.
    • AutoScalingEnabled
    • ConfigurationType
    • CurrentParallelism
    • Parallelism
    • ParallelismPerKPU

ParallelismConfigurationUpdate

  • ParallelismConfigurationUpdate object: Describes updates to parameters for how
datafireaws-sdk
@infinitebrahmanuniverse/nolb-_datafire_am@everything-registry/sub-chunk-220
5.0.0

5 years ago