edu.snu.coral.runtime.executor.data

Class SerializedPartition<K>

java.lang.Object

edu.snu.coral.runtime.executor.data.SerializedPartition<K>

Type Parameters:

K - the key type of its partitions.

All Implemented Interfaces:

Partition<byte[],K>

public final class SerializedPartition<K>
extends Object
implements Partition<byte[],K>

A collection of data elements. The data is stored as an array of bytes. This is a unit of read / write towards Blocks.

Constructor Summary

Constructors

Constructor and Description
SerializedPartition(K key, long elementsTotal, byte[] serializedData, int length) Creates a serialized Partition having a specific key value.

Method Summary

Modifier and Type	Method and Description
byte[]	getData()
long	getElementsTotal()
K	getKey()
int	getLength()
boolean	isSerialized()

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializedPartition

public SerializedPartition(K key,
                           long elementsTotal,
                           byte[] serializedData,
                           int length)

Creates a serialized Partition having a specific key value.

Parameters:

key - the key.

elementsTotal - the total number of elements.

serializedData - the serialized data.

length - the length of the actual serialized data. (It can be different with serializedData.length)

Method Detail

getKey

public K getKey()

Specified by:

getKey in interface Partition<byte[],K>

Returns:

the key value.

isSerialized

public boolean isSerialized()

Specified by:

isSerialized in interface Partition<byte[],K>

Returns:

whether the data in this Partition is serialized or not.

getData

public byte[] getData()

Specified by:

getData in interface Partition<byte[],K>

Returns:

the serialized data.

getLength

public int getLength()

Returns:

the length of the actual data.

getElementsTotal

public long getElementsTotal()

Returns:

the number of elements.