public class DataUtil
extends java.lang.Object
Constructor and Description |
---|
DataUtil() |
Modifier and Type | Method and Description |
---|---|
static void |
addDataToQueueOrMap(int selfID,
EventQueue eventQueue,
EventType eventType,
DataMap dataMap,
Data data)
Add the Data to EventQueue or DataMap.
|
static java.util.List<Transferable> |
decodePartitionList(ByteArray byteArray)
Decode the ByteArray as a list of Partitions
|
static java.util.List<Transferable> |
decodeSimpleList(ByteArray byteArray)
Decode the ByteArray as a list of
Transferable objects
|
static ByteArray |
deserializeByteArray(Deserializer din)
Deserialize the data from a Deserializer as a
ByteArray
|
static DoubleArray |
deserializeDoubleArray(Deserializer din)
Deserialize the data from a Deserializer as a
DoubleArray
|
static FloatArray |
deserializeFloatArray(Deserializer din)
Deserialize the data from a Deserializer as a
FloatArray
|
static IntArray |
deserializeIntArray(Deserializer din)
Deserialize the data from a Deserializer as a
IntArray
|
static LongArray |
deserializeLongArray(Deserializer din)
Deserialize the data from a Deserializer as a
LongArray
|
static ShortArray |
deserializeShortArray(Deserializer din)
Deserialize the data from a Deserializer as a
ShortArray
|
static Writable |
deserializeWritable(java.io.DataInput din)
Deserialize the data from a Deserializer as a
Writable
|
static ByteArray |
encodeTransList(java.util.List<Transferable> objs)
Serialize multiple Transferable with
different data types
|
static void |
encodeTransList(java.util.List<Transferable> objs,
int size,
java.io.DataOutput dataOut)
Encode the data to DataOutput
|
static int |
getNumTransListBytes(java.util.List<Transferable> objs)
Get the size in bytes of the encoded data
|
static void |
releaseTransList(java.util.List<Transferable> transList)
Transferable List may include different types
Identify each of them and release
|
public static ByteArray deserializeByteArray(Deserializer din)
din
- the Deserializerpublic static ShortArray deserializeShortArray(Deserializer din)
din
- the Deserializerpublic static IntArray deserializeIntArray(Deserializer din)
din
- the Deserializerpublic static FloatArray deserializeFloatArray(Deserializer din)
din
- the Deserializerpublic static LongArray deserializeLongArray(Deserializer din)
din
- the Deserializerpublic static DoubleArray deserializeDoubleArray(Deserializer din)
din
- the Deserializerpublic static Writable deserializeWritable(java.io.DataInput din)
din
- the Deserializerpublic static java.util.List<Transferable> decodeSimpleList(ByteArray byteArray)
byteArray
- the ByteArray to be decodedpublic static java.util.List<Transferable> decodePartitionList(ByteArray byteArray)
byteArray
- the ByteArray to be decodedpublic static ByteArray encodeTransList(java.util.List<Transferable> objs)
objs
- the data to be serializedpublic static int getNumTransListBytes(java.util.List<Transferable> objs)
objs
- the datapublic static void encodeTransList(java.util.List<Transferable> objs, int size, java.io.DataOutput dataOut) throws java.lang.Exception
objs
- the objects to be encodedsize
- the size of the encoded datadataOut
- the DataOutputjava.lang.Exception
public static void releaseTransList(java.util.List<Transferable> transList)
pool
- trans
- public static void addDataToQueueOrMap(int selfID, EventQueue eventQueue, EventType eventType, DataMap dataMap, Data data)
selfID
- the ID of current workereventQueue
- the queue for eventseventType
- the type of the eventdataMap
- the DataMapdata
- the Data