From 0507bf77dbedf5e8e3565e9fbb9ec397ff6d642f Mon Sep 17 00:00:00 2001 From: Christopher Date: Thu, 16 Apr 2020 09:26:17 -0500 Subject: [PATCH] just do an insert on batch processing --- lib/cluster_kv/db.ex | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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 -- 2.45.3