Support objectLength in Record interface of udf-api (#16946)

Author: JackieTien97

iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/access/Record.java

@@ -124,6 +124,14 @@ public interface Record {
    */
   Optional<File> getObjectFile(int columnIndex);
 
+  /**
+   * Returns the OBJECT value's real file length at the specified column in this row.
+   *
+   * @param columnIndex index of the specified column
+   * @return length of the object
+   */
+  long objectLength(int columnIndex);
+
   /**
    * Returns the Binary representation of an object stored at the specified column in this row.
    *

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/partition/Slice.java

@@ -219,6 +219,15 @@ public Optional<File> getObjectFile(int columnIndex) {
       return ObjectTypeUtils.getObjectPathFromBinary(getBinarySafely(columnIndex));
     }
 
+    @Override
+    public long objectLength(int columnIndex) {
+      if (getDataType(columnIndex) != Type.OBJECT) {
+        throw new UnsupportedOperationException("current column is not object column");
+      }
+      Binary binary = getBinarySafely(columnIndex);
+      return ObjectTypeUtils.getObjectLength(binary);
+    }
+
     @Override
     public Binary readObject(int columnIndex, long offset, int length) {
       if (getDataType(columnIndex) != Type.OBJECT) {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/RecordIterator.java

@@ -164,6 +164,15 @@ public Optional<File> getObjectFile(int columnIndex) {
       return ObjectTypeUtils.getObjectPathFromBinary(getBinarySafely(columnIndex));
     }
 
+    @Override
+    public long objectLength(int columnIndex) {
+      if (getDataType(columnIndex) != Type.OBJECT) {
+        throw new UnsupportedOperationException("current column is not object column");
+      }
+      Binary binary = getBinarySafely(columnIndex);
+      return ObjectTypeUtils.getObjectLength(binary);
+    }
+
     @Override
     public Binary readObject(int columnIndex, long offset, int length) {
       if (getDataType(columnIndex) != Type.OBJECT) {

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/function/RecordObjectTypeTest.java

@@ -133,6 +133,8 @@ private void testRecordIterator(Iterator<Record> recordIterator) {
     Optional<File> objectFile = record.getObjectFile(0);
     assertTrue(objectFile.isPresent());
 
+    assertEquals(100L, record.objectLength(0));
+
     assertEquals("(Object) 100 B", record.getString(0));
     Assert.assertFalse(recordIterator.hasNext());
   }