public class ReplicatorStreamStatus extends ErrorCodeInfo
ErrorCodeInfo.Code| Constructor and Description |
|---|
ReplicatorStreamStatus()
Creates a new ReplicatorStreamStatus with default values.
|
ReplicatorStreamStatus(long insertedRows,
long dumpedRows,
ErrorCodeInfo errorInfo)
Creates a new ReplicatorStreamStatus with the specified values.
|
| Modifier and Type | Method and Description |
|---|---|
long |
getDumpedRows()
Gets the number of rows that have been successfully written to the server.
|
long |
getInsertedRows()
Gets the total number of rows that have been inserted into the queue.
|
long |
getPendingRows()
Gets the number of rows waiting in the queue (not yet written).
|
void |
setDumpedRows(long dumpedRows)
Sets the number of rows successfully written.
|
void |
setError(ErrorCodeInfo errorInfo)
Sets error information from another ErrorCodeInfo.
|
void |
setInsertedRows(long insertedRows)
Sets the total number of rows inserted.
|
String |
toString() |
clearError, formatApiCode, getErrorCode, getErrorInfo, hasError, set, set, set, set, setErrorCode, setErrorInfo, succeedpublic ReplicatorStreamStatus()
public ReplicatorStreamStatus(long insertedRows,
long dumpedRows,
ErrorCodeInfo errorInfo)
insertedRows - The total number of rows inserted into the queuedumpedRows - The number of rows successfully written to the servererrorInfo - ErrorCodeInfo containing error code and messagepublic long getInsertedRows()
public void setInsertedRows(long insertedRows)
insertedRows - The number of inserted rowspublic long getDumpedRows()
public void setDumpedRows(long dumpedRows)
dumpedRows - The number of dumped rowspublic long getPendingRows()
public void setError(ErrorCodeInfo errorInfo)
errorInfo - The error information to copypublic String toString()
toString in class ErrorCodeInfoCopyright © 2026 DolphinDB. All rights reserved.