Package com.pulumi.aws.kinesisanalyticsv2

Class Application

  • public class Application
extends com.pulumi.resources.CustomResource
    Manages a Kinesis Analytics v2 Application. This resource can be used to manage both Kinesis Data Analytics for SQL applications and Kinesis Data Analytics for Apache Flink applications. > **Note:** Kinesis Data Analytics for SQL applications created using this resource cannot currently be viewed in the AWS Console. To manage Kinesis Data Analytics for SQL applications that can also be viewed in the AWS Console, use the `aws.kinesis.AnalyticsApplication` resource. ## Example Usage ### Apache Flink Application 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.s3.Bucket;
 import com.pulumi.aws.s3.BucketArgs;
 import com.pulumi.aws.s3.BucketObjectv2;
 import com.pulumi.aws.s3.BucketObjectv2Args;
 import com.pulumi.aws.kinesisanalyticsv2.Application;
 import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationEnvironmentPropertiesArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs;
 import com.pulumi.asset.FileAsset;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new Bucket("example", BucketArgs.builder()
             .bucket("example-flink-application")
             .build());
 
         var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()
             .bucket(example.id())
             .key("example-flink-application")
             .source(new FileAsset("flink-app.jar"))
             .build());
 
         var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
             .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                 .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                     .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                         .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                             .bucketArn(example.arn())
                             .fileKey(exampleBucketObjectv2.key())
                             .build())
                         .build())
                     .codeContentType("ZIPFILE")
                     .build())
                 .environmentProperties(ApplicationApplicationConfigurationEnvironmentPropertiesArgs.builder()
                     .propertyGroups(                    
                         ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
                             .propertyGroupId("PROPERTY-GROUP-1")
                             .propertyMap(Map.of("Key1", "Value1"))
                             .build(),
                         ApplicationApplicationConfigurationEnvironmentPropertiesPropertyGroupArgs.builder()
                             .propertyGroupId("PROPERTY-GROUP-2")
                             .propertyMap(Map.ofEntries(
                                 Map.entry("KeyA", "ValueA"),
                                 Map.entry("KeyB", "ValueB")
                             ))
                             .build())
                     .build())
                 .flinkApplicationConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationArgs.builder()
                     .checkpointConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationCheckpointConfigurationArgs.builder()
                         .configurationType("DEFAULT")
                         .build())
                     .monitoringConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationMonitoringConfigurationArgs.builder()
                         .configurationType("CUSTOM")
                         .logLevel("DEBUG")
                         .metricsLevel("TASK")
                         .build())
                     .parallelismConfiguration(ApplicationApplicationConfigurationFlinkApplicationConfigurationParallelismConfigurationArgs.builder()
                         .autoScalingEnabled(true)
                         .configurationType("CUSTOM")
                         .parallelism(10)
                         .parallelismPerKpu(4)
                         .build())
                     .build())
                 .build())
             .name("example-flink-application")
             .runtimeEnvironment("FLINK-1_8")
             .serviceExecutionRole(exampleAwsIamRole.arn())
             .tags(Map.of("Environment", "test"))
             .build());
 
     }
 }
    ### SQL Application 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.cloudwatch.LogGroup;
 import com.pulumi.aws.cloudwatch.LogGroupArgs;
 import com.pulumi.aws.cloudwatch.LogStream;
 import com.pulumi.aws.cloudwatch.LogStreamArgs;
 import com.pulumi.aws.kinesisanalyticsv2.Application;
 import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationCloudwatchLoggingOptionsArgs;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new LogGroup("example", LogGroupArgs.builder()
             .name("example-sql-application")
             .build());
 
         var exampleLogStream = new LogStream("exampleLogStream", LogStreamArgs.builder()
             .name("example-sql-application")
             .logGroupName(example.name())
             .build());
 
         var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
             .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                 .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                     .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                         .textContent("""
 SELECT 1;
                         """)
                         .build())
                     .codeContentType("PLAINTEXT")
                     .build())
                 .sqlApplicationConfiguration(ApplicationApplicationConfigurationSqlApplicationConfigurationArgs.builder()
                     .input(ApplicationApplicationConfigurationSqlApplicationConfigurationInputArgs.builder()
                         .inputParallelism(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputParallelismArgs.builder()
                             .count(3)
                             .build())
                         .inputSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaArgs.builder()
                             .recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatArgs.builder()
                                 .mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersArgs.builder()
                                     .csvMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordFormatMappingParametersCsvMappingParametersArgs.builder()
                                         .recordColumnDelimiter(",")
                                         .recordRowDelimiter("""
 
                                         """)
                                         .build())
                                     .build())
                                 .recordFormatType("CSV")
                                 .build())
                             .recordColumns(                            
                                 ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
                                     .name("COLUMN_1")
                                     .sqlType("VARCHAR(8)")
                                     .mapping("MAPPING-1")
                                     .build(),
                                 ApplicationApplicationConfigurationSqlApplicationConfigurationInputInputSchemaRecordColumnArgs.builder()
                                     .name("COLUMN_2")
                                     .sqlType("DOUBLE")
                                     .build())
                             .recordEncoding("UTF-8")
                             .build())
                         .kinesisStreamsInput(ApplicationApplicationConfigurationSqlApplicationConfigurationInputKinesisStreamsInputArgs.builder()
                             .resourceArn(exampleAwsKinesisStream.arn())
                             .build())
                         .namePrefix("PREFIX_1")
                         .build())
                     .referenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceArgs.builder()
                         .referenceSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaArgs.builder()
                             .recordFormat(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatArgs.builder()
                                 .mappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersArgs.builder()
                                     .jsonMappingParameters(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordFormatMappingParametersJsonMappingParametersArgs.builder()
                                         .recordRowPath("$")
                                         .build())
                                     .build())
                                 .recordFormatType("JSON")
                                 .build())
                             .recordColumns(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceReferenceSchemaRecordColumnArgs.builder()
                                 .name("COLUMN_1")
                                 .sqlType("INTEGER")
                                 .build())
                             .build())
                         .s3ReferenceDataSource(ApplicationApplicationConfigurationSqlApplicationConfigurationReferenceDataSourceS3ReferenceDataSourceArgs.builder()
                             .bucketArn(exampleAwsS3Bucket.arn())
                             .fileKey("KEY-1")
                             .build())
                         .tableName("TABLE-1")
                         .build())
                     .outputs(                    
                         ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                             .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                                 .recordFormatType("JSON")
                                 .build())
                             .lambdaOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputLambdaOutputArgs.builder()
                                 .resourceArn(exampleAwsLambdaFunction.arn())
                                 .build())
                             .name("OUTPUT_1")
                             .build(),
                         ApplicationApplicationConfigurationSqlApplicationConfigurationOutputArgs.builder()
                             .destinationSchema(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputDestinationSchemaArgs.builder()
                                 .recordFormatType("CSV")
                                 .build())
                             .kinesisFirehoseOutput(ApplicationApplicationConfigurationSqlApplicationConfigurationOutputKinesisFirehoseOutputArgs.builder()
                                 .resourceArn(exampleAwsKinesisFirehoseDeliveryStream.arn())
                                 .build())
                             .name("OUTPUT_2")
                             .build())
                     .build())
                 .build())
             .cloudwatchLoggingOptions(ApplicationCloudwatchLoggingOptionsArgs.builder()
                 .logStreamArn(exampleLogStream.arn())
                 .build())
             .name("example-sql-application")
             .runtimeEnvironment("SQL-1_0")
             .serviceExecutionRole(exampleAwsIamRole.arn())
             .build());
 
     }
 }
    ### VPC Configuration 
     
 package generated_program;
 
 import com.pulumi.Context;
 import com.pulumi.Pulumi;
 import com.pulumi.core.Output;
 import com.pulumi.aws.s3.Bucket;
 import com.pulumi.aws.s3.BucketArgs;
 import com.pulumi.aws.s3.BucketObjectv2;
 import com.pulumi.aws.s3.BucketObjectv2Args;
 import com.pulumi.aws.kinesisanalyticsv2.Application;
 import com.pulumi.aws.kinesisanalyticsv2.ApplicationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs;
 import com.pulumi.aws.kinesisanalyticsv2.inputs.ApplicationApplicationConfigurationVpcConfigurationArgs;
 import com.pulumi.asset.FileAsset;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Map;
 import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 
 public class App {
     public static void main(String[] args) {
         Pulumi.run(App::stack);
     }
 
     public static void stack(Context ctx) {
         var example = new Bucket("example", BucketArgs.builder()
             .bucket("example-flink-application")
             .build());
 
         var exampleBucketObjectv2 = new BucketObjectv2("exampleBucketObjectv2", BucketObjectv2Args.builder()
             .bucket(example.id())
             .key("example-flink-application")
             .source(new FileAsset("flink-app.jar"))
             .build());
 
         var exampleApplication = new Application("exampleApplication", ApplicationArgs.builder()
             .applicationConfiguration(ApplicationApplicationConfigurationArgs.builder()
                 .applicationCodeConfiguration(ApplicationApplicationConfigurationApplicationCodeConfigurationArgs.builder()
                     .codeContent(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentArgs.builder()
                         .s3ContentLocation(ApplicationApplicationConfigurationApplicationCodeConfigurationCodeContentS3ContentLocationArgs.builder()
                             .bucketArn(example.arn())
                             .fileKey(exampleBucketObjectv2.key())
                             .build())
                         .build())
                     .codeContentType("ZIPFILE")
                     .build())
                 .vpcConfiguration(ApplicationApplicationConfigurationVpcConfigurationArgs.builder()
                     .securityGroupIds(                    
                         exampleAwsSecurityGroup[0].id(),
                         exampleAwsSecurityGroup[1].id())
                     .subnetIds(exampleAwsSubnet.id())
                     .build())
                 .build())
             .name("example-flink-application")
             .runtimeEnvironment("FLINK-1_8")
             .serviceExecutionRole(exampleAwsIamRole.arn())
             .build());
 
     }
 }
    ## Import Using `pulumi import`, import `aws.kinesisanalyticsv2.Application` using the application ARN. For example: ```sh $ pulumi import aws:kinesisanalyticsv2/application:Application example arn:aws:kinesisanalytics:us-west-2:123456789012:application/example-sql-application ```

    • Nested Class Summary

      • Nested classes/interfaces inherited from class com.pulumi.resources.CustomResource

        com.pulumi.resources.CustomResource.CustomResourceInternal

      • Nested classes/interfaces inherited from class com.pulumi.resources.Resource

        com.pulumi.resources.Resource.LazyField<T extends java.lang.Object>, com.pulumi.resources.Resource.LazyFields, com.pulumi.resources.Resource.ResourceInternal

    • Field Summary

      • Fields inherited from class com.pulumi.resources.Resource

        childResources, remote

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      com.pulumi.core.Output<ApplicationApplicationConfiguration> applicationConfiguration()  
      com.pulumi.core.Output<java.lang.String> applicationMode()  
      com.pulumi.core.Output<java.lang.String> arn()  
      com.pulumi.core.Output<java.util.Optional<ApplicationCloudwatchLoggingOptions>> cloudwatchLoggingOptions()  
      com.pulumi.core.Output<java.lang.String> createTimestamp()  
      com.pulumi.core.Output<java.util.Optional<java.lang.String>> description()  
      com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> forceStop()  
      static Application get​(java.lang.String name, com.pulumi.core.Output<java.lang.String> id, ApplicationState state, com.pulumi.resources.CustomResourceOptions options)
      Get an existing Host resource's state with the given name, ID, and optional extra properties used to qualify the lookup.
      com.pulumi.core.Output<java.lang.String> lastUpdateTimestamp()  
      com.pulumi.core.Output<java.lang.String> name()  
      com.pulumi.core.Output<java.lang.String> region()  
      com.pulumi.core.Output<java.lang.String> runtimeEnvironment()  
      com.pulumi.core.Output<java.lang.String> serviceExecutionRole()  
      com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> startApplication()  
      com.pulumi.core.Output<java.lang.String> status()  
      com.pulumi.core.Output<java.util.Optional<java.util.Map<java.lang.String,​java.lang.String>>> tags()  
      com.pulumi.core.Output<java.util.Map<java.lang.String,​java.lang.String>> tagsAll()  
      com.pulumi.core.Output<java.lang.Integer> versionId()  

      • Methods inherited from class com.pulumi.resources.CustomResource

        getId, id, idFuture

      • Methods inherited from class com.pulumi.resources.Resource

        getChildResources, getResourceName, getResourceType, getUrn, pulumiChildResources, pulumiResourceName, pulumiResourceType, urn

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • Application

        public Application​(java.lang.String name)
        Parameters:
        name - The _unique_ name of the resulting resource.

      • Application

        public Application​(java.lang.String name,
                   ApplicationArgs args)
        Parameters:
        name - The _unique_ name of the resulting resource.
        args - The arguments to use to populate this resource's properties.

      • Application

        public Application​(java.lang.String name,
                   ApplicationArgs args,
                   @Nullable
                   com.pulumi.resources.CustomResourceOptions options)
        Parameters:
        name - The _unique_ name of the resulting resource.
        args - The arguments to use to populate this resource's properties.
        options - A bag of options that control this resource's behavior.

    • Method Detail

      • applicationConfiguration

        public com.pulumi.core.Output<ApplicationApplicationConfiguration> applicationConfiguration()
        Returns:
        Application configuration. See `applicationConfiguration` Block below.

      • applicationMode

        public com.pulumi.core.Output<java.lang.String> applicationMode()
        Returns:
        Application's mode. Valid values are `STREAMING`, `INTERACTIVE`.

      • arn

        public com.pulumi.core.Output<java.lang.String> arn()
        Returns:
        ARN of the application.

      • cloudwatchLoggingOptions

        public com.pulumi.core.Output<java.util.Optional<ApplicationCloudwatchLoggingOptions>> cloudwatchLoggingOptions()
        Returns:
        CloudWatch log stream to monitor application configuration errors. See `cloudwatchLoggingOptions` Block below.

      • createTimestamp

        public com.pulumi.core.Output<java.lang.String> createTimestamp()
        Returns:
        Current timestamp when the application was created.

      • description

        public com.pulumi.core.Output<java.util.Optional<java.lang.String>> description()
        Returns:
        Summary description of the application.

      • forceStop

        public com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> forceStop()
        Returns:
        Whether to force stop an unresponsive Flink-based application.

      • lastUpdateTimestamp

        public com.pulumi.core.Output<java.lang.String> lastUpdateTimestamp()
        Returns:
        Current timestamp when the application was last updated.

      • name

        public com.pulumi.core.Output<java.lang.String> name()
        Returns:
        Name of the application.

      • region

        public com.pulumi.core.Output<java.lang.String> region()
        Returns:
        Region where this resource will be [managed](https://docs.aws.amazon.com/general/latest/gr/rande.html#regional-endpoints). Defaults to the Region set in the provider configuration.

      • runtimeEnvironment

        public com.pulumi.core.Output<java.lang.String> runtimeEnvironment()
        Returns:
        Runtime environment for the application. Valid values: `SQL-1_0`, `FLINK-1_6`, `FLINK-1_8`, `FLINK-1_11`, `FLINK-1_13`, `FLINK-1_15`, `FLINK-1_18`, `FLINK-1_19`, `FLINK-1_20`, `FLINK-2_2`, `FLINK-2_3`.

      • serviceExecutionRole

        public com.pulumi.core.Output<java.lang.String> serviceExecutionRole()
        Returns:
        ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources. The following arguments are optional:

      • startApplication

        public com.pulumi.core.Output<java.util.Optional<java.lang.Boolean>> startApplication()
        Returns:
        Whether to start or stop the application.

      • status

        public com.pulumi.core.Output<java.lang.String> status()
        Returns:
        Status of the application.

      • tags

        public com.pulumi.core.Output<java.util.Optional<java.util.Map<java.lang.String,​java.lang.String>>> tags()
        Returns:
        Map of tags to assign to the application. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

      • tagsAll

        public com.pulumi.core.Output<java.util.Map<java.lang.String,​java.lang.String>> tagsAll()
        Returns:
        Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

      • versionId

        public com.pulumi.core.Output<java.lang.Integer> versionId()
        Returns:
        Current application version. Kinesis Data Analytics updates the `versionId` each time the application is updated.

      • get

        public static Application get​(java.lang.String name,
                              com.pulumi.core.Output<java.lang.String> id,
                              @Nullable
                              ApplicationState state,
                              @Nullable
                              com.pulumi.resources.CustomResourceOptions options)
        Get an existing Host resource's state with the given name, ID, and optional extra properties used to qualify the lookup.
        Parameters:
        name - The _unique_ name of the resulting resource.
        id - The _unique_ provider ID of the resource to lookup.
        state -
        options - Optional settings to control the behavior of the CustomResource.