public class Data
extends org.jumpmind.symmetric.io.data.CsvData
implements java.io.Serializable
ATTRIBUTE_CHANNEL_ID, ATTRIBUTE_CREATE_TIME, ATTRIBUTE_DATA_ID, ATTRIBUTE_EXTERNAL_DATA, ATTRIBUTE_NODE_LIST, ATTRIBUTE_SOURCE_NODE_ID, ATTRIBUTE_TABLE_ID, ATTRIBUTE_TABLE_NAME, ATTRIBUTE_TX_ID, changedDataIndicators, dataEventType, MAX_DATA_SIZE_TO_PRINT_TO_LOG, OLD_DATA, PK_DATA, RESOLVE_DATA, ROW_DATA| Constructor and Description |
|---|
Data() |
Data(long dataId,
java.lang.String pkData,
java.lang.String rowData,
org.jumpmind.symmetric.io.data.DataEventType eventType,
java.lang.String tableName,
java.util.Date createTime,
TriggerHistory triggerHistory,
java.lang.String channelId,
java.lang.String transactionId,
java.lang.String sourceNodeId) |
Data(java.lang.String tableName,
org.jumpmind.symmetric.io.data.DataEventType eventType,
java.lang.String rowData,
java.lang.String pkData,
TriggerHistory triggerHistory,
java.lang.String channelId,
java.lang.String transactionId,
java.lang.String sourceNodeId) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getChannelId() |
java.util.Date |
getCreateTime() |
long |
getDataId() |
java.lang.String |
getExternalData() |
java.lang.String |
getNodeList() |
java.lang.String |
getOldData() |
java.lang.String |
getPkData() |
java.lang.String |
getPkDataFor(java.lang.String columnName) |
java.lang.String |
getRowData() |
java.lang.String |
getSourceNodeId() |
java.lang.String |
getTableName() |
java.lang.String |
getTransactionId() |
TriggerHistory |
getTriggerHistory() |
boolean |
isPreRouted() |
void |
setChannelId(java.lang.String channelId) |
void |
setCreateTime(java.util.Date createTime) |
void |
setDataId(long dataId) |
void |
setExternalData(java.lang.String externalData) |
void |
setNodeList(java.lang.String nodeList) |
void |
setOldData(java.lang.String oldData) |
void |
setPkData(java.lang.String pkData) |
void |
setPreRouted(boolean isPreRouted) |
void |
setRowData(java.lang.String rowData) |
void |
setSourceNodeId(java.lang.String sourceNodeId) |
void |
setTableName(java.lang.String tableName) |
void |
setTransactionId(java.lang.String transactionId) |
void |
setTriggerHistory(TriggerHistory triggerHistory) |
java.lang.String[] |
toParsedOldData() |
java.lang.String[] |
toParsedPkData() |
java.lang.String[] |
toParsedRowData() |
contains, copyWithoutOldData, getAttribute, getChangedDataIndicators, getCsvData, getDataEventType, getParsedData, getPkData, getSizeInBytes, isNoBinaryOldData, putAttribute, putCsvData, putParsedData, removeAllData, removeCsvData, removeParsedData, requiresTable, setDataEventType, setNoBinaryOldData, toColumnNameValuePairs, toKeyColumnValuePairs, writeCsvDataDetailspublic Data(long dataId,
java.lang.String pkData,
java.lang.String rowData,
org.jumpmind.symmetric.io.data.DataEventType eventType,
java.lang.String tableName,
java.util.Date createTime,
TriggerHistory triggerHistory,
java.lang.String channelId,
java.lang.String transactionId,
java.lang.String sourceNodeId)
public Data(java.lang.String tableName,
org.jumpmind.symmetric.io.data.DataEventType eventType,
java.lang.String rowData,
java.lang.String pkData,
TriggerHistory triggerHistory,
java.lang.String channelId,
java.lang.String transactionId,
java.lang.String sourceNodeId)
public Data()
public java.lang.String[] toParsedRowData()
public java.lang.String[] toParsedOldData()
public java.lang.String[] toParsedPkData()
public long getDataId()
public void setDataId(long dataId)
public java.lang.String getTableName()
public void setTableName(java.lang.String tableName)
public java.lang.String getRowData()
public void setRowData(java.lang.String rowData)
public java.lang.String getPkData()
public void setPkData(java.lang.String pkData)
public java.lang.String getOldData()
public void setOldData(java.lang.String oldData)
public TriggerHistory getTriggerHistory()
public void setTriggerHistory(TriggerHistory triggerHistory)
public java.lang.String getChannelId()
public void setChannelId(java.lang.String channelId)
public java.lang.String getTransactionId()
public void setTransactionId(java.lang.String transactionId)
public java.lang.String getSourceNodeId()
public void setSourceNodeId(java.lang.String sourceNodeId)
public java.lang.String getExternalData()
public void setExternalData(java.lang.String externalData)
public void setNodeList(java.lang.String nodeList)
public java.lang.String getNodeList()
public boolean isPreRouted()
public void setPreRouted(boolean isPreRouted)
public java.util.Date getCreateTime()
public void setCreateTime(java.util.Date createTime)
public java.lang.String getPkDataFor(java.lang.String columnName)