com.gigaspaces.serialization.pbs

Class PbsEntryFormatter

java.lang.Object

com.gigaspaces.serialization.pbs.PbsEntryFormatter

public class PbsEntryFormatter
extends Object

Provides PBS services for writing/reading Entries to/from the space.

Since:

6.1

Author:

Niv

Field Summary

Fields

Modifier and Type	Field and Description
static int	BITMAP_FIFO
static int	BITMAP_METADATA
static int	BITMAP_REPLICATE
static int	BITMAP_TRANSIENT

Constructor Summary

Constructors

Constructor and Description
PbsEntryFormatter()

Method Summary

Modifier and Type	Method and Description
static ITemplatePacket	getCppTemplatePacketFromSqlQuery(SQLQuery<?> sqlQuery, ISpaceProxy spaceProxy)
static ITemplatePacket	getTemplatePacketFromSqlQuery(SQLQuery<?> sqlQuery, ISpaceProxy spaceProxy, PbsProjectionTemplate projectionTemplate, QueryResultTypeInternal resultType)
static DocumentProperties	readDynamicProperties(PbsInputStream input)
static EntryType	readEntryType(PbsInputStream input)
static Object	readFieldValue(PbsInputStream input)
static Object	readFieldValue(PbsInputStream input, ISpaceProxy contextSpaceProxy)
static PbsEntryPacket	readPbsEntryPacket(PbsInputStream input)
static PbsEntryPacket[]	readPbsEntryPacketArray(PbsInputStream input)
static ITemplatePacket	readPbsTemplate(PbsInputStream input, ISpaceProxy spaceProxy)
static ITemplatePacket	readPbsTemplate(PbsInputStream input, ISpaceProxy spaceProxy, ITypeDesc typeDescriptor)
static PbsTemplatePacket	readPbsTemplatePacket(PbsInputStream input)
static Object[]	readPrimitiveArray(PbsInputStream input, ISpaceProxy contextSpaceProxy)
static PbsProjectionTemplate	readProjectionTemplate(PbsInputStream input)
static QueryResultTypeInternal	readQueryResultType(PbsInputStream input)
static ITemplatePacket	readSqlQuery(PbsInputStream input, ISpaceProxy spaceProxy, ITypeDesc typeDescriptor)
static ITypeDesc	readTypeDesc(PbsInputStream input, String typeName, EntryType entryType, int flags)
static ITypeDesc	readTypeDescIfExists(PbsInputStream input, String typeName, EntryType entryType)
static ITypeDesc	readTypeDescriptor(PbsInputStream input)
static void	writeDynamicProperties(PbsOutputStream output, Map<String,Object> dynamicProperties)
static void	writeEntry(PbsOutputStream output, Object[] values, String className, String uid, int version, boolean isTransient, boolean isFifo, boolean isReplicatable)
static void	writeExternalEntry(PbsOutputStream output, IGSEntry entry)
static void	writeFieldValue(PbsOutputStream output, Object value)
static void	writeNullablePbsEntryPacket(PbsOutputStream output, PbsEntryPacket pbsEntry) Writes a pbs entry packet to the stream
static void	writeNullablePbsEntryPacketObjectArray(PbsOutputStream output, Object[] objects) Write an object array of nullable pbs entries to the stream
static void	writePbsEntryPacket(PbsOutputStream output, PbsEntryPacket pbsEntry) Writes a pbs entry packet to the stream
static void	writePbsEntryPacketLazy(PbsOutputStream output, PbsEntryPacket packet)
static void	writePbsEntryPacketObjectArray(PbsOutputStream output, Object[] objects) Write an object array of pbs entries to the stream
static void	writePrimitiveArray(PbsOutputStream output, Object[] array) Serialize a primitive (PbsFormatter primitive types) to the given stream
static void	writeTypeDesc(PbsOutputStream output, ITypeDesc typeDescriptor)

Methods inherited from class java.lang.Object

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

Field Detail

BITMAP_TRANSIENT

public static final int BITMAP_TRANSIENT

See Also:

Constant Field Values

BITMAP_FIFO

public static final int BITMAP_FIFO

See Also:

Constant Field Values

BITMAP_REPLICATE

public static final int BITMAP_REPLICATE

See Also:

Constant Field Values

BITMAP_METADATA

public static final int BITMAP_METADATA

See Also:

Constant Field Values

Constructor Detail

PbsEntryFormatter

public PbsEntryFormatter()

Method Detail

writeExternalEntry

public static void writeExternalEntry(PbsOutputStream output,
                                      IGSEntry entry)

writeEntry

public static void writeEntry(PbsOutputStream output,
                              Object[] values,
                              String className,
                              String uid,
                              int version,
                              boolean isTransient,
                              boolean isFifo,
                              boolean isReplicatable)

readTypeDescriptor

public static ITypeDesc readTypeDescriptor(PbsInputStream input)

readTypeDescIfExists

public static ITypeDesc readTypeDescIfExists(PbsInputStream input,
                                             String typeName,
                                             EntryType entryType)

readTypeDesc

public static ITypeDesc readTypeDesc(PbsInputStream input,
                                     String typeName,
                                     EntryType entryType,
                                     int flags)

writePbsEntryPacket

public static void writePbsEntryPacket(PbsOutputStream output,
                                       PbsEntryPacket pbsEntry)

Writes a pbs entry packet to the stream

writeDynamicProperties

public static void writeDynamicProperties(PbsOutputStream output,
                                          Map<String,Object> dynamicProperties)

writePbsEntryPacketLazy

public static void writePbsEntryPacketLazy(PbsOutputStream output,
                                           PbsEntryPacket packet)

writeNullablePbsEntryPacket

public static void writeNullablePbsEntryPacket(PbsOutputStream output,
                                               PbsEntryPacket pbsEntry)

Writes a pbs entry packet to the stream

writePbsEntryPacketObjectArray

public static void writePbsEntryPacketObjectArray(PbsOutputStream output,
                                                  Object[] objects)

Write an object array of pbs entries to the stream

writeNullablePbsEntryPacketObjectArray

public static void writeNullablePbsEntryPacketObjectArray(PbsOutputStream output,
                                                          Object[] objects)

Write an object array of nullable pbs entries to the stream

writeFieldValue

public static void writeFieldValue(PbsOutputStream output,
                                   Object value)

readFieldValue

public static Object readFieldValue(PbsInputStream input)

readFieldValue

public static Object readFieldValue(PbsInputStream input,
                                    ISpaceProxy contextSpaceProxy)

writePrimitiveArray

public static void writePrimitiveArray(PbsOutputStream output,
                                       Object[] array)

Serialize a primitive (PbsFormatter primitive types) to the given stream

Parameters:

output - Stream to serialize into

array - Array of objects to serialize

readPrimitiveArray

public static Object[] readPrimitiveArray(PbsInputStream input,
                                          ISpaceProxy contextSpaceProxy)

readPbsEntryPacket

public static PbsEntryPacket readPbsEntryPacket(PbsInputStream input)

readPbsTemplatePacket

public static PbsTemplatePacket readPbsTemplatePacket(PbsInputStream input)

readPbsEntryPacketArray

public static PbsEntryPacket[] readPbsEntryPacketArray(PbsInputStream input)

readDynamicProperties

public static DocumentProperties readDynamicProperties(PbsInputStream input)

readPbsTemplate

public static ITemplatePacket readPbsTemplate(PbsInputStream input,
                                              ISpaceProxy spaceProxy)

readPbsTemplate

public static ITemplatePacket readPbsTemplate(PbsInputStream input,
                                              ISpaceProxy spaceProxy,
                                              ITypeDesc typeDescriptor)

readSqlQuery

public static ITemplatePacket readSqlQuery(PbsInputStream input,
                                           ISpaceProxy spaceProxy,
                                           ITypeDesc typeDescriptor)

readProjectionTemplate

public static PbsProjectionTemplate readProjectionTemplate(PbsInputStream input)

getCppTemplatePacketFromSqlQuery

public static ITemplatePacket getCppTemplatePacketFromSqlQuery(SQLQuery<?> sqlQuery,
                                                               ISpaceProxy spaceProxy)

getTemplatePacketFromSqlQuery

public static ITemplatePacket getTemplatePacketFromSqlQuery(SQLQuery<?> sqlQuery,
                                                            ISpaceProxy spaceProxy,
                                                            PbsProjectionTemplate projectionTemplate,
                                                            QueryResultTypeInternal resultType)

writeTypeDesc

public static void writeTypeDesc(PbsOutputStream output,
                                 ITypeDesc typeDescriptor)

readQueryResultType

public static QueryResultTypeInternal readQueryResultType(PbsInputStream input)

readEntryType

public static EntryType readEntryType(PbsInputStream input)