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.
|
CheckpointHistoryWrapper.CompletedCheckpointInfo |
Information about the latest completed checkpoint/savepoint.
|
CheckpointHistoryWrapper.PendingCheckpointInfo |
Information about the currently pending checkpoint/savepoint.
|
CustomCheckpointingStatisticsHeaders |
Custom Headers for handling checkpoint history in a multi-version compatible way.
|
CustomDashboardConfiguration |
Custom Response for handling dashboard configs.
|
CustomDashboardConfigurationHeaders |
|
FlinkResourceContextFactory |
|
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.
|