Package org.apache.iceberg.flink.util
-
Class Summary Class Description ElapsedTimeGauge This gauge measures the elapsed time between now and last recorded time set byElapsedTimeGauge.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