com.twitter.chill

Class KryoPool

java.lang.Object

com.twitter.chill.ResourcePool<SerDeState>

com.twitter.chill.KryoPool

public abstract class KryoPool
extends ResourcePool<SerDeState>

Simple ResourcePool to save on Kryo instances, which are expensive to allocate

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	KryoPool(int poolSize)

Method Summary

Modifier and Type	Method and Description
<T> T	deepCopy(T obj)
java.lang.Object	fromBytes(byte[] ary)
<T> T	fromBytes(byte[] ary, java.lang.Class<T> cls)
boolean	hasRegistration(java.lang.Class obj)
void	release(SerDeState st)
byte[]	toBytesWithClass(java.lang.Object obj)
byte[]	toBytesWithoutClass(java.lang.Object obj)
static KryoPool	withBuffer(int poolSize, KryoInstantiator ki, int outBufferMin, int outBufferMax) Output is created with new Output(outBufferMin, outBufferMax);
static KryoPool	withByteArrayOutputStream(int poolSize, KryoInstantiator ki) Output is created with new Output(new ByteArrayOutputStream()) This will automatically resize internally

Methods inherited from class com.twitter.chill.ResourcePool

borrow, newInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

KryoPool

protected KryoPool(int poolSize)

Method Detail

release

public void release(SerDeState st)

Overrides:

release in class ResourcePool<SerDeState>

withBuffer

public static KryoPool withBuffer(int poolSize,
                                  KryoInstantiator ki,
                                  int outBufferMin,
                                  int outBufferMax)

Output is created with new Output(outBufferMin, outBufferMax);

withByteArrayOutputStream

public static KryoPool withByteArrayOutputStream(int poolSize,
                                                 KryoInstantiator ki)

Output is created with new Output(new ByteArrayOutputStream()) This will automatically resize internally

deepCopy

public <T> T deepCopy(T obj)

fromBytes

public java.lang.Object fromBytes(byte[] ary)

fromBytes

public <T> T fromBytes(byte[] ary,
                       java.lang.Class<T> cls)

toBytesWithClass

public byte[] toBytesWithClass(java.lang.Object obj)

toBytesWithoutClass

public byte[] toBytesWithoutClass(java.lang.Object obj)

hasRegistration

public boolean hasRegistration(java.lang.Class obj)