com.twitter.chill

Class SerDeState

java.lang.Object

com.twitter.chill.SerDeState

public class SerDeState
extends java.lang.Object

This holds a Kryo Instance, Input and Output so that these objects can be pooled and no reallocated on each serialization.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.esotericsoftware.kryo.io.Input	input
protected com.esotericsoftware.kryo.Kryo	kryo
protected com.esotericsoftware.kryo.io.Output	output

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SerDeState(com.esotericsoftware.kryo.Kryo k, com.esotericsoftware.kryo.io.Input in, com.esotericsoftware.kryo.io.Output out)

Method Summary

Modifier and Type	Method and Description
void	clear() Call this when to reset the state to the initial state
boolean	hasRegistration(java.lang.Class obj)
int	numOfReadBytes()
int	numOfWrittenBytes()
byte[]	outputToBytes()
java.lang.Object	readClassAndObject()
<T> T	readObject(java.lang.Class<T> cls)
void	setInput(byte[] in)
void	setInput(byte[] in, int offset, int count)
void	setInput(java.io.InputStream in)
void	writeClassAndObject(java.lang.Object o)
void	writeObject(java.lang.Object o)
void	writeOutputTo(java.io.OutputStream os)

Methods inherited from class java.lang.Object

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

Field Detail

kryo

protected final com.esotericsoftware.kryo.Kryo kryo

input

protected final com.esotericsoftware.kryo.io.Input input

output

protected final com.esotericsoftware.kryo.io.Output output

Constructor Detail

SerDeState

protected SerDeState(com.esotericsoftware.kryo.Kryo k,
                     com.esotericsoftware.kryo.io.Input in,
                     com.esotericsoftware.kryo.io.Output out)

Method Detail

clear

public void clear()

Call this when to reset the state to the initial state

setInput

public void setInput(byte[] in)

setInput

public void setInput(byte[] in,
                     int offset,
                     int count)

setInput

public void setInput(java.io.InputStream in)

numOfWrittenBytes

public int numOfWrittenBytes()

numOfReadBytes

public int numOfReadBytes()

readObject

public <T> T readObject(java.lang.Class<T> cls)

readClassAndObject

public java.lang.Object readClassAndObject()

writeObject

public void writeObject(java.lang.Object o)

writeClassAndObject

public void writeClassAndObject(java.lang.Object o)

outputToBytes

public byte[] outputToBytes()

writeOutputTo

public void writeOutputTo(java.io.OutputStream os)
                   throws java.io.IOException

Throws:

java.io.IOException

hasRegistration

public boolean hasRegistration(java.lang.Class obj)