org.apache.reef.vortex.common

Class VortexAvroUtils

java.lang.Object

org.apache.reef.vortex.common.VortexAvroUtils

public final class VortexAvroUtils
extends Object

Serialize and deserialize Vortex message to/from byte array.

Method Summary

Methods

Modifier and Type	Method and Description
byte[]	toBytes(VortexRequest vortexRequest) Serialize VortexRequest to byte array.
byte[]	toBytes(WorkerReport workerReport) Serialize WorkerReport to byte array.
VortexRequest	toVortexRequest(byte[] bytes) Deserialize byte array to VortexRequest.
WorkerReport	toWorkerReport(byte[] bytes) Deserialize byte array to WorkerReport.

Methods inherited from class java.lang.Object

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

Method Detail

toBytes

public byte[] toBytes(VortexRequest vortexRequest)

Serialize VortexRequest to byte array.

Parameters:

vortexRequest - Vortex request message to serialize.

Returns:

Serialized byte array.

toBytes

public byte[] toBytes(WorkerReport workerReport)

Serialize WorkerReport to byte array.

Parameters:

workerReport - Worker report message to serialize.

Returns:

Serialized byte array.

toVortexRequest

public VortexRequest toVortexRequest(byte[] bytes)

Deserialize byte array to VortexRequest.

Parameters:

bytes - Byte array to deserialize.

Returns:

De-serialized VortexRequest.

toWorkerReport

public WorkerReport toWorkerReport(byte[] bytes)

Deserialize byte array to WorkerReport.

Parameters:

bytes - Byte array to deserialize.

Returns:

De-serialized WorkerReport.