Merge pull request #6035 from soerenreichardt/2.1-speedup-csv-parsing

Speedup csv parsing

Author: soerenreichardt

graph-projection-api/src/main/java/org/neo4j/gds/api/nodeproperties/ValueType.java

@@ -19,6 +19,7 @@
  */
 package org.neo4j.gds.api.nodeproperties;
 
+import org.jetbrains.annotations.Nullable;
 import org.neo4j.gds.api.DefaultValue;
 
 public enum ValueType {
@@ -37,6 +38,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.forLong();
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitLong();
+        }
     },
     DOUBLE {
         @Override
@@ -53,6 +59,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.forDouble();
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitDouble();
+        }
     },
     STRING {
         @Override
@@ -69,6 +80,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.DEFAULT;
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitString();
+        }
     },
     DOUBLE_ARRAY {
         @Override
@@ -85,6 +101,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.forDoubleArray();
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitDoubleArray();
+        }
     },
     FLOAT_ARRAY {
         @Override
@@ -101,6 +122,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.forFloatArray();
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitFloatArray();
+        }
     },
     LONG_ARRAY {
         @Override
@@ -117,6 +143,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.forLongArray();
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitLongArray();
+        }
     },
     UNKNOWN {
         @Override
@@ -133,6 +164,11 @@ public String csvName() {
         public DefaultValue fallbackValue() {
             return DefaultValue.DEFAULT;
         }
+
+        @Override
+        public <RESULT> RESULT accept(Visitor<RESULT> visitor) {
+            return visitor.visitUnknown();
+        }
     };
 
     public abstract String cypherName();
@@ -141,6 +177,8 @@ public DefaultValue fallbackValue() {
 
     public abstract DefaultValue fallbackValue();
 
+    public abstract <RESULT> RESULT accept(Visitor<RESULT> visitor);
+
     public static ValueType fromCsvName(String csvName) {
         for (ValueType value : values()) {
             if (value == UNKNOWN) {
@@ -152,4 +190,15 @@ public static ValueType fromCsvName(String csvName) {
         }
         throw new IllegalArgumentException("Unexpected value: " + csvName);
     }
+
+    public interface Visitor<RESULT> {
+        RESULT visitLong();
+        RESULT visitDouble();
+        RESULT visitString();
+        RESULT visitLongArray();
+        RESULT visitDoubleArray();
+        RESULT visitFloatArray();
+
+        default @Nullable RESULT visitUnknown() { return null; }
+    }
 }