FlinkApplicationConfiguration class

Describes configuration parameters for a Flink-based Kinesis Data Analytics application.

Constructors

FlinkApplicationConfiguration({CheckpointConfiguration? checkpointConfiguration, MonitoringConfiguration? monitoringConfiguration, ParallelismConfiguration? parallelismConfiguration})

Properties

checkpointConfiguration CheckpointConfiguration?
Describes an application's checkpointing configuration. Checkpointing is the process of persisting application state for fault tolerance. For more information, see Checkpoints for Fault Tolerance in the Apache Flink Documentation.
final
hashCode int
The hash code for this object.
no setterinherited
monitoringConfiguration MonitoringConfiguration?
Describes configuration parameters for Amazon CloudWatch logging for an application.
final
parallelismConfiguration ParallelismConfiguration?
Describes parameters for how an application executes multiple tasks simultaneously.
final
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toJson() Map<String, dynamic>
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited