just do an insert on batch processing

diff --git a/lib/cluster_kv/db.ex b/lib/cluster_kv/db.ex
index a73c1561f086dbc9e3bc90dabccae96222281c2d..a1d0b8e006bfa0cdd48d0ec77d910a8f5faedcd4 100644 (file)
--- 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