Class Batch

java.lang.Object
org.jumpmind.symmetric.io.data.Batch

public class Batch extends Object
  • Field Details

    • UNKNOWN_BATCH_ID

      public static final long UNKNOWN_BATCH_ID
      See Also:
    • DEFAULT_CHANNEL_ID

      public static final String DEFAULT_CHANNEL_ID
      See Also:
    • batchId

      protected long batchId
    • sourceNodeId

      protected String sourceNodeId
    • targetNodeId

      protected String targetNodeId
    • initialLoad

      protected boolean initialLoad
    • channelId

      protected String channelId
    • binaryEncoding

      protected BinaryEncoding binaryEncoding
    • startTime

      protected Date startTime
    • lineCount

      protected long lineCount
    • dataReadMillis

      protected long dataReadMillis
    • dataWriteMillis

      protected long dataWriteMillis
    • ignored

      protected boolean ignored
    • common

      protected boolean common
    • complete

      protected boolean complete
    • batchType

      protected Batch.BatchType batchType
    • statistics

      protected Statistics statistics
    • invalidRetry

      protected boolean invalidRetry
    • bulkLoaderFlag

      protected boolean bulkLoaderFlag
    • timers

      protected Map<String,Long> timers
  • Constructor Details

  • Method Details

    • isBulkLoaderFlag

      public boolean isBulkLoaderFlag()
    • setBulkLoaderFlag

      public void setBulkLoaderFlag(boolean bulkLoaderFlag)
    • setBatchId

      public void setBatchId(long batchId)
    • incrementLineCount

      public long incrementLineCount()
    • incrementDataReadMillis

      public void incrementDataReadMillis(long millis)
    • incrementDataWriteMillis

      public void incrementDataWriteMillis(long millis)
    • startTimer

      public void startTimer(String name)
    • endTimer

      public long endTimer(String name)
    • getDataReadMillis

      public long getDataReadMillis()
    • getDataWriteMillis

      public long getDataWriteMillis()
    • getLineCount

      public long getLineCount()
    • setLineCount

      public void setLineCount(long lineCount)
    • getStartTime

      public Date getStartTime()
    • setStartTime

      public void setStartTime(Date startTime)
    • getSourceNodeId

      public String getSourceNodeId()
    • getTargetNodeId

      public String getTargetNodeId()
    • getNodeBatchId

      public String getNodeBatchId()
    • getBatchId

      public long getBatchId()
    • getChannelId

      public String getChannelId()
    • isInitialLoad

      public boolean isInitialLoad()
    • getBinaryEncoding

      public BinaryEncoding getBinaryEncoding()
    • setIgnored

      public void setIgnored(boolean ignored)
    • isIgnored

      public boolean isIgnored()
    • setCommon

      public void setCommon(boolean commonFlag)
    • isCommon

      public boolean isCommon()
    • getBatchType

      public Batch.BatchType getBatchType()
    • getStagedLocation

      public String getStagedLocation()
    • getStagedLocation

      public static String getStagedLocation(boolean common, String nodeId, long batchId)
    • setComplete

      public void setComplete(boolean complete)
    • isComplete

      public boolean isComplete()
    • setBinaryEncoding

      public void setBinaryEncoding(BinaryEncoding binaryEncoding)
    • setSourceNodeId

      public void setSourceNodeId(String sourceNodeId)
    • setStatistics

      public void setStatistics(Statistics statistics)
    • getStatistics

      public Statistics getStatistics()
    • setInvalidRetry

      public void setInvalidRetry(boolean invalidRetry)
    • isInvalidRetry

      public boolean isInvalidRetry()
    • encodeBinary

      public String encodeBinary(String value)
    • decodeBinary

      public byte[] decodeBinary(String value)