| AbstractFlinkService |
An abstract FlinkService containing some common implementations for the native and
standalone Flink Services.
|
| CheckpointHistoryWrapper |
Custom Response for handling checkpoint history in a multi-version compatible way.
|
| CustomCheckpointingStatisticsHeaders |
Custom Headers for handling checkpoint history in a multi-version compatible way.
|
| CustomDashboardConfiguration |
Custom Response for handling dashboard configs.
|
| CustomDashboardConfigurationHeaders |
|
| FlinkServiceFactory |
The factory to create the FlinkService based on the FlinkDeployment mode.
|
| NativeFlinkService |
Implementation of FlinkService submitting and interacting with Native Kubernetes Flink
clusters and jobs.
|
| StandaloneFlinkService |
Implementation of FlinkService submitting and interacting with Standalone Kubernetes
Flink clusters and jobs.
|