問題タブ [rocksdb]

私の起動方法：

私のシャットダウン方法：

しかし、シャットダウンが完了した後も、すべての列ファミリーのハンドルが破棄されたため、もちろん失敗するmergeスタックの下のリクエストを取得しています。rocksdb::DBImpl::BGWorkCompaction(void * arg)

コンパクションまたはフラッシュを停止するようにマークするにはどうすればよいですか? db インスタンスを削除するだけでは十分ではないようです。

私のイテレータコード:

反復の順序は重要ではありませんが、不要な要素を反復しないように、ループを壊すことが重要です。いつブレークするかを知るために、要素が意味のある順序でソートされているという事実を利用しています。callback長い時間がかかる可能性があります。

だから私がやりたいことの疑似コードは

concurrency::parallel_for_each を適用しようとしましたが、rocksdb api には適合しないようです。

同時反復を実装するにはどうすればよいでしょうか?

Spark がストレージとやり取りする方法を理解できません。

RocksDB データベース (またはその他のキーと値のストア) からデータをフェッチする Spark クラスターを作成したいと考えています。ただし、現時点で私ができる最善の方法は、データベースからデータセット全体を各クラスター ノードのメモリ (たとえば、マップ) にフェッチし、そのオブジェクトから RDD を構築することです。

必要なデータのみをフェッチするにはどうすればよいですか (Spark が HDFS で行うように)? Hadoop Input Format と Record Readers について読んだことがありますが、何を実装すべきかを完全には理解していません。

これは幅広い質問であることは承知していますが、私を始めるための助けをいただければ幸いです。前もって感謝します。

snappy で shared_lib をビルドする方法を知っている人はいますか?

過去3時間で私は試しました：

1. 環境変数の設定WITH_SNAPPY
2. 編集して 1thirdparty.incに変更するUSE_SNAPPY_DEFAULT
3. 経由で作成する変数を渡すmake shared_lib EXTRA_CFLAGS=-DSNAPPY
4. タンバリンで踊る。

何も役に立ちません。私は何をすべきか ？