Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions bindings/c/src/tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1932,6 +1932,9 @@ fn test_write_commit_read_roundtrip() {
assert!(pc_result.error.is_null());
assert!(!pc_result.messages.is_null());

// Closing must preserve the commit messages already handed to the caller.
assert!(paimon_table_write_close(tw).is_null());

let tc_result = paimon_write_builder_new_commit(wb);
assert!(tc_result.error.is_null());
let tc = tc_result.commit;
Expand Down
22 changes: 22 additions & 0 deletions bindings/c/src/write.rs
Original file line number Diff line number Diff line change
Expand Up @@ -571,6 +571,26 @@ pub unsafe extern "C" fn paimon_postpone_fixed_bucket_write_builder_new_write(
}
}

/// Close a standard TableWrite, discarding outstanding output without preparing a commit.
///
/// Previously prepared commit messages remain owned by the caller. This does not free
/// the handle; call `paimon_table_write_free` after closing it.
///
/// # Safety
/// `tw` must be a live standard TableWrite handle, or null (returns an error).
/// The handle must not be used concurrently.
#[no_mangle]
pub unsafe extern "C" fn paimon_table_write_close(
tw: *mut paimon_table_write,
) -> *mut paimon_error {
if let Err(error) = check_non_null(tw, "tw") {
return error;
}
let state = &mut *((*tw).inner as *mut TableWriteState);
runtime().block_on(state.write.close());
ptr::null_mut()
}

/// Free a standard TableWrite.
///
/// # Safety
Expand Down Expand Up @@ -1510,6 +1530,8 @@ const _: unsafe extern "C" fn(
*mut c_void,
*mut c_void,
) -> *mut paimon_error = paimon_postpone_fixed_bucket_write_builder_with_bucket_plan;
const _: unsafe extern "C" fn(*mut paimon_table_write) -> *mut paimon_error =
paimon_table_write_close;
const _: unsafe extern "C" fn(*mut paimon_table_write) -> paimon_result_prepare_commit =
paimon_table_write_prepare_commit;
const _: extern "C" fn() -> i32 = paimon_commit_messages_serializer_version;
Expand Down
Loading