From: Christopher <chris@entropealabs.com>
Date: Thu, 16 Apr 2020 14:26:17 +0000 (-0500)
Subject: just do an insert on batch processing
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=0507bf77dbedf5e8e3565e9fbb9ec397ff6d642f;p=cluster_kv.git

just do an insert on batch processing
---

diff --git a/lib/cluster_kv/db.ex b/lib/cluster_kv/db.ex
index a73c156..a1d0b8e 100644
--- a/lib/cluster_kv/db.ex
+++ b/lib/cluster_kv/db.ex
@@ -136,13 +136,14 @@ defmodule ClusterKV.DB do
           last_batch :: integer(),
           fun :: fun()
         ) :: {[element()], integer(), reference()}
-  defp handle_next_batch_chunk(db, batch, chunk, last_batch, fun) do
+  defp handle_next_batch_chunk(db, batch, chunk, last_batch, _fun) do
     Logger.debug("processing batch of #{length(batch)} from #{last_batch} with chunk of #{chunk}")
 
     batch
     |> Enum.slice(last_batch, chunk)
-    |> Enum.each(fn {k, v} ->
-      do_upsert(db, k, v, fun)
+    |> Enum.each(fn {_k, _v} = v ->
+      :ets.insert(db, v)
+      # do_upsert(db, k, v, fun)
     end)
 
     case last_batch + chunk do