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 and Description
static byte	ID ID.
protected OptimizedMarshaller	opMarsh Optimized marshaller.

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and 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
                             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.