public class IncomingBatch extends AbstractBatch
AbstractBatch.Status| Constructor and Description |
|---|
IncomingBatch() |
IncomingBatch(org.jumpmind.symmetric.io.data.Batch batch) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(java.lang.Object o) |
long |
getFailedLineNumber() |
long |
getFailedRowNumber() |
long |
getStartTime() |
int |
hashCode() |
boolean |
isPersistable()
An indicator to the incoming batch service as to whether this batch
should be saved off.
|
boolean |
isRetry() |
void |
mergeInjectedBatchStatistics(org.jumpmind.util.Statistics statistics) |
void |
setFailedLineNumber(long failedLineNumber) |
void |
setFailedRowNumber(long failedRowNumber) |
void |
setNodeBatchId(java.lang.String value) |
void |
setRetry(boolean isRetry) |
void |
setStartTime(long startTime) |
void |
setValues(org.jumpmind.util.Statistics readerStatistics,
org.jumpmind.util.Statistics writerStatistics,
boolean isSuccess) |
java.lang.String |
toString() |
buildBatchSummary, getBatchId, getByteCount, getChannelId, getCreateBy, getCreateTime, getDataDeleteRowCount, getDataInsertRowCount, getDataRowCount, getDataUpdateRowCount, getExtractCount, getExtractDeleteRowCount, getExtractInsertRowCount, getExtractMillis, getExtractRowCount, getExtractUpdateRowCount, getFailedDataId, getFallbackInsertCount, getFallbackUpdateCount, getFilterMillis, getIgnoreCount, getIgnoreRowCount, getLastUpdatedHostName, getLastUpdatedTime, getLoadCount, getLoadDeleteRowCount, getLoadId, getLoadInsertRowCount, getLoadMillis, getLoadRowCount, getLoadUpdateRowCount, getMissingDeleteCount, getNetworkMillis, getNodeBatchId, getNodeId, getOtherRowCount, getProcessedRowCount, getReloadRowCount, getRouterMillis, getSentCount, getSkipCount, getSqlCode, getSqlMessage, getSqlState, getStagedLocation, getStatus, getSummary, getTableCounts, getTransformExtractMillis, getTransformLoadMillis, incrementByteCount, incrementDataInsertRowCount, incrementDataRowCount, incrementExtractRowCount, incrementExtractRowCount, incrementIgnoreCount, incrementIgnoreRowCount, incrementRowCount, incrementTableCount, isCommonFlag, isErrorFlag, isLoadFlag, resetExtractRowStats, resetRouterStats, resetStats, revertStatsOnError, setBatchId, setByteCount, setChannelId, setCommonFlag, setCreateBy, setCreateTime, setDataDeleteRowCount, setDataInsertRowCount, setDataRowCount, setDataUpdateRowCount, setErrorFlag, setExtractCount, setExtractDeleteRowCount, setExtractInsertRowCount, setExtractMillis, setExtractRowCount, setExtractUpdateRowCount, setFailedDataId, setFallbackInsertCount, setFallbackUpdateCount, setFilterMillis, setIgnoreCount, setIgnoreRowCount, setLastUpdatedHostName, setLastUpdatedTime, setLoadCount, setLoadDeleteRowCount, setLoadFlag, setLoadId, setLoadInsertRowCount, setLoadMillis, setLoadRowCount, setLoadUpdateRowCount, setMissingDeleteCount, setNetworkMillis, setNodeId, setOtherRowCount, setProcessedRowCount, setReloadRowCount, setRouterMillis, setSentCount, setSkipCount, setSqlCode, setSqlMessage, setSqlState, setStatus, setStatusFromString, setSummary, setTransformExtractMillis, setTransformLoadMillis, totalRowCountpublic IncomingBatch()
public IncomingBatch(org.jumpmind.symmetric.io.data.Batch batch)
public void setValues(org.jumpmind.util.Statistics readerStatistics,
org.jumpmind.util.Statistics writerStatistics,
boolean isSuccess)
public void mergeInjectedBatchStatistics(org.jumpmind.util.Statistics statistics)
public void setNodeBatchId(java.lang.String value)
public boolean isRetry()
public void setRetry(boolean isRetry)
public long getFailedRowNumber()
public void setFailedRowNumber(long failedRowNumber)
public long getStartTime()
public void setStartTime(long startTime)
public boolean isPersistable()
public void setFailedLineNumber(long failedLineNumber)
public long getFailedLineNumber()
public java.lang.String toString()
toString in class java.lang.Objectpublic boolean equals(java.lang.Object o)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Object