Package org.apache.iceberg.flink.util
package org.apache.iceberg.flink.util
-
ClassesClassDescriptionThis gauge measures the elapsed time between now and last recorded time set by
ElapsedTimeGauge.refreshLastRecordedTime().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.Helper class to serialize and deserialize strings longer than 65K.