public static final class ApplicationProps.Builder
extends java.lang.Object
ApplicationProps
Constructor and Description |
---|
Builder() |
public ApplicationProps.Builder code(ApplicationCode code)
ApplicationProps.getCode()
code
- The Flink code asset to run. This parameter is required.this
public ApplicationProps.Builder runtime(Runtime runtime)
ApplicationProps.getRuntime()
runtime
- The Flink version to use for this application. This parameter is required.this
public ApplicationProps.Builder applicationName(java.lang.String applicationName)
ApplicationProps.getApplicationName()
applicationName
- A name for your Application that is unique to an AWS account.this
public ApplicationProps.Builder autoScalingEnabled(java.lang.Boolean autoScalingEnabled)
ApplicationProps.getAutoScalingEnabled()
autoScalingEnabled
- Whether the Kinesis Data Analytics service can increase the parallelism of the application in response to resource usage.this
public ApplicationProps.Builder checkpointingEnabled(java.lang.Boolean checkpointingEnabled)
ApplicationProps.getCheckpointingEnabled()
checkpointingEnabled
- Whether checkpointing is enabled while your application runs.this
public ApplicationProps.Builder checkpointInterval(Duration checkpointInterval)
ApplicationProps.getCheckpointInterval()
checkpointInterval
- The interval between checkpoints.this
public ApplicationProps.Builder logGroup(ILogGroup logGroup)
ApplicationProps.getLogGroup()
logGroup
- The log group to send log entries to.this
public ApplicationProps.Builder logLevel(LogLevel logLevel)
ApplicationProps.getLogLevel()
logLevel
- The level of log verbosity from the Flink application.this
public ApplicationProps.Builder metricsLevel(MetricsLevel metricsLevel)
ApplicationProps.getMetricsLevel()
metricsLevel
- 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).this
public ApplicationProps.Builder minPauseBetweenCheckpoints(Duration minPauseBetweenCheckpoints)
ApplicationProps.getMinPauseBetweenCheckpoints()
minPauseBetweenCheckpoints
- The minimum amount of time in to wait after a checkpoint finishes to start a new checkpoint.this
public ApplicationProps.Builder parallelism(java.lang.Number parallelism)
ApplicationProps.getParallelism()
parallelism
- 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).this
public ApplicationProps.Builder parallelismPerKpu(java.lang.Number parallelismPerKpu)
ApplicationProps.getParallelismPerKpu()
parallelismPerKpu
- The Flink parallelism allowed per Kinesis Processing Unit (KPU).this
public ApplicationProps.Builder propertyGroups(PropertyGroups propertyGroups)
ApplicationProps.getPropertyGroups()
propertyGroups
- Configuration PropertyGroups.
You can use these property groups to pass
arbitrary runtime configuration values to your Flink app.this
public ApplicationProps.Builder removalPolicy(RemovalPolicy removalPolicy)
ApplicationProps.getRemovalPolicy()
removalPolicy
- Provide a RemovalPolicy to override the default.this
public ApplicationProps.Builder role(IRole role)
ApplicationProps.getRole()
role
- A role to use to grant permissions to your application.
Prefer omitting
this property and using the default role.this
public ApplicationProps.Builder snapshotsEnabled(java.lang.Boolean snapshotsEnabled)
ApplicationProps.getSnapshotsEnabled()
snapshotsEnabled
- Determines if Flink snapshots are enabled.this
public ApplicationProps build()
ApplicationProps
java.lang.NullPointerException
- if any required attribute was not provided