Package org.apache.paimon.utils

Interface Summary

Interface	Description
BatchRecordWriter	Write BundleRecords directly.
BiFunctionWithIOE<T,U,R>	A bi function with IOException.
CloseableIterator<T>	This interface represents an Iterator that is also AutoCloseable.
FieldsComparator	A Comparator to compare fields for InternalRow.
Filter<T>	Represents a filter (boolean-valued function) of one argument.
FunctionWithException<T,R,E extends Throwable>	A functional interface for a Function that may throw exceptions.
FunctionWithIOException<T,R>	A FunctionWithException with IOException.
IntIterator	Iterator for ints.
IOExceptionSupplier<T>	A Supplier throws IOException.
IOFunction<T,R>	A functional interface for a Function that may throw IOException.
IteratorWithException<V,E extends Exception>	An iterator which might throws exception.
JsonDeserializer<T>	Json deserializer for jackson.
JsonSerializer<T>	Json serializer for jackson.
KeyValueIterator<K,V>	An iterator for Key and Value.
MutableObjectIterator<E>	A simple iterator interface.
ParallelExecution.ParallelBatch<T,E>	A batch provides next and extra message.
PathFactory	Path factory to create a path.
Pool.Recycler<T>	A Recycler puts objects into the pool that the recycler is associated with.
RecordWriter<T>	The RecordWriter is responsible for writing data and handling in-progress files used to write yet un-staged data.
Restorable<S>	Operations implementing this interface can checkpoint and restore their states between different instances.
RowIterator	A simple iterator which provides simple next.
SerBiFunction<T,U,R>	A BiFunction that is also Serializable.
SerializableFunction<T,R>	A Function that is also Serializable.
SerializableRunnable	A serializable Runnable.
SerializableSupplier<T>	A serializable Supplier.
SimpleFileReader<T>	A reader for reading file to entries.
ThrowingConsumer<T,E extends Throwable>	This interface is basically Java's Consumer interface enhanced with the ability to throw an exception.

Class Summary

Class	Description
ArrayUtils	Utils for array.
AsyncRecordReader<T>	A RecordReader to use ASYNC_EXECUTOR to read records async.
BinaryRowDataUtil	Utilities for BinaryRow.
BinaryStringUtils	Util for BinaryString.
BinPacking	Contains bin packing implementations.
BitSet	BitSet based on MemorySegment.
BlockingExecutor	A executor wrapper to execute with Semaphore.
BloomFilter	Bloom filter based on one memory segment.
BloomFilter.Builder	Bloom filter based on one memory segment.
BloomFilter64	Bloom filter 64 handle 64 bits hash.
BloomFilter64.BitSet	Bit set used for bloom filter 64.
BooleanArrayList	Minimal implementation of an array-backed list of booleans.
BranchManager	Manager for Branch.
BulkFormatMapping	Class with index mapping and bulk format.
CloseableIterator.IteratorAdapter<E>	Adapter from Iterator to CloseableIterator.
CommitIncrement	Changes to commit.
ConvertBinaryUtil	BinaryUtil util to convert the value to binary.
DateTimeUtils	Utils for date time.
DecimalUtils	Utilities for Decimal.
EncodingUtils	General utilities for string-encoding.
ExceptionUtils	A collection of utility functions for dealing with exceptions and exception workflows.
ExecutorThreadFactory	A thread factory intended for use by critical thread pools.
ExecutorThreadFactory.Builder	Builder for ExecutorThreadFactory.
ExecutorUtils	Utilities for Executors.
FatalExitExceptionHandler	Handler for uncaught exceptions that will log the exception and kill the process afterwards.
FileBasedBloomFilter	Util to apply a built bloom filter .
FileDeletionThreadPool	Thread pool to delete files using FileIO.
FileIOUtils	This is a utility class to deal files and directories.
FileStorePathFactory	Factory which produces Paths for manifest files.
FileUtils	Utils for file reading and writing.
FixLenByteArrayOutputStream	A ByteArrayOutputStream which can reuse byte array.
FutureUtils	A collection of utilities that expand the usage of CompletableFuture.
HadoopUtils	Utility class for working with Hadoop-related classes.
HllSketchUtil	A compressed bitmap for 32-bit integer.
IDMapping<T>	Incremental id generation.
InstantiationUtil	Utility class to create instances from class objects and checking failure reasons.
InstantiationUtil.ClassLoaderObjectInputStream	A custom ObjectInputStream that can load classes using a specific ClassLoader.
Int2ShortHashMap	Int to short hash map.
Int2ShortHashMap.Builder	Builder of Int2ShortHashMap.
IntArrayList	Minimal implementation of an array-backed list of ints.
InternalRowPartitionComputer	PartitionComputer for InternalRow.
InternalRowUtils	Utils for InternalRow structures.
IntFileUtils	File to store ints.
IntHashSet	A hash set for ints.
IntObjectSerializer	A ObjectSerializer for int.
IOUtils	An utility class for I/O related functionality.
IteratorRecordReader<T>	Wrap a Iterator as an RecordReader.
IteratorResultIterator	A simple RecordReader.RecordIterator that returns the elements of an iterator.
JsonSerdeUtil	A utility class that provide abilities for JSON serialization and deserialization.
KeyComparatorSupplier	A Supplier that returns the comparator for the file store key.
KeyProjectedRow	A InternalRow to project key fields with RowKind.INSERT.
KeyValueWithLevelNoReusingSerializer	Serializer for KeyValue with Level.
LazyField<T>	A class to lazy initialized field.
ListDelimitedSerializer	Encapsulates a logic of serialization and deserialization of a list with a delimiter.
LocalFileUtils	Utils for local file.
LongArrayList	Minimal implementation of an array-backed list of longs.
LongCounter	An counter that sums up long values.
ManifestReadThreadPool	Thread pool to read manifests.
MapBuilder<K,V>	Build for Map.
MathUtils	Collection of simple mathematical routines.
MurmurHashUtils	Murmur Hash.
NextSnapshotFetcher	Fetcher for getting the next snapshot by snapshot id.
ObjectsCache<K,V>	Cache records to SegmentsCache by compacted serializer.
ObjectSerializer<T>	A serializer to serialize object by InternalRowSerializer.
ObjectsFile<T>	A file which contains several Ts, provides read and write.
ObjectUtils	Utils for objects.
OffsetRow	A InternalRow to wrap row with offset.
OptionalUtils	Utils for Optional.
Pair<L,R>	Pair contains left and right.
ParallelExecution<T,E>	A class to help parallel execution.
ParameterUtils	This is a util class for converting string parameter to another format.
PartialRow	A InternalRow to wrap row with partial fields.
PartitionPathUtils	Utils for file system.
Pool<T>	A pool to cache and recycle heavyweight objects, to reduce object allocation.
PositiveIntInt	IntInt pojo class.
PositiveIntIntSerializer	A SerializerSingleton for PositiveIntInt.
Preconditions	A collection of static utility methods to validate input.
ProjectedRow	An implementation of InternalRow which provides a projected view of the underlying InternalRow.
Projection	Projection represents a list of (possibly nested) indexes that can be used to project data types.
ProjectToRowFunction	Project BinaryRow fields into InternalRow.
RecyclableIterator<E>	Utility base class for iterators that accept a recycler.
Reference<T>	Refer a object.
ReflectionUtils	Utils for java reflection.
ReuseByteArrayOutputStream	A ByteArrayOutputStream which can reuse byte array.
RoaringBitmap32	A compressed bitmap for 32-bit integer.
RoaringBitmap64	A compressed bitmap for 64-bit integer.
RowDataToObjectArrayConverter	Convert InternalRow to object array.
SegmentsCache<T>	Cache Segments.
SerializationUtils	Utils for serialization.
SnapshotManager	Manager for Snapshot, providing utility methods related to paths and snapshot hints.
SortUtil	Util for sort.
StatsCollectorFactories	The stats utils to create SimpleColStatsCollector.Factorys.
StringUtils	Utils for BinaryString and utility class to convert objects into strings in vice-versa.
TagManager	Manager for Tag.
ThetaSketch	A compressed bitmap for 32-bit integer.
ThreadPoolUtils	Utils for thread pool.
ThreadUtils	Utils for thread.
TimeUtils	Collection of utilities about time intervals.
Triple<T0,T1,T2>	Container that accommodates three fields.
TypeCheckUtils	Utils for type.
TypeUtils	Type related helper functions.
UserDefinedSeqComparator	A FieldsComparator for user defined sequence fields.
ValueEqualiserSupplier	A Supplier that returns the equaliser for the file store value.
VarLengthIntUtils	Utils for encoding int/long to var length bytes.
VectorMappingUtils	This is a util about how to expand the ColumnVectors with the partition row and index mapping.
VersionedObjectSerializer<T>	A ObjectSerializer for versioned serialization.
ZOrderByteUtils	Within Z-Ordering the byte representations of objects being compared must be ordered, this requires several types to be transformed when converted to bytes.

Enum Summary

Enum	Description
HadoopUtils.HadoopConfigLoader	Specifies the way of loading hadoop config.
OperatingSystem	An enumeration indicating the operating system that the JVM runs on.

Exception Summary

Exception	Description
SnapshotNotExistException	Thrown by TagManager or SnapshotManager when the specified snapshotId does not exist.