Package org.jumpmind.symmetric.model

Class AbstractBatch

java.lang.Object
org.jumpmind.symmetric.model.AbstractBatch
All Implemented Interfaces:
Serializable
Direct Known Subclasses:
IncomingBatch, OutgoingBatch
public class AbstractBatch extends Object implements Serializable
See Also:

  • Constructor Details

    • AbstractBatch

      public AbstractBatch()

  • Method Details

    • 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 String getNodeId()

    • setNodeId

      public void setNodeId(String nodeId)

    • getChannelId

      public String getChannelId()

    • setChannelId

      public void setChannelId(String channelId)

    • getNodeBatchId

      public 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 String getStagedLocation()

    • incrementByteCount

      public void incrementByteCount(int size)

    • setIgnoreCount

      public void setIgnoreCount(long ignoreCount)

    • incrementIgnoreCount

      public void incrementIgnoreCount()

    • getIgnoreCount

      public long getIgnoreCount()

    • getSqlState

      public String getSqlState()

    • setSqlState

      public void setSqlState(String sqlState)

    • getSqlCode

      public int getSqlCode()

    • setSqlCode

      public void setSqlCode(int sqlCode)

    • getSqlMessage

      public String getSqlMessage()

    • setSqlMessage

      public void setSqlMessage(String sqlMessage)

    • setSqlMessage

      public void setSqlMessage(Throwable t)

    • getLastUpdatedHostName

      public String getLastUpdatedHostName()

    • setLastUpdatedHostName

      public void setLastUpdatedHostName(String lastUpdatedHostName)

    • getLastUpdatedTime

      public Date getLastUpdatedTime()

    • setLastUpdatedTime

      public void setLastUpdatedTime(Date lastUpdatedTime)

    • getCreateTime

      public Date getCreateTime()

    • setCreateTime

      public void setCreateTime(Date createTime)

    • setCreateBy

      public void setCreateBy(String createBy)

    • getCreateBy

      public String getCreateBy()

    • getTableCounts

      public Map<String,Integer> getTableCounts()

    • getFileCounts

      public Map<String,Integer> getFileCounts()

    • getSummary

      public String getSummary()

    • setSummary

      public void setSummary(String summary)

    • buildBatchSummary

      protected String buildBatchSummary()

    • incrementTableCount

      public void incrementTableCount(String tableName)

    • incrementFileCount

      public void incrementFileCount(String fileName)

    • getStatus

      public AbstractBatch.Status getStatus()

    • setStatus

      public void setStatus(AbstractBatch.Status status)

    • setStatusFromString

      public void setStatusFromString(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(DataEventType type)

    • incrementExtractRowCount

      public void incrementExtractRowCount(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)

    • getConflictWinCount

      public long getConflictWinCount()

    • setConflictWinCount

      public void setConflictWinCount(long conflictWinCount)

    • getConflictLoseCount

      public long getConflictLoseCount()

    • setConflictLoseCount

      public void setConflictLoseCount(long conflictLoseCount)

    • 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)

    • setFailedLineNumber

      public void setFailedLineNumber(long failedLineNumber)

    • getFailedLineNumber

      public long getFailedLineNumber()

    • getProcessedRowCount

      public long getProcessedRowCount()

    • setProcessedRowCount

      public void setProcessedRowCount(long processedRowCount)

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • getTableLoadedCount

      public Map<String,Map<String,Long>> getTableLoadedCount()

    • setTableLoadedCount

      public void setTableLoadedCount(Map<String,Map<String,Long>> tableLoadedCount)

    • getTableExtractedCount

      public Map<String,Map<String,Long>> getTableExtractedCount()

    • setTableExtractedCount

      public void setTableExtractedCount(Map<String,Map<String,Long>> tableExtractedCount)

    • isBulkLoaderFlag

      public boolean isBulkLoaderFlag()

    • setBulkLoaderFlag

      public void setBulkLoaderFlag(boolean bulkLoaderFlag)