diff --git a/README.md b/README.md index 9c0bb9d..5e16faa 100644 --- a/README.md +++ b/README.md @@ -37,7 +37,6 @@ code, message = db.create_column_family( true, -- Enable compression db.COMPRESS_SNAPPY, -- Compression algorithm can be NO_COMPRESSION, COMPRESS_SNAPPY, COMPRESS_LZ4, COMPRESS_ZSTD true, -- Enable bloom filter - db.TDB_MEMTABLE_SKIP_LIST, -- Use skip list for memtable ) -- Put key-value pair into the database diff --git a/spec/tidesdb_spec.lua b/spec/tidesdb_spec.lua index 172437f..b594e60 100644 --- a/spec/tidesdb_spec.lua +++ b/spec/tidesdb_spec.lua @@ -37,7 +37,6 @@ local prob_skip_list = 0.24 local enable_compression = true local compression_algo = lib.COMPRESS_SNAPPY local enable_bloom_filter = true -local db_data_struct = lib.TDB_MEMTABLE_SKIP_LIST local key = "key" local key_size = string.len(key) @@ -70,8 +69,7 @@ describe("create and drop column", function() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert.is_equal(0, code) code, message = db:drop_column_family(name) @@ -95,8 +93,7 @@ describe("put and get", function() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert.is_equal(0, code) code, message = db:put(name, key, value, ttl) @@ -127,8 +124,7 @@ describe("put and delete", function() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert.is_equal(0, code) code, message = db:put(name, key, value, ttl) @@ -158,8 +154,7 @@ describe("list column families", function() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert.is_equal(0, code) code, message, list = db:list_column_families() @@ -186,8 +181,7 @@ describe("transactions begin and free", function() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert.is_equal(0, code) code, message, txn = lib.txn_begin(db, name) @@ -217,8 +211,7 @@ describe("transactions put and delete", function() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert.is_equal(0, code) code, message, txn = lib.txn_begin(db, name) diff --git a/src/tidesdb-lua.c b/src/tidesdb-lua.c index e9870e9..fe0ffbb 100644 --- a/src/tidesdb-lua.c +++ b/src/tidesdb-lua.c @@ -141,10 +141,10 @@ static int create_column_family(lua_State *L) const tidesdb_compression_algo_t compression_algo = (tidesdb_compression_algo_t)luaL_checkinteger(L, 7); const bool enable_bloom_filter = lua_toboolean(L, 8); - const tidesdb_memtable_ds_t db_data_struct = (tidesdb_memtable_ds_t)luaL_checkinteger(L, 9); + tidesdb_err_t *ret = tidesdb_create_column_family( db, column_family, flush_threshold, max_skip_level, prob_skip_level, enable_compression, - compression_algo, enable_bloom_filter, db_data_struct); + compression_algo, enable_bloom_filter); LUA_RET_CODE() } static int drop_column_family(lua_State *L) diff --git a/test_lua.lua b/test_lua.lua index ebb8b61..f0f0f15 100644 --- a/test_lua.lua +++ b/test_lua.lua @@ -29,7 +29,6 @@ local prob_skip_list = 0.24 local enable_compression = true local compression_algo = lib.COMPRESS_SNAPPY local enable_bloom_filter = true -local db_data_struct = lib.TDB_MEMTABLE_SKIP_LIST local key = "key" local key_size = string.len(key) @@ -54,8 +53,7 @@ function test_create_and_drop_column() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) code, message = db:drop_column_family(name) @@ -75,8 +73,7 @@ function test_put_and_get() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) code, message = db:put(name, key, value, ttl) @@ -103,8 +100,7 @@ function test_put_and_delete() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) code, message = db:put(name, key, value, ttl) @@ -130,8 +126,7 @@ function test_put_and_compact() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) for i=1,20 do @@ -158,8 +153,7 @@ function test_list_column_families() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) assert(code == 0, message) @@ -185,8 +179,7 @@ function test_txn_begin_and_free() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) code, message, txn = lib.txn_begin(db, name) @@ -211,8 +204,7 @@ function test_txn_put_and_delete() prob_skip_list, enable_compression, compression_algo, - enable_bloom_filter, - db_data_struct) + enable_bloom_filter) assert(code == 0, message) code, message, txn = lib.txn_begin(db, name)