@InterfaceAudience.Private @InterfaceStability.Evolving public class BackupInfo extends java.lang.Object implements java.lang.Comparable<BackupInfo>
Modifier and Type | Class and Description |
---|---|
static class |
BackupInfo.BackupPhase |
static class |
BackupInfo.BackupState |
Constructor and Description |
---|
BackupInfo() |
BackupInfo(java.lang.String backupId,
BackupType type,
TableName[] tables,
java.lang.String targetRootDir) |
Modifier and Type | Method and Description |
---|---|
void |
addTables(TableName[] tables) |
int |
compareTo(BackupInfo o) |
static BackupInfo |
fromByteArray(byte[] data) |
static BackupInfo |
fromProto(BackupProtos.BackupInfo proto) |
static BackupInfo |
fromStream(java.io.InputStream stream) |
java.lang.String |
getBackupId() |
BackupStatus |
getBackupStatus(TableName table) |
long |
getBandwidth() |
long |
getEndTs() |
java.lang.String |
getFailedMsg() |
java.lang.String |
getHlogTargetDir() |
java.lang.String |
getHLogTargetDir() |
java.util.List<java.lang.String> |
getIncrBackupFileList() |
java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
getIncrTimestampMap()
Get new region server log timestamps after distributed log roll
|
java.lang.String |
getJobId() |
BackupInfo.BackupPhase |
getPhase() |
int |
getProgress()
Get current progress
|
java.lang.String |
getShortDescription() |
java.lang.String |
getSnapshotName(TableName table) |
java.util.List<java.lang.String> |
getSnapshotNames() |
long |
getStartTs() |
BackupInfo.BackupState |
getState() |
java.lang.String |
getStatusAndProgressAsString() |
TableName |
getTableBySnapshot(java.lang.String snapshotName) |
java.lang.String |
getTableListAsString() |
java.util.List<TableName> |
getTableNames() |
java.util.Set<TableName> |
getTables() |
java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
getTableSetTimestampMap() |
java.lang.String |
getTargetRootDir() |
long |
getTotalBytesCopied() |
BackupType |
getType() |
int |
getWorkers() |
void |
setBackupId(java.lang.String backupId) |
void |
setBackupStatusMap(java.util.Map<TableName,BackupStatus> backupStatusMap) |
void |
setBandwidth(long bandwidth) |
void |
setEndTs(long endTs) |
void |
setFailedMsg(java.lang.String failedMsg) |
void |
setHlogTargetDir(java.lang.String hlogTagetDir) |
void |
setIncrBackupFileList(java.util.List<java.lang.String> incrBackupFileList) |
void |
setIncrTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> newTableSetTimestampMap)
Set the new region server log timestamps after distributed log roll
|
void |
setJobId(java.lang.String jobId) |
void |
setPhase(BackupInfo.BackupPhase phase) |
void |
setProgress(int p)
Set progress (0-100%)
|
void |
setSnapshotName(TableName table,
java.lang.String snapshotName) |
void |
setStartTs(long startTs) |
void |
setState(BackupInfo.BackupState flag) |
void |
setTableSetTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> tableSetTimestampMap) |
void |
setTargetRootDir(java.lang.String targetRootDir) |
void |
setTotalBytesCopied(long totalBytesCopied) |
void |
setType(BackupType type) |
void |
setWorkers(int workers) |
byte[] |
toByteArray() |
BackupProtos.BackupInfo |
toProtosBackupInfo() |
public BackupInfo()
public BackupInfo(java.lang.String backupId, BackupType type, TableName[] tables, java.lang.String targetRootDir)
public java.lang.String getJobId()
public void setJobId(java.lang.String jobId)
public int getWorkers()
public void setWorkers(int workers)
public long getBandwidth()
public void setBandwidth(long bandwidth)
public void setBackupStatusMap(java.util.Map<TableName,BackupStatus> backupStatusMap)
public java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> getTableSetTimestampMap()
public void setTableSetTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> tableSetTimestampMap)
public java.lang.String getHlogTargetDir()
public void setType(BackupType type)
public void setTargetRootDir(java.lang.String targetRootDir)
public void setTotalBytesCopied(long totalBytesCopied)
public void setProgress(int p)
msg
- progress valuepublic int getProgress()
public java.lang.String getBackupId()
public void setBackupId(java.lang.String backupId)
public BackupStatus getBackupStatus(TableName table)
public java.lang.String getFailedMsg()
public void setFailedMsg(java.lang.String failedMsg)
public long getStartTs()
public void setStartTs(long startTs)
public long getEndTs()
public void setEndTs(long endTs)
public long getTotalBytesCopied()
public BackupInfo.BackupState getState()
public void setState(BackupInfo.BackupState flag)
public BackupInfo.BackupPhase getPhase()
public void setPhase(BackupInfo.BackupPhase phase)
public BackupType getType()
public void setSnapshotName(TableName table, java.lang.String snapshotName)
public java.lang.String getSnapshotName(TableName table)
public java.util.List<java.lang.String> getSnapshotNames()
public java.util.Set<TableName> getTables()
public java.util.List<TableName> getTableNames()
public void addTables(TableName[] tables)
public java.lang.String getTargetRootDir()
public void setHlogTargetDir(java.lang.String hlogTagetDir)
public java.lang.String getHLogTargetDir()
public java.util.List<java.lang.String> getIncrBackupFileList()
public void setIncrBackupFileList(java.util.List<java.lang.String> incrBackupFileList)
public void setIncrTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> newTableSetTimestampMap)
newTableSetTimestampMap
- table timestamp mappublic java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> getIncrTimestampMap()
public TableName getTableBySnapshot(java.lang.String snapshotName)
public BackupProtos.BackupInfo toProtosBackupInfo()
public byte[] toByteArray() throws java.io.IOException
java.io.IOException
public static BackupInfo fromByteArray(byte[] data) throws java.io.IOException
java.io.IOException
public static BackupInfo fromStream(java.io.InputStream stream) throws java.io.IOException
java.io.IOException
public static BackupInfo fromProto(BackupProtos.BackupInfo proto)
public java.lang.String getShortDescription()
public java.lang.String getStatusAndProgressAsString()
public java.lang.String getTableListAsString()
public int compareTo(BackupInfo o)
compareTo
in interface java.lang.Comparable<BackupInfo>