rocksdb

    0热度

    1回答

    Kafka Streams - 删除/清除状态存储

    我有一个自定义Transformer实施在我的kafka流DSL的结尾，并持续更新日志KeyValueStore绑定到它。 自从几周以来，我一直在商店中放置太多数据。现在，无论何时加载应用程序，它都会消耗太多内存。 但是，应用程序本身只是一个原型，所以我不介意完全清理商店。 我可以重命名kafka.application.id和state-store-name，但这是一个临时解决方法（并且相应的数
    apache-kafka apache-kafka-streams rocksdb 2017-10-11

    1热度

    2回答

    如何通过字典键值促进字典记录过滤？

    我想在我的python应用程序中与rocksdb进行交互，并在其中存储任意的字典。我收集这些信息是为了我可以使用类似pickle的东西来进行序列化。但我需要能够根据其键的值过滤记录。这里有什么合适的方法？
    python rocksdb 2017-07-24

    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写
    windows sbt rocksdb 2016-11-27

    0热度

    1回答

    RocksDB：太小的SST文件太多

    我在运行服务一段时间后使用RocksDBJava我可以看到“太多打开的文件”异常。挖掘虽然在门户网站上提到的前一个问题，我发现这是因为系统限制打开最大数量的文件。 当我检查rocksDB使用的目录时，我注意到有超过100K的1KB大小的sst文件，这可能是给定错误的原因。 我想知道有没有什么方法可以让我们配置rocksBD来生成大尺寸的SST文件，以便创建的文件总数最少，并且我们可以避免这个错误。
    java rocksdb 2017-08-04

    1热度

    2回答

    Gui查看器的RocksDb sst文件

    我正在与Kafka一起将数据保存到rocksdb中。 现在我想看看由Kafka创建的db键和值。 我下载了FastNoSQL并尝试失败。 该文件夹包含： 文件名为.sst .log文件 当前文件 标识文件 LOCK文件 LOG文件 清单文件 选项文件 我该如何看值？
    apache-kafka apache-kafka-streams rocksdb rocks 2017-06-18

    0热度

    1回答

    并行化rocksdb迭代

    我的迭代器代码： Iterator* iterator = _db->NewIterator(ReadOptions()); for (iterator->SeekToFirst(); iterator->Valid(); iterator->Next()) { Slice const& key = iterator->key(); Slice const& value =
    c++11 concurrency iterator parallel-for rocksdb 2016-12-01

    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
    apache-kafka apache-kafka-streams confluent rocksdb confluent-kafka 2017-05-02

    0热度

    1回答

    为RocksDB实现一个比较器

    我有一些链接问题与当前类扩展rocksdb :: Comparator。 “NumericKeyComparator.cpp” #include <rocksdb/db.h> #include <rocksdb/comparator.h> #include "../../structure/structure.h" #include "../../NumberToString.h" #in
    c++ c++11 leveldb rocksdb 2017-08-10

    1热度

    1回答

    Kafka Streams - 低级别处理器API - RocksDB TimeToLive（TTL）

    我正在尝试低级别处理器API。我正在使用处理器API对传入记录进行数据聚合，并将聚合记录写入RocksDB。 但是，我想保留在rocksdb中添加的记录只能在24小时内处于活动状态。 24小时后，记录应该删除。这可以通过更改ttl设置来完成。但是，没有太多的文档可以帮助我解决这个问题。 如何更改ttl值？我应该使用什么java api将ttl时间设置为24小时，以及当前默认的ttl设置时间？
    apache-kafka apache-kafka-streams rocksdb 2017-05-09

    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>
    python macos rocksdb 2017-10-11
最新问题