io.druid.common.utils

Class SerializerUtils

java.lang.Object

io.druid.common.utils.SerializerUtils

public class SerializerUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
SerializerUtils()

Method Summary

Modifier and Type	Method and Description
int	getSerializedStringByteSize(String str)
byte[]	readBytes(ByteBuffer in, int length)
String	readString(ByteBuffer in)
static void	writeBigEndianIntToOutputStream(OutputStream out, int value, ByteBuffer helperBuffer) Writes the given int value into the given OutputStream in big-endian byte order, using the helperBuffer.
void	writeFloat(OutputStream out, float floatValue)
void	writeLong(WritableByteChannel out, long longValue)
void	writeString(com.google.common.io.OutputSupplier<? extends OutputStream> supplier, String name)
<T extends OutputStream> void	writeString(T out, String name)
void	writeString(WritableByteChannel out, String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializerUtils

public SerializerUtils()

Method Detail

writeBigEndianIntToOutputStream

public static void writeBigEndianIntToOutputStream(OutputStream out,
                                                   int value,
                                                   ByteBuffer helperBuffer)
                                            throws IOException

Writes the given int value into the given OutputStream in big-endian byte order, using the helperBuffer. Faster alternative to out.write(Ints.toByteArray(value)), more convenient (sometimes) than wrapping the OutputStream into DataOutputStream.

Parameters:

helperBuffer - a big-endian heap ByteBuffer with capacity of at least 4

Throws:

IOException

writeString

public <T extends OutputStream> void writeString(T out,
                                                 String name)
                                          throws IOException

Throws:

IOException

writeString

public void writeString(com.google.common.io.OutputSupplier<? extends OutputStream> supplier,
                        String name)
                 throws IOException

Throws:

IOException

writeString

public void writeString(WritableByteChannel out,
                        String name)
                 throws IOException

Throws:

IOException

readString

public String readString(ByteBuffer in)
                  throws IOException

Throws:

IOException

readBytes

public byte[] readBytes(ByteBuffer in,
                        int length)
                 throws IOException

Throws:

IOException

writeLong

public void writeLong(WritableByteChannel out,
                      long longValue)
               throws IOException

Throws:

IOException

writeFloat

public void writeFloat(OutputStream out,
                       float floatValue)
                throws IOException

Throws:

IOException

getSerializedStringByteSize

public int getSerializedStringByteSize(String str)