Versions in this module Expand all Collapse all v0 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