public class ProcessInfo extends java.lang.Object implements java.io.Serializable, java.lang.Comparable<ProcessInfo>, java.lang.Cloneable
| Modifier and Type | Class and Description |
|---|---|
static class |
ProcessInfo.ProcessStatus |
static class |
ProcessInfo.ThreadData |
| Constructor and Description |
|---|
ProcessInfo() |
ProcessInfo(ProcessInfoKey key) |
public ProcessInfo()
public ProcessInfo(ProcessInfoKey key)
public java.lang.String getSourceNodeId()
public java.lang.String getTargetNodeId()
public ProcessType getProcessType()
public ProcessInfoKey getKey()
public void setKey(ProcessInfoKey key)
public ProcessInfo.ProcessStatus getStatus()
public void setStatus(ProcessInfo.ProcessStatus status)
public long getCurrentDataCount()
public void setCurrentDataCount(long dataCount)
public long getTotalBatchCount()
public void setTotalBatchCount(long batchCount)
public void incrementCurrentDataCount()
public void incrementBatchCount()
public void incrementCurrentBatchCount()
public long getCurrentBatchCount()
public void setCurrentBatchCount(long currentBatchCount)
public long getCurrentBatchId()
public void setCurrentBatchId(long currentBatchId)
public void setCurrentLoadId(long loadId)
public long getCurrentLoadId()
public java.lang.String getQueue()
public java.lang.String getCurrentChannelId()
public void setCurrentChannelId(java.lang.String currentChannelId)
public java.lang.Thread getThread()
public void setThread(java.lang.Thread thread)
public java.util.Date getStartTime()
public java.util.Date getEndTime()
public void setEndTime(java.util.Date endTime)
public void setCurrentTableName(java.lang.String currentTableName)
public java.lang.String getCurrentTableName()
public java.util.Date getLastStatusChangeTime()
public java.util.Date getCurrentBatchStartTime()
public void setCurrentBatchStartTime(java.util.Date currentBatchStartTime)
public java.lang.String toString()
toString in class java.lang.Objectpublic java.lang.String showInError(java.lang.String identityNodeId)
public int compareTo(ProcessInfo o)
compareTo in interface java.lang.Comparable<ProcessInfo>public ProcessInfo.ThreadData getThreadData()
public static ProcessInfo.ThreadData getThreadData(long threadId)
public long getTotalDataCount()
public void setTotalDataCount(long totalDataCount)
public ProcessInfo copy()