iceberg

package module

Go to main page

Versions in this module

v0

v0.7.0

Sep 28, 2026

Changes in this version

+ const DefaultGeoCRS

+ const EnvironmentEngineNameKey

+ const EnvironmentEngineVersionKey

+ const MaxStructFieldID

+ var ErrBBoxNotSerializable = fmt.Errorf("%w: geospatial bbox predicates cannot be serialized to REST expression JSON", ...)

+ var ErrEmptyManifest = errors.New("empty manifest file has been written")

+ var ErrExtractNotSerializable = fmt.Errorf("%w: variant extract terms cannot be serialized to REST expression JSON", ...)

+ var ErrInvalidFixedLength = errors.New("invalid fixed literal length")

+ func CloneDefaultValue(value any) any

+ func EntriesWithProjection(fs iceio.IO, m ManifestFile, discardDeleted bool, ...) iter.Seq2[ManifestEntry, error]

+ func EnvironmentContext() map[string]string

+ func IsReservedFieldID(fieldID int) bool

+ func NormalizeVariantPath(fields []string) string

+ func RemoveEnvironmentProperty(key string)

+ func SetEnvironmentProperty(key, value string)

+ func TranslateColumnNamesForScan(expr BooleanExpression, fileSchema *Schema) (BooleanExpression, []VariantExtractColumn, error)

+ func VisitBoundPredicateRef[T any](e BoundPredicate, visitor BoundBooleanExprVisitor[T], ...) T

+ func VisitExprEvaluator(expr BooleanExpression, visitor BooleanExprVisitor[bool]) (res bool, err error)

type AlwaysFalse

+ func (AlwaysFalse) MarshalJSON() ([]byte, error)

type AlwaysTrue

+ func (AlwaysTrue) MarshalJSON() ([]byte, error)

type AndExpr

+ func (a AndExpr) MarshalJSON() ([]byte, error)

type BinaryLiteral

+ func (l BinaryLiteral) MarshalJSON() ([]byte, error)

type BoolLiteral

+ func (l BoolLiteral) MarshalJSON() ([]byte, error)

type BooleanExpression

+ func ParseExpr(data []byte, schema *Schema) (BooleanExpression, error)

+ func SanitizeExpression(expr BooleanExpression) (BooleanExpression, error)

+ type BoundBBoxPredicate interface

+ BBox func() BoundingBox

+ type BoundExtract interface

+ ExtractValue func(v variant.Value) (Literal, bool)

+ Path func() string

+ type BoundGeospatialExprVisitor interface

+ VisitBBoxIntersects func(BoundTerm, BoundingBox) T

+ VisitBBoxNotIntersects func(BoundTerm, BoundingBox) T

type BoundTransform

+ func (b *BoundTransform) MarshalJSON() ([]byte, error)

+ type BoundingBox struct

+ MaxX float64

+ MaxY float64

+ MinX float64

+ MinY float64

+ func (b BoundingBox) Equals(other BoundingBox) bool

+ func (b BoundingBox) String() string

+ func (b BoundingBox) Valid() bool

type BucketTransform

+ func (t BucketTransform) ToHumanStrType(_ Type, val any) string

type DataFile

+ func DataFileWithoutColumnStats(file DataFile) DataFile

type DateLiteral

+ func (l DateLiteral) MarshalJSON() ([]byte, error)

type DayTransform

+ func (t DayTransform) ToHumanStrType(_ Type, val any) string

type DecimalLiteral

+ func (l DecimalLiteral) MarshalJSON() ([]byte, error)

+ type FieldLabel struct

+ FieldID int

+ Labels Properties

type FixedLiteral

+ func (l FixedLiteral) MarshalJSON() ([]byte, error)

type Float32Literal

+ func (l Float32Literal) MarshalJSON() ([]byte, error)

type Float64Literal

+ func (l Float64Literal) MarshalJSON() ([]byte, error)

+ type GeoLiteral struct

+ func (g GeoLiteral) Any() any

+ func (g GeoLiteral) Equals(other Literal) bool

+ func (g GeoLiteral) MarshalBinary() ([]byte, error)

+ func (g GeoLiteral) String() string

+ func (g GeoLiteral) To(typ Type) (Literal, error)

+ func (g GeoLiteral) Type() Type

+ func (g GeoLiteral) Value() []byte

+ type GeographyType struct

+ func GeographyTypeOf(crs string, algorithm string) (GeographyType, error)

+ func (g GeographyType) Algorithm() string

+ func (g GeographyType) CRS() string

+ func (g GeographyType) Equals(other Type) bool

+ func (g GeographyType) String() string

+ func (g GeographyType) Type() string

+ type GeometryType struct

+ func GeometryTypeOf(crs string) (GeometryType, error)

+ func (g GeometryType) CRS() string

+ func (g GeometryType) Equals(other Type) bool

+ func (g GeometryType) String() string

+ func (g GeometryType) Type() string

type HourTransform

+ func (t HourTransform) ToHumanStrType(_ Type, val any) string

type IdentityTransform

+ func (t IdentityTransform) ToHumanStrType(typ Type, val any) string

type Int32Literal

+ func (l Int32Literal) MarshalJSON() ([]byte, error)

type Int64Literal

+ func (l Int64Literal) MarshalJSON() ([]byte, error)

+ type Labels struct

+ Fields []FieldLabel

+ ObjectLabels Properties

+ func (l *Labels) Field(fieldID int) Properties

+ func (l *Labels) IsEmpty() bool

+ func (l *Labels) Object() Properties

type Literal

+ func CastVariantLiteral(v variant.Value, typ PrimitiveType) (Literal, bool)

type ManifestEntry

+ func ManifestEntryWithoutColumnStats(entry ManifestEntry) ManifestEntry

+ type ManifestEntryProjection struct

+ IncludePruningStats bool

type ManifestFile

+ func WriteManifestV3(filename string, out io.Writer, firstRowID int64, spec PartitionSpec, ...) (mf ManifestFile, nextFirstRowID int64, err error)

type ManifestReader

+ func NewManifestReaderWithProjection(file ManifestFile, in io.Reader, projection ManifestEntryProjection) (*ManifestReader, error)

type MonthTransform

+ func (t MonthTransform) ToHumanStrType(_ Type, val any) string

type NotExpr

+ func (n NotExpr) MarshalJSON() ([]byte, error)

type Operation

+ const OpBBoxIntersects

+ const OpBBoxNotIntersects

type OrExpr

+ func (o OrExpr) MarshalJSON() ([]byte, error)

type PartitionSpec

+ func (ps *PartitionSpec) Clone() PartitionSpec

+ func (ps *PartitionSpec) FieldsRef(_ internal.PartitionSpecRef) []PartitionField

type Properties

+ func (p Properties) GetInt64(key string, defVal int64) int64

+ func (p Properties) GetUInt64(key string, defVal uint64) uint64

type Reference

+ func (r Reference) MarshalJSON() ([]byte, error)

type Schema

+ func SchemaWithRowID(s *Schema) *Schema

+ func SchemaWithRowLineage(s *Schema) *Schema

+ func SchemaWithRowLineageColumns(s *Schema, rowID, lastUpdatedSeq bool) *Schema

+ func (s *Schema) FieldsRef(_ internal.SchemaRef) []NestedField

+ func (s *Schema) FindFieldByIDRef(id int, _ internal.SchemaRef) (NestedField, bool)

type SchemaVisitorPerPrimitiveType

+ VisitGeography func(GeographyType) T

+ VisitGeometry func(GeometryType) T

type StringLiteral

+ func (l StringLiteral) MarshalJSON() ([]byte, error)

type TimeLiteral

+ func (l TimeLiteral) MarshalJSON() ([]byte, error)

type TimestampLiteral

+ func (TimestampLiteral) MarshalJSON() ([]byte, error)

type TimestampNsLiteral

+ func (TimestampNsLiteral) MarshalJSON() ([]byte, error)

type Transform

+ ToHumanStrType func(typ Type, val any) string

type TruncateTransform

+ func (t TruncateTransform) ToHumanStrType(_ Type, val any) string

type UUIDLiteral

+ func (l UUIDLiteral) MarshalJSON() ([]byte, error)

+ type UnboundPartitionSpec struct

+ func (u *UnboundPartitionSpec) UnmarshalJSON(b []byte) error

type UnboundPredicate

+ func BBoxIntersects(t UnboundTerm, bbox BoundingBox) UnboundPredicate

type UnboundTerm

+ func Extract(ref Reference, path string, typ PrimitiveType) UnboundTerm

+ type UnboundTransform struct

+ func NewUnboundTransform(transform Transform, term UnboundTerm) *UnboundTransform

+ func (u *UnboundTransform) Bind(schema *Schema, caseSensitive bool) (BoundTerm, error)

+ func (u *UnboundTransform) Equals(other UnboundTerm) bool

+ func (u *UnboundTransform) MarshalJSON() ([]byte, error)

+ func (u *UnboundTransform) String() string

+ func (u *UnboundTransform) Transform() Transform

+ type UnknownTransform struct

+ func (UnknownTransform) Apply(Optional[Literal]) Optional[Literal]

+ func (UnknownTransform) CanTransform(Type) bool

+ func (UnknownTransform) PreservesOrder() bool

+ func (UnknownTransform) Project(string, BoundPredicate) (UnboundPredicate, error)

+ func (UnknownTransform) ResultType(Type) Type

+ func (UnknownTransform) ToHumanStr(val any) string

+ func (UnknownTransform) ToHumanStrType(typ Type, val any) string

+ func (t UnknownTransform) Equals(other Transform) bool

+ func (t UnknownTransform) MarshalText() ([]byte, error)

+ func (t UnknownTransform) String() string

+ type VariantExtractColumn struct

+ FieldID int

+ Name string

+ SourcePath []string

+ Term BoundExtract

type VoidTransform

+ func (VoidTransform) ToHumanStrType(Type, any) string

type YearTransform

+ func (t YearTransform) ToHumanStrType(_ Type, val any) string

v0.7.0-rc0

Sep 28, 2026

v0.6.0

May 21, 2026

Changes in this version

+ const LastUpdatedSequenceNumberColumnName

+ const LastUpdatedSequenceNumberFieldID

+ const RowIDColumnName

+ const RowIDFieldID

+ func IsMetadataColumn(fieldID int) bool

+ func PropUInt(p Properties, key string, defVal uint) uint

+ func SetSchemaCacheSize(size int) error

+ type AvroEntryMarshaler interface

+ MarshalAvroEntry func(spec PartitionSpec, schema *Schema, version int) ([]byte, error)

type FileFormat

+ const PuffinFile

+ func FileFormatFromString(s string) (FileFormat, error)

type ManifestFile

+ Entries func(fs iceio.IO, discardDeleted bool) iter.Seq2[ManifestEntry, error]

+ FirstRowID func() *int64

type ManifestReader

+ func (c *ManifestReader) Close() error

type NestedField

+ func LastUpdatedSequenceNumber() NestedField

+ func RowID() NestedField

type PartitionField

+ SourceIDs []int

+ func (p PartitionField) MarshalJSON() ([]byte, error)

type PreOrderSchemaVisitor

+ Variant func(VariantType) T

type SchemaVisitor

+ Variant func(v VariantType) T

type SchemaVisitorPerPrimitiveType

+ VisitVariant func() T

type SchemaWithPartnerVisitor

+ Variant func(v VariantType, variantPartner P) T

+ type StructLike interface

+ Get func(pos int) any

+ Set func(pos int, val any)

+ Size func() int

+ type VariantLiteral variant.Value

+ func (VariantLiteral) Comparator() Comparator[variant.Value]

+ func (VariantLiteral) Type() Type

+ func (v VariantLiteral) Any() any

+ func (v VariantLiteral) Equals(other Literal) bool

+ func (v VariantLiteral) MarshalBinary() ([]byte, error)

+ func (v VariantLiteral) String() string

+ func (v VariantLiteral) To(typ Type) (Literal, error)

+ func (v VariantLiteral) Value() variant.Value

+ type VariantType struct

+ func (VariantType) Equals(other Type) bool

+ func (VariantType) String() string

+ func (VariantType) Type() string

v0.6.0-rc2

May 21, 2026

v0.6.0-rc1

May 21, 2026

v0.6.0-rc0

May 18, 2026

v0.5.0

Feb 27, 2026

Changes in this version

+ type ManifestFileOption func(mf *manifestFile)

+ func WithManifestFileContent(content ManifestContent) ManifestFileOption

+ type ManifestWriterOption func(w *ManifestWriter)

+ func WithManifestWriterContent(content ManifestContent) ManifestWriterOption

type PartitionField

+ func (p *PartitionField) EscapedName() string

+ func (p PartitionField) Equals(other PartitionField) bool

type Schema

+ func (s *Schema) FlatFields() (iter.Seq[NestedField], error)

type SchemaVisitorPerPrimitiveType

+ VisitTimestampNs func() T

+ VisitTimestampNsTz func() T

+ VisitUnknown func() T

type Timestamp

+ func (t Timestamp) ToNanos() TimestampNano

+ type TimestampNano int64

+ func (t TimestampNano) ToDate() Date

+ func (t TimestampNano) ToMicros() Timestamp

+ func (t TimestampNano) ToTime() time.Time

+ type TimestampNsLiteral TimestampNano

+ func (TimestampNsLiteral) Comparator() Comparator[TimestampNano]

+ func (t *TimestampNsLiteral) UnmarshalBinary(data []byte) error

+ func (t TimestampNsLiteral) Any() any

+ func (t TimestampNsLiteral) Decrement() Literal

+ func (t TimestampNsLiteral) Equals(other Literal) bool

+ func (t TimestampNsLiteral) Increment() Literal

+ func (t TimestampNsLiteral) MarshalBinary() (data []byte, err error)

+ func (t TimestampNsLiteral) String() string

+ func (t TimestampNsLiteral) To(typ Type) (Literal, error)

+ func (t TimestampNsLiteral) Type() Type

+ func (t TimestampNsLiteral) Value() TimestampNano

+ type TimestampNsType struct

+ func (TimestampNsType) Equals(other Type) bool

+ func (TimestampNsType) String() string

+ func (TimestampNsType) Type() string

+ type TimestampTzNsType struct

+ func (TimestampTzNsType) Equals(other Type) bool

+ func (TimestampTzNsType) String() string

+ func (TimestampTzNsType) Type() string

+ type UnknownType struct

+ func (UnknownType) Equals(other Type) bool

+ func (UnknownType) String() string

+ func (UnknownType) Type() string

v0.5.0-rc0

Feb 27, 2026

v0.4.0

Oct 9, 2025

Changes in this version

+ const PartitionDataIDStart

+ var ErrInvalidFormatVersion = fmt.Errorf("%w: invalid format version", ErrInvalidArgument)

+ var ErrInvalidPartitionSpec = errors.New("invalid partition spec")

+ func GeneratePartitionFieldName(schema *Schema, field PartitionField) (string, error)

type BucketTransform

+ func (BucketTransform) CanTransform(t Type) bool

type DataFile

+ ContentOffset func() *int64

+ ContentSizeInBytes func() *int64

+ FirstRowID func() *int64

+ ReferencedDataFile func() *string

type DataFileBuilder

+ func (b *DataFileBuilder) ContentOffset(offset int64) *DataFileBuilder

+ func (b *DataFileBuilder) ContentSizeInBytes(size int64) *DataFileBuilder

+ func (b *DataFileBuilder) FirstRowID(id int64) *DataFileBuilder

+ func (b *DataFileBuilder) ReferencedDataFile(path string) *DataFileBuilder

type DayTransform

+ func (t DayTransform) CanTransform(sourceType Type) bool

type HourTransform

+ func (t HourTransform) CanTransform(sourceType Type) bool

type IdentityTransform

+ func (IdentityTransform) CanTransform(t Type) bool

type ManifestListWriter

+ func NewManifestListWriterV3(out io.Writer, snapshotId, sequenceNumber, firstRowID int64, ...) (*ManifestListWriter, error)

+ func (m *ManifestListWriter) NextRowID() *int64

type MonthTransform

+ func (t MonthTransform) CanTransform(sourceType Type) bool

type NameMapping

+ func UpdateNameMapping(nameMapping NameMapping, updates map[int]NestedField, ...) (NameMapping, error)

+ type PartitionOption func(*PartitionSpec) error

+ func AddPartitionFieldByName(sourceName string, targetName string, transform Transform, schema *Schema, ...) PartitionOption

+ func AddPartitionFieldBySourceID(sourceID int, targetName string, transform Transform, schema *Schema, ...) PartitionOption

+ func WithSpecID(id int) PartitionOption

type PartitionSpec

+ func NewPartitionSpecOpts(opts ...PartitionOption) (PartitionSpec, error)

+ func (p *PartitionSpec) BindToSchema(schema *Schema, lastPartitionID *int, newSpecID *int) (PartitionSpec, error)

+ func (p *PartitionSpec) Len() int

+ type TimeTransform interface

+ Transformer func(Type) (func(any) Optional[int32], error)

type Transform

+ CanTransform func(t Type) bool

type TruncateTransform

+ func (TruncateTransform) CanTransform(t Type) bool

type VoidTransform

+ func (VoidTransform) CanTransform(Type) bool

type YearTransform

+ func (t YearTransform) CanTransform(sourceType Type) bool

v0.4.0-rc2

Oct 9, 2025

v0.4.0-rc1

Oct 6, 2025

v0.4.0-rc0

Sep 23, 2025

v0.3.0

May 21, 2025

Changes in this version

type ManifestEntry

+ func ReadManifest(m ManifestFile, f io.Reader, discardDeleted bool) ([]ManifestEntry, error)

+ type ManifestReader struct

+ func NewManifestReader(file ManifestFile, in io.Reader) (*ManifestReader, error)

+ func (c *ManifestReader) ManifestContent() ManifestContent

+ func (c *ManifestReader) PartitionSpec() (*PartitionSpec, error)

+ func (c *ManifestReader) PartitionSpecID() (int, error)

+ func (c *ManifestReader) ReadEntry() (ManifestEntry, error)

+ func (c *ManifestReader) Schema() (*Schema, error)

+ func (c *ManifestReader) SchemaID() (int, error)

+ func (c *ManifestReader) Version() int

type Schema

+ func NewSchemaFromJsonFields(id int, jsonFieldsStr string) (*Schema, error)

+ func SanitizeColumnNames(sc *Schema) (*Schema, error)

v0.3.0-rc0

May 21, 2025

v0.2.0

Mar 20, 2025

Changes in this version

+ func PreOrderVisit[T any](sc *Schema, visitor PreOrderSchemaVisitor[T]) (res T, err error)

+ func VisitMappedFields[S, T any](fields []MappedField, visitor NameMappingVisitor[S, T]) (res S, err error)

+ func VisitNameMapping[S, T any](obj NameMapping, visitor NameMappingVisitor[S, T]) (res S, err error)

type BinaryLiteral

+ func (b BinaryLiteral) Any() any

type BoolLiteral

+ func (b BoolLiteral) Any() any

type BucketTransform

+ func (BucketTransform) PreservesOrder() bool

+ func (BucketTransform) ToHumanStr(val any) string

type DataFile

+ SpecID func() int32

type DateLiteral

+ func (d DateLiteral) Any() any

type DayTransform

+ func (DayTransform) PreservesOrder() bool

+ func (DayTransform) ToHumanStr(val any) string

type Decimal

+ func (d Decimal) String() string

type DecimalLiteral

+ func (d DecimalLiteral) Any() any

type FixedLiteral

+ func (f FixedLiteral) Any() any

type Float32Literal

+ func (f Float32Literal) Any() any

type Float64Literal

+ func (f Float64Literal) Any() any

type HourTransform

+ func (HourTransform) PreservesOrder() bool

+ func (HourTransform) ToHumanStr(val any) string

type IdentityTransform

+ func (IdentityTransform) PreservesOrder() bool

+ func (IdentityTransform) ToHumanStr(val any) string

type Int32Literal

+ func (i Int32Literal) Any() any

type Int64Literal

+ func (i Int64Literal) Any() any

type Literal

+ Any func() any

+ type ManifestBuilder struct

+ func NewManifestFile(version int, path string, length int64, partitionSpecID int32, ...) *ManifestBuilder

+ func (b *ManifestBuilder) AddedFiles(cnt int32) *ManifestBuilder

+ func (b *ManifestBuilder) AddedRows(cnt int64) *ManifestBuilder

+ func (b *ManifestBuilder) Build() ManifestFile

+ func (b *ManifestBuilder) Content(content ManifestContent) *ManifestBuilder

+ func (b *ManifestBuilder) DeletedFiles(cnt int32) *ManifestBuilder

+ func (b *ManifestBuilder) DeletedRows(cnt int64) *ManifestBuilder

+ func (b *ManifestBuilder) ExistingFiles(cnt int32) *ManifestBuilder

+ func (b *ManifestBuilder) ExistingRows(cnt int64) *ManifestBuilder

+ func (b *ManifestBuilder) KeyMetadata(km []byte) *ManifestBuilder

+ func (b *ManifestBuilder) Partitions(p []FieldSummary) *ManifestBuilder

+ func (b *ManifestBuilder) SequenceNum(num, minSeqNum int64) *ManifestBuilder

type ManifestContent

+ func (m ManifestContent) String() string

type ManifestEntry

+ func NewManifestEntry(status ManifestEntryStatus, snapshotID *int64, seqNum, fileSeqNum *int64, ...) ManifestEntry

+ type ManifestEntryBuilder struct

+ func NewManifestEntryBuilder(status ManifestEntryStatus, snapshotID *int64, data DataFile) *ManifestEntryBuilder

+ func (b *ManifestEntryBuilder) Build() ManifestEntry

+ func (b *ManifestEntryBuilder) FileSequenceNum(num int64) *ManifestEntryBuilder

+ func (b *ManifestEntryBuilder) SequenceNum(num int64) *ManifestEntryBuilder

type ManifestFile

+ func WriteManifest(filename string, out io.Writer, version int, spec PartitionSpec, ...) (ManifestFile, error)

+ type ManifestListWriter struct

+ func NewManifestListWriterV1(out io.Writer, snapshotID int64, parentSnapshot *int64) (*ManifestListWriter, error)

+ func NewManifestListWriterV2(out io.Writer, snapshotID, sequenceNumber int64, parentSnapshot *int64) (*ManifestListWriter, error)

+ func (m *ManifestListWriter) AddManifests(files []ManifestFile) error

+ func (m *ManifestListWriter) Close() error

+ type ManifestWriter struct

+ func NewManifestWriter(version int, out io.Writer, spec PartitionSpec, schema *Schema, ...) (*ManifestWriter, error)

+ func (w *ManifestWriter) Add(entry ManifestEntry) error

+ func (w *ManifestWriter) Close() error

+ func (w *ManifestWriter) Delete(entry ManifestEntry) error

+ func (w *ManifestWriter) Existing(entry ManifestEntry) error

+ func (w *ManifestWriter) ToManifestFile(location string, length int64) (ManifestFile, error)

+ type MappedField struct

+ FieldID *int

+ Fields []MappedField

+ Names []string

+ func (m *MappedField) GetField(field string) *MappedField

+ func (m *MappedField) ID() int

+ func (m *MappedField) Len() int

+ func (m *MappedField) String() string

type MonthTransform

+ func (MonthTransform) PreservesOrder() bool

+ func (t MonthTransform) ToHumanStr(val any) string

+ type NameMapping []MappedField

+ func (nm NameMapping) String() string

+ type NameMappingAccessor struct

+ func (NameMappingAccessor) SchemaPartner(partner *MappedField) *MappedField

+ func (n NameMappingAccessor) FieldPartner(partnerStruct *MappedField, _ int, fieldName string) *MappedField

+ func (n NameMappingAccessor) ListElementPartner(partnerList *MappedField) *MappedField

+ func (n NameMappingAccessor) MapKeyPartner(partnerMap *MappedField) *MappedField

+ func (n NameMappingAccessor) MapValuePartner(partnerMap *MappedField) *MappedField

+ type NameMappingVisitor interface

+ Field func(field MappedField, fieldResult S) T

+ Fields func(st []MappedField, fieldResults []T) S

+ Mapping func(nm NameMapping, fieldResults S) S

type PartitionSpec

+ func AssignFreshPartitionSpecIDs(spec *PartitionSpec, old, fresh *Schema) (PartitionSpec, error)

+ func (ps *PartitionSpec) Fields() iter.Seq[PartitionField]

+ func (ps *PartitionSpec) PartitionToPath(data structLike, sc *Schema) string

+ type PreOrderSchemaVisitor interface

+ Field func(NestedField, func() T) T

+ List func(ListType, func() T) T

+ Map func(MapType, func() T, func() T) T

+ Primitive func(PrimitiveType) T

+ Schema func(*Schema, func() T) T

+ Struct func(StructType, []func() T) T

type Properties

+ func (p Properties) GetBool(key string, defVal bool) bool

+ func (p Properties) GetInt(key string, defVal int) int

type Schema

+ func ApplyNameMapping(schemaWithoutIDs *Schema, nameMapping NameMapping) (*Schema, error)

+ func AssignFreshSchemaIDs(sc *Schema, nextID func() int) (*Schema, error)

+ func (s *Schema) FieldIDs() []int

+ func (s *Schema) NameMapping() NameMapping

type StringLiteral

+ func (s StringLiteral) Any() any

type Time

+ func (t Time) ToTime() time.Time

type TimeLiteral

+ func (t TimeLiteral) Any() any

type TimestampLiteral

+ func (t TimestampLiteral) Any() any

type Transform

+ PreservesOrder func() bool

+ ToHumanStr func(any) string

type TruncateTransform

+ func (TruncateTransform) PreservesOrder() bool

+ func (TruncateTransform) ToHumanStr(val any) string

type UUIDLiteral

+ func (u UUIDLiteral) Any() any

type VoidTransform

+ func (VoidTransform) PreservesOrder() bool

+ func (VoidTransform) ToHumanStr(any) string

type YearTransform

+ func (YearTransform) PreservesOrder() bool

+ func (YearTransform) ToHumanStr(val any) string

v0.2.0-rc1

Mar 20, 2025

v0.2.0-rc0

Mar 19, 2025

v0.1.0

Nov 13, 2024

Changes in this version

+ const InitialPartitionSpecID

+ var ErrBadCast = errors.New("could not cast value")

+ var ErrBadLiteral = errors.New("invalid literal value")

+ var ErrInvalidArgument = errors.New("invalid argument")

+ var ErrInvalidBinSerialization = errors.New("invalid binary serialization")

+ var ErrInvalidSchema = errors.New("invalid schema")

+ var ErrInvalidTransform = errors.New("invalid transform syntax")

+ var ErrInvalidTypeString = errors.New("invalid type")

+ var ErrNotImplemented = errors.New("not implemented")

+ var ErrResolve = errors.New("cannot resolve type")

+ var ErrType = errors.New("type error")

+ var PositionalDeleteSchema = NewSchema(0, NestedField{ ... }, NestedField{ ... })

+ var PrimitiveTypes = struct{ ... }

+ var UnpartitionedSpec = &PartitionSpec

+ func Difference(a, b []string) []string

+ func ExpressionEvaluator(s *Schema, unbound BooleanExpression, caseSensitive bool) (func(structLike) (bool, error), error)

+ func ExtractFieldIDs(expr BooleanExpression) ([]int, error)

+ func IndexByID(schema *Schema) (map[int]NestedField, error)

+ func IndexByName(schema *Schema) (map[string]int, error)

+ func IndexNameByID(schema *Schema) (map[int]string, error)

+ func IndexParents(schema *Schema) (map[int]int, error)

+ func Version() string

+ func VisitBoundPredicate[T any](e BoundPredicate, visitor BoundBooleanExprVisitor[T]) T

+ func VisitExpr[T any](expr BooleanExpression, visitor BooleanExprVisitor[T]) (res T, err error)

+ func VisitSchemaWithPartner[T, P any](sc *Schema, partner P, visitor SchemaWithPartnerVisitor[T, P], ...) (res T, err error)

+ func Visit[T any](sc *Schema, visitor SchemaVisitor[T]) (res T, err error)

+ func WriteManifestList(out io.Writer, files []ManifestFile) error

+ type AboveMaxLiteral interface

+ type AfterFieldVisitor interface

+ AfterField func(field NestedField)

+ type AfterListElementVisitor interface

+ AfterListElement func(elem NestedField)

+ type AfterMapKeyVisitor interface

+ AfterMapKey func(key NestedField)

+ type AfterMapValueVisitor interface

+ AfterMapValue func(value NestedField)

+ type AlwaysFalse struct

+ func (AlwaysFalse) Equals(other BooleanExpression) bool

+ func (AlwaysFalse) Negate() BooleanExpression

+ func (AlwaysFalse) Op() Operation

+ func (AlwaysFalse) String() string

+ type AlwaysTrue struct

+ func (AlwaysTrue) Equals(other BooleanExpression) bool

+ func (AlwaysTrue) Negate() BooleanExpression

+ func (AlwaysTrue) Op() Operation

+ func (AlwaysTrue) String() string

+ type AndExpr struct

+ func (AndExpr) Op() Operation

+ func (a AndExpr) Equals(other BooleanExpression) bool

+ func (a AndExpr) Negate() BooleanExpression

+ func (a AndExpr) String() string

+ type BeforeFieldVisitor interface

+ BeforeField func(field NestedField)

+ type BeforeListElementVisitor interface

+ BeforeListElement func(elem NestedField)

+ type BeforeMapKeyVisitor interface

+ BeforeMapKey func(key NestedField)

+ type BeforeMapValueVisitor interface

+ BeforeMapValue func(value NestedField)

+ type BelowMinLiteral interface

+ type BinaryLiteral []byte

+ func (BinaryLiteral) Comparator() Comparator[[]byte]

+ func (b *BinaryLiteral) UnmarshalBinary(data []byte) error

+ func (b BinaryLiteral) Equals(other Literal) bool

+ func (b BinaryLiteral) MarshalBinary() (data []byte, err error)

+ func (b BinaryLiteral) String() string

+ func (b BinaryLiteral) To(typ Type) (Literal, error)

+ func (b BinaryLiteral) Type() Type

+ func (b BinaryLiteral) Value() []byte

+ type BinaryType struct

+ func (BinaryType) Equals(other Type) bool

+ func (BinaryType) String() string

+ func (BinaryType) Type() string

+ type BoolLiteral bool

+ func (BoolLiteral) Comparator() Comparator[bool]

+ func (b *BoolLiteral) UnmarshalBinary(data []byte) error

+ func (b BoolLiteral) Equals(l Literal) bool

+ func (b BoolLiteral) MarshalBinary() (data []byte, err error)

+ func (b BoolLiteral) String() string

+ func (b BoolLiteral) To(t Type) (Literal, error)

+ func (b BoolLiteral) Type() Type

+ func (b BoolLiteral) Value() bool

+ type BooleanExprVisitor interface

+ VisitAnd func(left, right T) T

+ VisitBound func(BoundPredicate) T

+ VisitFalse func() T

+ VisitNot func(childResult T) T

+ VisitOr func(left, right T) T

+ VisitTrue func() T

+ VisitUnbound func(UnboundPredicate) T

+ type BooleanExpression interface

+ Equals func(BooleanExpression) bool

+ Negate func() BooleanExpression

+ Op func() Operation

+ func BindExpr(s *Schema, expr BooleanExpression, caseSensitive bool) (BooleanExpression, error)

+ func IsIn[T LiteralType](t UnboundTerm, vals ...T) BooleanExpression

+ func NewAnd(left, right BooleanExpression, addl ...BooleanExpression) BooleanExpression

+ func NewNot(child BooleanExpression) BooleanExpression

+ func NewOr(left, right BooleanExpression, addl ...BooleanExpression) BooleanExpression

+ func NotIn[T LiteralType](t UnboundTerm, vals ...T) BooleanExpression

+ func RewriteNotExpr(expr BooleanExpression) (BooleanExpression, error)

+ func SetPredicate(op Operation, t UnboundTerm, lits []Literal) BooleanExpression

+ func TranslateColumnNames(expr BooleanExpression, fileSchema *Schema) (BooleanExpression, error)

+ type BooleanType struct

+ func (BooleanType) Equals(other Type) bool

+ func (BooleanType) String() string

+ func (BooleanType) Type() string

+ type BoundBooleanExprVisitor interface

+ VisitEqual func(BoundTerm, Literal) T

+ VisitGreater func(BoundTerm, Literal) T

+ VisitGreaterEqual func(BoundTerm, Literal) T

+ VisitIn func(BoundTerm, Set[Literal]) T

+ VisitIsNan func(BoundTerm) T

+ VisitIsNull func(BoundTerm) T

+ VisitLess func(BoundTerm, Literal) T

+ VisitLessEqual func(BoundTerm, Literal) T

+ VisitNotEqual func(BoundTerm, Literal) T

+ VisitNotIn func(BoundTerm, Set[Literal]) T

+ VisitNotNan func(BoundTerm) T

+ VisitNotNull func(BoundTerm) T

+ VisitNotStartsWith func(BoundTerm, Literal) T

+ VisitStartsWith func(BoundTerm, Literal) T

+ type BoundLiteralPredicate interface

+ AsUnbound func(Reference, Literal) UnboundPredicate

+ Literal func() Literal

+ type BoundPredicate interface

+ Ref func() BoundReference

+ Term func() BoundTerm

+ type BoundReference interface

+ Field func() NestedField

+ Pos func() int

+ PosPath func() []int

+ type BoundSetPredicate interface

+ AsUnbound func(Reference, []Literal) UnboundPredicate

+ Literals func() Set[Literal]

+ type BoundTerm interface

+ Equals func(BoundTerm) bool

+ Ref func() BoundReference

+ Type func() Type

+ type BoundTransform struct

+ func (b *BoundTransform) Equals(other BoundTerm) bool

+ func (b *BoundTransform) Ref() BoundReference

+ func (b *BoundTransform) String() string

+ func (b *BoundTransform) Type() Type

+ type BoundUnaryPredicate interface

+ AsUnbound func(Reference) UnboundPredicate

+ type BucketTransform struct

+ NumBuckets int

+ func (BucketTransform) ResultType(Type) Type

+ func (t BucketTransform) Apply(value Optional[Literal]) Optional[Literal]

+ func (t BucketTransform) Equals(other Transform) bool

+ func (t BucketTransform) MarshalText() ([]byte, error)

+ func (t BucketTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

+ func (t BucketTransform) String() string

+ func (t BucketTransform) Transformer(src Type) func(any) Optional[int32]

+ type Comparator func(v1, v2 T) int

+ type DataFile interface

+ ColumnSizes func() map[int]int64

+ ContentType func() ManifestEntryContent

+ Count func() int64

+ DistinctValueCounts func() map[int]int64

+ EqualityFieldIDs func() []int

+ FileFormat func() FileFormat

+ FilePath func() string

+ FileSizeBytes func() int64

+ KeyMetadata func() []byte

+ LowerBoundValues func() map[int][]byte

+ NaNValueCounts func() map[int]int64

+ NullValueCounts func() map[int]int64

+ Partition func() map[string]any

+ SortOrderID func() *int

+ SplitOffsets func() []int64

+ UpperBoundValues func() map[int][]byte

+ ValueCounts func() map[int]int64

+ type DataFileBuilder struct

+ func NewDataFileBuilder(content ManifestEntryContent, path string, format FileFormat, ...) (*DataFileBuilder, error)

+ func (b *DataFileBuilder) BlockSizeInBytes(size int64) *DataFileBuilder

+ func (b *DataFileBuilder) Build() DataFile

+ func (b *DataFileBuilder) ColumnSizes(sizes map[int]int64) *DataFileBuilder

+ func (b *DataFileBuilder) DistinctValueCounts(counts map[int]int64) *DataFileBuilder

+ func (b *DataFileBuilder) EqualityFieldIDs(ids []int) *DataFileBuilder

+ func (b *DataFileBuilder) KeyMetadata(key []byte) *DataFileBuilder

+ func (b *DataFileBuilder) LowerBoundValues(bounds map[int][]byte) *DataFileBuilder

+ func (b *DataFileBuilder) NaNValueCounts(counts map[int]int64) *DataFileBuilder

+ func (b *DataFileBuilder) NullValueCounts(counts map[int]int64) *DataFileBuilder

+ func (b *DataFileBuilder) SortOrderID(id int) *DataFileBuilder

+ func (b *DataFileBuilder) SplitOffsets(offsets []int64) *DataFileBuilder

+ func (b *DataFileBuilder) UpperBoundValues(bounds map[int][]byte) *DataFileBuilder

+ func (b *DataFileBuilder) ValueCounts(counts map[int]int64) *DataFileBuilder

+ type Date int32

+ func (d Date) ToTime() time.Time

+ type DateLiteral Date

+ func (DateLiteral) Comparator() Comparator[Date]

+ func (d *DateLiteral) UnmarshalBinary(data []byte) error

+ func (d DateLiteral) Decrement() Literal

+ func (d DateLiteral) Equals(other Literal) bool

+ func (d DateLiteral) Increment() Literal

+ func (d DateLiteral) MarshalBinary() (data []byte, err error)

+ func (d DateLiteral) String() string

+ func (d DateLiteral) To(t Type) (Literal, error)

+ func (d DateLiteral) Type() Type

+ func (d DateLiteral) Value() Date

+ type DateType struct

+ func (DateType) Equals(other Type) bool

+ func (DateType) String() string

+ func (DateType) Type() string

+ type DayTransform struct

+ func (DayTransform) Apply(value Optional[Literal]) (out Optional[Literal])

+ func (DayTransform) Equals(other Transform) bool

+ func (DayTransform) ResultType(Type) Type

+ func (DayTransform) String() string

+ func (DayTransform) Transformer(src Type) (func(any) Optional[int32], error)

+ func (t DayTransform) MarshalText() ([]byte, error)

+ func (t DayTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

+ type Decimal struct

+ Scale int

+ Val decimal128.Num

+ type DecimalLiteral Decimal

+ func (DecimalLiteral) Comparator() Comparator[Decimal]

+ func (d *DecimalLiteral) UnmarshalBinary(data []byte) error

+ func (d DecimalLiteral) Decrement() Literal

+ func (d DecimalLiteral) Equals(other Literal) bool

+ func (d DecimalLiteral) Increment() Literal

+ func (d DecimalLiteral) MarshalBinary() (data []byte, err error)

+ func (d DecimalLiteral) String() string

+ func (d DecimalLiteral) To(t Type) (Literal, error)

+ func (d DecimalLiteral) Type() Type

+ func (d DecimalLiteral) Value() Decimal

+ type DecimalType struct

+ func DecimalTypeOf(prec, scale int) DecimalType

+ func (d DecimalType) Equals(other Type) bool

+ func (d DecimalType) Precision() int

+ func (d DecimalType) Scale() int

+ func (d DecimalType) String() string

+ func (d DecimalType) Type() string

+ type FieldSummary struct

+ ContainsNaN *bool

+ ContainsNull bool

+ LowerBound *[]byte

+ UpperBound *[]byte

+ type FileFormat string

+ const AvroFile

+ const OrcFile

+ const ParquetFile

+ type FixedLiteral []byte

+ func (FixedLiteral) Comparator() Comparator[[]byte]

+ func (f *FixedLiteral) UnmarshalBinary(data []byte) error

+ func (f FixedLiteral) Equals(other Literal) bool

+ func (f FixedLiteral) MarshalBinary() (data []byte, err error)

+ func (f FixedLiteral) String() string

+ func (f FixedLiteral) To(typ Type) (Literal, error)

+ func (f FixedLiteral) Type() Type

+ func (f FixedLiteral) Value() []byte

+ type FixedType struct

+ func FixedTypeOf(n int) FixedType

+ func (f FixedType) Equals(other Type) bool

+ func (f FixedType) Len() int

+ func (f FixedType) String() string

+ func (f FixedType) Type() string

+ type Float32Literal float32

+ func (Float32Literal) Comparator() Comparator[float32]

+ func (f *Float32Literal) UnmarshalBinary(data []byte) error

+ func (f Float32Literal) Equals(other Literal) bool

+ func (f Float32Literal) MarshalBinary() (data []byte, err error)

+ func (f Float32Literal) String() string

+ func (f Float32Literal) To(t Type) (Literal, error)

+ func (f Float32Literal) Type() Type

+ func (f Float32Literal) Value() float32

+ type Float32Type struct

+ func (Float32Type) Equals(other Type) bool

+ func (Float32Type) String() string

+ func (Float32Type) Type() string

+ type Float64Literal float64

+ func (Float64Literal) Comparator() Comparator[float64]

+ func (f *Float64Literal) UnmarshalBinary(data []byte) error

+ func (f Float64Literal) Equals(other Literal) bool

+ func (f Float64Literal) MarshalBinary() (data []byte, err error)

+ func (f Float64Literal) String() string

+ func (f Float64Literal) To(t Type) (Literal, error)

+ func (f Float64Literal) Type() Type

+ func (f Float64Literal) Value() float64

+ type Float64Type struct

+ func (Float64Type) Equals(other Type) bool

+ func (Float64Type) String() string

+ func (Float64Type) Type() string

+ type HourTransform struct

+ func (HourTransform) Apply(value Optional[Literal]) (out Optional[Literal])

+ func (HourTransform) Equals(other Transform) bool

+ func (HourTransform) ResultType(Type) Type

+ func (HourTransform) String() string

+ func (HourTransform) Transformer(src Type) (func(any) Optional[int32], error)

+ func (t HourTransform) MarshalText() ([]byte, error)

+ func (t HourTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

+ type IdentityTransform struct

+ func (IdentityTransform) Apply(value Optional[Literal]) Optional[Literal]

+ func (IdentityTransform) Equals(other Transform) bool

+ func (IdentityTransform) ResultType(t Type) Type

+ func (IdentityTransform) String() string

+ func (t IdentityTransform) MarshalText() ([]byte, error)

+ func (t IdentityTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

+ type Int32Literal int32

+ func (Int32Literal) Comparator() Comparator[int32]

+ func (i *Int32Literal) UnmarshalBinary(data []byte) error

+ func (i Int32Literal) Decrement() Literal

+ func (i Int32Literal) Equals(other Literal) bool

+ func (i Int32Literal) Increment() Literal

+ func (i Int32Literal) MarshalBinary() (data []byte, err error)

+ func (i Int32Literal) String() string

+ func (i Int32Literal) To(t Type) (Literal, error)

+ func (i Int32Literal) Type() Type

+ func (i Int32Literal) Value() int32

+ type Int32Type struct

+ func (Int32Type) Equals(other Type) bool

+ func (Int32Type) String() string

+ func (Int32Type) Type() string

+ type Int64Literal int64

+ func (Int64Literal) Comparator() Comparator[int64]

+ func (i *Int64Literal) UnmarshalBinary(data []byte) error

+ func (i Int64Literal) Decrement() Literal

+ func (i Int64Literal) Equals(other Literal) bool

+ func (i Int64Literal) Increment() Literal

+ func (i Int64Literal) MarshalBinary() (data []byte, err error)

+ func (i Int64Literal) String() string

+ func (i Int64Literal) To(t Type) (Literal, error)

+ func (i Int64Literal) Type() Type

+ func (i Int64Literal) Value() int64

+ type Int64Type struct

+ func (Int64Type) Equals(other Type) bool

+ func (Int64Type) String() string

+ func (Int64Type) Type() string

+ type ListType struct

+ Element Type

+ ElementID int

+ ElementRequired bool

+ func (*ListType) Type() string

+ func (l *ListType) ElementField() NestedField

+ func (l *ListType) Equals(other Type) bool

+ func (l *ListType) Fields() []NestedField

+ func (l *ListType) MarshalJSON() ([]byte, error)

+ func (l *ListType) String() string

+ func (l *ListType) UnmarshalJSON(b []byte) error

+ type Literal interface

+ Equals func(Literal) bool

+ To func(Type) (Literal, error)

+ Type func() Type

+ func Float32AboveMaxLiteral() Literal

+ func Float32BelowMinLiteral() Literal

+ func Float64AboveMaxLiteral() Literal

+ func Float64BelowMinLiteral() Literal

+ func Int32AboveMaxLiteral() Literal

+ func Int32BelowMinLiteral() Literal

+ func Int64AboveMaxLiteral() Literal

+ func Int64BelowMinLiteral() Literal

+ func LiteralFromBytes(typ Type, data []byte) (Literal, error)

+ func NewLiteral[T LiteralType](val T) Literal

+ type LiteralType interface

+ type ManifestContent int32

+ const ManifestContentData

+ const ManifestContentDeletes

+ type ManifestEntry interface

+ DataFile func() DataFile

+ FileSequenceNum func() *int64

+ SequenceNum func() int64

+ SnapshotID func() int64

+ Status func() ManifestEntryStatus

+ type ManifestEntryContent int8

+ const EntryContentData

+ const EntryContentEqDeletes

+ const EntryContentPosDeletes

+ func (m ManifestEntryContent) String() string

+ type ManifestEntryStatus int8

+ const EntryStatusADDED

+ const EntryStatusDELETED

+ const EntryStatusEXISTING

+ type ManifestEntryV1Builder struct

+ func NewManifestEntryV1Builder(status ManifestEntryStatus, snapshotID int64, data DataFile) (*ManifestEntryV1Builder, error)

+ func (b *ManifestEntryV1Builder) Build() ManifestEntry

+ type ManifestEntryV2Builder struct

+ func NewManifestEntryV2Builder(status ManifestEntryStatus, snapshotID int64, data DataFile) *ManifestEntryV2Builder

+ func (b *ManifestEntryV2Builder) Build() ManifestEntry

+ func (b *ManifestEntryV2Builder) FileSequenceNum(num int64) *ManifestEntryV2Builder

+ func (b *ManifestEntryV2Builder) SequenceNum(num int64) *ManifestEntryV2Builder

+ type ManifestFile interface

+ AddedDataFiles func() int32

+ AddedRows func() int64

+ DeletedDataFiles func() int32

+ DeletedRows func() int64

+ ExistingDataFiles func() int32

+ ExistingRows func() int64

+ FetchEntries func(fs iceio.IO, discardDeleted bool) ([]ManifestEntry, error)

+ FilePath func() string

+ HasAddedFiles func() bool

+ HasExistingFiles func() bool

+ KeyMetadata func() []byte

+ Length func() int64

+ ManifestContent func() ManifestContent

+ MinSequenceNum func() int64

+ PartitionSpecID func() int32

+ Partitions func() []FieldSummary

+ SequenceNum func() int64

+ SnapshotID func() int64

+ Version func() int

+ WriteEntries func(out io.Writer, entries []ManifestEntry) error

+ func ReadManifestList(in io.Reader) ([]ManifestFile, error)

+ type ManifestV1Builder struct

+ func NewManifestV1Builder(path string, length int64, partitionSpecID int32, addedSnapshotID int64) *ManifestV1Builder

+ func (b *ManifestV1Builder) AddedFiles(cnt int32) *ManifestV1Builder

+ func (b *ManifestV1Builder) AddedRows(cnt int64) *ManifestV1Builder

+ func (b *ManifestV1Builder) Build() ManifestFile

+ func (b *ManifestV1Builder) DeletedFiles(cnt int32) *ManifestV1Builder

+ func (b *ManifestV1Builder) DeletedRows(cnt int64) *ManifestV1Builder

+ func (b *ManifestV1Builder) ExistingFiles(cnt int32) *ManifestV1Builder

+ func (b *ManifestV1Builder) ExistingRows(cnt int64) *ManifestV1Builder

+ func (b *ManifestV1Builder) KeyMetadata(km []byte) *ManifestV1Builder

+ func (b *ManifestV1Builder) Partitions(p []FieldSummary) *ManifestV1Builder

+ type ManifestV2Builder struct

+ func NewManifestV2Builder(path string, length int64, partitionSpecID int32, content ManifestContent, ...) *ManifestV2Builder

+ func (b *ManifestV2Builder) AddedFiles(cnt int32) *ManifestV2Builder

+ func (b *ManifestV2Builder) AddedRows(cnt int64) *ManifestV2Builder

+ func (b *ManifestV2Builder) Build() ManifestFile

+ func (b *ManifestV2Builder) DeletedFiles(cnt int32) *ManifestV2Builder

+ func (b *ManifestV2Builder) DeletedRows(cnt int64) *ManifestV2Builder

+ func (b *ManifestV2Builder) ExistingFiles(cnt int32) *ManifestV2Builder

+ func (b *ManifestV2Builder) ExistingRows(cnt int64) *ManifestV2Builder

+ func (b *ManifestV2Builder) KeyMetadata(km []byte) *ManifestV2Builder

+ func (b *ManifestV2Builder) Partitions(p []FieldSummary) *ManifestV2Builder

+ func (b *ManifestV2Builder) SequenceNum(num, minSeqNum int64) *ManifestV2Builder

+ type MapType struct

+ KeyID int

+ KeyType Type

+ ValueID int

+ ValueRequired bool

+ ValueType Type

+ func (*MapType) Type() string

+ func (m *MapType) Equals(other Type) bool

+ func (m *MapType) Fields() []NestedField

+ func (m *MapType) KeyField() NestedField

+ func (m *MapType) MarshalJSON() ([]byte, error)

+ func (m *MapType) String() string

+ func (m *MapType) UnmarshalJSON(b []byte) error

+ func (m *MapType) ValueField() NestedField

+ type MonthTransform struct

+ func (MonthTransform) Apply(value Optional[Literal]) (out Optional[Literal])

+ func (MonthTransform) Equals(other Transform) bool

+ func (MonthTransform) ResultType(Type) Type

+ func (MonthTransform) String() string

+ func (MonthTransform) Transformer(src Type) (func(any) Optional[int32], error)

+ func (t MonthTransform) MarshalText() ([]byte, error)

+ func (t MonthTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

+ type NestedField struct

+ Doc string

+ ID int

+ InitialDefault any

+ Name string

+ Required bool

+ WriteDefault any

+ func (n *NestedField) Equals(other NestedField) bool

+ func (n *NestedField) UnmarshalJSON(b []byte) error

+ func (n NestedField) MarshalJSON() ([]byte, error)

+ func (n NestedField) String() string

+ type NestedType interface

+ Fields func() []NestedField

+ type NotExpr struct

+ func (NotExpr) Op() Operation

+ func (n NotExpr) Equals(other BooleanExpression) bool

+ func (n NotExpr) Negate() BooleanExpression

+ func (n NotExpr) String() string

+ type NumericLiteral interface

+ Decrement func() Literal

+ Increment func() Literal

+ type Operation int

+ const OpAnd

+ const OpEQ

+ const OpFalse

+ const OpGT

+ const OpGTEQ

+ const OpIn

+ const OpIsNan

+ const OpIsNull

+ const OpLT

+ const OpLTEQ

+ const OpNEQ

+ const OpNot

+ const OpNotIn

+ const OpNotNan

+ const OpNotNull

+ const OpNotStartsWith

+ const OpOr

+ const OpStartsWith

+ const OpTrue

+ func (i Operation) String() string

+ func (op Operation) FlipLR() Operation

+ func (op Operation) Negate() Operation

+ type Optional struct

+ Val T

+ Valid bool

+ type OrExpr struct

+ func (OrExpr) Op() Operation

+ func (o OrExpr) Equals(other BooleanExpression) bool

+ func (o OrExpr) Negate() BooleanExpression

+ func (o OrExpr) String() string

+ type PartitionField struct

+ FieldID int

+ Name string

+ SourceID int

+ Transform Transform

+ func (p *PartitionField) String() string

+ func (p *PartitionField) UnmarshalJSON(b []byte) error

+ type PartitionSpec struct

+ func NewPartitionSpec(fields ...PartitionField) PartitionSpec

+ func NewPartitionSpecID(id int, fields ...PartitionField) PartitionSpec

+ func (ps *PartitionSpec) CompatibleWith(other *PartitionSpec) bool

+ func (ps *PartitionSpec) Field(i int) PartitionField

+ func (ps *PartitionSpec) FieldsBySourceID(fieldID int) []PartitionField

+ func (ps *PartitionSpec) ID() int

+ func (ps *PartitionSpec) IsUnpartitioned() bool

+ func (ps *PartitionSpec) LastAssignedFieldID() int

+ func (ps *PartitionSpec) NumFields() int

+ func (ps *PartitionSpec) PartitionType(schema *Schema) *StructType

+ func (ps *PartitionSpec) UnmarshalJSON(b []byte) error

+ func (ps PartitionSpec) Equals(other PartitionSpec) bool

+ func (ps PartitionSpec) MarshalJSON() ([]byte, error)

+ func (ps PartitionSpec) String() string

+ type PartnerAccessor interface

+ FieldPartner func(partnerStruct P, fieldID int, fieldName string) P

+ ListElementPartner func(P) P

+ MapKeyPartner func(P) P

+ MapValuePartner func(P) P

+ SchemaPartner func(P) P

+ type PrimitiveType interface

+ type Properties map[string]string

+ func (p Properties) Get(key, defVal string) string

+ type Reference string

+ func (r Reference) Bind(s *Schema, caseSensitive bool) (BoundTerm, error)

+ func (r Reference) Equals(other UnboundTerm) bool

+ func (r Reference) String() string

+ type Schema struct

+ ID int

+ IdentifierFieldIDs []int

+ func NewSchema(id int, fields ...NestedField) *Schema

+ func NewSchemaWithIdentifiers(id int, identifierIDs []int, fields ...NestedField) *Schema

+ func PruneColumns(schema *Schema, selected map[int]Void, selectFullTypes bool) (*Schema, error)

+ func (s *Schema) AsStruct() StructType

+ func (s *Schema) Equals(other *Schema) bool

+ func (s *Schema) Field(i int) NestedField

+ func (s *Schema) FieldHasOptionalParent(id int) bool

+ func (s *Schema) Fields() []NestedField

+ func (s *Schema) FindColumnName(fieldID int) (string, bool)

+ func (s *Schema) FindFieldByID(id int) (NestedField, bool)

+ func (s *Schema) FindFieldByName(name string) (NestedField, bool)

+ func (s *Schema) FindFieldByNameCaseInsensitive(name string) (NestedField, bool)

+ func (s *Schema) FindTypeByID(id int) (Type, bool)

+ func (s *Schema) FindTypeByName(name string) (Type, bool)

+ func (s *Schema) FindTypeByNameCaseInsensitive(name string) (Type, bool)

+ func (s *Schema) HighestFieldID() int

+ func (s *Schema) MarshalJSON() ([]byte, error)

+ func (s *Schema) NumFields() int

+ func (s *Schema) Select(caseSensitive bool, names ...string) (*Schema, error)

+ func (s *Schema) String() string

+ func (s *Schema) Type() string

+ func (s *Schema) UnmarshalJSON(b []byte) error

+ type SchemaVisitor interface

+ Field func(field NestedField, fieldResult T) T

+ List func(list ListType, elemResult T) T

+ Map func(mapType MapType, keyResult, valueResult T) T

+ Primitive func(p PrimitiveType) T

+ Schema func(schema *Schema, structResult T) T

+ Struct func(st StructType, fieldResults []T) T

+ type SchemaVisitorPerPrimitiveType interface

+ VisitBinary func() T

+ VisitBoolean func() T

+ VisitDate func() T

+ VisitDecimal func(DecimalType) T

+ VisitFixed func(FixedType) T

+ VisitFloat32 func() T

+ VisitFloat64 func() T

+ VisitInt32 func() T

+ VisitInt64 func() T

+ VisitString func() T

+ VisitTime func() T

+ VisitTimestamp func() T

+ VisitTimestampTz func() T

+ VisitUUID func() T

+ type SchemaWithPartnerVisitor interface

+ Field func(field NestedField, fieldPartner P, fieldResult T) T

+ List func(l ListType, listPartner P, elemResult T) T

+ Map func(m MapType, mapPartner P, keyResult, valResult T) T

+ Primitive func(p PrimitiveType, primitivePartner P) T

+ Schema func(sc *Schema, schemaPartner P, structResult T) T

+ Struct func(st StructType, structPartner P, fieldResults []T) T

+ type Set interface

+ Add func(...E)

+ All func(func(E) bool) bool

+ Contains func(E) bool

+ Equals func(Set[E]) bool

+ Len func() int

+ Members func() []E

+ type StringLiteral string

+ func (StringLiteral) Comparator() Comparator[string]

+ func (s *StringLiteral) UnmarshalBinary(data []byte) error

+ func (s StringLiteral) Equals(other Literal) bool

+ func (s StringLiteral) MarshalBinary() (data []byte, err error)

+ func (s StringLiteral) String() string

+ func (s StringLiteral) To(typ Type) (Literal, error)

+ func (s StringLiteral) Type() Type

+ func (s StringLiteral) Value() string

+ type StringType struct

+ func (StringType) Equals(other Type) bool

+ func (StringType) String() string

+ func (StringType) Type() string

+ type StructType struct

+ FieldList []NestedField

+ func (*StructType) Type() string

+ func (s *StructType) Equals(other Type) bool

+ func (s *StructType) Fields() []NestedField

+ func (s *StructType) MarshalJSON() ([]byte, error)

+ func (s *StructType) String() string

+ type Term interface

+ type Time int64

+ type TimeLiteral Time

+ func (TimeLiteral) Comparator() Comparator[Time]

+ func (t *TimeLiteral) UnmarshalBinary(data []byte) error

+ func (t TimeLiteral) Equals(other Literal) bool

+ func (t TimeLiteral) MarshalBinary() (data []byte, err error)

+ func (t TimeLiteral) String() string

+ func (t TimeLiteral) To(typ Type) (Literal, error)

+ func (t TimeLiteral) Type() Type

+ func (t TimeLiteral) Value() Time

+ type TimeType struct

+ func (TimeType) Equals(other Type) bool

+ func (TimeType) String() string

+ func (TimeType) Type() string

+ type Timestamp int64

+ func (t Timestamp) ToDate() Date

+ func (t Timestamp) ToTime() time.Time

+ type TimestampLiteral Timestamp

+ func (TimestampLiteral) Comparator() Comparator[Timestamp]

+ func (t *TimestampLiteral) UnmarshalBinary(data []byte) error

+ func (t TimestampLiteral) Decrement() Literal

+ func (t TimestampLiteral) Equals(other Literal) bool

+ func (t TimestampLiteral) Increment() Literal

+ func (t TimestampLiteral) MarshalBinary() (data []byte, err error)

+ func (t TimestampLiteral) String() string

+ func (t TimestampLiteral) To(typ Type) (Literal, error)

+ func (t TimestampLiteral) Type() Type

+ func (t TimestampLiteral) Value() Timestamp

+ type TimestampType struct

+ func (TimestampType) Equals(other Type) bool

+ func (TimestampType) String() string

+ func (TimestampType) Type() string

+ type TimestampTzType struct

+ func (TimestampTzType) Equals(other Type) bool

+ func (TimestampTzType) String() string

+ func (TimestampTzType) Type() string

+ type Transform interface

+ Apply func(Optional[Literal]) Optional[Literal]

+ Equals func(Transform) bool

+ Project func(name string, pred BoundPredicate) (UnboundPredicate, error)

+ ResultType func(t Type) Type

+ func ParseTransform(s string) (Transform, error)

+ type TruncateTransform struct

+ Width int

+ func (TruncateTransform) ResultType(t Type) Type

+ func (t TruncateTransform) Apply(value Optional[Literal]) (out Optional[Literal])

+ func (t TruncateTransform) Equals(other Transform) bool

+ func (t TruncateTransform) MarshalText() ([]byte, error)

+ func (t TruncateTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

+ func (t TruncateTransform) String() string

+ func (t TruncateTransform) Transformer(src Type) (func(any) any, error)

+ type Type interface

+ Equals func(Type) bool

+ Type func() string

+ func PromoteType(fileType, readType Type) (Type, error)

+ type TypedLiteral interface

+ Comparator func() Comparator[T]

+ Value func() T

+ type UUIDLiteral uuid.UUID

+ func (UUIDLiteral) Comparator() Comparator[uuid.UUID]

+ func (UUIDLiteral) Type() Type

+ func (u *UUIDLiteral) UnmarshalBinary(data []byte) error

+ func (u UUIDLiteral) Equals(other Literal) bool

+ func (u UUIDLiteral) MarshalBinary() (data []byte, err error)

+ func (u UUIDLiteral) String() string

+ func (u UUIDLiteral) To(typ Type) (Literal, error)

+ func (u UUIDLiteral) Value() uuid.UUID

+ type UUIDType struct

+ func (UUIDType) Equals(other Type) bool

+ func (UUIDType) String() string

+ func (UUIDType) Type() string

+ type UnboundPredicate interface

+ Term func() UnboundTerm

+ func EqualTo[T LiteralType](t UnboundTerm, v T) UnboundPredicate

+ func GreaterThanEqual[T LiteralType](t UnboundTerm, v T) UnboundPredicate

+ func GreaterThan[T LiteralType](t UnboundTerm, v T) UnboundPredicate

+ func IsNaN(t UnboundTerm) UnboundPredicate

+ func IsNull(t UnboundTerm) UnboundPredicate

+ func LessThanEqual[T LiteralType](t UnboundTerm, v T) UnboundPredicate

+ func LessThan[T LiteralType](t UnboundTerm, v T) UnboundPredicate

+ func LiteralPredicate(op Operation, t UnboundTerm, lit Literal) UnboundPredicate

+ func NotEqualTo[T LiteralType](t UnboundTerm, v T) UnboundPredicate

+ func NotNaN(t UnboundTerm) UnboundPredicate

+ func NotNull(t UnboundTerm) UnboundPredicate

+ func NotStartsWith(t UnboundTerm, v string) UnboundPredicate

+ func StartsWith(t UnboundTerm, v string) UnboundPredicate

+ func UnaryPredicate(op Operation, t UnboundTerm) UnboundPredicate

+ type UnboundTerm interface

+ Bind func(schema *Schema, caseSensitive bool) (BoundTerm, error)

+ Equals func(UnboundTerm) bool

+ type Void = struct

+ type VoidTransform struct

+ func (VoidTransform) Apply(value Optional[Literal]) Optional[Literal]

+ func (VoidTransform) Equals(other Transform) bool

+ func (VoidTransform) Project(string, BoundPredicate) (UnboundPredicate, error)

+ func (VoidTransform) ResultType(t Type) Type

+ func (VoidTransform) String() string

+ func (t VoidTransform) MarshalText() ([]byte, error)

+ type YearTransform struct

+ func (YearTransform) Apply(value Optional[Literal]) (out Optional[Literal])

+ func (YearTransform) Equals(other Transform) bool

+ func (YearTransform) ResultType(Type) Type

+ func (YearTransform) String() string

+ func (YearTransform) Transformer(src Type) (func(any) Optional[int32], error)

+ func (t YearTransform) MarshalText() ([]byte, error)

+ func (t YearTransform) Project(name string, pred BoundPredicate) (UnboundPredicate, error)

v0.1.0-rc2

Nov 13, 2024

v0.1.0-rc1

Nov 13, 2024

v0.1.0-rc0

Nov 8, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL