rocksdb

0熱度

1回答

我有一個自定義Transformer實施在我的kafka流DSL的結尾，並持續更新日誌KeyValueStore綁定到它。自從幾周以來，我一直在商店中放置太多數據。現在，無論何時加載應用程序，它都會消耗太多內存。但是，應用程序本身只是一個原型，所以我不介意完全清理商店。我可以重命名kafka.application.id和state-store-name，但這是一個臨時解決方法（並且相應的數

1熱度

2回答

如何通過字典鍵值促進字典記錄過濾？

我想在我的python應用程序中與rocksdb進行交互，並在其中存儲任意的字典。我收集這些信息是爲了我可以使用類似pickle的東西來進行序列化。但我需要能夠根據其鍵的值過濾記錄。這裏有什麼合適的方法？

0熱度

1回答

在SBT中引用RocksDB DLL

我在一個帶有SBT的scala項目中使用RocksDB。對於Windows我知道我需要關於jar文件中的win64 DLL的infor SBT，但我仍然沒有得到正確的答案。我已經試過什麼我們這裏，但沒有運氣 How to resolve a non-jar (dll/jnilib) library dependencies in sbt? 如何在Windows Java項目使用RocksDB寫

0熱度

1回答

RocksDB：太小的SST文件太多

我在運行服務一段時間後使用RocksDBJava我可以看到「太多打開的文件」異常。挖掘雖然在門戶網站上提到的前一個問題，我發現這是因爲系統限制打開最大數量的文件。當我檢查rocksDB使用的目錄時，我注意到有超過100K的1KB大小的sst文件，這可能是給定錯誤的原因。我想知道有沒有什麼方法可以讓我們配置rocksBD來生成大尺寸的SST文件，以便創建的文件總數最少，並且我們可以避免這個錯誤。

1熱度

2回答

Gui查看器的RocksDb sst文件

我正在與Kafka一起將數據保存到rocksdb中。現在我想看看由Kafka創建的db鍵和值。我下載了FastNoSQL並嘗試失敗。該文件夾包含：文件名爲.sst .log文件當前文件標識文件 LOCK文件 LOG文件清單文件選項文件我該如何看值？

0熱度

1回答

並行化rocksdb迭代

我的迭代器代碼： Iterator* iterator = _db->NewIterator(ReadOptions()); for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { Slice const& key = iterator->key(); Slice const& value =

0熱度

3回答

Lib岩石上的UnsatisfiedLinkError使用Kafka Stream進行開發時的DB dll

我正在開發Windows機器上編寫Kafka Streams應用程序。如果我嘗試使用卡夫卡流的leftJoin和branch功能我得到執行的jar應用程序時的錯誤如下： Exception in thread "StreamThread-1" java.lang.UnsatisfiedLinkError: C:\Users\user\AppData\Local\Temp\librocksdbjn

0熱度

1回答

爲RocksDB實現一個比較器

我有一些鏈接問題與當前類擴展rocksdb :: Comparator。「NumericKeyComparator.cpp」 #include <rocksdb/db.h> #include <rocksdb/comparator.h> #include "../../structure/structure.h" #include "../../NumberToString.h" #in

1熱度

1回答

Kafka Streams - 低級別處理器API - RocksDB TimeToLive（TTL）

我正在嘗試低級別處理器API。我正在使用處理器API對傳入記錄進行數據聚合，並將聚合記錄寫入RocksDB。但是，我想保留在rocksdb中添加的記錄只能在24小時內處於活動狀態。 24小時後，記錄應該刪除。這可以通過更改ttl設置來完成。但是，沒有太多的文檔可以幫助我解決這個問題。如何更改ttl值？我應該使用什麼java api將ttl時間設置爲24小時，以及當前默認的ttl設置時間？

1熱度

1回答

rocksdb.errors.RocksIOError：IO錯誤：鎖定文件：sample.db/LOCK：資源暫時不可用

如何去除rocksDB 的LOCK我嘗試運行下面的代碼，但得到以下錯誤 * Running on http://127.0.0.1:5000/ (Press CTRL+C to quit) * Restarting with stat Traceback (most recent call last): File "hello flask.py", line 18, in <module>