| Class | Description |
|---|---|
| ElapsedTimeGauge |
This gauge measures the elapsed time between now and last recorded time set by
ElapsedTimeGauge.refreshLastRecordedTime(). |
| FlinkAlterTableUtil | |
| FlinkCompatibilityUtil |
This is a small util class that try to hide calls to Flink Internal or PublicEvolve interfaces as
Flink can change those APIs during minor version release.
|
| FlinkPackage |