fix comments

Author: lxy-9602

src/paimon/common/data/blob_utils.cpp

@@ -132,7 +132,7 @@ bool BlobUtils::IsMapBlobField(const std::shared_ptr<arrow::Field>& field) {
     return map_type.item_type()->id() == arrow::Type::LARGE_BINARY;
 }
 
-bool BlobUtils::IsBlobFileField(const std::shared_ptr<arrow::Field>& field) {
+bool BlobUtils::IsAnyBlobField(const std::shared_ptr<arrow::Field>& field) {
     return IsBlobField(field) || IsArrayBlobField(field) || IsMapBlobField(field);
 }
 

src/paimon/common/data/blob_utils.h

@@ -81,7 +81,7 @@ class PAIMON_EXPORT BlobUtils {
     /// Returns whether the field is a top-level MAP whose values are BLOBs.
     static bool IsMapBlobField(const std::shared_ptr<arrow::Field>& field);
     /// Returns whether the field is stored in a standalone blob file.
-    static bool IsBlobFileField(const std::shared_ptr<arrow::Field>& field);
+    static bool IsAnyBlobField(const std::shared_ptr<arrow::Field>& field);
     /// Returns whether an ARRAY<BLOB> row is the internal fallback sentinel.
     static bool IsArrayBlobPlaceholder(const arrow::ListArray& array, int64_t row);
     /// Returns whether a MAP<..., BLOB> row is the internal fallback sentinel.

src/paimon/common/data/blob_utils_test.cpp

@@ -83,7 +83,7 @@ TEST_F(BlobUtilsTest, IsArrayBlobField) {
     auto array_blob_field =
         arrow::field("array_blob", arrow::list(BlobUtils::ToArrowField("item", true)));
     ASSERT_TRUE(BlobUtils::IsArrayBlobField(array_blob_field));
-    ASSERT_TRUE(BlobUtils::IsBlobFileField(array_blob_field));
+    ASSERT_TRUE(BlobUtils::IsAnyBlobField(array_blob_field));
 
     ASSERT_FALSE(BlobUtils::IsArrayBlobField(nullptr));
     ASSERT_FALSE(BlobUtils::IsArrayBlobField(

src/paimon/common/reader/blob_fallback_batch_reader.cpp

@@ -56,7 +56,7 @@ Result<std::unique_ptr<BlobFallbackBatchReader>> BlobFallbackBatchReader::Create
     }
     int32_t blob_field_idx = -1;
     for (int32_t i = 0; i < read_schema->num_fields(); i++) {
-        if (BlobUtils::IsBlobFileField(read_schema->field(i))) {
+        if (BlobUtils::IsAnyBlobField(read_schema->field(i))) {
             if (blob_field_idx != -1) {
                 return Status::Invalid(
                     "Blob fallback read schema should contain exactly one blob field.");

src/paimon/core/schema/schema_validation.cpp

@@ -775,7 +775,7 @@ Status SchemaValidation::ValidateRowTracking(const TableSchema& table_schema,
 
     std::vector<std::string> blob_names;
     for (const auto& field : table_schema.Fields()) {
-        if (BlobUtils::IsBlobFileField(field.ArrowField())) {
+        if (BlobUtils::IsAnyBlobField(field.ArrowField())) {
             blob_names.push_back(field.Name());
         }
     }
@@ -817,9 +817,8 @@ Status SchemaValidation::ValidateBlobFields(const TableSchema& schema, const Cor
         PAIMON_RETURN_NOT_OK(ValidateNoDuplicateField(field_names, option_key));
         PAIMON_ASSIGN_OR_RAISE(std::vector<DataField> blob_fields, schema.GetFields(field_names));
         for (const auto& blob_field : blob_fields) {
-            bool is_blob = allow_container_blob
-                               ? BlobUtils::IsBlobFileField(blob_field.ArrowField())
-                               : BlobUtils::IsBlobField(blob_field.ArrowField());
+            bool is_blob = allow_container_blob ? BlobUtils::IsAnyBlobField(blob_field.ArrowField())
+                                                : BlobUtils::IsBlobField(blob_field.ArrowField());
             if (!is_blob) {
                 const std::string expected_type =
                     allow_container_blob ? "BLOB, ARRAY<BLOB> or MAP<..., BLOB>" : "BLOB";
@@ -909,7 +908,7 @@ Status SchemaValidation::ValidateMosaicDataFields(const TableSchema& schema,
     // Top-level blob-file fields stored in separate files are skipped; descriptor and view fields
     // are inline, so Mosaic must reject them here.
     for (const DataField& field : schema.Fields()) {
-        if (BlobUtils::IsBlobFileField(field.ArrowField()) &&
+        if (BlobUtils::IsAnyBlobField(field.ArrowField()) &&
             inline_blob_field_set.count(field.Name()) == 0) {
             continue;
         }
@@ -975,7 +974,7 @@ Status SchemaValidation::ValidateLanceDataFields(const TableSchema& schema,
             return Status::OK();
         }
         for (const DataField& field : schema.Fields()) {
-            if (BlobUtils::IsBlobFileField(field.ArrowField()) &&
+            if (BlobUtils::IsAnyBlobField(field.ArrowField()) &&
                 inline_blob_field_set.count(field.Name()) == 0) {
                 continue;
             }

src/paimon/format/blob/blob_file_batch_reader.cpp

@@ -264,7 +264,7 @@ Status BlobFileBatchReader::SetReadSchema(::ArrowSchema* read_schema,
             fmt::format("read schema field number {} is not 1", arrow_schema->num_fields()));
     }
     std::shared_ptr<arrow::Field> read_field = arrow_schema->field(0);
-    if (!BlobUtils::IsBlobFileField(read_field)) {
+    if (!BlobUtils::IsAnyBlobField(read_field)) {
         return Status::Invalid(fmt::format("field {} must be BLOB, ARRAY<BLOB> or MAP<..., BLOB>",
                                            read_field->ToString()));
     }

src/paimon/format/blob/blob_stats_extractor.cpp

@@ -46,7 +46,7 @@ BlobStatsExtractor::ExtractWithFileInfo(const std::shared_ptr<FileSystem>& file_
         return Status::Invalid(
             fmt::format("schema field number {} is not 1", write_schema_->num_fields()));
     }
-    if (!BlobUtils::IsBlobFileField(write_schema_->field(0))) {
+    if (!BlobUtils::IsAnyBlobField(write_schema_->field(0))) {
         return Status::Invalid(
             fmt::format("field {} is not a blob-file field", write_schema_->field(0)->ToString()));
     }