software.amazon.awscdk.services.kinesis.analytics.flink

Class ApplicationProps.Builder

java.lang.Object

software.amazon.awscdk.services.kinesis.analytics.flink.ApplicationProps.Builder

Enclosing interface:

ApplicationProps

public static final class ApplicationProps.Builder
extends java.lang.Object

A builder for ApplicationProps

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
ApplicationProps.Builder	applicationName(java.lang.String applicationName) Sets the value of ApplicationProps.getApplicationName()
ApplicationProps.Builder	autoScalingEnabled(java.lang.Boolean autoScalingEnabled) Sets the value of ApplicationProps.getAutoScalingEnabled()
ApplicationProps	build() Builds the configured instance.
ApplicationProps.Builder	checkpointingEnabled(java.lang.Boolean checkpointingEnabled) Sets the value of ApplicationProps.getCheckpointingEnabled()
ApplicationProps.Builder	checkpointInterval(Duration checkpointInterval) Sets the value of ApplicationProps.getCheckpointInterval()
ApplicationProps.Builder	code(ApplicationCode code) Sets the value of ApplicationProps.getCode()
ApplicationProps.Builder	logGroup(ILogGroup logGroup) Sets the value of ApplicationProps.getLogGroup()
ApplicationProps.Builder	logLevel(LogLevel logLevel) Sets the value of ApplicationProps.getLogLevel()
ApplicationProps.Builder	metricsLevel(MetricsLevel metricsLevel) Sets the value of ApplicationProps.getMetricsLevel()
ApplicationProps.Builder	minPauseBetweenCheckpoints(Duration minPauseBetweenCheckpoints) Sets the value of ApplicationProps.getMinPauseBetweenCheckpoints()
ApplicationProps.Builder	parallelism(java.lang.Number parallelism) Sets the value of ApplicationProps.getParallelism()
ApplicationProps.Builder	parallelismPerKpu(java.lang.Number parallelismPerKpu) Sets the value of ApplicationProps.getParallelismPerKpu()
ApplicationProps.Builder	propertyGroups(PropertyGroups propertyGroups) Sets the value of ApplicationProps.getPropertyGroups()
ApplicationProps.Builder	removalPolicy(RemovalPolicy removalPolicy) Sets the value of ApplicationProps.getRemovalPolicy()
ApplicationProps.Builder	role(IRole role) Sets the value of ApplicationProps.getRole()
ApplicationProps.Builder	runtime(Runtime runtime) Sets the value of ApplicationProps.getRuntime()
ApplicationProps.Builder	snapshotsEnabled(java.lang.Boolean snapshotsEnabled) Sets the value of ApplicationProps.getSnapshotsEnabled()

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

code

public ApplicationProps.Builder code(ApplicationCode code)

Sets the value of ApplicationProps.getCode()

Parameters:

code - The Flink code asset to run. This parameter is required.

Returns:

this

runtime

public ApplicationProps.Builder runtime(Runtime runtime)

Sets the value of ApplicationProps.getRuntime()

Parameters:

runtime - The Flink version to use for this application. This parameter is required.

Returns:

this

applicationName

public ApplicationProps.Builder applicationName(java.lang.String applicationName)

Sets the value of ApplicationProps.getApplicationName()

Parameters:

applicationName - A name for your Application that is unique to an AWS account.

Returns:

this

autoScalingEnabled

public ApplicationProps.Builder autoScalingEnabled(java.lang.Boolean autoScalingEnabled)

Sets the value of ApplicationProps.getAutoScalingEnabled()

Parameters:

autoScalingEnabled - Whether the Kinesis Data Analytics service can increase the parallelism of the application in response to resource usage.

Returns:

this

checkpointingEnabled

public ApplicationProps.Builder checkpointingEnabled(java.lang.Boolean checkpointingEnabled)

Sets the value of ApplicationProps.getCheckpointingEnabled()

Parameters:

checkpointingEnabled - Whether checkpointing is enabled while your application runs.

Returns:

this

checkpointInterval

public ApplicationProps.Builder checkpointInterval(Duration checkpointInterval)

Sets the value of ApplicationProps.getCheckpointInterval()

Parameters:

checkpointInterval - The interval between checkpoints.

Returns:

this

logGroup

public ApplicationProps.Builder logGroup(ILogGroup logGroup)

Sets the value of ApplicationProps.getLogGroup()

Parameters:

logGroup - The log group to send log entries to.

Returns:

this

logLevel

public ApplicationProps.Builder logLevel(LogLevel logLevel)

Sets the value of ApplicationProps.getLogLevel()

Parameters:

logLevel - The level of log verbosity from the Flink application.

Returns:

this

metricsLevel

public ApplicationProps.Builder metricsLevel(MetricsLevel metricsLevel)

Sets the value of ApplicationProps.getMetricsLevel()

Parameters:

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).

Returns:

this

minPauseBetweenCheckpoints

public ApplicationProps.Builder minPauseBetweenCheckpoints(Duration minPauseBetweenCheckpoints)

Sets the value of ApplicationProps.getMinPauseBetweenCheckpoints()

Parameters:

minPauseBetweenCheckpoints - The minimum amount of time in to wait after a checkpoint finishes to start a new checkpoint.

Returns:

this

parallelism

public ApplicationProps.Builder parallelism(java.lang.Number parallelism)

Sets the value of ApplicationProps.getParallelism()

Parameters:

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).

Returns:

this

parallelismPerKpu

public ApplicationProps.Builder parallelismPerKpu(java.lang.Number parallelismPerKpu)

Sets the value of ApplicationProps.getParallelismPerKpu()

Parameters:

parallelismPerKpu - The Flink parallelism allowed per Kinesis Processing Unit (KPU).

Returns:

this

propertyGroups

public ApplicationProps.Builder propertyGroups(PropertyGroups propertyGroups)

Sets the value of ApplicationProps.getPropertyGroups()

Parameters:

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

Returns:

this

removalPolicy

public ApplicationProps.Builder removalPolicy(RemovalPolicy removalPolicy)

Sets the value of ApplicationProps.getRemovalPolicy()

Parameters:

removalPolicy - Provide a RemovalPolicy to override the default.

Returns:

this

role

public ApplicationProps.Builder role(IRole role)

Sets the value of ApplicationProps.getRole()

Parameters:

role - A role to use to grant permissions to your application. Prefer omitting this property and using the default role.

Returns:

this

snapshotsEnabled

public ApplicationProps.Builder snapshotsEnabled(java.lang.Boolean snapshotsEnabled)

Sets the value of ApplicationProps.getSnapshotsEnabled()

Parameters:

snapshotsEnabled - Determines if Flink snapshots are enabled.

Returns:

this

build

public ApplicationProps build()

Builds the configured instance.

Returns:

a new instance of ApplicationProps

Throws:

java.lang.NullPointerException - if any required attribute was not provided