Class JsonXOutput

java.lang.Object

io.protostuff.WriteSession

io.protostuff.JsonXOutput

All Implemented Interfaces:

Output, StatefulOutput

public final class JsonXOutput
extends WriteSession
implements Output, StatefulOutput

An optimized json output which is efficient in writing numeric keys and pre-encoded utf8 strings (in byte array form).

This is the appropriate output sink to use when writing from binary (protostuff,protobuf,etc) pipes.

Nested Class Summary

Nested classes/interfaces inherited from class WriteSession

WriteSession.FlushHandler

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte	COMMA
private static final byte[]	COMMA_AND_QUOTE
private static final byte[]	COMMA_AND_START_OBJECT
private static final byte	END_ARRAY
private static final byte[]	END_ARRAY__COMMA__QUOTE
private static final byte[]	END_ARRAY_AND_END_OBJECT
private static final byte	END_OBJECT
private static final byte[]	FALSE
(package private) static final byte[]	HEX_BYTES
private static final byte[]	KEY_SUFFIX
private static final byte[]	KEY_SUFFIX_ARRAY
private static final byte[]	KEY_SUFFIX_ARRAY_OBJECT
private static final byte[]	KEY_SUFFIX_ARRAY_STRING
private static final byte[]	KEY_SUFFIX_OBJECT
private static final byte[]	KEY_SUFFIX_STRING
private int	lastNumber
private boolean	lastRepeated
private final boolean	numeric
private static final byte	QUOTE
private Schema<?>	schema
(package private) static final int[]	sOutputEscapes
private static final byte	START_ARRAY
private static final byte	START_OBJECT
private static final byte[]	TRUE

Fields inherited from class WriteSession

flushHandler, head, nextBufferSize, out, sink, size, tail

Constructor Summary

Constructors

Constructor	Description
JsonXOutput(LinkedBuffer head, boolean numeric, Schema<?> schema)
JsonXOutput(LinkedBuffer head, OutputStream out, boolean numeric, Schema<?> schema)
JsonXOutput(LinkedBuffer head, OutputStream out, WriteSession.FlushHandler flushHandler, int nextBufferSize, boolean numeric, Schema<?> schema)

Method Summary

Modifier and Type	Method	Description
JsonXOutput	clear()	The buffer will be cleared (tail will point to the head) and the size will be reset to zero.
int	getLastNumber()	Gets the last field number written.
boolean	isLastRepeated()	Returns true if the last written field was a repeated field.
boolean	isNumeric()	Returns whether the incoming messages' field names are numeric.
void	reset()	Resets this output for re-use.
void	updateLast(Schema<?> schema, Schema<?> lastSchema)	Updates the schema if lastSchema was indeed the last schema used.
JsonXOutput	use(Schema<?> schema)	Before serializing a message/object tied to a schema, this should be called.
void	writeBool(int fieldNumber, boolean value, boolean repeated)	Writes a boolean field.
void	writeByteArray(int fieldNumber, byte[] value, boolean repeated)	Writes a byte array field.
void	writeByteRange(boolean utf8String, int fieldNumber, byte[] value, int offset, int length, boolean repeated)	Writes a binary or a pre-encoded utf8 string.
void	writeBytes(int fieldNumber, ByteString value, boolean repeated)	Writes a ByteString(wraps byte array) field.
void	writeBytes(int fieldNumber, ByteBuffer value, boolean repeated)	Writes a ByteBuffer field.
(package private) JsonXOutput	writeCommaAndStartObject()
void	writeDouble(int fieldNumber, double value, boolean repeated)	Writes a double field.
(package private) JsonXOutput	writeEndArray()
(package private) JsonXOutput	writeEndObject()
void	writeEnum(int fieldNumber, int value, boolean repeated)	Writes a enum(its number) field.
void	writeFixed32(int fieldNumber, int value, boolean repeated)	Writes a fixed int(4 bytes) field.
void	writeFixed64(int fieldNumber, long value, boolean repeated)	Writes a fixed long(8 bytes) field.
void	writeFloat(int fieldNumber, float value, boolean repeated)	Writes a float field.
void	writeInt32(int fieldNumber, int value, boolean repeated)	Writes a variable int field.
void	writeInt64(int fieldNumber, long value, boolean repeated)	Writes a variable long field.
private LinkedBuffer	writeKey(int fieldNumber, WriteSink sink, byte[] keySuffix)
<T> void	writeObject(int fieldNumber, T value, Schema<T> schema, boolean repeated)	Writes an object(using its schema) field.
void	writeSFixed32(int fieldNumber, int value, boolean repeated)	Writes a signed+fixed int(4 bytes) field.
void	writeSFixed64(int fieldNumber, long value, boolean repeated)	Writes a signed+fixed long(8 bytes) field.
void	writeSInt32(int fieldNumber, int value, boolean repeated)	Writes a signed int field.
void	writeSInt64(int fieldNumber, long value, boolean repeated)	Writes a signed long field.
(package private) JsonXOutput	writeStartArray()
(package private) JsonXOutput	writeStartObject()
void	writeString(int fieldNumber, CharSequence value, boolean repeated)	Writes a String field.
void	writeUInt32(int fieldNumber, int value, boolean repeated)	Writes an unsigned int field.
void	writeUInt64(int fieldNumber, long value, boolean repeated)	Writes an unsigned long field.
private static LinkedBuffer	writeUTF8Escaped(byte[] input, int inStart, int inLen, WriteSink sink, WriteSession session, LinkedBuffer lb)
private static LinkedBuffer	writeUTF8Escaped(CharSequence str, WriteSink sink, WriteSession session, LinkedBuffer lb)

Methods inherited from class WriteSession

flush, flush, flush, getSize, toByteArray

Methods inherited from class Object

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

Field Details

START_OBJECT

private static final byte START_OBJECT

See Also:

• Constant Field Values

END_OBJECT

private static final byte END_OBJECT

See Also:

• Constant Field Values

START_ARRAY

private static final byte START_ARRAY

See Also:

• Constant Field Values

END_ARRAY

private static final byte END_ARRAY

See Also:

• Constant Field Values

COMMA

private static final byte COMMA

See Also:

• Constant Field Values

QUOTE

private static final byte QUOTE

See Also:

• Constant Field Values

TRUE

private static final byte[] TRUE

FALSE

private static final byte[] FALSE

KEY_SUFFIX_ARRAY

private static final byte[] KEY_SUFFIX_ARRAY

KEY_SUFFIX_ARRAY_OBJECT

private static final byte[] KEY_SUFFIX_ARRAY_OBJECT

KEY_SUFFIX_ARRAY_STRING

private static final byte[] KEY_SUFFIX_ARRAY_STRING

KEY_SUFFIX_OBJECT

private static final byte[] KEY_SUFFIX_OBJECT

KEY_SUFFIX_STRING

private static final byte[] KEY_SUFFIX_STRING

KEY_SUFFIX

private static final byte[] KEY_SUFFIX

COMMA_AND_QUOTE

private static final byte[] COMMA_AND_QUOTE

COMMA_AND_START_OBJECT

private static final byte[] COMMA_AND_START_OBJECT

END_ARRAY_AND_END_OBJECT

private static final byte[] END_ARRAY_AND_END_OBJECT

END_ARRAY__COMMA__QUOTE

private static final byte[] END_ARRAY__COMMA__QUOTE

schema

private Schema<?> schema

numeric

private final boolean numeric

lastRepeated

private boolean lastRepeated

lastNumber

private int lastNumber

HEX_BYTES

static final byte[] HEX_BYTES

sOutputEscapes

static final int[] sOutputEscapes

Constructor Details

JsonXOutput

public JsonXOutput(LinkedBuffer head,
 boolean numeric,
 Schema<?> schema)

JsonXOutput

public JsonXOutput(LinkedBuffer head,
 OutputStream out,
 WriteSession.FlushHandler flushHandler,
 int nextBufferSize,
 boolean numeric,
 Schema<?> schema)

JsonXOutput

public JsonXOutput(LinkedBuffer head,
 OutputStream out,
 boolean numeric,
 Schema<?> schema)

Method Details

reset

public void reset()

Resets this output for re-use.

Overrides:

reset in class WriteSession

clear

public JsonXOutput clear()

Description copied from class: WriteSession

The buffer will be cleared (tail will point to the head) and the size will be reset to zero.

Overrides:

clear in class WriteSession

use

public JsonXOutput use(Schema<?> schema)

Before serializing a message/object tied to a schema, this should be called.

isNumeric

public boolean isNumeric()

Returns whether the incoming messages' field names are numeric.

getLastNumber

public int getLastNumber()

Gets the last field number written.

isLastRepeated

public boolean isLastRepeated()

Returns true if the last written field was a repeated field.

updateLast

public void updateLast(Schema<?> schema,
 Schema<?> lastSchema)

Description copied from interface: StatefulOutput

Updates the schema if lastSchema was indeed the last schema used.

Specified by:

updateLast in interface StatefulOutput

writeCommaAndStartObject

JsonXOutput writeCommaAndStartObject()
                              throws IOException

Throws:

IOException

writeStartObject

JsonXOutput writeStartObject()
                      throws IOException

Throws:

IOException

writeEndObject

JsonXOutput writeEndObject()
                    throws IOException

Throws:

IOException

writeStartArray

JsonXOutput writeStartArray()
                     throws IOException

Throws:

IOException

writeEndArray

JsonXOutput writeEndArray()
                   throws IOException

Throws:

IOException

writeKey

private LinkedBuffer writeKey(int fieldNumber,
 WriteSink sink,
 byte[] keySuffix)
                       throws IOException

Throws:

IOException

writeBool

public void writeBool(int fieldNumber,
 boolean value,
 boolean repeated)
               throws IOException

Description copied from interface: Output

Writes a boolean field.

Specified by:

writeBool in interface Output

Throws:

IOException

writeByteArray

public void writeByteArray(int fieldNumber,
 byte[] value,
 boolean repeated)
                    throws IOException

Description copied from interface: Output

Writes a byte array field.

Specified by:

writeByteArray in interface Output

Throws:

IOException

writeByteRange

public void writeByteRange(boolean utf8String,
 int fieldNumber,
 byte[] value,
 int offset,
 int length,
 boolean repeated)
                    throws IOException

Description copied from interface: Output

Writes a binary or a pre-encoded utf8 string.

Specified by:

writeByteRange in interface Output

Throws:

IOException

writeBytes

public void writeBytes(int fieldNumber,
 ByteString value,
 boolean repeated)
                throws IOException

Description copied from interface: Output

Writes a ByteString(wraps byte array) field.

Specified by:

writeBytes in interface Output

Throws:

IOException

writeDouble

public void writeDouble(int fieldNumber,
 double value,
 boolean repeated)
                 throws IOException

Description copied from interface: Output

Writes a double field.

Specified by:

writeDouble in interface Output

Throws:

IOException

writeEnum

public void writeEnum(int fieldNumber,
 int value,
 boolean repeated)
               throws IOException

Description copied from interface: Output

Writes a enum(its number) field.

Specified by:

writeEnum in interface Output

Throws:

IOException

writeFixed32

public void writeFixed32(int fieldNumber,
 int value,
 boolean repeated)
                  throws IOException

Description copied from interface: Output

Writes a fixed int(4 bytes) field.

Specified by:

writeFixed32 in interface Output

Throws:

IOException

writeFixed64

public void writeFixed64(int fieldNumber,
 long value,
 boolean repeated)
                  throws IOException

Description copied from interface: Output

Writes a fixed long(8 bytes) field.

Specified by:

writeFixed64 in interface Output

Throws:

IOException

writeFloat

public void writeFloat(int fieldNumber,
 float value,
 boolean repeated)
                throws IOException

Description copied from interface: Output

Writes a float field.

Specified by:

writeFloat in interface Output

Throws:

IOException

writeInt32

public void writeInt32(int fieldNumber,
 int value,
 boolean repeated)
                throws IOException

Description copied from interface: Output

Writes a variable int field.

Specified by:

writeInt32 in interface Output

Throws:

IOException

writeInt64

public void writeInt64(int fieldNumber,
 long value,
 boolean repeated)
                throws IOException

Description copied from interface: Output

Writes a variable long field.

Specified by:

writeInt64 in interface Output

Throws:

IOException

writeSFixed32

public void writeSFixed32(int fieldNumber,
 int value,
 boolean repeated)
                   throws IOException

Description copied from interface: Output

Writes a signed+fixed int(4 bytes) field.

Specified by:

writeSFixed32 in interface Output

Throws:

IOException

writeSFixed64

public void writeSFixed64(int fieldNumber,
 long value,
 boolean repeated)
                   throws IOException

Description copied from interface: Output

Writes a signed+fixed long(8 bytes) field.

Specified by:

writeSFixed64 in interface Output

Throws:

IOException

writeSInt32

public void writeSInt32(int fieldNumber,
 int value,
 boolean repeated)
                 throws IOException

Description copied from interface: Output

Writes a signed int field.

Specified by:

writeSInt32 in interface Output

Throws:

IOException

writeSInt64

public void writeSInt64(int fieldNumber,
 long value,
 boolean repeated)
                 throws IOException

Description copied from interface: Output

Writes a signed long field.

Specified by:

writeSInt64 in interface Output

Throws:

IOException

writeString

public void writeString(int fieldNumber,
 CharSequence value,
 boolean repeated)
                 throws IOException

Description copied from interface: Output

Writes a String field.

Specified by:

writeString in interface Output

Throws:

IOException

writeUInt32

public void writeUInt32(int fieldNumber,
 int value,
 boolean repeated)
                 throws IOException

Description copied from interface: Output

Writes an unsigned int field.

Specified by:

writeUInt32 in interface Output

Throws:

IOException

writeUInt64

public void writeUInt64(int fieldNumber,
 long value,
 boolean repeated)
                 throws IOException

Description copied from interface: Output

Writes an unsigned long field.

Specified by:

writeUInt64 in interface Output

Throws:

IOException

writeObject

public <T> void writeObject(int fieldNumber,
 T value,
 Schema<T> schema,
 boolean repeated)
                     throws IOException

Description copied from interface: Output

Writes an object(using its schema) field.

Specified by:

writeObject in interface Output

Throws:

IOException

writeUTF8Escaped

private static LinkedBuffer writeUTF8Escaped(byte[] input,
 int inStart,
 int inLen,
 WriteSink sink,
 WriteSession session,
 LinkedBuffer lb)
                                      throws IOException

Throws:

IOException

writeUTF8Escaped

private static LinkedBuffer writeUTF8Escaped(CharSequence str,
 WriteSink sink,
 WriteSession session,
 LinkedBuffer lb)
                                      throws IOException

Throws:

IOException

writeBytes

public void writeBytes(int fieldNumber,
 ByteBuffer value,
 boolean repeated)
                throws IOException

Writes a ByteBuffer field.

Specified by:

writeBytes in interface Output

Throws:

IOException