| Modifier and Type | Class and Description |
|---|---|
class |
Snapshot
This file is the entrance to all data committed at some specific time point.
|
| Modifier and Type | Class and Description |
|---|---|
interface |
Public
Annotation for marking classes as public, stable interfaces.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Catalog
This interface is responsible for reading and writing metadata such as database/table from a
paimon catalog.
|
class |
CatalogContext
Context of catalog.
|
interface |
CatalogFactory
Factory to create
Catalog. |
interface |
CatalogLock
An interface that allows source and sink to use global lock to some transaction-related things.
|
class |
Identifier
Identifies an object in a catalog.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BinaryArray
A binary implementation of
InternalArray which is backed by MemorySegments. |
class |
BinaryMap
[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
|
class |
BinaryRow
An implementation of
InternalRow which is backed by MemorySegment instead of
Object. |
class |
BinaryString
A string which is backed by
MemorySegments. |
interface |
DataGetters
Getters to get data.
|
class |
Decimal
An internal data structure representing data of
DecimalType. |
class |
GenericArray
An internal data structure representing data of
ArrayType. |
class |
GenericMap
An internal data structure representing data of
MapType or MultisetType. |
class |
GenericRow
An internal data structure representing data of
RowType. |
interface |
InternalArray
Base interface of an internal data structure representing data of
ArrayType. |
interface |
InternalMap
Base interface of an internal data structure representing data of
MapType or MultisetType. |
interface |
InternalRow
Base interface for an internal data structure representing data of
RowType. |
class |
JoinedRow
An implementation of
InternalRow which is backed by two concatenated InternalRow. |
class |
LocalZoneTimestamp
An internal data structure representing data of
LocalZonedTimestampType. |
class |
Timestamp
An internal data structure representing data of
TimestampType. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BufferFileReader
Read
Buffer from file. |
interface |
BufferFileWriter
Write
MemorySegment to file. |
interface |
FileIOChannel
A Channel represents a collection of files that belong logically to the same resource.
|
interface |
IOManager
The facade for the provided disk I/O services.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FlinkSinkBuilder
DataStream API for building Flink Sink.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RichCdcSinkBuilder
DataStream API for building Flink Sink for
RichCdcRecord to write with schema evolution. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
FileIO
File IO to read and write file.
|
interface |
FileIOLoader
Loader to load
FileIO. |
interface |
FileStatus
Interface that represents the client side information for a file independent of the file system.
|
class |
Path
Names a file or directory in a
FileIO. |
class |
PositionOutputStream
PositionOutputStream provides position methods. |
class |
SeekableInputStream
SeekableInputStream provides seek methods. |
class |
UnsupportedSchemeException
An exception to indicate that a specific file system scheme is not supported.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IndexFileMeta
Metadata of index file.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
BundleRecords
Interface of bundle records.
|
class |
DataFileMeta
Metadata of a data file.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BucketEntry
Entry representing a bucket.
|
class |
FileKind
Kind of a file.
|
class |
IndexManifestEntry
Manifest entry for index file.
|
class |
ManifestEntry
Entry of a manifest file, representing an addition / deletion of a data file.
|
class |
ManifestFileMeta
Metadata of a manifest file.
|
class |
PartitionEntry
Entry representing a partition.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Buffer
A buffer with size.
|
class |
MemorySegment
This class represents a piece of memory.
|
interface |
MemorySegmentPool
MemorySegment pool to hold pages in memory.
|
interface |
MemorySegmentSource
Interface describing entities that can provide memory segments.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Counter
A Counter is a
Metric that measures a count. |
interface |
Gauge<T>
A Gauge is a
Metric that calculates a specific value at a point in time. |
interface |
Histogram
The histogram allows to record values, get the current count of recorded values and create
histogram statistics for the currently seen elements.
|
class |
HistogramStatistics
Histogram statistics represent the current snapshot of elements recorded in the histogram.
|
interface |
Metric
An interface to indicate a class is a metric.
|
interface |
MetricGroup
A MetricGroup is a named container for
Metrics and further metric subgroups. |
class |
MetricType
Enum describing the different metric types.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Lock
An interface that allows file store to use global lock to some transaction-related things.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ConfigOption<T>
A
ConfigOption describes a configuration parameter. |
class |
ConfigOptions
ConfigOptions are used to build a ConfigOption. |
class |
MemorySize
MemorySize is a representation of a number of bytes, viewable in different units.
|
class |
Options
Options which stores key/value pairs.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Description
Description for
ConfigOption. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
Predicate
Predicate which returns Boolean and provides testing by stats.
|
class |
PredicateBuilder
A utility class to create
Predicate object for common filter conditions. |
| Modifier and Type | Class and Description |
|---|---|
class |
EntityType
Entity type in privilege system.
|
class |
PrivilegeType
Types of privilege.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
RecordReader<T>
The reader that reads the batches of records.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Schema
Schema of a table.
|
interface |
SchemaChange
Schema change to table.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SecurityContext
Security context that provides security module install and holds the security context.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SimpleStats
The statistics for columns, supports the following stats.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
FormatTable
A file format table refers to a directory that contains multiple files of the same format, where
operations on this table allow for reading or writing to these files, facilitating the retrieval
of existing data and the addition of new files.
|
interface |
Table
A table provides basic abstraction for table type and table scan and table read.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
BatchTableCommit
A
TableCommit for batch processing. |
interface |
BatchTableWrite
A
TableWrite for batch processing. |
interface |
BatchWriteBuilder
An interface for building the
BatchTableWrite and BatchTableCommit. |
interface |
CommitMessage
Commit message for partition and bucket.
|
interface |
StreamTableCommit
A
TableCommit for stream processing. |
interface |
StreamTableWrite
A
TableWrite for stream processing. |
interface |
StreamWriteBuilder
An interface for building the
StreamTableWrite and StreamTableCommit. |
interface |
TableCommit
Create and commit snapshots of a
Table. |
interface |
TableWrite
Write of
Table to provide InternalRow writing. |
interface |
WriteBuilder
An interface for building the
TableWrite and TableCommit. |
| Modifier and Type | Class and Description |
|---|---|
class |
DeletionFile
Deletion file for data file, the first 4 bytes are length, should, the following is the bitmap
content.
|
class |
EndOfScanException
Signals that an end of scanning has been reached unexpectedly during input.
|
class |
RawFile
A data file from the table which can be read directly without merging.
|
interface |
ReadBuilder
|
interface |
Split
An input split for reading.
|
interface |
StreamTableScan
TableScan for streaming, supports StreamTableScan.checkpoint() and StreamTableScan.restore(java.lang.Long). |
interface |
TableRead
An abstraction layer above
SplitRead to provide reading of InternalRow. |
interface |
TableScan
|
static interface |
TableScan.Plan
Plan of scan.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ArrayType
Data type of an array of elements with same subtype.
|
class |
BigIntType
Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to
9,223,372,036,854,775,807.
|
class |
BinaryType
Data type of a fixed-length binary string (=a sequence of bytes).
|
class |
BooleanType
Data type of a boolean with a (possibly) three-valued logic of
TRUE, FALSE, UNKNOWN. |
class |
CharType
Data type of a fixed-length character string.
|
class |
DataField
Defines the field of a row type.
|
class |
DataType
Describes the data type in the paimon ecosystem.
|
class |
DataTypeDefaultVisitor<R>
Implementation of
DataTypeVisitor that redirects all calls to DataTypeDefaultVisitor.defaultMethod(DataType). |
class |
DataTypeFamily
An enumeration of Data type families for clustering
DataTypeRoots into categories. |
class |
DataTypeRoot
An enumeration of Data type roots containing static information about logical data types.
|
class |
DataTypes
Utils for creating
DataTypes. |
interface |
DataTypeVisitor<R>
The visitor definition of
DataType. |
class |
DateType
Data type of a date consisting of
year-month-day with values ranging from 0000-01-01 to 9999-12-31. |
class |
DecimalType
Data type of a decimal number with fixed precision and scale.
|
class |
DoubleType
Data type of an 8-byte double precision floating point number.
|
class |
FloatType
Data type of a 4-byte single precision floating point number.
|
class |
IntType
Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
|
class |
LocalZonedTimestampType
Data type of a timestamp WITH LOCAL time zone consisting of
year-month-day
hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from
0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59. |
class |
MapType
Data type of an associative array that maps keys (including
NULL) to values (including
NULL). |
class |
MultisetType
Data type of a multiset (=bag).
|
class |
RowKind
Lists all kinds of changes that a row can describe in a changelog.
|
class |
RowType
Data type of a sequence of fields.
|
class |
SmallIntType
Data type of a 2-byte signed integer with values from -32,768 to 32,767.
|
class |
TimestampType
Data type of a timestamp WITHOUT time zone consisting of
year-month-day
hour:minute:second[.fractional] with up to nanosecond precision and values ranging from 0000-01-01 00:00:00.000000000 to 9999-12-31 23:59:59.999999999. |
class |
TimeType
Data type of a time WITHOUT time zone consisting of
hour:minute:second[.fractional] with
up to nanosecond precision and values ranging from 00:00:00.000000000 to 23:59:59.999999999. |
class |
TinyIntType
Data type of a 1-byte signed integer with values from -128 to 127.
|
class |
VarBinaryType
Data type of a variable-length binary string (=a sequence of bytes).
|
class |
VarCharType
Data type of a variable-length character string.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CloseableIterator<T>
This interface represents an
Iterator that is also AutoCloseable. |
interface |
Restorable<S>
Operations implementing this interface can checkpoint and restore their states between different
instances.
|
interface |
SimpleFileReader<T>
A reader for reading file to entries.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.