Package org.apache.paimon.io

Interface Summary

Interface	Description
BundleRecords	Interface of bundle records.
DataFileIndexWriter.FileIndexResult	File index result.
DataInputView	This interface defines a view over some memory that can be used to sequentially read the contents of the memory.
DataOutputView	This interface defines a view over some memory that can be used to sequentially write contents to the memory.
FileReaderFactory<T>	Factory to read records from file.
FileWriter<T,R>	File writer to accept one record or a branch of records and generate metadata after closing it.
PageFileInput	An interface to read pages from file.
PageFileOutput	An interface to write bytes with pages into file.
SeekableDataInputView	Interface marking a DataInputView as seekable.

Class Summary

Class	Description
CompactIncrement	Files changed before and after compaction, with changelog produced during compaction.
CompressedPageFileInput	A class to wrap compressed RandomAccessFile.
CompressedPageFileOutput	A class to output bytes with compression.
DataFileIndexWriter	Index file writer for a data file.
DataFileMeta	Metadata of a data file.
DataFileMeta08Serializer	Serializer for DataFileMeta with safe deserializer.
DataFileMeta09Serializer	Serializer for DataFileMeta with 0.9 version.
DataFileMetaSerializer	Serializer for DataFileMeta.
DataFilePathFactory	Factory which produces new Paths for data files.
DataFileRecordReader	Reads InternalRow from data files.
DataIncrement	Newly created data files and changelog files.
DataInputDeserializer	A simple and efficient deserializer for the DataInput interface.
DataInputViewStream	An input stream that draws its data from a DataInputView.
DataInputViewStreamWrapper	Utility class that turns an InputStream into a DataInputView.
DataOutputSerializer	A simple and efficient serializer for the DataOutput interface.
DataOutputViewStream	An output stream that draws its data from a DataOutputView.
DataOutputViewStreamWrapper	Utility class that turns an OutputStream into a DataOutputView.
FileIndexEvaluator	Evaluate file index result.
IdentifierSerializer	Serializer for Identifier.
IndexIncrement	Incremental index files.
KeyValueDataFileRecordReader	RecordReader for reading KeyValue data files.
KeyValueDataFileWriter	A StatsCollectingSingleFileWriter to write data files containing KeyValues.
KeyValueFileReaderFactory	Factory to create RecordReaders for reading KeyValue files.
KeyValueFileReaderFactory.Builder	Builder for KeyValueFileReaderFactory.
KeyValueFileWriterFactory	A factory to create FileWriters for writing KeyValue files.
KeyValueFileWriterFactory.Builder	Builder of KeyValueFileWriterFactory.
RecordLevelExpire	A factory to create RecordReader expires records by time.
RollingFileWriter<T,R>	Writer to roll over to a new file if the current size exceed the target file size.
RowDataFileWriter	A StatsCollectingSingleFileWriter to write data files containing InternalRow.
RowDataRollingFileWriter	RollingFileWriter for data files containing InternalRow.
SingleFileWriter<T,R>	A FileWriter to produce a single file.
SingleFileWriter.AbortExecutor	Abort executor to just have reference of path instead of whole writer.
SplitsParallelReadUtil	An util class to wrap ParallelExecution to parallel execution for Split reader.
StatsCollectingSingleFileWriter<T,R>	A SingleFileWriter which also produces statistics for each written field.
UncompressedPageFileInput	A class to wrap uncompressed RandomAccessFile.
UncompressedPageFileOutput	A class to wrap uncompressed FileOutputStream.