Upgrade to faster protocol impl for perf sensitive protocols

Author: cnuernber

deps.edn

@@ -1,6 +1,6 @@
 {:paths ["src" "resources" "target/classes"]
  :deps {;;org.clojure/clojure {:mvn/version "1.11.1"}
-        cnuernber/dtype-next {:mvn/version "10.145"}
+        cnuernber/dtype-next {:mvn/version "11.000-SNAPSHOT"}
         techascent/tech.io {:mvn/version "4.31"
                             :exclusions [org.apache.commons/commons-compress]}
         org.apache.datasketches/datasketches-java {:mvn/version "4.2.0"}

src/tech/v3/dataset/impl/column.clj

@@ -1,6 +1,7 @@
 (ns ^:no-doc tech.v3.dataset.impl.column
   (:require [tech.v3.dataset.protocols :as ds-proto]
             [tech.v3.datatype.protocols :as dtype-proto]
+            [tech.v3.datatype.hamf-proto :as dtype-hamf-proto]
             [tech.v3.datatype :as dtype]
             [tech.v3.datatype.unary-pred :as un-pred]
             [tech.v3.datatype.casting :as casting]
@@ -299,13 +300,13 @@
          (dtype-proto/convertible-to-native-buffer? data)))
   (->native-buffer [_this]
     (dtype-proto/->native-buffer data))
-  dtype-proto/PElemwiseDatatype
-  (elemwise-datatype [_this] (dtype-proto/elemwise-datatype data))
+  dtype-hamf-proto/PElemwiseDatatype
+  (elemwise-datatype [_this] (dtype-hamf-proto/elemwise-datatype data))
   dtype-proto/POperationalElemwiseDatatype
   (operational-elemwise-datatype [this]
     (if (.isEmpty missing)
-      (dtype-proto/elemwise-datatype this)
-      (let [ewise-dt (dtype-proto/elemwise-datatype data)]
+      (dtype-hamf-proto/elemwise-datatype this)
+      (let [ewise-dt (dtype-hamf-proto/elemwise-datatype data)]
         (cond
           (packing/packed-datatype? ewise-dt)
           (packing/unpack-datatype ewise-dt)
@@ -324,12 +325,12 @@
                nil)))
   dtype-proto/PElemwiseReaderCast
   (elemwise-reader-cast [this new-dtype]
-    (if (= new-dtype (dtype-proto/elemwise-datatype data))
+    (if (= new-dtype (dtype-hamf-proto/elemwise-datatype data))
       (cached-buffer!)
       (make-column-buffer missing (dtype-proto/elemwise-reader-cast data new-dtype)
                           new-dtype new-dtype)))
-  dtype-proto/PECount
-  (ecount [this] (dtype-proto/ecount data))
+  dtype-hamf-proto/PECount
+  (ecount [this] (dtype-hamf-proto/ecount data))
   dtype-proto/PToBuffer
   (convertible-to-buffer? [_this] true)
   (->buffer [this]
@@ -419,7 +420,7 @@
   (invoke [this idx] (.invoke (cached-buffer!) idx))
   (invoke [this idx def-val] (.invoke (cached-buffer!) idx def-val))
   (meta [this] (assoc metadata
-                      :datatype (dtype-proto/elemwise-datatype this)
+                      :datatype (dtype-hamf-proto/elemwise-datatype this)
                       :n-elems (dtype-proto/ecount this)))
   (withMeta [_this new-meta] (Column. missing
                                      data
@@ -432,7 +433,7 @@
   (equiv [this o] (if (identical? this o) true (.equiv (cached-buffer!) o)))
   (empty [this]
     (Column. (->bitmap)
-             (column-base/make-container (dtype-proto/elemwise-datatype this) 0)
+             (column-base/make-container (dtype-hamf-proto/elemwise-datatype this) 0)
              {}
              nil))
   (reduce [this rfn init] (.reduce (cached-buffer!) rfn init))

src/tech/v3/dataset/io/column_parsers.clj

@@ -199,9 +199,8 @@
                           column-name
                           ^:unsynchronized-mutable ^long max-idx
                           disable-na-as-missing?]
-  dtype-proto/PECount
-  (ecount [_this] (inc max-idx))
   Indexed
+  (count [this] (inc max-idx))
   (nth [this idx] (.nth this idx nil))
   (nth [this idx dv]
     (let [cec (.size container)]
@@ -387,9 +386,8 @@
                                   ^:unsynchronized-mutable ^long last-idx
                                   options
                                   disable-na-as-missing?]
-  dtype-proto/PECount
-  (ecount [_this] (inc last-idx))
   Indexed
+  (count [this] (inc last-idx))
   (nth [this idx] (.nth this idx nil))
   (nth [this idx dv]
     (let [cec (.size container)]
@@ -490,9 +488,8 @@
                                   ^:unsynchronized-mutable ^long mc
                                   disable-na-as-missing?
                                   options]
-  dtype-proto/PECount
-  (ecount [_this] (inc max-idx))
   Indexed
+  (count [this] (inc max-idx))
   (nth [this idx] (.nth this idx nil))
   (nth [this idx dv]
     (let [cec (.size container)]