Local test for map reducer

Author: jpalharini

dev/map-reducer.repl

@@ -0,0 +1,26 @@
+(require '[aux :as a])
+(import '[java.io ByteArrayInputStream ByteArrayOutputStream]
+        '[org.fressian FressianReader FressianWriter]
+        '[org.fressian.handlers ILookup IReduceKV IReduceList ReadHandler]
+        '[java.util HashMap])
+
+(def map-reducer (reify IReduceKV
+                   (init [_ len]
+                     (HashMap. len))
+
+                   (step [_ acc k v]
+                     (.put ^HashMap acc k v))
+
+                   (complete [_ acc]
+                     acc)))
+
+(def map-handler (reify ReadHandler
+                   (read [_ reader _ _]
+                     (.readWithReducer ^FressianReader reader ^IReduceKV map-reducer))))
+
+(def custom-read-handlers
+  (reify ILookup
+    (valAt [_ k]
+      (get {"map" map-handler} k))))
+
+(type (a/defressian (a/fressian {"my" "map"}) custom-read-handlers))