Package org.apache.ignite.internal.client.marshaller.optimized

Class GridClientOptimizedMarshaller

java.lang.Object

org.apache.ignite.internal.client.marshaller.optimized.GridClientOptimizedMarshaller

All Implemented Interfaces:

GridClientMarshaller

Direct Known Subclasses:

GridClientZipOptimizedMarshaller

public class GridClientOptimizedMarshaller
extends Object
implements GridClientMarshaller

Wrapper, that adapts OptimizedMarshaller to GridClientMarshaller interface.

Field Summary

Fields

Modifier and Type	Field	Description
static byte	ID	ID.
protected OptimizedMarshaller	opMarsh	Optimized marshaller.

Constructor Summary

Constructors

Constructor	Description
GridClientOptimizedMarshaller()	Default constructor.
GridClientOptimizedMarshaller(boolean requireSer, int poolSize)	Constructs optimized marshaller with specific parameters.
GridClientOptimizedMarshaller(@Nullable List<PluginProvider> plugins)	Constructor.

Method Summary

Modifier and Type	Method	Description
ByteBuffer	marshal(Object obj, int off)	Marshals object to byte array.
<T> T	unmarshal(byte[] bytes)	Unmarshals object from byte array.

Methods inherited from class java.lang.Object

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

Field Detail

ID

public static final byte ID

ID.

See Also:

Constant Field Values

opMarsh

protected final OptimizedMarshaller opMarsh

Optimized marshaller.

Constructor Detail

GridClientOptimizedMarshaller

public GridClientOptimizedMarshaller()

Default constructor.

GridClientOptimizedMarshaller

public GridClientOptimizedMarshaller(@Nullable
                                     @Nullable List<PluginProvider> plugins)

Constructor.

Parameters:

plugins - Plugins.

GridClientOptimizedMarshaller

public GridClientOptimizedMarshaller(boolean requireSer,
                                     int poolSize)
                              throws IOException

Constructs optimized marshaller with specific parameters.

Parameters:

requireSer - Require serializable flag.

poolSize - Object streams pool size.

Throws:

IOException - If an I/O error occurs while writing stream header.

IgniteException - If this marshaller is not supported on the current JVM.

See Also:

OptimizedMarshaller

Method Detail

marshal

public ByteBuffer marshal(Object obj,
                          int off)
                   throws IOException

Marshals object to byte array.

Specified by:

marshal in interface GridClientMarshaller

Parameters:

obj - Object to marshal.

off - Start offset.

Returns:

Byte buffer.

Throws:

IOException - If marshalling failed.

unmarshal

public <T> T unmarshal(byte[] bytes)
                throws IOException

Unmarshals object from byte array.

Specified by:

unmarshal in interface GridClientMarshaller

Parameters:

bytes - Byte array.

Returns:

Unmarshalled object.

Throws:

IOException - If unmarshalling failed.