Package software.amazon.awscdk.services.kinesisanalytics.flink.alpha

Class ApplicationProps.Jsii$Proxy

java.lang.Object
software.amazon.jsii.JsiiObject
software.amazon.awscdk.services.kinesisanalytics.flink.alpha.ApplicationProps.Jsii$Proxy
All Implemented Interfaces:
ApplicationProps, software.amazon.jsii.JsiiSerializable
Enclosing interface:
ApplicationProps
@Stability(Experimental) @Internal public static final class ApplicationProps.Jsii$Proxy extends software.amazon.jsii.JsiiObject implements ApplicationProps
An implementation for ApplicationProps

  • Constructor Details

    • Jsii$Proxy

      protected Jsii$Proxy(software.amazon.jsii.JsiiObjectRef objRef)
      Constructor that initializes the object based on values retrieved from the JsiiObject.
      Parameters:
      objRef - Reference to the JSII managed object.

    • Jsii$Proxy

      protected Jsii$Proxy(ApplicationProps.Builder builder)
      Constructor that initializes the object based on literal property values passed by the ApplicationProps.Builder.

  • Method Details

    • getCode

      public final ApplicationCode getCode()
      Description copied from interface: ApplicationProps
      (experimental) The Flink code asset to run.
      Specified by:
      getCode in interface ApplicationProps

    • getRuntime

      public final Runtime getRuntime()
      Description copied from interface: ApplicationProps
      (experimental) The Flink version to use for this application.
      Specified by:
      getRuntime in interface ApplicationProps

    • getApplicationName

      public final String getApplicationName()
      Description copied from interface: ApplicationProps
      (experimental) A name for your Application that is unique to an AWS account.

      Default: - CloudFormation-generated name

      Specified by:
      getApplicationName in interface ApplicationProps

    • getAutoScalingEnabled

      public final Boolean getAutoScalingEnabled()
      Description copied from interface: ApplicationProps
      (experimental) Whether the Kinesis Data Analytics service can increase the parallelism of the application in response to resource usage.

      Default: true

      Specified by:
      getAutoScalingEnabled in interface ApplicationProps

    • getCheckpointingEnabled

      public final Boolean getCheckpointingEnabled()
      Description copied from interface: ApplicationProps
      (experimental) Whether checkpointing is enabled while your application runs.

      Default: true

      Specified by:
      getCheckpointingEnabled in interface ApplicationProps

    • getCheckpointInterval

      public final Duration getCheckpointInterval()
      Description copied from interface: ApplicationProps
      (experimental) The interval between checkpoints.

      Default: - 1 minute

      Specified by:
      getCheckpointInterval in interface ApplicationProps

    • getLogGroup

      public final ILogGroup getLogGroup()
      Description copied from interface: ApplicationProps
      (experimental) The log group to send log entries to.

      Default: - CDK's default LogGroup

      Specified by:
      getLogGroup in interface ApplicationProps

    • getLogLevel

      public final LogLevel getLogLevel()
      Description copied from interface: ApplicationProps
      (experimental) The level of log verbosity from the Flink application.

      Default: FlinkLogLevel.INFO

      Specified by:
      getLogLevel in interface ApplicationProps

    • getMetricsLevel

      public final MetricsLevel getMetricsLevel()
      Description copied from interface: ApplicationProps
      (experimental) Describes the granularity of the CloudWatch metrics for an application.

      Use caution with Parallelism level metrics. Parallelism granularity logs metrics for each parallel thread and can quickly become expensive when parallelism is high (e.g. > 64).

      Default: MetricsLevel.APPLICATION

      Specified by:
      getMetricsLevel in interface ApplicationProps

    • getMinPauseBetweenCheckpoints

      public final Duration getMinPauseBetweenCheckpoints()
      Description copied from interface: ApplicationProps
      (experimental) The minimum amount of time in to wait after a checkpoint finishes to start a new checkpoint.

      Default: - 5 seconds

      Specified by:
      getMinPauseBetweenCheckpoints in interface ApplicationProps

    • getParallelism

      public final Number getParallelism()
      Description copied from interface: ApplicationProps
      (experimental) The initial parallelism for the application.

      Kinesis Data Analytics can stop the app, increase the parallelism, and start the app again if autoScalingEnabled is true (the default value).

      Default: 1

      Specified by:
      getParallelism in interface ApplicationProps

    • getParallelismPerKpu

      public final Number getParallelismPerKpu()
      Description copied from interface: ApplicationProps
      (experimental) The Flink parallelism allowed per Kinesis Processing Unit (KPU).

      Default: 1

      Specified by:
      getParallelismPerKpu in interface ApplicationProps

    • getPropertyGroups

      public final Map<String,Map<String,String>> getPropertyGroups()
      Description copied from interface: ApplicationProps
      (experimental) Configuration PropertyGroups.

      You can use these property groups to pass arbitrary runtime configuration values to your Flink app.

      Default: - No property group configuration provided to the Flink app

      Specified by:
      getPropertyGroups in interface ApplicationProps

    • getRemovalPolicy

      public final RemovalPolicy getRemovalPolicy()
      Description copied from interface: ApplicationProps
      (experimental) Provide a RemovalPolicy to override the default.

      Default: RemovalPolicy.DESTROY

      Specified by:
      getRemovalPolicy in interface ApplicationProps

    • getRole

      public final IRole getRole()
      Description copied from interface: ApplicationProps
      (experimental) A role to use to grant permissions to your application.

      Prefer omitting this property and using the default role.

      Default: - a new Role will be created

      Specified by:
      getRole in interface ApplicationProps

    • getSecurityGroups

      public final List<ISecurityGroup> getSecurityGroups()
      Description copied from interface: ApplicationProps
      (experimental) Security groups to use with a provided VPC.

      Default: - a new security group is created for this application.

      Specified by:
      getSecurityGroups in interface ApplicationProps

    • getSnapshotsEnabled

      public final Boolean getSnapshotsEnabled()
      Description copied from interface: ApplicationProps
      (experimental) Determines if Flink snapshots are enabled.

      Default: true

      Specified by:
      getSnapshotsEnabled in interface ApplicationProps

    • getVpc

      public final IVpc getVpc()
      Description copied from interface: ApplicationProps
      (experimental) Deploy the Flink application in a VPC.

      Default: - no VPC

      Specified by:
      getVpc in interface ApplicationProps

    • getVpcSubnets

      public final SubnetSelection getVpcSubnets()
      Description copied from interface: ApplicationProps
      (experimental) Choose which VPC subnets to use.

      Default: - SubnetType.PRIVATE_WITH_EGRESS subnets

      Specified by:
      getVpcSubnets in interface ApplicationProps

    • $jsii$toJson

      @Internal public com.fasterxml.jackson.databind.JsonNode $jsii$toJson()
      Specified by:
      $jsii$toJson in interface software.amazon.jsii.JsiiSerializable

    • equals

      public final boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public final int hashCode()
      Overrides:
      hashCode in class Object