🥮 mooncakes.io

    moondelta-core

    MoonBit-native Delta Lake table-format kernel: transaction log replay, snapshots, time travel, scan planning and append writes.

    delta-lake
    table-format
    lakehouse
    parquet
    data
    Download zip
    Version
    0.3.1
    License
    Apache-2.0
    Repository
    Last updated
    5 days ago
    Downloads
    50

    #moondelta-core

    CI

    MoonBit 原生的 Delta Lake 表格式内核：回放 _delta_log 事务日志、构建快照、时间旅行、分区/统计剪枝的扫描规划，读取数据文件，并在受支持的列类型上 append 提交新版本。

    生态里已经有 Parquet 编解码、DataFrame、对 Parquet 跑 SQL 的查询引擎、Iceberg 只读——缺的是"带事务日志的表"这一层。本项目补这一层。

    参赛申报书：申报书.md ｜ 第三方声明：THIRD_PARTY_NOTICES.md

    已发布：mooncakes.io/docs/xiguaAp6y3/moondelta-core（0.3.1；空工程安装日志见 artifacts/acceptance/mooncakes-0.3.1/）。registry 版本与当前源码一致。

    #状态

    0.3.1（M1 协议基线 → M2 嵌套读取 → M3 checkpoint 恢复 → M4 嵌套写入 + 类型/安全检查；能力口径为已验证子集，不是任意标准 Delta 表的完整兼容）：

    • 日志解析与回放：protocol / metaData / add / remove / commitInfo，txn 识别，cdc / domainMetadata 显式忽略并在输出中提示，未知 action 结构化拒绝，_last_checkpoint 识别
    • 协议范围（0.2.0 起强制）：只读 minReaderVersion = 1 的表——reader v2/v3 与 readerFeatures 拒绝并说明原因（column mapping / 删除向量 / v2 checkpoint 为高版本特性）；JSON 与 checkpoint 的 add.deletionVector 均拒绝；日志文件名严格按 20 位校验；add.path 与 remove.path 统一 percent-decoding；写出到 minReaderVersion = 1, minWriterVersion = 2（writer > 2 或非空 writerFeatures 的表拒绝 append）；日志从非 0 起点/缺版本明确拒绝；M3 起日志被截断 / checkpoint-only 的表从最新单文件 checkpoint 恢复基底并叠加其后 JSON commit（不再静默读旧快照；多部分 checkpoint 显式拒绝）
    • 快照、版本历史、时间旅行（snapshot_at）
    • 扫描规划：分区等值过滤 + 文件级 min/max 统计剪枝（stats 损坏显式报错，不再静默返 0）
    • 读取：11 种 primitive + UNCOMPRESSED/SNAPPY；M2 起支持嵌套读取、M4 起支持嵌套写入——struct / 标准 3-level list / map（含 NULL、空集合、null 元素/子字段），读写均与 delta-rs/DuckDB 逐值对拍一致（artifacts/acceptance/m2|m4/）
    • 写入：create_table（已存在的表拒绝）+ append_rows 覆盖 11 种 primitive 与嵌套叶；校验列名/类型/NOT NULL；数据文件与 commit 均为 put-if-absent；分区列读取时按 partitionValues 补齐
    • CLI：inspect / history / scan / read / create / version；错误输出到 stderr、非 0 退出码、未知参数/缺值报错
    • 37 个单元测试（新增场景并入既有用例：11 种 primitive 与嵌套 logical type 回环、ISO date 分区、协议门控、JSON/checkpoint 删除向量、remove 路径解码、stats 类型、物理类型一致性等）+ 真实与自造 Delta fixture 与外部互操作脚本

    已用真实数据验证（均为仓库 fixture 读取，D1 已复核）：delta-rs table_a（13 个版本回放 → 120 个文件，仓库只含日志、不含数据文件）、Databricks 写出的 COVID-19_NYT 表的 1 个数据文件（157,865 行 6 列，snappy；该表共 8 个数据文件，其余 7 个未入库）。

    外部引擎互操作：与 delta-rs 1.6.6、DuckDB 1.5.6 在指定 flat/nested fixture 上完成双向对拍（flat 49 PASS / 0 FAIL / 2 项已记录差异，见 artifacts/interop-flat/README.md；nested 见 artifacts/acceptance/m2/ 与 m4/）。11 种 primitive 的写出另经 delta-rs 与 DuckDB 验证（artifacts/interop-flat/all-primitives-written/、artifacts/acceptance/all_types_verify.py；DuckDB 环境缺 pytz，timestamp 列由 delta-rs/pyarrow 验证）。这些结果不外推到任意 reader v1 表；Spark / Databricks 未验证。完整口径见 docs/协议兼容性与互操作范围.md。

    #快速开始

    要求：MoonBit 工具链（moon / moonc，建议 2026-10 之后的版本）。

    # 从 mooncakes.io 安装当前发布版本 0.3.1
moon add xiguaAp6y3/moondelta-core

# 或从源码构建
moon check --target native
moon test --target native

# CLI（源码根目录为 src/，因此包路径带 src/ 前缀）
moon run --target native src/cmd/delta -- inspect fixtures/delta/table_a
moon run --target native src/cmd/delta -- history fixtures/delta/table_a
moon run --target native src/cmd/delta -- scan fixtures/delta/table_a --where "id>=60"
moon run --target native src/cmd/delta -- read fixtures/delta/covid --limit 5

    inspect fixtures/delta/table_a 输出示例：

    table            : fixtures/delta/table_a
current version  : 12  (log versions: 13)
files            : 120  rows: 120  bytes: 54232
protocol         : reader=1 writer=1
format           : parquet
partition columns: (none)
schema:
  id: int
last checkpoint  : version=10
note             : checkpoint present; truncated / checkpoint-only tables are recovered from the latest single-file checkpoint

    注：样例中的 reader=1 writer=1 是 delta-rs fixture 自身的协议字段；本项目写出的表为 minReaderVersion = 1, minWriterVersion = 2。

    scan ... --where "id>=60" 会利用日志里的 min/max 统计把 120 个文件剪到 60 个（skipped stats: 60）。

    #作为库使用

    let table = @delta.DeltaTable::open("path/to/table")
    let snapshot = table.snapshot()              // 最新版本
    let old = table.snapshot_at(1)               // 时间旅行
    let report = @delta.scan(snapshot, {
      partitions: [("dt", "2026-10-18")],
      predicate: Some({ column: "id", op: GeV, value: 60.0 }),
    })
    let rows = @delta.read_snapshot("path/to/table", snapshot, Some(100))
    for c in rows.columns {
      println(c.name + " : " + @delta.delta_type_name(c.type_))
    }

    写入：

    @delta.create_table(root, schema_json, [])
    let columns : Array[@delta.ReadColumn] = [
      { name: "id", type_: Int64Type, cells: [CellI64(1L), CellI64(2L)] },
      { name: "name", type_: StringType, cells: [CellStr("a"), CellStr("b")] },
    ]
    @delta.append_rows(root, columns, 1750000000000L) // 写 parquet + 提交新版本

    #能力边界（已验证子集）

    维度支持不支持 / 显式拒绝
    protocolreader v1 读取；writer v2 写出reader > 1、readerFeatures、非空 writerFeatures；未声称任意 reader v1 表全部兼容
    日志version 0 起连续 JSON commit；20 位文件名；截断 / checkpoint-only 从单文件 checkpoint 恢复多部分 checkpoint；checkpoint 缺失 protocol/metaData；checkpoint 中真实出现的未知 action
    schema11 种 primitive 与 struct / 3-level list / map 读写；flat 与 nested 叶均校验 Delta 类型和 Parquet 物理类型decimal、uuid、timestamp_ntz、timestamp millis/nanos
    压缩UNCOMPRESSED、SNAPPYZSTD、GZIP、BROTLI、LZ4
    写入类型boolean / byte / short / int / long / float / double / string / binary / date / timestamp，包含嵌套叶decimal、uuid、timestamp_ntz、timestamp millis/nanos
    写入表非分区 append；校验列名/类型/NOT NULL；put-if-absent分区 append；列在 Parquet 中恒为 Optional
    删除向量JSON 与 checkpoint 的 add.deletionVector 均拒绝column mapping、v2 checkpoint、CDF、MERGE/UPDATE/DELETE
    存储本地文件系统对象存储（S3/R2）

    分区值回填覆盖 11 种 primitive；date 同时接受 YYYY-MM-DD 与 epoch 天数，timestamp 分区值使用 epoch 微秒。add.stats 必须是 JSON 编码字符串；非字符串或损坏内容直接报错。CLI 成功退出 0，错误走 stderr 并以非 0 退出。

    #依赖说明：vendored parquet

    mizchi/parquet@0.2.2 声明了 mizchi/duckdb@0.6.4，后者仍使用旧版 moon.mod.json，当前 MoonBit 工具链会拒绝解析。该依赖只被上游的 DuckDB 演示子包使用，因此本项目把 parquet 的 src/ 以 Apache-2.0 许可证 vendored 到 src/vendor/parquet，删除了 cmd/duckdb_e2e 与 playground_bridge 两个子包；新增 shredded 嵌套读写入口并修复 REPEATED definition level 规则，writer 另扩展 BOOLEAN / FLOAT / DOUBLE 与 DATE / TIMESTAMP_MICROS logical annotation（见 NOTICE）。详见 src/vendor/parquet/NOTICE.md。

    #Fixtures 与数据来源

    fixtures/ 中仅包含测试数据（不含上游实现代码），来源与许可证见 fixtures/README.md：

    • fixtures/delta/table_a：delta-rs 测试表（13 个日志版本 + checkpoint），Apache-2.0
    • fixtures/delta/covid：Databricks 写出的 COVID-19_NYT 表数据文件，Apache-2.0
    • fixtures/parquet/list_columns.parquet：apache/parquet-testing 的嵌套 LIST 正读样例，Apache-2.0
    • fixtures/checkpoint-negative/：checkpoint 删除向量/未知 action/缺失状态负向用例，由 fixtures/generate_checkpoint_negative.py 生成

    #路线图

    完整路线图见 docs/ROADMAP.md。0.3.1 已完成 M1–M4 与类型/安全加固，当前剩余重点：

    • 发布包含本轮安全加固的新版本并复核 registry 安装；
    • 补带时区/精度语义的 timestamp_ntz、timestamp millis/nanos；
    • ZSTD/GZIP/BROTLI 解压、分区表 append、对象存储（S3/R2）、CDF、Float/Timestamp 写入；
    • 流式读取与 row-group 级剪枝、Arrow IPC / DataFrame / moonice 互操作。

    #开发

    moon check --target native
moon test --target native
moon fmt

    CI：.github/workflows/ci.yml（安装最新 MoonBit 工具链 → moon update → check/test/build）。本地已通过 moon check --target native 与 37/37 测试；远端 Actions 运行链接仍需在可联网环境核对。

    #许可证

    Apache-2.0。Delta Lake 协议参考 https://github.com/delta-io/delta（Apache-2.0）；本项目为原创实现，未复制上游代码。

    DeltaError

    source
    pub(all) suberror DeltaError {
      IoError(String)
      ParseError(String)
      Unsupported(String)
      NotFound(String)
    } derive(Eq, 
    Debug    )

    impl Show for DeltaError

    Action

    source
    pub(all) enum Action {
      ProtocolAction(Protocol)
      MetaDataAction(TableInfo)
      AddAction(AddFile)
      RemoveAction(RemoveFile)
      CommitInfoAction(CommitInfo)
      TxnAction(Txn)
      IgnoredAction(String)
    } derive(Eq, 
    Debug    )

    Action 闭集：已实现语义的 5 类 + txn（识别）+ 显式忽略的快照无关 action。 不存在"未知 action 静默忽略"——未识别的 action 在解析期直接报错。

    AddFile

    source
    pub(all) struct AddFile {
      path : String
      partition_values : Array[(String, String)]
      size : Int64
      modification_time : Int64
      data_change : Bool
      stats : String?
      has_deletion_vector : Bool
    } derive(Eq, 
    Debug    )

    Cell

    source
    pub(all) enum Cell {
      CellI32(Int)
      CellI64(Int64)
      CellF32(Float)
      CellF64(Double)
      CellBool(Bool)
      CellStr(String)
      CellBin(Bytes)
      CellTs(Int64)
      CellNull
      CellStruct(Array[(String, Cell)])
      CellList(Array[Cell])
      CellMap(Array[(Cell, Cell)])
    } derive(
    Debug    )

    读取路径的统一单元格表示（将 parquet 的值收敛成 Delta 语义类型）

    CheckpointInfo

    source
    pub(all) struct CheckpointInfo {
      version : Int
      size : Int?
      parts : Int?
    } derive(Eq, 
    Debug    )

    ColumnPredicate

    source
    pub(all) struct ColumnPredicate {
      column : String
      op : CompareOp
      value : Double
    } derive(Eq, 
    Debug    )

    CommitInfo

    source
    pub(all) struct CommitInfo {
      version : Int
      timestamp : Int64?
      operation : String?
      operation_parameters : Array[(String, String)]
    } derive(Eq, 
    Debug    )

    CompareOp

    source
    pub(all) enum CompareOp {
      EqV
      GtV
      GeV
      LtV
      LeV
    } derive(Eq, 
    Debug    )

    比较运算符（用于文件级 min/max 统计剪枝）

    DeltaField

    source
    pub(all) struct DeltaField {
      name : String
      type_ : DeltaType
      nullable : Bool
    } derive(Eq, 
    Debug    )

    DeltaSchema

    source
    pub(all) struct DeltaSchema {
      fields : Array[DeltaField]
      raw_json : String
    } derive(Eq, 
    Debug    )

    DeltaTable

    source
    pub(all) struct DeltaTable {
      root : String
    }

    DeltaTable::current_version

    source
    fn DeltaTable::current_version(self : DeltaTable) -> Int raise DeltaError

    当前版本 = max(最新 JSON commit, 最新 checkpoint)。checkpoint-only 表 返回 checkpoint 版本。

    DeltaTable::history

    source
    fn DeltaTable::history(self : DeltaTable) -> Array[HistoryEntry] raise DeltaError

    DeltaTable::inspect

    source
    fn DeltaTable::inspect(self : DeltaTable) -> (Snapshot, CheckpointInfo?, Bool) raise DeltaError

    读取表的最新版本号 + snapshot + 是否检测到 checkpoint（用于 CLI 提示）

    DeltaTable::open

    source
    fn DeltaTable::open(root : String) -> DeltaTable raise DeltaError

    DeltaTable::snapshot

    source
    fn DeltaTable::snapshot(self : DeltaTable) -> Snapshot raise DeltaError

    DeltaTable::snapshot_at

    source
    fn DeltaTable::snapshot_at(self : DeltaTable, version : Int) -> Snapshot raise DeltaError

    DeltaTable::versions

    source
    fn DeltaTable::versions(self : DeltaTable) -> Array[Int] raise DeltaError

    DeltaType

    source
    pub(all) enum DeltaType {
      Int32Type
      Int64Type
      FloatType
      DoubleType
      BooleanType
      StringType
      BinaryType
      ByteType
      ShortType
      DateType
      TimestampType
      DecimalType(precision~ : Int, scale~ : Int)
      NestedType(kind~ : String, fields~ : Array[DeltaField])
      UnknownType(raw~ : String)
    } derive(Eq, 
    Debug    )

    Delta Lake 状态类型（本实现支持的类型子集 + 明确的"不支持"标记）

    Delta schema 保留嵌套子树；读写能力分别在 read/write 路径校验， 未支持的逻辑类型显式拒绝，不静默丢失语义。

    HistoryEntry

    source
    pub(all) struct HistoryEntry {
      version : Int
      timestamp : Int64?
      operation : String?
    } derive(Eq, 
    Debug    )

    NestWriteCtx

    source
    type NestWriteCtx

    Protocol

    source
    pub(all) struct Protocol {
      min_reader_version : Int
      min_writer_version : Int
      reader_features : Array[String]
      writer_features : Array[String]
    } derive(Eq, 
    Debug    )

    ReadColumn

    source
    pub(all) struct ReadColumn {
      name : String
      type_ : DeltaType
      cells : Array[Cell]
    } derive(
    Debug    )

    ReadResult

    source
    pub(all) struct ReadResult {
      columns : Array[ReadColumn]
      row_count : Int
      files_read : Int
    } derive(
    Debug    )

    RemoveFile

    source
    pub(all) struct RemoveFile {
      path : String
      deletion_timestamp : Int64?
      data_change : Bool
    } derive(Eq, 
    Debug    )

    ReplayState

    source
    type ReplayState

    ScanFilter

    source
    pub(all) struct ScanFilter {
      partitions : Array[(String, String)]
      predicate : ColumnPredicate?
    } derive(Eq, 
    Debug    )

    扫描过滤条件：分区等值过滤 + 单列统计剪枝

    ScanReport

    source
    pub(all) struct ScanReport {
      files : Array[AddFile]
      skipped_partition : Int
      skipped_stats : Int
      matched_rows : Int64
      matched_bytes : Int64
    } derive(Eq, 
    Debug    )

    扫描结果（不读数据文件，只做文件级规划）

    Snapshot

    source
    pub(all) struct Snapshot {
      version : Int
      protocol : Protocol
      metadata : TableInfo
      files : Array[AddFile]
      total_rows : Int64
      total_bytes : Int64
      ignored_actions : Array[String]
    } derive(Eq, 
    Debug    )

    TableInfo

    source
    pub(all) struct TableInfo {
      id : String
      name : String?
      schema : DeltaSchema
      partition_columns : Array[String]
      format_provider : String
      configuration : Array[(String, String)]
    } derive(Eq, 
    Debug    )

    Txn

    source
    pub(all) struct Txn {
      app_id : String
      version : Int64
    } derive(Eq, 
    Debug    )

    append_rows

    source
    fn append_rows(root : String, columns : Array[ReadColumn], timestamp : Int64) -> Int raise DeltaError

    追加一批行（列式输入），写 parquet 数据文件并提交新版本。 只支持非分区表；列必须与表 schema 逐列同名同型，NOT NULL 列不得含 null。

    cell_to_display

    source
    fn cell_to_display(cell : Cell) -> String

    单元格的展示形式（CLI / 示例用）。嵌套值以 JSON 风格渲染。

    checkpoint_info

    source
    fn checkpoint_info(root : String) -> CheckpointInfo? raise DeltaError

    读取 _last_checkpoint（不存在返回 None）

    create_table

    source
    fn create_table(root : String, schema_json : String, partition_columns : Array[String]) -> Int raise DeltaError

    创建一张新的 Delta 表（写入 version 0：commitInfo + protocol + metaData）。 表已存在时拒绝——绝不覆盖既有日志。

    decode_action_path

    source
    fn decode_action_path(encoded : String) -> String raise DeltaError

    Delta 规范：add/remove.path 是 percent-encoded 的 URI 路径成分。 所有路径先解码为同一规范形式，再用于文件访问或状态匹配。

    delta_type_name

    source
    fn delta_type_name(ty : DeltaType) -> String

    describe_error

    source
    fn describe_error(e : DeltaError) -> String

    ensure_dir

    source
    fn ensure_dir(path : String) -> Unit raise DeltaError

    逐级创建目录（等价于 mkdir -p）

    ensure_readable_schema

    source
    fn ensure_readable_schema(schema : DeltaSchema) -> Unit raise DeltaError

    判断 schema 是否能在当前读取路径上安全读取；不能则给出明确原因。 M2 起 struct/array/map 可读；decimal/uuid 等仍拒绝（显式例外清单）。

    has_checkpoint_file

    source
    fn has_checkpoint_file(root : String) -> Bool

    是否存在 checkpoint 文件（.checkpoint.parquet）

    is_writable_type

    source
    fn is_writable_type(ty : DeltaType) -> Bool

    判断某个类型是否能由写入路径产出

    json_as_array

    source
    fn json_as_array(j : Json) -> Array[Json]?

    json_as_bool

    source
    fn json_as_bool(j : Json) -> Bool?

    json_as_double

    source
    fn json_as_double(j : Json) -> Double?

    json_as_int

    source
    fn json_as_int(j : Json) -> Int?

    json_as_int64

    source
    fn json_as_int64(j : Json) -> Int64?

    json_as_object

    source
    fn json_as_object(j : Json) -> Map[String, Json]?

    JSON 访问小工具。核心 json 包以 prelude 形式导出类型与构造子， 这里统一用模式匹配读取，避免 deprecated accessor。

    json_as_string

    source
    fn json_as_string(j : Json) -> String?

    json_field

    source
    fn json_field(j : Json, key : String) -> Json?

    读取对象字段

    json_field_array

    source
    fn json_field_array(j : Json, key : String) -> Array[Json]?

    读取对象字段为数组

    json_field_bool

    source
    fn json_field_bool(j : Json, key : String) -> Bool?

    读取对象字段为 Bool

    json_field_int

    source
    fn json_field_int(j : Json, key : String) -> Int?

    读取对象字段为 Int

    json_field_int64

    source
    fn json_field_int64(j : Json, key : String) -> Int64?

    读取对象字段为 Int64

    json_field_string

    source
    fn json_field_string(j : Json, key : String) -> String?

    读取对象字段为字符串

    json_object_pairs_string

    source
    fn json_object_pairs_string(j : Json) -> Array[(String, String)]

    JSON 对象 → (key, value-string) 列表（用于 partitionValues / configuration）

    list_checkpoint_versions

    source
    fn list_checkpoint_versions(root : String) -> Array[Int] raise DeltaError

    列出 _delta_log 中单文件 checkpoint 的版本（升序）。 多部分 checkpoint（<v>.checkpoint.<p>.parquet）显式不支持并报错。

    list_versions

    source
    fn list_versions(root : String) -> Array[Int] raise DeltaError

    列出所有日志版本（升序、去重）。 .json 文件名必须严格符合 20 位零填充版本号，其余视为表目录损坏并报错。

    log_dir

    source
    fn log_dir(root : String) -> String

    _delta_log 目录路径

    parse_action

    source
    fn parse_action(line : StringView, version : Int) -> Action raise DeltaError

    解析一行 Delta 日志（一行一个 action）。 已知但与快照无关的 action（cdc / domainMetadata）显式忽略并记录名字； 未识别的 action 直接报错——不静默跳过。

    parse_add

    source
    fn parse_add(j : Json) -> AddFile raise DeltaError

    parse_checkpoint

    source
    fn parse_checkpoint(path : String) -> (Protocol?, TableInfo?, Array[AddFile]) raise DeltaError

    解析 checkpoint parquet，返回其中的 protocol / metaData / add 集合。

    parse_commit_info

    source
    fn parse_commit_info(j : Json, version : Int) -> CommitInfo

    parse_metadata

    source
    fn parse_metadata(j : Json) -> TableInfo raise DeltaError

    parse_remove

    source
    fn parse_remove(j : Json) -> RemoveFile raise DeltaError

    parse_schema

    source
    fn parse_schema(raw : String) -> DeltaSchema raise DeltaError

    解析 Delta schemaString（形如 {"type":"struct","fields":[...]}）

    parse_schema_fields

    source
    fn parse_schema_fields(j : Json) -> Array[DeltaField] raise DeltaError

    解析 fields 数组

    read_actions

    source
    fn read_actions(root : String, version : Int) -> Array[Action] raise DeltaError

    读取某个版本的日志 actions

    read_snapshot

    source
    fn read_snapshot(root : String, snapshot : Snapshot, limit : Int?) -> ReadResult raise DeltaError

    读取 snapshot 中的数据文件。

    • root 是表目录（parquet 路径相对它）
    • limit 限制读入行数（None = 全部） 分区列不会出现在数据文件里，这里用 partitionValues 补齐常量列。 schema 含嵌套字段时走 shredded 装配路径（src/shred.mbt）。

    read_snapshot_shredded

    source
    fn read_snapshot_shredded(root : String, snapshot : Snapshot, limit : Int?) -> ReadResult raise DeltaError

    嵌套 schema 的读取路径：shredded 解码（值 + def/rep levels）后按 Delta schema 树装配。文件遍历、limit 语义与分区列补齐与扁平路径一致。

    read_text

    source
    fn read_text(path : String) -> String raise DeltaError

    读取文本文件

    scan

    source
    fn scan(snapshot : Snapshot, filter : ScanFilter) -> ScanReport raise DeltaError

    文件级扫描规划：分区过滤 + min/max 统计剪枝。 不读取数据文件，因此可离线测试、也可用于"改动了多少行"这类审计场景。 stats 损坏时显式报错（不静默失真）。

    shred_rows

    source
    fn shred_rows(schema : DeltaSchema, leaves : Array[
    LeafColumn    ], row_count : Int) -> Array[Array[Cell]] raise DeltaError

    从 shredded 叶列 + Delta schema 装配出全部行（列式结果，行数 = row_count）。 返回与 schema.fields 顺序一致的列。

    version_file_name

    source
    fn version_file_name(version : Int) -> String

    版本号 → 日志文件名（20 位零填充，Delta 规范）

    write_nested_parquet_bytes

    source
    fn write_nested_parquet_bytes(schema : DeltaSchema, columns : Array[ReadColumn], row_count : Int) -> Bytes raise DeltaError

    把（与表 schema 同构的）列式输入拆成叶级槽位流 + schema 树并写出 parquet。

    write_text

    source
    fn write_text(path : String, content : String) -> Unit raise DeltaError

    写入文本文件

    write_text_new

    source
    fn write_text_new(path : String, content : String) -> Unit raise DeltaError

    写入文本文件（put-if-absent 语义）：目标已存在时直接失败。 这是 commit 原子性的进程内保证——MoonBit fs 层没有 O_EXCL 原语， 并发写方之间的真原子性由调用方自行仲裁（当前内核为单进程模型）。

    Source Files

    Powered by MoonBit

    Site sourceReport issueModulesSkillsCLIBuild queueStatistics

    © 2026 mooncakes.io