public class BaseSerializeTest
extends java.lang.Object
Constructor and Description |
---|
BaseSerializeTest() |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
createDataObject(int size,
MessageType dataType) |
java.util.concurrent.BlockingQueue<DataBuffer> |
createDataQueue(int numBuffers,
int size) |
java.lang.Object |
createKeyedData(int size,
MessageType dataType,
int keySize,
MessageType keyType) |
java.lang.Object |
createKeyedData(int size,
MessageType dataType,
MessageType keyType) |
java.lang.Object |
createKeyObject(MessageType dataType) |
java.lang.Object |
createKeyObject(MessageType dataType,
int size) |
InMessage |
keyedListValueCase(int numBuffers,
int size,
java.util.List<java.lang.Object> data,
MessageType type,
MessageType keyType) |
InMessage |
keyedSingleValueCase(int numBuffers,
int size,
MessageType type,
MessageType keyType,
java.lang.Object data) |
public InMessage keyedListValueCase(int numBuffers, int size, java.util.List<java.lang.Object> data, MessageType type, MessageType keyType)
public InMessage keyedSingleValueCase(int numBuffers, int size, MessageType type, MessageType keyType, java.lang.Object data)
public java.util.concurrent.BlockingQueue<DataBuffer> createDataQueue(int numBuffers, int size)
public java.lang.Object createDataObject(int size, MessageType dataType)
public java.lang.Object createKeyObject(MessageType dataType, int size)
public java.lang.Object createKeyObject(MessageType dataType)
public java.lang.Object createKeyedData(int size, MessageType dataType, MessageType keyType)
public java.lang.Object createKeyedData(int size, MessageType dataType, int keySize, MessageType keyType)