Package org.apache.flink.table.runtime.util
-
Interface Summary Interface Description KeyValueIterator<K,V> An internal iterator interface which presents a more restrictive API thanIterator.LRUMap.RemovalListener<K,V> An object that can receive a notification when an entry is removed from a LRUMap.MemorySegmentPool MemorySegment pool to hold pages in memory.ResettableRowBuffer Resettable buffer that addRowDataand returnBinaryRowDataiterator.ResettableRowBuffer.ResettableIterator Row iterator that can be reset.RowIterator<T extends org.apache.flink.table.data.RowData> An internal iterator interface which presents a more restrictive API thanIterator. -
Class Summary Class Description FileChannelUtil File channel util for runtime.LazyMemorySegmentPool MemorySegmentPoolthat lazy allocate memory pages fromMemoryManager.LRUMap<K,V> An LRU cache, based onLinkedHashMap.MurmurHashUtil Murmur hasher.ResettableExternalBuffer A resettable external buffer for binary row.SegmentsUtil Util for data format segments calc.SingleElementIterator<E> Copied fromSingleElementIterator.StateConfigUtil Utility to create aStateTtlConfigobject.StreamRecordCollector<T> Wrapper around anOutputfor wrapTtoStreamRecord.StringUtf8Utils String utf-8 utils.TimeWindowUtil Time util to deals window start and end in different timezone.WindowKey TheWindowKeystructure represents a combination of key and window.