org.jumpmind.symmetric.model

Class AbstractBatch

java.lang.Object

org.jumpmind.symmetric.model.AbstractBatch

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

IncomingBatch, OutgoingBatch

public class AbstractBatch
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractBatch.Status

Constructor Summary

Constructors

Constructor and Description
AbstractBatch()

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	buildBatchSummary()
long	getBatchId()
long	getByteCount()
java.lang.String	getChannelId()
java.lang.String	getCreateBy()
java.util.Date	getCreateTime()
long	getDataDeleteRowCount()
long	getDataInsertRowCount()
long	getDataRowCount()
long	getDataUpdateRowCount()
long	getExtractCount()
long	getExtractDeleteRowCount()
long	getExtractInsertRowCount()
long	getExtractMillis()
long	getExtractRowCount()
long	getExtractUpdateRowCount()
long	getFailedDataId()
long	getFallbackInsertCount()
long	getFallbackUpdateCount()
long	getFilterMillis()
long	getIgnoreCount()
long	getIgnoreRowCount()
java.lang.String	getLastUpdatedHostName()
java.util.Date	getLastUpdatedTime()
long	getLoadCount()
long	getLoadDeleteRowCount()
long	getLoadId()
long	getLoadInsertRowCount()
long	getLoadMillis()
long	getLoadRowCount()
long	getLoadUpdateRowCount()
long	getMissingDeleteCount()
long	getNetworkMillis()
java.lang.String	getNodeBatchId()
java.lang.String	getNodeId()
long	getOtherRowCount()
long	getProcessedRowCount()
long	getReloadRowCount()
long	getRouterMillis()
long	getSentCount()
long	getSkipCount()
int	getSqlCode()
java.lang.String	getSqlMessage()
java.lang.String	getSqlState()
java.lang.String	getStagedLocation()
AbstractBatch.Status	getStatus()
java.lang.String	getSummary()
java.util.Map<java.lang.String,java.lang.Integer>	getTableCounts()
long	getTransformExtractMillis()
long	getTransformLoadMillis()
void	incrementByteCount(int size)
void	incrementDataInsertRowCount()
void	incrementDataRowCount()
void	incrementExtractRowCount()
void	incrementExtractRowCount(org.jumpmind.symmetric.io.data.DataEventType type)
void	incrementIgnoreCount()
void	incrementIgnoreRowCount()
void	incrementRowCount(org.jumpmind.symmetric.io.data.DataEventType type)
void	incrementTableCount(java.lang.String tableName)
boolean	isCommonFlag()
boolean	isErrorFlag()
boolean	isLoadFlag()
void	resetExtractRowStats()
void	resetRouterStats()
void	resetStats()
void	revertStatsOnError()
void	setBatchId(long batchId)
void	setByteCount(long byteCount)
void	setChannelId(java.lang.String channelId)
void	setCommonFlag(boolean commonFlag)
void	setCreateBy(java.lang.String createBy)
void	setCreateTime(java.util.Date createTime)
void	setDataDeleteRowCount(long dataDeleteRowCount)
void	setDataInsertRowCount(long dataInsertRowCount)
void	setDataRowCount(long dataRowCount)
void	setDataUpdateRowCount(long dataUpdateRowCount)
void	setErrorFlag(boolean errorFlag)
void	setExtractCount(long extractCount)
void	setExtractDeleteRowCount(long extractDeleteRowCount)
void	setExtractInsertRowCount(long extractInsertRowCount)
void	setExtractMillis(long extractMillis)
void	setExtractRowCount(long extractRowCount)
void	setExtractUpdateRowCount(long extractUpdateRowCount)
void	setFailedDataId(long failedDataId)
void	setFallbackInsertCount(long fallbackInsertCount)
void	setFallbackUpdateCount(long fallbackUpdateCount)
void	setFilterMillis(long filterMillis)
void	setIgnoreCount(long ignoreCount)
void	setIgnoreRowCount(long ignoreRowCount)
void	setLastUpdatedHostName(java.lang.String lastUpdatedHostName)
void	setLastUpdatedTime(java.util.Date lastUpdatedTime)
void	setLoadCount(long loadCount)
void	setLoadDeleteRowCount(long loadDeleteRowCount)
void	setLoadFlag(boolean loadFlag)
void	setLoadId(long loadId)
void	setLoadInsertRowCount(long loadInsertRowCount)
void	setLoadMillis(long loadMillis)
void	setLoadRowCount(long loadRowCount)
void	setLoadUpdateRowCount(long loadUpdateRowCount)
void	setMissingDeleteCount(long missingDeleteCount)
void	setNetworkMillis(long networkMillis)
void	setNodeId(java.lang.String nodeId)
void	setOtherRowCount(long otherRowCount)
void	setProcessedRowCount(long processedRowCount)
void	setReloadRowCount(long reloadRowCount)
void	setRouterMillis(long routerMillis)
void	setSentCount(long sentCount)
void	setSkipCount(long skipCount)
void	setSqlCode(int sqlCode)
void	setSqlMessage(java.lang.String sqlMessage)
void	setSqlState(java.lang.String sqlState)
void	setStatus(AbstractBatch.Status status)
void	setStatusFromString(java.lang.String status)
void	setSummary(java.lang.String summary)
void	setTransformExtractMillis(long transformExtractMillis)
void	setTransformLoadMillis(long transformLoadMillis)
long	totalRowCount()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractBatch

public AbstractBatch()

Method Detail

resetStats

public void resetStats()

resetRouterStats

public void resetRouterStats()

revertStatsOnError

public void revertStatsOnError()

resetExtractRowStats

public void resetExtractRowStats()

getBatchId

public long getBatchId()

setBatchId

public void setBatchId(long batchId)

getNodeId

public java.lang.String getNodeId()

setNodeId

public void setNodeId(java.lang.String nodeId)

getChannelId

public java.lang.String getChannelId()

setChannelId

public void setChannelId(java.lang.String channelId)

getNodeBatchId

public java.lang.String getNodeBatchId()

setErrorFlag

public void setErrorFlag(boolean errorFlag)

isErrorFlag

public boolean isErrorFlag()

getRouterMillis

public long getRouterMillis()

setRouterMillis

public void setRouterMillis(long routerMillis)

getNetworkMillis

public long getNetworkMillis()

setNetworkMillis

public void setNetworkMillis(long networkMillis)

getFilterMillis

public long getFilterMillis()

setFilterMillis

public void setFilterMillis(long filterMillis)

getLoadMillis

public long getLoadMillis()

setLoadMillis

public void setLoadMillis(long loadMillis)

setExtractMillis

public void setExtractMillis(long extractMillis)

getExtractMillis

public long getExtractMillis()

getTransformExtractMillis

public long getTransformExtractMillis()

setTransformExtractMillis

public void setTransformExtractMillis(long transformExtractMillis)

getTransformLoadMillis

public long getTransformLoadMillis()

setTransformLoadMillis

public void setTransformLoadMillis(long transformLoadMillis)

getByteCount

public long getByteCount()

setByteCount

public void setByteCount(long byteCount)

getStagedLocation

public java.lang.String getStagedLocation()

incrementByteCount

public void incrementByteCount(int size)

setIgnoreCount

public void setIgnoreCount(long ignoreCount)

incrementIgnoreCount

public void incrementIgnoreCount()

getIgnoreCount

public long getIgnoreCount()

getSqlState

public java.lang.String getSqlState()

setSqlState

public void setSqlState(java.lang.String sqlState)

getSqlCode

public int getSqlCode()

setSqlCode

public void setSqlCode(int sqlCode)

getSqlMessage

public java.lang.String getSqlMessage()

setSqlMessage

public void setSqlMessage(java.lang.String sqlMessage)

getLastUpdatedHostName

public java.lang.String getLastUpdatedHostName()

setLastUpdatedHostName

public void setLastUpdatedHostName(java.lang.String lastUpdatedHostName)

getLastUpdatedTime

public java.util.Date getLastUpdatedTime()

setLastUpdatedTime

public void setLastUpdatedTime(java.util.Date lastUpdatedTime)

getCreateTime

public java.util.Date getCreateTime()

setCreateTime

public void setCreateTime(java.util.Date createTime)

setCreateBy

public void setCreateBy(java.lang.String createBy)

getCreateBy

public java.lang.String getCreateBy()

getTableCounts

public java.util.Map<java.lang.String,java.lang.Integer> getTableCounts()

getSummary

public java.lang.String getSummary()

setSummary

public void setSummary(java.lang.String summary)

buildBatchSummary

protected java.lang.String buildBatchSummary()

incrementTableCount

public void incrementTableCount(java.lang.String tableName)

getStatus

public AbstractBatch.Status getStatus()

setStatus

public void setStatus(AbstractBatch.Status status)

setStatusFromString

public void setStatusFromString(java.lang.String status)

setLoadFlag

public void setLoadFlag(boolean loadFlag)

isLoadFlag

public boolean isLoadFlag()

setExtractCount

public void setExtractCount(long extractCount)

getExtractCount

public long getExtractCount()

setSentCount

public void setSentCount(long sentCount)

getSentCount

public long getSentCount()

setLoadCount

public void setLoadCount(long loadCount)

getLoadCount

public long getLoadCount()

setReloadRowCount

public void setReloadRowCount(long reloadRowCount)

getReloadRowCount

public long getReloadRowCount()

setOtherRowCount

public void setOtherRowCount(long otherRowCount)

getOtherRowCount

public long getOtherRowCount()

setDataUpdateRowCount

public void setDataUpdateRowCount(long dataUpdateRowCount)

getDataUpdateRowCount

public long getDataUpdateRowCount()

setDataDeleteRowCount

public void setDataDeleteRowCount(long dataDeleteRowCount)

getDataDeleteRowCount

public long getDataDeleteRowCount()

incrementRowCount

public void incrementRowCount(org.jumpmind.symmetric.io.data.DataEventType type)

incrementExtractRowCount

public void incrementExtractRowCount(org.jumpmind.symmetric.io.data.DataEventType type)

incrementExtractRowCount

public void incrementExtractRowCount()

setDataInsertRowCount

public void setDataInsertRowCount(long dataInsertRowCount)

getDataInsertRowCount

public long getDataInsertRowCount()

getDataRowCount

public long getDataRowCount()

setDataRowCount

public void setDataRowCount(long dataRowCount)

incrementDataRowCount

public void incrementDataRowCount()

incrementDataInsertRowCount

public void incrementDataInsertRowCount()

totalRowCount

public long totalRowCount()

setLoadId

public void setLoadId(long loadId)

getLoadId

public long getLoadId()

setCommonFlag

public void setCommonFlag(boolean commonFlag)

isCommonFlag

public boolean isCommonFlag()

getFallbackInsertCount

public long getFallbackInsertCount()

setFallbackInsertCount

public void setFallbackInsertCount(long fallbackInsertCount)

getFallbackUpdateCount

public long getFallbackUpdateCount()

setFallbackUpdateCount

public void setFallbackUpdateCount(long fallbackUpdateCount)

getMissingDeleteCount

public long getMissingDeleteCount()

setMissingDeleteCount

public void setMissingDeleteCount(long missingDeleteCount)

setSkipCount

public void setSkipCount(long skipCount)

getSkipCount

public long getSkipCount()

getIgnoreRowCount

public long getIgnoreRowCount()

incrementIgnoreRowCount

public void incrementIgnoreRowCount()

setIgnoreRowCount

public void setIgnoreRowCount(long ignoreRowCount)

getLoadRowCount

public long getLoadRowCount()

setLoadRowCount

public void setLoadRowCount(long loadRowCount)

getLoadInsertRowCount

public long getLoadInsertRowCount()

setLoadInsertRowCount

public void setLoadInsertRowCount(long loadInsertRowCount)

getLoadUpdateRowCount

public long getLoadUpdateRowCount()

setLoadUpdateRowCount

public void setLoadUpdateRowCount(long loadUpdateRowCount)

getLoadDeleteRowCount

public long getLoadDeleteRowCount()

setLoadDeleteRowCount

public void setLoadDeleteRowCount(long loadDeleteRowCount)

getExtractRowCount

public long getExtractRowCount()

setExtractRowCount

public void setExtractRowCount(long extractRowCount)

getExtractInsertRowCount

public long getExtractInsertRowCount()

setExtractInsertRowCount

public void setExtractInsertRowCount(long extractInsertRowCount)

getExtractUpdateRowCount

public long getExtractUpdateRowCount()

setExtractUpdateRowCount

public void setExtractUpdateRowCount(long extractUpdateRowCount)

getExtractDeleteRowCount

public long getExtractDeleteRowCount()

setExtractDeleteRowCount

public void setExtractDeleteRowCount(long extractDeleteRowCount)

getFailedDataId

public long getFailedDataId()

setFailedDataId

public void setFailedDataId(long failedDataId)

getProcessedRowCount

public long getProcessedRowCount()

setProcessedRowCount

public void setProcessedRowCount(long processedRowCount)