Package org.apache.flink.table.runtime.util

Interface Summary

Interface	Description
KeyValueIterator<K,V>	An internal iterator interface which presents a more restrictive API than Iterator.
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 add RowData and return BinaryRowData iterator.
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 than Iterator.

Class Summary

Class	Description
EqualityAndHashcodeProvider	This class is used for scalar function, in that it is used for sharing the initialization context between scalar functions that need code generated hashcode and equals method.
FileChannelUtil	File channel util for runtime.
LazyMemorySegmentPool	MemorySegmentPool that lazy allocate memory pages from MemoryManager.
LRUMap<K,V>	An LRU cache, based on LinkedHashMap.
MurmurHashUtil	Murmur hasher.
ObjectContainer	This class is used for scalar function, in that it is used for comparing Objects using code generated hashCode and equals instead of using the Object#equals/Object#hashcode versions.
ResettableExternalBuffer	A resettable external buffer for binary row.
SegmentsUtil	Util for data format segments calc.
SingleElementIterator<E>	Copied from SingleElementIterator.
StateConfigUtil	Utility to create a StateTtlConfig object.
StreamRecordCollector<T>	Wrapper around an Output for wrap T to StreamRecord.
StringUtf8Utils	String utf-8 utils.
TimeWindowUtil	Time util to deals window start and end in different timezone.
WindowKey	The WindowKey structure represents a combination of key and window.