mitonize.datastore

クラス Compressor

java.lang.Object

mitonize.datastore.Compressor

直系の既知のサブクラス:

JdkDeflaterCompressor, LZFCompressor

public abstract class Compressor
extends Object

Okuyamaに保管する値を圧縮するためのクラスのための抽象クラス。圧縮アルゴリズムは値の容量や アクセスの特性によって選択することができる。

Okuyamaの値として保管する際は、マジックコードとして1バイト目、2バイト目として 0xAC 0xEE を 設定し、更に3バイト目に圧縮に使用したCompressor具象クラスのIDを格納する。これにより、値を参照した 際に圧縮の有無を判定し、展開に必要なCompressorを選択して透過的に値の参照ができるようになっている。

ただし、この格納形式はOkuyamaサーバに同梱のOkuyamaClientの圧縮方式とは互換性がない。オリジナルのOkuyamaClientは 値が圧縮されているかどうかを判定できないため、取得側で全てを圧縮するか、圧縮しないかを決める必要がある。

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
Compressor()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
abstract ByteBuffer	compress(byte[] serialized)
abstract ByteBuffer	compress(byte[] serialized, int offset, int length)
abstract ByteBuffer	decompress(byte[] b, int offset, int length)
static Compressor	getAppliedCompressor(byte[] data, int offset, int length) 独自仕様：圧縮されたバイト列はマジックコード 0xac 0xee で始めることとする。
static Compressor	getCompressor(int compressorId)
abstract int	getCompressorId()
static void	registerCompressor(Compressor compressor)
protected void	writeMagicBytes(byte[] buf)

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

コンストラクタの詳細

Compressor

public Compressor()

メソッドの詳細

getAppliedCompressor

public static Compressor getAppliedCompressor(byte[] data,
                                              int offset,
                                              int length)
                                       throws IllegalStateException

• 独自仕様：圧縮されたバイト列はマジックコード 0xac 0xee で始めることとする。
• 独自仕様：3バイト目には格納時に使用されたCompressorの識別子を設定する。

パラメータ:

data - データストアから取得したペイロードが格納されたバッファ

offset - 参照するバッファのオフセット

length - バッファのサイズ

戻り値:

与えられたバイト列がCompressorによって圧縮されている場合は、展開に必要なCompressorを返す。

例外:

IllegalStateException - 圧縮されたペイロードだが該当するCompressorが登録されていない。registerCompressor(Compressor)を初期化時に実行しておく必要がある。

getCompressor

public static Compressor getCompressor(int compressorId)

registerCompressor

public static void registerCompressor(Compressor compressor)

writeMagicBytes

protected void writeMagicBytes(byte[] buf)

getCompressorId

public abstract int getCompressorId()

compress

public abstract ByteBuffer compress(byte[] serialized)

compress

public abstract ByteBuffer compress(byte[] serialized,
                                    int offset,
                                    int length)

decompress

public abstract ByteBuffer decompress(byte[] b,
                                      int offset,
                                      int length)
                               throws OperationFailedException

例外:

OperationFailedException