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

Class Application

java.lang.Object

software.constructs.Construct

software.amazon.awscdk.core.Construct

software.amazon.awscdk.core.Resource

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

All Implemented Interfaces:

IConstruct, IDependable, IResource, IGrantable, IApplication

@Generated(value="jsii-pacmak/1.73.0 (build 6faeda3)",
           date="2023-01-31T18:36:53.621Z")
public class Application
extends Resource
implements IApplication

(experimental) The L2 construct for Flink Kinesis Data Applications.

Example:

 import path.*;
 import software.amazon.awscdk.core.*;
 import software.amazon.awscdk.services.kinesis.analytics.flink.*;
 import software.amazon.awscdk.services.cloudwatch.*;
 App app = new App();
 Stack stack = new Stack(app, "FlinkAppTest");
 Application flinkApp = Application.Builder.create(stack, "App")
         .code(ApplicationCode.fromAsset(join(__dirname, "code-asset")))
         .runtime(Runtime.FLINK_1_11)
         .build();
 Alarm.Builder.create(stack, "Alarm")
         .metric(flinkApp.metricFullRestarts())
         .evaluationPeriods(1)
         .threshold(3)
         .build();
 app.synth();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Application.Builder (experimental) A fluent builder for Application.

Nested classes/interfaces inherited from interface software.amazon.awscdk.services.kinesis.analytics.flink.IApplication

IApplication.Jsii$Default, IApplication.Jsii$Proxy

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Application(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)
protected	Application(software.amazon.jsii.JsiiObjectRef objRef)
	Application(software.constructs.Construct scope, java.lang.String id, ApplicationProps props)

Method Summary

Modifier and Type	Method and Description
java.lang.Boolean	addToRolePolicy(PolicyStatement policyStatement) (experimental) Implement the convenience IApplication.addToPrincipalPolicy method.
static IApplication	fromApplicationArn(software.constructs.Construct scope, java.lang.String id, java.lang.String applicationArn) (experimental) Import an existing application defined outside of CDK code by applicationArn.
static IApplication	fromApplicationName(software.constructs.Construct scope, java.lang.String id, java.lang.String applicationName) (experimental) Import an existing Flink application defined outside of CDK code by applicationName.
java.lang.String	getApplicationArn() (experimental) The application ARN.
java.lang.String	getApplicationName() (experimental) The name of the Flink application.
IPrincipal	getGrantPrincipal() (experimental) The principal to grant permissions to.
IRole	getRole() (experimental) The application IAM role.
Metric	metric(java.lang.String metricName) (experimental) Return a CloudWatch metric associated with this Flink application.
Metric	metric(java.lang.String metricName, MetricOptions props) (experimental) Return a CloudWatch metric associated with this Flink application.
Metric	metricBackPressuredTimeMsPerSecond() (experimental) The time (in milliseconds) this task or operator is back pressured per second.
Metric	metricBackPressuredTimeMsPerSecond(MetricOptions props) (experimental) The time (in milliseconds) this task or operator is back pressured per second.
Metric	metricBusyTimePerMsPerSecond() (experimental) The time (in milliseconds) this task or operator is busy (neither idle nor back pressured) per second.
Metric	metricBusyTimePerMsPerSecond(MetricOptions props) (experimental) The time (in milliseconds) this task or operator is busy (neither idle nor back pressured) per second.
Metric	metricCpuUtilization() (experimental) The overall percentage of CPU utilization across task managers.
Metric	metricCpuUtilization(MetricOptions props) (experimental) The overall percentage of CPU utilization across task managers.
Metric	metricCurrentInputWatermark() (experimental) The last watermark this application/operator/task/thread has received.
Metric	metricCurrentInputWatermark(MetricOptions props) (experimental) The last watermark this application/operator/task/thread has received.
Metric	metricCurrentOutputWatermark() (experimental) The last watermark this application/operator/task/thread has received.
Metric	metricCurrentOutputWatermark(MetricOptions props) (experimental) The last watermark this application/operator/task/thread has received.
Metric	metricDowntime() (experimental) The time elapsed during an outage for failing/recovering jobs.
Metric	metricDowntime(MetricOptions props) (experimental) The time elapsed during an outage for failing/recovering jobs.
Metric	metricFullRestarts() (experimental) The total number of times this job has fully restarted since it was submitted.
Metric	metricFullRestarts(MetricOptions props) (experimental) The total number of times this job has fully restarted since it was submitted.
Metric	metricHeapMemoryUtilization() (experimental) Overall heap memory utilization across task managers.
Metric	metricHeapMemoryUtilization(MetricOptions props) (experimental) Overall heap memory utilization across task managers.
Metric	metricIdleTimeMsPerSecond() (experimental) The time (in milliseconds) this task or operator is idle (has no data to process) per second.
Metric	metricIdleTimeMsPerSecond(MetricOptions props) (experimental) The time (in milliseconds) this task or operator is idle (has no data to process) per second.
Metric	metricKpus() (experimental) The number of Kinesis Processing Units that are used to run your stream processing application.
Metric	metricKpus(MetricOptions props) (experimental) The number of Kinesis Processing Units that are used to run your stream processing application.
Metric	metricLastCheckpointDuration() (experimental) The time it took to complete the last checkpoint.
Metric	metricLastCheckpointDuration(MetricOptions props) (experimental) The time it took to complete the last checkpoint.
Metric	metricLastCheckpointSize() (experimental) The total size of the last checkpoint.
Metric	metricLastCheckpointSize(MetricOptions props) (experimental) The total size of the last checkpoint.
Metric	metricManagedMemoryTotal() (experimental) The total amount of managed memory.
Metric	metricManagedMemoryTotal(MetricOptions props) (experimental) The total amount of managed memory.
Metric	metricManagedMemoryUsed() (experimental) The amount of managed memory currently used.
Metric	metricManagedMemoryUsed(MetricOptions props) (experimental) The amount of managed memory currently used.
Metric	metricManagedMemoryUtilization() (experimental) Derived from managedMemoryUsed/managedMemoryTotal.
Metric	metricManagedMemoryUtilization(MetricOptions props) (experimental) Derived from managedMemoryUsed/managedMemoryTotal.
Metric	metricNumberOfFailedCheckpoints() (experimental) The number of times checkpointing has failed.
Metric	metricNumberOfFailedCheckpoints(MetricOptions props) (experimental) The number of times checkpointing has failed.
Metric	metricNumLateRecordsDropped() (experimental) The number of records this operator or task has dropped due to arriving late.
Metric	metricNumLateRecordsDropped(MetricOptions props) (experimental) The number of records this operator or task has dropped due to arriving late.
Metric	metricNumRecordsIn() (experimental) The total number of records this application, operator, or task has received.
Metric	metricNumRecordsIn(MetricOptions props) (experimental) The total number of records this application, operator, or task has received.
Metric	metricNumRecordsInPerSecond() (experimental) The total number of records this application, operator or task has received per second.
Metric	metricNumRecordsInPerSecond(MetricOptions props) (experimental) The total number of records this application, operator or task has received per second.
Metric	metricNumRecordsOut() (experimental) The total number of records this application, operator or task has emitted.
Metric	metricNumRecordsOut(MetricOptions props) (experimental) The total number of records this application, operator or task has emitted.
Metric	metricNumRecordsOutPerSecond() (experimental) The total number of records this application, operator or task has emitted per second.
Metric	metricNumRecordsOutPerSecond(MetricOptions props) (experimental) The total number of records this application, operator or task has emitted per second.
Metric	metricOldGenerationGCCount() (experimental) The total number of old garbage collection operations that have occurred across all task managers.
Metric	metricOldGenerationGCCount(MetricOptions props) (experimental) The total number of old garbage collection operations that have occurred across all task managers.
Metric	metricOldGenerationGCTime() (experimental) The total time spent performing old garbage collection operations.
Metric	metricOldGenerationGCTime(MetricOptions props) (experimental) The total time spent performing old garbage collection operations.
Metric	metricThreadsCount() (experimental) The total number of live threads used by the application.
Metric	metricThreadsCount(MetricOptions props) (experimental) The total number of live threads used by the application.
Metric	metricUptime() (experimental) The time that the job has been running without interruption.
Metric	metricUptime(MetricOptions props) (experimental) The time that the job has been running without interruption.

Methods inherited from class software.amazon.awscdk.core.Resource

applyRemovalPolicy, generatePhysicalName, getEnv, getPhysicalName, getResourceArnAttribute, getResourceNameAttribute, getStack, isResource

Methods inherited from class software.amazon.awscdk.core.Construct

getNode, isConstruct, onPrepare, onSynthesize, onValidate, prepare, synthesize, validate

Methods inherited from class java.lang.Object

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

Methods inherited from interface software.amazon.awscdk.core.IResource

applyRemovalPolicy, getEnv, getStack

Methods inherited from interface software.amazon.awscdk.core.IConstruct

getNode

Constructor Detail

Application

protected Application(software.amazon.jsii.JsiiObjectRef objRef)

Application

protected Application(software.amazon.jsii.JsiiObject.InitializationMode initializationMode)

Application

public Application(software.constructs.Construct scope,
                   java.lang.String id,
                   ApplicationProps props)

Parameters:

scope - This parameter is required.

id - This parameter is required.

props - This parameter is required.

Method Detail

fromApplicationArn

public static IApplication fromApplicationArn(software.constructs.Construct scope,
                                              java.lang.String id,
                                              java.lang.String applicationArn)

(experimental) Import an existing application defined outside of CDK code by applicationArn.

Parameters:

scope - This parameter is required.

id - This parameter is required.

applicationArn - This parameter is required.

fromApplicationName

public static IApplication fromApplicationName(software.constructs.Construct scope,
                                               java.lang.String id,
                                               java.lang.String applicationName)

(experimental) Import an existing Flink application defined outside of CDK code by applicationName.

Parameters:

scope - This parameter is required.

id - This parameter is required.

applicationName - This parameter is required.

addToRolePolicy

public java.lang.Boolean addToRolePolicy(PolicyStatement policyStatement)

(experimental) Implement the convenience IApplication.addToPrincipalPolicy method.

Specified by:

addToRolePolicy in interface IApplication

Parameters:

policyStatement - This parameter is required.

metric

public Metric metric(java.lang.String metricName,
                     MetricOptions props)

(experimental) Return a CloudWatch metric associated with this Flink application.

Specified by:

metric in interface IApplication

Parameters:

metricName - The name of the metric. This parameter is required.

props - Customization properties.

metric

public Metric metric(java.lang.String metricName)

(experimental) Return a CloudWatch metric associated with this Flink application.

Specified by:

metric in interface IApplication

Parameters:

metricName - The name of the metric. This parameter is required.

metricBackPressuredTimeMsPerSecond

public Metric metricBackPressuredTimeMsPerSecond(MetricOptions props)

(experimental) The time (in milliseconds) this task or operator is back pressured per second.

Units: Milliseconds

Reporting Level: Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricBackPressuredTimeMsPerSecond in interface IApplication

Parameters:

props -

metricBackPressuredTimeMsPerSecond

public Metric metricBackPressuredTimeMsPerSecond()

(experimental) The time (in milliseconds) this task or operator is back pressured per second.

Units: Milliseconds

Reporting Level: Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricBackPressuredTimeMsPerSecond in interface IApplication

metricBusyTimePerMsPerSecond

public Metric metricBusyTimePerMsPerSecond(MetricOptions props)

(experimental) The time (in milliseconds) this task or operator is busy (neither idle nor back pressured) per second.

Can be NaN, if the value could not be calculated.

Units: Milliseconds

Reporting Level: Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricBusyTimePerMsPerSecond in interface IApplication

Parameters:

props -

metricBusyTimePerMsPerSecond

public Metric metricBusyTimePerMsPerSecond()

(experimental) The time (in milliseconds) this task or operator is busy (neither idle nor back pressured) per second.

Can be NaN, if the value could not be calculated.

Units: Milliseconds

Reporting Level: Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricBusyTimePerMsPerSecond in interface IApplication

metricCpuUtilization

public Metric metricCpuUtilization(MetricOptions props)

(experimental) The overall percentage of CPU utilization across task managers.

For example, if there are five task managers, Kinesis Data Analytics publishes five samples of this metric per reporting interval.

Units: Percentage

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricCpuUtilization in interface IApplication

Parameters:

props -

metricCpuUtilization

public Metric metricCpuUtilization()

(experimental) The overall percentage of CPU utilization across task managers.

For example, if there are five task managers, Kinesis Data Analytics publishes five samples of this metric per reporting interval.

Units: Percentage

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricCpuUtilization in interface IApplication

metricCurrentInputWatermark

public Metric metricCurrentInputWatermark(MetricOptions props)

(experimental) The last watermark this application/operator/task/thread has received.

Units: Milliseconds

Reporting Level: Application, Operator, Task, Parallelism

Default: maximum over 5 minutes

Specified by:

metricCurrentInputWatermark in interface IApplication

Parameters:

props -

metricCurrentInputWatermark

public Metric metricCurrentInputWatermark()

(experimental) The last watermark this application/operator/task/thread has received.

Units: Milliseconds

Reporting Level: Application, Operator, Task, Parallelism

Default: maximum over 5 minutes

Specified by:

metricCurrentInputWatermark in interface IApplication

metricCurrentOutputWatermark

public Metric metricCurrentOutputWatermark(MetricOptions props)

(experimental) The last watermark this application/operator/task/thread has received.

Units: Milliseconds

Reporting Level: Application, Operator, Task, Parallelism

Default: maximum over 5 minutes

Specified by:

metricCurrentOutputWatermark in interface IApplication

Parameters:

props -

metricCurrentOutputWatermark

public Metric metricCurrentOutputWatermark()

(experimental) The last watermark this application/operator/task/thread has received.

Units: Milliseconds

Reporting Level: Application, Operator, Task, Parallelism

Default: maximum over 5 minutes

Specified by:

metricCurrentOutputWatermark in interface IApplication

metricDowntime

public Metric metricDowntime(MetricOptions props)

(experimental) The time elapsed during an outage for failing/recovering jobs.

Units: Milliseconds

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricDowntime in interface IApplication

Parameters:

props -

metricDowntime

public Metric metricDowntime()

(experimental) The time elapsed during an outage for failing/recovering jobs.

Units: Milliseconds

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricDowntime in interface IApplication

metricFullRestarts

public Metric metricFullRestarts(MetricOptions props)

(experimental) The total number of times this job has fully restarted since it was submitted.

This metric does not measure fine-grained restarts.

Units: Count

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricFullRestarts in interface IApplication

Parameters:

props -

metricFullRestarts

public Metric metricFullRestarts()

(experimental) The total number of times this job has fully restarted since it was submitted.

This metric does not measure fine-grained restarts.

Units: Count

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricFullRestarts in interface IApplication

metricHeapMemoryUtilization

public Metric metricHeapMemoryUtilization(MetricOptions props)

(experimental) Overall heap memory utilization across task managers.

For example, if there are five task managers, Kinesis Data Analytics publishes five samples of this metric per reporting interval.

Units: Percentage

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricHeapMemoryUtilization in interface IApplication

Parameters:

props -

metricHeapMemoryUtilization

public Metric metricHeapMemoryUtilization()

(experimental) Overall heap memory utilization across task managers.

For example, if there are five task managers, Kinesis Data Analytics publishes five samples of this metric per reporting interval.

Units: Percentage

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricHeapMemoryUtilization in interface IApplication

metricIdleTimeMsPerSecond

public Metric metricIdleTimeMsPerSecond(MetricOptions props)

(experimental) The time (in milliseconds) this task or operator is idle (has no data to process) per second.

Idle time excludes back pressured time, so if the task is back pressured it is not idle.

Units: Milliseconds

Reporting Level: Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricIdleTimeMsPerSecond in interface IApplication

Parameters:

props -

metricIdleTimeMsPerSecond

public Metric metricIdleTimeMsPerSecond()

(experimental) The time (in milliseconds) this task or operator is idle (has no data to process) per second.

Idle time excludes back pressured time, so if the task is back pressured it is not idle.

Units: Milliseconds

Reporting Level: Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricIdleTimeMsPerSecond in interface IApplication

metricKpus

public Metric metricKpus(MetricOptions props)

(experimental) The number of Kinesis Processing Units that are used to run your stream processing application.

The average number of KPUs used each hour determines the billing for your application.

Units: Count

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricKpus in interface IApplication

Parameters:

props -

metricKpus

public Metric metricKpus()

(experimental) The number of Kinesis Processing Units that are used to run your stream processing application.

The average number of KPUs used each hour determines the billing for your application.

Units: Count

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricKpus in interface IApplication

metricLastCheckpointDuration

public Metric metricLastCheckpointDuration(MetricOptions props)

(experimental) The time it took to complete the last checkpoint.

Units: Milliseconds

Reporting Level: Application

Default: maximum over 5 minutes

Specified by:

metricLastCheckpointDuration in interface IApplication

Parameters:

props -

metricLastCheckpointDuration

public Metric metricLastCheckpointDuration()

(experimental) The time it took to complete the last checkpoint.

Units: Milliseconds

Reporting Level: Application

Default: maximum over 5 minutes

Specified by:

metricLastCheckpointDuration in interface IApplication

metricLastCheckpointSize

public Metric metricLastCheckpointSize(MetricOptions props)

(experimental) The total size of the last checkpoint.

Units: Bytes

Reporting Level: Application

Default: maximum over 5 minutes

Specified by:

metricLastCheckpointSize in interface IApplication

Parameters:

props -

metricLastCheckpointSize

public Metric metricLastCheckpointSize()

(experimental) The total size of the last checkpoint.

Units: Bytes

Reporting Level: Application

Default: maximum over 5 minutes

Specified by:

metricLastCheckpointSize in interface IApplication

metricManagedMemoryTotal

public Metric metricManagedMemoryTotal(MetricOptions props)

(experimental) The total amount of managed memory.

Units: Bytes

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricManagedMemoryTotal in interface IApplication

Parameters:

props -

metricManagedMemoryTotal

public Metric metricManagedMemoryTotal()

(experimental) The total amount of managed memory.

Units: Bytes

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricManagedMemoryTotal in interface IApplication

metricManagedMemoryUsed

public Metric metricManagedMemoryUsed(MetricOptions props)

(experimental) The amount of managed memory currently used.

Units: Bytes

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricManagedMemoryUsed in interface IApplication

Parameters:

props -

metricManagedMemoryUsed

public Metric metricManagedMemoryUsed()

(experimental) The amount of managed memory currently used.

Units: Bytes

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricManagedMemoryUsed in interface IApplication

metricManagedMemoryUtilization

public Metric metricManagedMemoryUtilization(MetricOptions props)

(experimental) Derived from managedMemoryUsed/managedMemoryTotal.

Units: Percentage

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricManagedMemoryUtilization in interface IApplication

Parameters:

props -

metricManagedMemoryUtilization

public Metric metricManagedMemoryUtilization()

(experimental) Derived from managedMemoryUsed/managedMemoryTotal.

Units: Percentage

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricManagedMemoryUtilization in interface IApplication

metricNumberOfFailedCheckpoints

public Metric metricNumberOfFailedCheckpoints(MetricOptions props)

(experimental) The number of times checkpointing has failed.

Units: Count

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricNumberOfFailedCheckpoints in interface IApplication

Parameters:

props -

metricNumberOfFailedCheckpoints

public Metric metricNumberOfFailedCheckpoints()

(experimental) The number of times checkpointing has failed.

Units: Count

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricNumberOfFailedCheckpoints in interface IApplication

metricNumLateRecordsDropped

public Metric metricNumLateRecordsDropped(MetricOptions props)

(experimental) The number of records this operator or task has dropped due to arriving late.

Units: Count

Reporting Level: Application, Operator, Task, Parallelism

Default: sum over 5 minutes

Specified by:

metricNumLateRecordsDropped in interface IApplication

Parameters:

props -

metricNumLateRecordsDropped

public Metric metricNumLateRecordsDropped()

(experimental) The number of records this operator or task has dropped due to arriving late.

Units: Count

Reporting Level: Application, Operator, Task, Parallelism

Default: sum over 5 minutes

Specified by:

metricNumLateRecordsDropped in interface IApplication

metricNumRecordsIn

public Metric metricNumRecordsIn(MetricOptions props)

(experimental) The total number of records this application, operator, or task has received.

Units: Count

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsIn in interface IApplication

Parameters:

props -

metricNumRecordsIn

public Metric metricNumRecordsIn()

(experimental) The total number of records this application, operator, or task has received.

Units: Count

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsIn in interface IApplication

metricNumRecordsInPerSecond

public Metric metricNumRecordsInPerSecond(MetricOptions props)

(experimental) The total number of records this application, operator or task has received per second.

Units: Count/Second

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsInPerSecond in interface IApplication

Parameters:

props -

metricNumRecordsInPerSecond

public Metric metricNumRecordsInPerSecond()

(experimental) The total number of records this application, operator or task has received per second.

Units: Count/Second

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsInPerSecond in interface IApplication

metricNumRecordsOut

public Metric metricNumRecordsOut(MetricOptions props)

(experimental) The total number of records this application, operator or task has emitted.

Units: Count

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsOut in interface IApplication

Parameters:

props -

metricNumRecordsOut

public Metric metricNumRecordsOut()

(experimental) The total number of records this application, operator or task has emitted.

Units: Count

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsOut in interface IApplication

metricNumRecordsOutPerSecond

public Metric metricNumRecordsOutPerSecond(MetricOptions props)

(experimental) The total number of records this application, operator or task has emitted per second.

Units: Count/Second

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsOutPerSecond in interface IApplication

Parameters:

props -

metricNumRecordsOutPerSecond

public Metric metricNumRecordsOutPerSecond()

(experimental) The total number of records this application, operator or task has emitted per second.

Units: Count/Second

Reporting Level: Application, Operator, Task, Parallelism

Default: average over 5 minutes

Specified by:

metricNumRecordsOutPerSecond in interface IApplication

metricOldGenerationGCCount

public Metric metricOldGenerationGCCount(MetricOptions props)

(experimental) The total number of old garbage collection operations that have occurred across all task managers.

Units: Count

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricOldGenerationGCCount in interface IApplication

Parameters:

props -

metricOldGenerationGCCount

public Metric metricOldGenerationGCCount()

(experimental) The total number of old garbage collection operations that have occurred across all task managers.

Units: Count

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricOldGenerationGCCount in interface IApplication

metricOldGenerationGCTime

public Metric metricOldGenerationGCTime(MetricOptions props)

(experimental) The total time spent performing old garbage collection operations.

Units: Milliseconds

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricOldGenerationGCTime in interface IApplication

Parameters:

props -

metricOldGenerationGCTime

public Metric metricOldGenerationGCTime()

(experimental) The total time spent performing old garbage collection operations.

Units: Milliseconds

Reporting Level: Application

Default: sum over 5 minutes

Specified by:

metricOldGenerationGCTime in interface IApplication

metricThreadsCount

public Metric metricThreadsCount(MetricOptions props)

(experimental) The total number of live threads used by the application.

Units: Count

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricThreadsCount in interface IApplication

Parameters:

props -

metricThreadsCount

public Metric metricThreadsCount()

(experimental) The total number of live threads used by the application.

Units: Count

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricThreadsCount in interface IApplication

metricUptime

public Metric metricUptime(MetricOptions props)

(experimental) The time that the job has been running without interruption.

Units: Milliseconds

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricUptime in interface IApplication

Parameters:

props -

metricUptime

public Metric metricUptime()

(experimental) The time that the job has been running without interruption.

Units: Milliseconds

Reporting Level: Application

Default: average over 5 minutes

Specified by:

metricUptime in interface IApplication

getApplicationArn

public java.lang.String getApplicationArn()

(experimental) The application ARN.

Specified by:

getApplicationArn in interface IApplication

getApplicationName

public java.lang.String getApplicationName()

(experimental) The name of the Flink application.

Specified by:

getApplicationName in interface IApplication

getGrantPrincipal

public IPrincipal getGrantPrincipal()

(experimental) The principal to grant permissions to.

Specified by:

getGrantPrincipal in interface IGrantable

getRole

public IRole getRole()

(experimental) The application IAM role.

Specified by:

getRole in interface IApplication