static LinkedBuffer |
LinkedBuffer.allocate(int size,
LinkedBuffer previous) |
Allocates a new buffer with the specified size and appends it to the previous buffer.
|
abstract LinkedBuffer |
WriteSink.drain(WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
B64Code.encode(byte[] input,
int inOffset,
int inLen,
WriteSession session,
LinkedBuffer lb) |
Encodes the byte array into the LinkedBuffer and grows when full.
|
(package private) static int |
IOUtil.fillBufferWithDelimitedMessageFrom(java.io.InputStream in,
boolean drainRemainingBytesIfTooLarge,
LinkedBuffer lb) |
Fills the buffer based from the varint32 read from the input stream.
|
protected int |
WriteSession.flush(LinkedBuffer lb,
byte[] buf,
int offset,
int len) |
|
int |
WriteSession.FlushHandler.flush(WriteSession session,
LinkedBuffer lb,
byte[] buf,
int offset,
int len) |
|
private static void |
StreamedStringSerializer.flushAndReset(LinkedBuffer node,
WriteSession session) |
|
static <T> int |
GraphIOUtil.mergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Merges the message (delimited) from the InputStream using the given schema .
|
static <T> int |
ProtobufIOUtil.mergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Merges the message (delimited) from the InputStream using the given schema .
|
static <T> int |
ProtostuffIOUtil.mergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Merges the message (delimited) from the InputStream using the given schema .
|
static <T> void |
GraphIOUtil.mergeFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Merges the message from the InputStream using the given schema .
|
static <T> void |
JsonIOUtil.mergeFrom(java.io.InputStream in,
T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Merges the message from the InputStream using the given schema .
|
static <T> void |
ProtobufIOUtil.mergeFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Merges the message from the InputStream using the given schema .
|
static <T> void |
ProtostuffIOUtil.mergeFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Merges the message from the InputStream using the given schema .
|
static <T> void |
SmileIOUtil.mergeFrom(java.io.InputStream in,
T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Merges the message from the InputStream using the given schema .
|
private static LinkedBuffer |
YamlOutput.newLine(int indent,
WriteSink sink,
WriteSession session,
LinkedBuffer lb) |
|
static <T> boolean |
GraphIOUtil.optMergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
boolean drainRemainingBytesIfTooLarge,
LinkedBuffer buffer) |
Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method
will return false.
|
static <T> boolean |
GraphIOUtil.optMergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method
will return false.
|
static <T> boolean |
ProtobufIOUtil.optMergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
boolean drainRemainingBytesIfTooLarge,
LinkedBuffer buffer) |
Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method
will return false.
|
static <T> boolean |
ProtobufIOUtil.optMergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method
will return false.
|
static <T> boolean |
ProtostuffIOUtil.optMergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
boolean drainRemainingBytesIfTooLarge,
LinkedBuffer buffer) |
Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method
will return false.
|
static <T> boolean |
ProtostuffIOUtil.optMergeDelimitedFrom(java.io.InputStream in,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Optimal/Optional mergeDelimitedFrom - If the message does not fit the buffer, no merge is done and this method
will return false.
|
static <T> int |
GraphIOUtil.optWriteDelimitedTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Optimal writeDelimitedTo - The varint32 prefix is written to the buffer instead of directly writing to
outputstream.
|
static <T> int |
ProtobufIOUtil.optWriteDelimitedTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Optimal writeDelimitedTo - The varint32 prefix is written to the buffer instead of directly writing to
outputstream.
|
static <T> int |
ProtostuffIOUtil.optWriteDelimitedTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Optimal writeDelimitedTo - The varint32 prefix is written to the buffer instead of directly writing to
outputstream.
|
static <T> java.util.List<T> |
JsonIOUtil.parseListFrom(java.io.InputStream in,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Parses the messages from the stream using the given schema .
|
static <T> java.util.List<T> |
SmileIOUtil.parseListFrom(java.io.InputStream in,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Parses the messages from the stream using the given schema .
|
static LinkedBuffer |
B64Code.sencode(byte[] input,
int inOffset,
int inLen,
WriteSession session,
LinkedBuffer lb) |
Encodes the byte array into the LinkedBuffer and flushes to the OutputStream when buffer is full.
|
static <T> byte[] |
GraphIOUtil.toByteArray(T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into a byte array using the given schema.
|
static <T> byte[] |
JsonIOUtil.toByteArray(T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the message into a byte array using the given schema .
|
static <T> byte[] |
JsonXIOUtil.toByteArray(T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
|
static <T> byte[] |
ProtobufIOUtil.toByteArray(T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into a byte array using the given schema.
|
static <T> byte[] |
ProtostuffIOUtil.toByteArray(T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into a byte array using the given schema.
|
static <T> byte[] |
SmileIOUtil.toByteArray(T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the message into a byte array using the given schema .
|
static <T> byte[] |
XmlXIOUtil.toByteArray(T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into a byte array using the given schema.
|
static <T> byte[] |
YamlIOUtil.toByteArray(T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into a byte array with the supplied buffer.
|
static LinkedBuffer |
StreamedStringSerializer.writeAscii(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
Writes the ascii bytes from the string into the LinkedBuffer .
|
static LinkedBuffer |
StringSerializer.writeAscii(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
Writes the ascii bytes from the string into the LinkedBuffer .
|
abstract LinkedBuffer |
WriteSink.writeByte(byte value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeByteArray(byte[] value,
int offset,
int length,
WriteSession session,
LinkedBuffer lb) |
|
LinkedBuffer |
WriteSink.writeByteArray(byte[] value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeByteArrayB64(byte[] value,
int offset,
int length,
WriteSession session,
LinkedBuffer lb) |
|
LinkedBuffer |
WriteSink.writeByteArrayB64(byte[] value,
WriteSession session,
LinkedBuffer lb) |
|
static <T> int |
GraphIOUtil.writeDelimitedTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message , prefixed with its length, into an OutputStream .
|
static <T> int |
ProtobufIOUtil.writeDelimitedTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message , prefixed with its length, into an OutputStream .
|
static <T> int |
ProtostuffIOUtil.writeDelimitedTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message , prefixed with its length, into an OutputStream .
|
static LinkedBuffer |
StreamedStringSerializer.writeDouble(double value,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StringSerializer.writeDouble(double value,
WriteSession session,
LinkedBuffer lb) |
|
LinkedBuffer |
WriteSink.writeDouble(double value,
WriteSession session,
LinkedBuffer lb) |
|
LinkedBuffer |
WriteSink.writeDoubleLE(double value,
WriteSession session,
LinkedBuffer lb) |
|
private LinkedBuffer |
KvpOutput.writeField(int number,
int valueLen,
LinkedBuffer lb) |
|
private LinkedBuffer |
KvpOutput.writeField(int number,
LinkedBuffer lb) |
|
static LinkedBuffer |
StreamedStringSerializer.writeFloat(float value,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StringSerializer.writeFloat(float value,
WriteSession session,
LinkedBuffer lb) |
|
LinkedBuffer |
WriteSink.writeFloat(float value,
WriteSession session,
LinkedBuffer lb) |
|
LinkedBuffer |
WriteSink.writeFloatLE(float value,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StreamedStringSerializer.writeInt(int value,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StringSerializer.writeInt(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeInt16(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeInt16LE(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeInt32(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeInt32LE(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeInt64(long value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeInt64LE(long value,
WriteSession session,
LinkedBuffer lb) |
|
private static LinkedBuffer |
YamlOutput.writeKey(java.lang.String name,
int indent,
boolean repeated,
WriteSink sink,
WriteSession session,
LinkedBuffer lb) |
|
static <T> void |
JsonIOUtil.writeListTo(java.io.OutputStream out,
java.util.List<T> messages,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the messages into the stream using the given schema.
|
static <T> void |
JsonXIOUtil.writeListTo(LinkedBuffer buffer,
java.util.List<T> messages,
Schema<T> schema,
boolean numeric) |
Serializes the messages into the LinkedBuffer using the given schema.
|
static <T> void |
JsonXIOUtil.writeListTo(java.io.OutputStream out,
java.util.List<T> messages,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the messages into the stream using the given schema with the supplied buffer.
|
static <T> int |
ProtobufIOUtil.writeListTo(java.io.OutputStream out,
java.util.List<T> messages,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the messages (delimited) into an OutputStream using the given schema.
|
static <T> int |
ProtostuffIOUtil.writeListTo(java.io.OutputStream out,
java.util.List<T> messages,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the messages (delimited) into an OutputStream using the given schema.
|
static <T> void |
SmileIOUtil.writeListTo(java.io.OutputStream out,
java.util.List<T> messages,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the messages into the stream using the given schema.
|
static <T> int |
YamlIOUtil.writeListTo(LinkedBuffer buffer,
java.util.List<T> messages,
Schema<T> schema) |
Serializes the messages a LinkedBuffer using the given schema.
|
static <T> int |
YamlIOUtil.writeListTo(java.io.OutputStream out,
java.util.List<T> messages,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the messages into an OutputStream using the given schema with the supplied buffer.
|
static LinkedBuffer |
StreamedStringSerializer.writeLong(long value,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StringSerializer.writeLong(long value,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
ProtobufOutput.writeRawVarInt32(int value,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the variable int 32.
|
abstract LinkedBuffer |
WriteSink.writeStrAscii(java.lang.CharSequence value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrFromDouble(double value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrFromFloat(float value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrFromInt(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrFromLong(long value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrUTF8(java.lang.CharSequence value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrUTF8FixedDelimited(java.lang.CharSequence value,
boolean littleEndian,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeStrUTF8VarDelimited(java.lang.CharSequence value,
WriteSession session,
LinkedBuffer lb) |
|
(package private) static LinkedBuffer |
YamlOutput.writeTag(java.lang.String name,
boolean repeated,
WriteSink sink,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
ProtobufOutput.writeTagAndByteArray(int tag,
byte[] value,
int offset,
int valueLen,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the tag and byte array
|
static LinkedBuffer |
ProtobufOutput.writeTagAndLinkedBuffer(int tag,
LinkedBuffer buffer,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the tag and LinkedBuffer (zero-copy)
|
static LinkedBuffer |
ProtobufOutput.writeTagAndRawLittleEndian32(int tag,
int value,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the tag and little endian 32
|
static LinkedBuffer |
ProtobufOutput.writeTagAndRawLittleEndian64(int tag,
long value,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the tag and little endian 64
|
static LinkedBuffer |
ProtobufOutput.writeTagAndRawVarInt32(int tag,
int value,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the tag and var int 32
|
static LinkedBuffer |
ProtobufOutput.writeTagAndRawVarInt64(int tag,
long value,
WriteSession session,
LinkedBuffer lb) |
Returns the buffer encoded with the tag and var int 64
|
static <T> int |
GraphIOUtil.writeTo(LinkedBuffer buffer,
T message,
Schema<T> schema) |
Writes the message into the LinkedBuffer using the given schema.
|
static <T> int |
GraphIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into an OutputStream using the given schema.
|
static <T> void |
JsonIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the message into an OutputStream using the given schema .
|
static <T> void |
JsonXIOUtil.writeTo(LinkedBuffer buffer,
T message,
Schema<T> schema,
boolean numeric) |
|
static <T extends Message<T>> void |
JsonXIOUtil.writeTo(java.io.OutputStream out,
T message,
boolean numeric,
LinkedBuffer buffer) |
Serializes the message into an OutputStream via JsonXOutput with the supplied buffer.
|
static <T> void |
JsonXIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the message into an OutputStream via JsonXOutput using the given
schema .
|
static int |
LinkedBuffer.writeTo(java.io.DataOutput out,
LinkedBuffer node) |
Writes the contents of the LinkedBuffer into the DataOutput .
|
static int |
LinkedBuffer.writeTo(java.io.OutputStream out,
LinkedBuffer node) |
Writes the contents of the LinkedBuffer into the OutputStream .
|
static <T> int |
ProtobufIOUtil.writeTo(LinkedBuffer buffer,
T message,
Schema<T> schema) |
Writes the message into the LinkedBuffer using the given schema.
|
static <T> int |
ProtobufIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into an OutputStream using the given schema.
|
static <T> int |
ProtostuffIOUtil.writeTo(LinkedBuffer buffer,
T message,
Schema<T> schema) |
Writes the message into the LinkedBuffer using the given schema.
|
static <T> int |
ProtostuffIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into an OutputStream using the given schema.
|
static <T> void |
SmileIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
boolean numeric,
LinkedBuffer buffer) |
Serializes the message into an OutputStream using the given schema .
|
static <T> int |
XmlXIOUtil.writeTo(LinkedBuffer buffer,
T message,
Schema<T> schema) |
Writes the message into the LinkedBuffer using the given schema.
|
static <T> int |
XmlXIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into an OutputStream using the given schema.
|
static <T> int |
YamlIOUtil.writeTo(LinkedBuffer buffer,
T message,
Schema<T> schema) |
|
static <T> int |
YamlIOUtil.writeTo(java.io.OutputStream out,
T message,
Schema<T> schema,
LinkedBuffer buffer) |
Serializes the message into an OutputStream with the supplied buffer.
|
static LinkedBuffer |
StreamedStringSerializer.writeUTF8(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
Writes the utf8-encoded bytes from the string into the LinkedBuffer .
|
(package private) static LinkedBuffer |
StringSerializer.writeUTF8(java.lang.CharSequence str,
int i,
int len,
byte[] buffer,
int offset,
int limit,
WriteSession session,
LinkedBuffer lb) |
Slow path.
|
(package private) static LinkedBuffer |
StringSerializer.writeUTF8(java.lang.CharSequence str,
int i,
int len,
WriteSession session,
LinkedBuffer lb) |
Fast path.
|
static LinkedBuffer |
StringSerializer.writeUTF8(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
Writes the utf8-encoded bytes from the string into the LinkedBuffer .
|
private static LinkedBuffer |
JsonXOutput.writeUTF8Escaped(byte[] input,
int inStart,
int inLen,
WriteSink sink,
WriteSession session,
LinkedBuffer lb) |
|
private static LinkedBuffer |
JsonXOutput.writeUTF8Escaped(java.lang.CharSequence str,
WriteSink sink,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StreamedStringSerializer.writeUTF8FixedDelimited(java.lang.CharSequence str,
boolean littleEndian,
WriteSession session,
LinkedBuffer lb) |
The length of the utf8 bytes is written first before the string - which is fixed 2-bytes.
|
static LinkedBuffer |
StreamedStringSerializer.writeUTF8FixedDelimited(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
The length of the utf8 bytes is written first (big endian) before the string - which is fixed 2-bytes.
|
static LinkedBuffer |
StringSerializer.writeUTF8FixedDelimited(java.lang.CharSequence str,
boolean littleEndian,
WriteSession session,
LinkedBuffer lb) |
The length of the utf8 bytes is written first before the string - which is fixed 2-bytes.
|
static LinkedBuffer |
StringSerializer.writeUTF8FixedDelimited(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
The length of the utf8 bytes is written first (big endian) before the string - which is fixed 2-bytes.
|
private static LinkedBuffer |
StreamedStringSerializer.writeUTF8OneByteDelimited(java.lang.CharSequence str,
int index,
int len,
WriteSession session,
LinkedBuffer lb) |
|
private static LinkedBuffer |
StringSerializer.writeUTF8OneByteDelimited(java.lang.CharSequence str,
int index,
int len,
WriteSession session,
LinkedBuffer lb) |
|
private static LinkedBuffer |
StreamedStringSerializer.writeUTF8VarDelimited(java.lang.CharSequence str,
int index,
int len,
int lowerLimit,
int expectedSize,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StreamedStringSerializer.writeUTF8VarDelimited(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
The length of the utf8 bytes is written first before the string - which is a variable int (1 to 5 bytes).
|
private static LinkedBuffer |
StringSerializer.writeUTF8VarDelimited(java.lang.CharSequence str,
int index,
int len,
int lowerLimit,
int expectedSize,
WriteSession session,
LinkedBuffer lb) |
|
static LinkedBuffer |
StringSerializer.writeUTF8VarDelimited(java.lang.CharSequence str,
WriteSession session,
LinkedBuffer lb) |
The length of the utf8 bytes is written first before the string - which is a variable int (1 to 5 bytes).
|
abstract LinkedBuffer |
WriteSink.writeVarInt32(int value,
WriteSession session,
LinkedBuffer lb) |
|
abstract LinkedBuffer |
WriteSink.writeVarInt64(long value,
WriteSession session,
LinkedBuffer lb) |
|