Versions in this module Expand all Collapse all v0 v0.4.0 Oct 12, 2026 Changes in this version + var ErrNegativeLimit = errors.New("paimon: read-builder limit must not be negative") + func StringBlobMapDescriptors(column arrow.Array, row int) (map[string][]byte, error) + type BlobReader struct + func NewBlobReader(storageOptions map[string]string) (*BlobReader, error) + func (r *BlobReader) Close() + func (r *BlobReader) OpenBlob(descriptor []byte) (*BlobStream, error) + func (r *BlobReader) ReadBlob(descriptor []byte) ([]byte, error) + func (r *BlobReader) ReadBlobs(descriptors [][]byte) ([][]byte, error) + type BlobStream struct + func (s *BlobStream) Close() error + func (s *BlobStream) Read(buffer []byte) (int, error) + func (s *BlobStream) Seek(offset int64, whence int) (int64, error) type Catalog + func (c *Catalog) CreateTag(id Identifier, tagName string, snapshotID *int64, ignoreIfExists bool) error + func (c *Catalog) DeleteTag(id Identifier, tagName string) error + func (c *Catalog) GetTag(id Identifier, tagName string) (GetTagResponse, error) + func (c *Catalog) ListDatabases() ([]string, error) + func (c *Catalog) ListTables(database string) ([]string, error) + type CommitKind string + const CommitKindAnalyze + const CommitKindAppend + const CommitKindCompact + const CommitKindOverwrite + type CommitMessages struct + func (m *CommitMessages) Close() + func (m *CommitMessages) Merge(source *CommitMessages) error type ErrorCode + const CodeResourceExhausted + type GetTagResponse struct + Snapshot Snapshot + TagCreateTime *int64 + TagName string + TagTimeRetained *string + type PostponeFixedBucketCommitMessages struct + func (m *PostponeFixedBucketCommitMessages) Close() + func (m *PostponeFixedBucketCommitMessages) Merge(source *PostponeFixedBucketCommitMessages) error + type PostponeFixedBucketTableCommit struct + func (tc *PostponeFixedBucketTableCommit) Abort(messages *PostponeFixedBucketCommitMessages) error + func (tc *PostponeFixedBucketTableCommit) Close() + func (tc *PostponeFixedBucketTableCommit) Commit(messages *PostponeFixedBucketCommitMessages) error + func (tc *PostponeFixedBucketTableCommit) CommitWithIdentifier(messages *PostponeFixedBucketCommitMessages, commitIdentifier int64) error + func (tc *PostponeFixedBucketTableCommit) FilterAndCommitWithIdentifier(messages *PostponeFixedBucketCommitMessages, commitIdentifier int64) error + func (tc *PostponeFixedBucketTableCommit) TruncateTable() error + func (tc *PostponeFixedBucketTableCommit) TruncateTableWithIdentifier(commitIdentifier int64) error + type PostponeFixedBucketTableWrite struct + func (tw *PostponeFixedBucketTableWrite) Close() + func (tw *PostponeFixedBucketTableWrite) PrepareCommit() (*PostponeFixedBucketCommitMessages, error) + func (tw *PostponeFixedBucketTableWrite) WriteArrowBatch(record arrow.Record) error + type PostponeFixedBucketWriteBuilder struct + func (wb *PostponeFixedBucketWriteBuilder) Close() + func (wb *PostponeFixedBucketWriteBuilder) NewCommit() (*PostponeFixedBucketTableCommit, error) + func (wb *PostponeFixedBucketWriteBuilder) NewWrite() (*PostponeFixedBucketTableWrite, error) + func (wb *PostponeFixedBucketWriteBuilder) WithBucketPlan(plan arrow.Record) error + func (wb *PostponeFixedBucketWriteBuilder) WithOverwrite() error + func (wb *PostponeFixedBucketWriteBuilder) WithResources(resources *ResourceContext) error type PredicateBuilder + func (pb *PredicateBuilder) Between(column string, low, high any) (*Predicate, error) + func (pb *PredicateBuilder) Contains(column string, substr string) (*Predicate, error) + func (pb *PredicateBuilder) EndsWith(column string, suffix string) (*Predicate, error) + func (pb *PredicateBuilder) Like(column string, pattern string) (*Predicate, error) + func (pb *PredicateBuilder) NotBetween(column string, low, high any) (*Predicate, error) + func (pb *PredicateBuilder) StartsWith(column string, prefix string) (*Predicate, error) + func (pb *PredicateBuilder) WithCaseSensitive(caseSensitive bool) *PredicateBuilder type ReadBuilder + func (rb *ReadBuilder) WithCaseSensitive(caseSensitive bool) error + func (rb *ReadBuilder) WithLimit(limit int) error + func (rb *ReadBuilder) WithResources(resources *ResourceContext) error + type ResourceContext struct + func NewResourceContext(memoryLimitBytes uintptr) (*ResourceContext, error) + func (r *ResourceContext) Close() + func (r *ResourceContext) Metrics() (ResourceMetrics, error) + type ResourceMetrics struct + PeakReservedMemoryBytes uintptr + ReservedMemoryBytes uintptr + type Snapshot struct + CommitKind CommitKind + DeltaRecordCount *int64 + ID int64 + TimeMillis int64 + TotalRecordCount *int64 type Table + func (t *Table) LatestSnapshot() (*Snapshot, error) + func (t *Table) NewBlobReader() (*BlobReader, error) + func (t *Table) NewPostponeFixedBucketWriteBuilder() (*PostponeFixedBucketWriteBuilder, error) + func (t *Table) NewPostponeFixedBucketWriteBuilderWithCommitUser(commitUser string) (*PostponeFixedBucketWriteBuilder, error) + func (t *Table) NewReadBuilderWithOptions(options map[string]string) (*ReadBuilder, error) + func (t *Table) NewWriteBuilder() (*WriteBuilder, error) + func (t *Table) NewWriteBuilderWithCommitUser(commitUser string) (*WriteBuilder, error) + type TableCommit struct + func (tc *TableCommit) Abort(messages *CommitMessages) error + func (tc *TableCommit) Close() + func (tc *TableCommit) Commit(messages *CommitMessages) error + func (tc *TableCommit) CommitWithIdentifier(messages *CommitMessages, commitIdentifier int64) error + func (tc *TableCommit) FilterAndCommitWithIdentifier(messages *CommitMessages, commitIdentifier int64) error + func (tc *TableCommit) TruncateTable() error + func (tc *TableCommit) TruncateTableWithIdentifier(commitIdentifier int64) error + type TableWrite struct + func (tw *TableWrite) Close() + func (tw *TableWrite) PrepareCommit() (*CommitMessages, error) + func (tw *TableWrite) WriteArrowBatch(record arrow.Record) error + type WriteBuilder struct + func (wb *WriteBuilder) Close() + func (wb *WriteBuilder) NewCommit() (*TableCommit, error) + func (wb *WriteBuilder) NewWrite() (*TableWrite, error) + func (wb *WriteBuilder) WithOverwrite() error + func (wb *WriteBuilder) WithResources(resources *ResourceContext) error v0.4.0-rc2 Oct 8, 2026 v0.4.0-rc1 Sep 20, 2026 v0.3.0 Jul 27, 2026 v0.3.0-rc1 Jul 23, 2026 v0.2.0 May 28, 2026 v0.2.0-rc1 May 20, 2026 v0.1.0 Apr 29, 2026 Changes in this version + var ErrClosed = errors.New("paimon: use of closed resource") + type Bytes []byte + type Catalog struct + func NewCatalog(options map[string]string) (*Catalog, error) + func (c *Catalog) Close() + func (c *Catalog) GetTable(id Identifier) (*Table, error) + type DataSplit struct + type Date int32 + type Datum struct + func BoolDatum(v bool) Datum + func DoubleDatum(v float64) Datum + func FloatDatum(v float32) Datum + func IntDatum(v int32) Datum + func LongDatum(v int64) Datum + func SmallIntDatum(v int16) Datum + func StringDatum(v string) Datum + func TinyIntDatum(v int8) Datum + type Decimal struct + Hi int64 + Lo int64 + Precision uint32 + Scale uint32 + func NewDecimal(unscaled int64, precision, scale uint32) Decimal + type Error struct + func (e *Error) Code() ErrorCode + func (e *Error) Error() string + func (e *Error) Message() string + type ErrorCode int32 + const CodeAlreadyExist + const CodeInvalidInput + const CodeIoError + const CodeNotFound + const CodeUnexpected + const CodeUnsupported + type FFI struct + type Identifier struct + func NewIdentifier(database, object string) Identifier + type LocalZonedTimestamp struct + Millis int64 + Nanos int32 + type Plan struct + func (p *Plan) Close() + func (p *Plan) NumSplits() int + func (p *Plan) Splits() []DataSplit + type Predicate struct + func (p *Predicate) And(other *Predicate) (*Predicate, error) + func (p *Predicate) Close() + func (p *Predicate) Not() (*Predicate, error) + func (p *Predicate) Or(other *Predicate) (*Predicate, error) + type PredicateBuilder struct + func (pb *PredicateBuilder) Eq(column string, value any) (*Predicate, error) + func (pb *PredicateBuilder) Ge(column string, value any) (*Predicate, error) + func (pb *PredicateBuilder) Gt(column string, value any) (*Predicate, error) + func (pb *PredicateBuilder) In(column string, values ...any) (*Predicate, error) + func (pb *PredicateBuilder) IsNotNull(column string) (*Predicate, error) + func (pb *PredicateBuilder) IsNull(column string) (*Predicate, error) + func (pb *PredicateBuilder) Le(column string, value any) (*Predicate, error) + func (pb *PredicateBuilder) Lt(column string, value any) (*Predicate, error) + func (pb *PredicateBuilder) NotEq(column string, value any) (*Predicate, error) + func (pb *PredicateBuilder) NotIn(column string, values ...any) (*Predicate, error) + type ReadBuilder struct + func (rb *ReadBuilder) Close() + func (rb *ReadBuilder) NewRead() (*TableRead, error) + func (rb *ReadBuilder) NewScan() (*TableScan, error) + func (rb *ReadBuilder) WithFilter(p *Predicate) error + func (rb *ReadBuilder) WithProjection(columns []string) error + type RecordBatchReader struct + func (r *RecordBatchReader) Close() + func (r *RecordBatchReader) NextRecord() (arrow.Record, error) + type Table struct + func (t *Table) Close() + func (t *Table) NewReadBuilder() (*ReadBuilder, error) + func (t *Table) PredicateBuilder() *PredicateBuilder + type TableRead struct + func (tr *TableRead) Close() + func (tr *TableRead) NewRecordBatchReader(splits []DataSplit) (*RecordBatchReader, error) + type TableScan struct + func (ts *TableScan) Close() + func (ts *TableScan) Plan() (*Plan, error) + type Time int32 + type Timestamp struct + Millis int64 + Nanos int32 v0.1.0-rc2 Apr 24, 2026 v0.1.0-rc1 Apr 15, 2026
Go to main page