kryo

    0

    1答えて

    私はthe SAMRecord classのスパークでKryoを使用しようとしていますが、実行時にエラーが表示されています。私はこのエラーの意味を理解していない、誰も説明することができますか? Kryoがこれに対応するためには何を変更する必要がありますか?問題は、メンバ変数mAlignmentBlocksがList<AlignmentBlock>の場合です。 Kryoはそのようなリストに問題があり

    1

    2答えて

    特殊クラスのClassオブジェクトを取得する必要があります。例えば import breeze.linalg.DenseVector val compileTimeClass = classOf[DenseVector[Double]] println(compileTimeClass) val denseVector = DenseVector(0.5, 1.0, 1.0, 0.5)

    1

    1答えて

    Kryoシリアライザを使用して特定の種類のリストを書き込もうとしていますが、読み書きしようとするとエラーが発生します。私が記述しようとしていますリストは私は何のArrayListまたはリストの他のタイプ コード Class FakeRegsitrator implements KryoRegistrator{ @Override public void registerCla

    1

    2答えて

    私はエントリとしての分散MAPを使用してHazelcastアプリケーションを実装しています。私JsonNodeSerializerしかし private final ObjectReader jsonNodeReader; private final ObjectWriter jsonNodeWriter; @Override public void write(ObjectDataOut

    0

    1答えて

    を読んでアンダーフロー例外をバッファ原因: private byte[] serialize() { KryoPool pool = new KryoPool.Builder(factory).softReferences().build(); Kryo kryo = pool.borrow(); Output output = new Output(0, 1024

    1

    1答えて

    私は自分のシリアライザをJavaで実装しました。これをabcSerializerと呼ぶことができます。私がシリアル化しようとしているオブジェクトは、abcです。これはGoogleプロトコルバッファクラスです。 このオブジェクトをシリアル化するためにkryoフレームワークを使用しようとしています。研究とGoogleの読書のビットの後、私はkryoシリアライザを進めることを決めた。私はシリアライザその

    1

    1答えて

    私はスパークするために新しいです。そしてさらにKryoに新しい。私のsparkアプリケーションでは、値オブジェクトをシリアル化するためにkryoを使用していますが、アルゴリズムを格納するオブジェクトにはSerializableインターフェイスを使用しています...その理由は、すべての単一クラスをKryoに登録したくないからです。 私はkryoを排他的に使用するべきですか? 混合は&と一致しています

    1

    1答えて

    Sparkを使用することは、推奨されるde /シリアライザであるため、Kryoを使用することに決めました。 は、私が持っていると言う: public Class1 { private Class2 field1; } は、私はクラス1クラス2 &か、単に登録Class1の両方を登録する必要があります自動的にも、クラス2に登録しますか?

    1

    1答えて

    私はSpark 1.6.0-cdh5.8.0を使用しています。 私はKryoを使用しようとしています。私はそれがスパークが使用していたと思ったので、オプションのグアバを持っています。 しかし、現在のクラスにはデフォルトの可視性があるので、Kryoを使ってそれをシリアル化することはできません。 だから誰もがこれを見つけて解決しました。 プレゼントが隠されているので、次のコードは動作しません... k

    1

    1答えて

    SparkのスカラコードにタイプList<someClassType>のリストがあります。 kryo.registerを使用して登録するにはどうすればいいですか?つまり、kryo.register関数のパラメータはどうなるでしょうか。