This is an automated email from the ASF dual-hosted git repository.
junhao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 731475b9b0 [docs] Fix error in blob.md docs (#6771)
731475b9b0 is described below
commit 731475b9b0c69cc2147039f933c4e66a4e651ce1
Author: YeJunHao <[email protected]>
AuthorDate: Mon Dec 8 14:13:02 2025 +0800
[docs] Fix error in blob.md docs (#6771)
---
docs/content/concepts/spec/blob.md | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/docs/content/concepts/spec/blob.md
b/docs/content/concepts/spec/blob.md
index 01c5776618..8452dcfcce 100644
--- a/docs/content/concepts/spec/blob.md
+++ b/docs/content/concepts/spec/blob.md
@@ -474,7 +474,7 @@ public class BlobDescriptorExample {
.column("video", DataTypes.BLOB())
.option(CoreOptions.ROW_TRACKING_ENABLED.key(), "true")
.option(CoreOptions.DATA_EVOLUTION_ENABLED.key(), "true")
- .option(CoreOptions.BLOB_AS_DESCRIPTOR.key(), "true") //
Enable descriptor mode
+ .option(CoreOptions.BLOB_AS_DESCRIPTOR.key(), "true") // This
is not necessary in java api
.build();
Identifier tableId = Identifier.create("my_db", "video_table");
@@ -502,14 +502,17 @@ public class BlobDescriptorExample {
long fileSize = 2L * 1024 * 1024 * 1024; // 2GB
BlobDescriptor descriptor = new BlobDescriptor(externalUri, 0,
fileSize);
+ // file io should be accessable to externalUri
+ FileIO fileIO = Table.fileIO();
+ UriReader uriReader = UriReader.fromFile(fileIO);
+ Blob blob = Blob.fromDescriptor(uriReader, descriptor);
// Write the serialized descriptor as blob data
// Paimon will read from the URI and copy data to .blob files in
chunks
GenericRow row = GenericRow.of(
1,
BinaryString.fromString("large_video"),
- new BlobData(descriptor.serialize())
- );
+ blob);
write.write(row);
commit.commit(write.prepareCommit());