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)
float	readFloat(InputStream in)
float[]	readFloats(InputStream in)
int	readInt(InputStream in)
int[]	readInts(InputStream in)
long	readLong(InputStream in)
long[]	readLongs(InputStream in)
String	readString(ByteBuffer in)
String	readString(InputStream in)
String[]	readStrings(ByteBuffer in)
String[]	readStrings(InputStream 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.
static void	writeBigEndianLongToOutputStream(OutputStream out, long value, ByteBuffer helperBuffer) Writes the given long value into the given OutputStream in big-endian byte order, using the helperBuffer.
void	writeFloat(OutputStream out, float floatValue)
void	writeFloat(WritableByteChannel out, float floatValue)
void	writeFloats(OutputStream out, float[] floats)
void	writeInt(OutputStream out, int intValue)
void	writeInt(WritableByteChannel out, int intValue)
void	writeInts(OutputStream out, int[] ints)
void	writeInts(OutputStream out, IntList ints)
void	writeLong(OutputStream out, long longValue)
void	writeLong(WritableByteChannel out, long longValue)
void	writeLongs(OutputStream out, long[] longs)
static void	writeNativeOrderedIntToOutputStream(OutputStream out, int value, ByteBuffer helperBuffer) Writes the given int value into the given OutputStream in the native byte order, using the given helperBuffer.
static void	writeNativeOrderedLongToOutputStream(OutputStream out, long value, ByteBuffer helperBuffer) Writes the given long value into the given OutputStream in the native byte order, using the helperBuffer.
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)
void	writeStrings(OutputStream out, List<String> names)
void	writeStrings(OutputStream out, String[] names)

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

writeBigEndianLongToOutputStream

public static void writeBigEndianLongToOutputStream(OutputStream out,
                                                    long value,
                                                    ByteBuffer helperBuffer)
                                             throws IOException

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

Parameters:

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

Throws:

IOException

writeNativeOrderedLongToOutputStream

public static void writeNativeOrderedLongToOutputStream(OutputStream out,
                                                        long value,
                                                        ByteBuffer helperBuffer)
                                                 throws IOException

Writes the given long value into the given OutputStream in the native byte order, using the helperBuffer.

Parameters:

helperBuffer - a heap ByteBuffer with capacity of at least 8, with the native byte order

Throws:

IOException

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

writeNativeOrderedIntToOutputStream

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

Writes the given int value into the given OutputStream in the native byte order, using the given helperBuffer.

Parameters:

helperBuffer - a heap ByteBuffer with capacity of at least 4, with the native byte order

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(InputStream in)
                  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

writeStrings

public void writeStrings(OutputStream out,
                         String[] names)
                  throws IOException

Throws:

IOException

writeStrings

public void writeStrings(OutputStream out,
                         List<String> names)
                  throws IOException

Throws:

IOException

readStrings

public String[] readStrings(InputStream in)
                     throws IOException

Throws:

IOException

readStrings

public String[] readStrings(ByteBuffer in)
                     throws IOException

Throws:

IOException

writeInt

public void writeInt(OutputStream out,
                     int intValue)
              throws IOException

Throws:

IOException

writeInt

public void writeInt(WritableByteChannel out,
                     int intValue)
              throws IOException

Throws:

IOException

readInt

public int readInt(InputStream in)
            throws IOException

Throws:

IOException

writeInts

public void writeInts(OutputStream out,
                      int[] ints)
               throws IOException

Throws:

IOException

writeInts

public void writeInts(OutputStream out,
                      IntList ints)
               throws IOException

Throws:

IOException

readInts

public int[] readInts(InputStream in)
               throws IOException

Throws:

IOException

writeLong

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

Throws:

IOException

writeLong

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

Throws:

IOException

readLong

public long readLong(InputStream in)
              throws IOException

Throws:

IOException

writeLongs

public void writeLongs(OutputStream out,
                       long[] longs)
                throws IOException

Throws:

IOException

readLongs

public long[] readLongs(InputStream in)
                 throws IOException

Throws:

IOException

writeFloat

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

Throws:

IOException

writeFloat

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

Throws:

IOException

readFloat

public float readFloat(InputStream in)
                throws IOException

Throws:

IOException

writeFloats

public void writeFloats(OutputStream out,
                        float[] floats)
                 throws IOException

Throws:

IOException

readFloats

public float[] readFloats(InputStream in)
                   throws IOException

Throws:

IOException

getSerializedStringByteSize

public int getSerializedStringByteSize(String str)