public class YCSBMessage
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Class and Description |
---|---|
static class |
YCSBMessage.Entity |
static class |
YCSBMessage.Type |
Modifier and Type | Method and Description |
---|---|
byte[] |
getBytes() |
YCSBMessage.Entity |
getEntity() |
java.lang.String |
getErrorMsg() |
java.util.Set<java.lang.String> |
getFields() |
java.lang.String |
getKey() |
static YCSBMessage |
getObject(byte[] theBytes) |
int |
getResult() |
java.util.HashMap<java.lang.String,byte[]> |
getResults() |
java.lang.String |
getTable() |
YCSBMessage.Type |
getType() |
java.util.HashMap<java.lang.String,byte[]> |
getValues() |
static YCSBMessage |
newErrorMessage(java.lang.String errorMsg) |
static YCSBMessage |
newInsertRequest(java.lang.String table,
java.lang.String key,
java.util.HashMap<java.lang.String,byte[]> values) |
static YCSBMessage |
newInsertResponse(int result) |
static YCSBMessage |
newReadRequest(java.lang.String table,
java.lang.String key,
java.util.Set<java.lang.String> fields,
java.util.HashMap<java.lang.String,byte[]> results) |
static YCSBMessage |
newReadResponse(java.util.HashMap<java.lang.String,byte[]> results,
int result) |
static YCSBMessage |
newUpdateRequest(java.lang.String table,
java.lang.String key,
java.util.HashMap<java.lang.String,byte[]> values) |
static YCSBMessage |
newUpdateResponse(int result) |
java.lang.String |
toString() |
public static YCSBMessage newInsertRequest(java.lang.String table, java.lang.String key, java.util.HashMap<java.lang.String,byte[]> values)
public static YCSBMessage newUpdateRequest(java.lang.String table, java.lang.String key, java.util.HashMap<java.lang.String,byte[]> values)
public static YCSBMessage newReadRequest(java.lang.String table, java.lang.String key, java.util.Set<java.lang.String> fields, java.util.HashMap<java.lang.String,byte[]> results)
public static YCSBMessage newInsertResponse(int result)
public static YCSBMessage newUpdateResponse(int result)
public static YCSBMessage newReadResponse(java.util.HashMap<java.lang.String,byte[]> results, int result)
public static YCSBMessage newErrorMessage(java.lang.String errorMsg)
public byte[] getBytes()
public static YCSBMessage getObject(byte[] theBytes)
public java.lang.String toString()
toString
in class java.lang.Object
public int getResult()
public java.util.HashMap<java.lang.String,byte[]> getResults()
public YCSBMessage.Type getType()
public YCSBMessage.Entity getEntity()
public java.lang.String getTable()
public java.lang.String getKey()
public java.util.Set<java.lang.String> getFields()
public java.util.HashMap<java.lang.String,byte[]> getValues()
public java.lang.String getErrorMsg()