add null type

alibaba · Jan 6, 2025 · bb959b4 · bb959b4
1 parent e1f8dd8
commit bb959b4
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/...piler/src/main/java/com/alibaba/graphscope/common/ir/meta/schema/IrDataTypeConvertor.java b/...piler/src/main/java/com/alibaba/graphscope/common/ir/meta/schema/IrDataTypeConvertor.java
@@ -198,6 +198,8 @@ public RelDataType convert(GSDataTypeDesc from) {
             Object value;
             if ((value = typeMap.get("primitive_type")) != null) {
                 switch (value.toString()) {
+                    case "DT_NULL":
+                        return typeFactory.createSqlType(SqlTypeName.NULL);
                     case "DT_ANY":
                         // any type
                         return typeFactory.createSqlType(SqlTypeName.ANY);
@@ -324,6 +326,9 @@ public GSDataTypeDesc convert(RelDataType from) {
             SqlTypeName typeName = from.getSqlTypeName();
             Map<String, Object> yamlDesc;
             switch (typeName) {
+                case NULL:
+                    yamlDesc = ImmutableMap.of("primitive_type", "DT_NULL");
+                    break;
                 case INTEGER:
                     yamlDesc = ImmutableMap.of("primitive_type", "DT_SIGNED_INT32");
                     break;

diff --git a/interactive_engine/executor/ir/proto/basic_type.proto b/interactive_engine/executor/ir/proto/basic_type.proto
@@ -13,6 +13,7 @@ enum PrimitiveType {
     DT_BOOL = 5;
     DT_FLOAT = 6;
     DT_DOUBLE = 7;
+    DT_NULL = 8; // denote the type of 'null' value
 }
 
 message Decimal { // precision=4 scale=2 : 23.12