Interface IApplication
(experimental) An interface expressing the public properties on both an imported and CDK-created Flink application.
Inherited Members
Namespace: Amazon.CDK.AWS.KinesisAnalyticsFlink
Assembly: Amazon.CDK.AWS.KinesisAnalyticsFlink.dll
Syntax (csharp)
public interface IApplication : IResource, IConstruct, IDependable, IGrantable
Syntax (vb)
Public Interface IApplication
Inherits IResource, IConstruct, IConstruct, IDependable, IGrantable
Remarks
Stability: Experimental
Synopsis
Properties
ApplicationArn | (experimental) The application ARN. |
ApplicationName | (experimental) The name of the Flink application. |
Role | (experimental) The application IAM role. |
Methods
AddToRolePolicy(PolicyStatement) | (experimental) Convenience method for adding a policy statement to the application role. |
Metric(String, IMetricOptions) | (experimental) Return a CloudWatch metric associated with this Flink application. |
MetricBackPressuredTimeMsPerSecond(IMetricOptions) | (experimental) The time (in milliseconds) this task or operator is back pressured per second. |
MetricBusyTimePerMsPerSecond(IMetricOptions) | (experimental) The time (in milliseconds) this task or operator is busy (neither idle nor back pressured) per second. |
MetricCpuUtilization(IMetricOptions) | (experimental) The overall percentage of CPU utilization across task managers. |
MetricCurrentInputWatermark(IMetricOptions) | (experimental) The last watermark this application/operator/task/thread has received. |
MetricCurrentOutputWatermark(IMetricOptions) | (experimental) The last watermark this application/operator/task/thread has received. |
MetricDowntime(IMetricOptions) | (experimental) The time elapsed during an outage for failing/recovering jobs. |
MetricFullRestarts(IMetricOptions) | (experimental) The total number of times this job has fully restarted since it was submitted. |
MetricHeapMemoryUtilization(IMetricOptions) | (experimental) Overall heap memory utilization across task managers. |
MetricIdleTimeMsPerSecond(IMetricOptions) | (experimental) The time (in milliseconds) this task or operator is idle (has no data to process) per second. |
MetricKpus(IMetricOptions) | (experimental) The number of Kinesis Processing Units that are used to run your stream processing application. |
MetricLastCheckpointDuration(IMetricOptions) | (experimental) The time it took to complete the last checkpoint. |
MetricLastCheckpointSize(IMetricOptions) | (experimental) The total size of the last checkpoint. |
MetricManagedMemoryTotal(IMetricOptions) | (experimental) The total amount of managed memory. |
MetricManagedMemoryUsed(IMetricOptions) | (experimental) The amount of managed memory currently used. |
MetricManagedMemoryUtilization(IMetricOptions) | (experimental) Derived from managedMemoryUsed/managedMemoryTotal. |
MetricNumberOfFailedCheckpoints(IMetricOptions) | (experimental) The number of times checkpointing has failed. |
MetricNumLateRecordsDropped(IMetricOptions) | (experimental) The number of records this operator or task has dropped due to arriving late. |
MetricNumRecordsIn(IMetricOptions) | (experimental) The total number of records this application, operator, or task has received. |
MetricNumRecordsInPerSecond(IMetricOptions) | (experimental) The total number of records this application, operator or task has received per second. |
MetricNumRecordsOut(IMetricOptions) | (experimental) The total number of records this application, operator or task has emitted. |
MetricNumRecordsOutPerSecond(IMetricOptions) | (experimental) The total number of records this application, operator or task has emitted per second. |
MetricOldGenerationGCCount(IMetricOptions) | (experimental) The total number of old garbage collection operations that have occurred across all task managers. |
MetricOldGenerationGCTime(IMetricOptions) | (experimental) The total time spent performing old garbage collection operations. |
MetricThreadsCount(IMetricOptions) | (experimental) The total number of live threads used by the application. |
MetricUptime(IMetricOptions) | (experimental) The time that the job has been running without interruption. |
Properties
ApplicationArn
(experimental) The application ARN.
string ApplicationArn { get; }
Property Value
System.String
Remarks
Stability: Experimental
Attribute: true
ApplicationName
(experimental) The name of the Flink application.
string ApplicationName { get; }
Property Value
System.String
Remarks
Stability: Experimental
Attribute: true
Role
(experimental) The application IAM role.
virtual IRole Role { get; }
Property Value
Remarks
Stability: Experimental
Methods
AddToRolePolicy(PolicyStatement)
(experimental) Convenience method for adding a policy statement to the application role.
bool AddToRolePolicy(PolicyStatement policyStatement)
Parameters
- policyStatement PolicyStatement
Returns
System.Boolean
Remarks
Stability: Experimental
Metric(String, IMetricOptions)
(experimental) Return a CloudWatch metric associated with this Flink application.
Metric Metric(string metricName, IMetricOptions props = null)
Parameters
- metricName System.String
The name of the metric.
- props IMetricOptions
Customization properties.
Returns
Remarks
Stability: Experimental
MetricBackPressuredTimeMsPerSecond(IMetricOptions)
(experimental) The time (in milliseconds) this task or operator is back pressured per second.
Metric MetricBackPressuredTimeMsPerSecond(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricBusyTimePerMsPerSecond(IMetricOptions)
(experimental) The time (in milliseconds) this task or operator is busy (neither idle nor back pressured) per second.
Metric MetricBusyTimePerMsPerSecond(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Can be NaN, if the value could not be calculated.
Units: Milliseconds
Reporting Level: Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricCpuUtilization(IMetricOptions)
(experimental) The overall percentage of CPU utilization across task managers.
Metric MetricCpuUtilization(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
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
Stability: Experimental
MetricCurrentInputWatermark(IMetricOptions)
(experimental) The last watermark this application/operator/task/thread has received.
Metric MetricCurrentInputWatermark(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Application, Operator, Task, Parallelism
Default: maximum over 5 minutes
Stability: Experimental
MetricCurrentOutputWatermark(IMetricOptions)
(experimental) The last watermark this application/operator/task/thread has received.
Metric MetricCurrentOutputWatermark(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Application, Operator, Task, Parallelism
Default: maximum over 5 minutes
Stability: Experimental
MetricDowntime(IMetricOptions)
(experimental) The time elapsed during an outage for failing/recovering jobs.
Metric MetricDowntime(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Application
Default: average over 5 minutes
Stability: Experimental
MetricFullRestarts(IMetricOptions)
(experimental) The total number of times this job has fully restarted since it was submitted.
Metric MetricFullRestarts(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
This metric does not measure fine-grained restarts.
Units: Count
Reporting Level: Application
Default: sum over 5 minutes
Stability: Experimental
MetricHeapMemoryUtilization(IMetricOptions)
(experimental) Overall heap memory utilization across task managers.
Metric MetricHeapMemoryUtilization(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
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
Stability: Experimental
MetricIdleTimeMsPerSecond(IMetricOptions)
(experimental) The time (in milliseconds) this task or operator is idle (has no data to process) per second.
Metric MetricIdleTimeMsPerSecond(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
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
Stability: Experimental
MetricKpus(IMetricOptions)
(experimental) The number of Kinesis Processing Units that are used to run your stream processing application.
Metric MetricKpus(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
The average number of KPUs used each hour determines the billing for your application.
Units: Count
Reporting Level: Application
Default: average over 5 minutes
Stability: Experimental
MetricLastCheckpointDuration(IMetricOptions)
(experimental) The time it took to complete the last checkpoint.
Metric MetricLastCheckpointDuration(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Application
Default: maximum over 5 minutes
Stability: Experimental
MetricLastCheckpointSize(IMetricOptions)
(experimental) The total size of the last checkpoint.
Metric MetricLastCheckpointSize(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Bytes
Reporting Level: Application
Default: maximum over 5 minutes
Stability: Experimental
MetricManagedMemoryTotal(IMetricOptions)
(experimental) The total amount of managed memory.
Metric MetricManagedMemoryTotal(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Bytes
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricManagedMemoryUsed(IMetricOptions)
(experimental) The amount of managed memory currently used.
Metric MetricManagedMemoryUsed(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Bytes
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricManagedMemoryUtilization(IMetricOptions)
(experimental) Derived from managedMemoryUsed/managedMemoryTotal.
Metric MetricManagedMemoryUtilization(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Percentage
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricNumberOfFailedCheckpoints(IMetricOptions)
(experimental) The number of times checkpointing has failed.
Metric MetricNumberOfFailedCheckpoints(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count
Reporting Level: Application
Default: sum over 5 minutes
Stability: Experimental
MetricNumLateRecordsDropped(IMetricOptions)
(experimental) The number of records this operator or task has dropped due to arriving late.
Metric MetricNumLateRecordsDropped(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count
Reporting Level: Application, Operator, Task, Parallelism
Default: sum over 5 minutes
Stability: Experimental
MetricNumRecordsIn(IMetricOptions)
(experimental) The total number of records this application, operator, or task has received.
Metric MetricNumRecordsIn(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricNumRecordsInPerSecond(IMetricOptions)
(experimental) The total number of records this application, operator or task has received per second.
Metric MetricNumRecordsInPerSecond(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count/Second
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricNumRecordsOut(IMetricOptions)
(experimental) The total number of records this application, operator or task has emitted.
Metric MetricNumRecordsOut(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricNumRecordsOutPerSecond(IMetricOptions)
(experimental) The total number of records this application, operator or task has emitted per second.
Metric MetricNumRecordsOutPerSecond(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count/Second
Reporting Level: Application, Operator, Task, Parallelism
Default: average over 5 minutes
Stability: Experimental
MetricOldGenerationGCCount(IMetricOptions)
(experimental) The total number of old garbage collection operations that have occurred across all task managers.
Metric MetricOldGenerationGCCount(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count
Reporting Level: Application
Default: sum over 5 minutes
Stability: Experimental
MetricOldGenerationGCTime(IMetricOptions)
(experimental) The total time spent performing old garbage collection operations.
Metric MetricOldGenerationGCTime(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Application
Default: sum over 5 minutes
Stability: Experimental
MetricThreadsCount(IMetricOptions)
(experimental) The total number of live threads used by the application.
Metric MetricThreadsCount(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Count
Reporting Level: Application
Default: average over 5 minutes
Stability: Experimental
MetricUptime(IMetricOptions)
(experimental) The time that the job has been running without interruption.
Metric MetricUptime(IMetricOptions props = null)
Parameters
- props IMetricOptions
Returns
Remarks
Units: Milliseconds
Reporting Level: Application
Default: sample count over 5 minutes
Stability: Experimental