@InterfaceAudience.Private public class BackupInfo extends Object implements Comparable<BackupInfo>
Modifier and Type | Class and Description |
---|---|
static class |
BackupInfo.BackupPhase
BackupPhase - phases of an ACTIVE backup session (running), when state of a backup session is
BackupState.RUNNING
|
static class |
BackupInfo.BackupState
Backup session states
|
static interface |
BackupInfo.Filter |
Modifier and Type | Field and Description |
---|---|
private String |
backupId
Backup id
|
private String |
backupRootDir
Target root directory for storing the backup files
|
private Map<TableName,BackupTableInfo> |
backupTableInfoMap
Backup status map for all tables
|
private long |
bandwidth
Bandwidth per worker in MB per sec.
|
private long |
completeTs
Actual end timestamp of the backup process
|
private String |
failedMsg
Backup failure message
|
private String |
hlogTargetDir
For incremental backup, a location of a backed-up hlogs
|
private List<String> |
incrBackupFileList
Incremental backup file list
|
private Map<TableName,Map<String,Long>> |
incrTimestampMap
Previous Region server log timestamps for table set after distributed log roll key - table
name, value - map of RegionServer hostname -> last log rolled timestamp
|
private static org.slf4j.Logger |
LOG |
private BackupInfo.BackupPhase |
phase
Backup phase
|
private int |
progress
Backup progress in %% (0-100)
|
private long |
startTs
Actual start timestamp of a backup process
|
private BackupInfo.BackupState |
state
Backup state
|
private Map<TableName,Map<String,Long>> |
tableSetTimestampMap
New region server log timestamps for table set after distributed log roll key - table name,
value - map of RegionServer hostname -> last log rolled timestamp
|
private long |
totalBytesCopied
Total bytes of incremental logs copied
|
private BackupType |
type
Backup type, full or incremental
|
private int |
workers
Number of parallel workers.
|
Constructor and Description |
---|
BackupInfo() |
BackupInfo(String backupId,
BackupType type,
TableName[] tables,
String targetRootDir) |
Modifier and Type | Method and Description |
---|---|
void |
addTables(TableName[] tables) |
int |
compareTo(BackupInfo o)
We use only time stamps to compare objects during sort operation
|
boolean |
equals(Object obj) |
static BackupInfo |
fromByteArray(byte[] data) |
static BackupInfo |
fromProto(org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo proto) |
static BackupInfo |
fromStream(InputStream stream) |
String |
getBackupId() |
String |
getBackupRootDir() |
BackupTableInfo |
getBackupTableInfo(TableName table) |
long |
getBandwidth() |
long |
getCompleteTs() |
String |
getFailedMsg() |
String |
getHLogTargetDir() |
List<String> |
getIncrBackupFileList() |
Map<TableName,Map<String,Long>> |
getIncrTimestampMap()
Get new region server log timestamps after distributed log roll
|
BackupInfo.BackupPhase |
getPhase() |
int |
getProgress()
Get current progress
|
String |
getShortDescription() |
String |
getSnapshotName(TableName table) |
List<String> |
getSnapshotNames() |
long |
getStartTs() |
BackupInfo.BackupState |
getState() |
String |
getStatusAndProgressAsString() |
String |
getTableBackupDir(TableName tableName) |
TableName |
getTableBySnapshot(String snapshotName) |
String |
getTableListAsString() |
List<TableName> |
getTableNames() |
Set<TableName> |
getTables() |
Map<TableName,Map<String,Long>> |
getTableSetTimestampMap() |
private static Map<TableName,Map<String,Long>> |
getTableSetTimestampMap(Map<String,org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo.RSTimestampMap> map) |
long |
getTotalBytesCopied() |
BackupType |
getType() |
int |
getWorkers() |
int |
hashCode() |
void |
setBackupId(String backupId) |
void |
setBackupRootDir(String targetRootDir) |
private void |
setBackupTableInfoMap(org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo.Builder builder) |
void |
setBackupTableInfoMap(Map<TableName,BackupTableInfo> backupTableInfoMap) |
void |
setBandwidth(long bandwidth) |
void |
setCompleteTs(long endTs) |
void |
setFailedMsg(String failedMsg) |
void |
setHLogTargetDir(String hlogTagetDir) |
void |
setIncrBackupFileList(List<String> incrBackupFileList) |
void |
setIncrTimestampMap(Map<TableName,Map<String,Long>> prevTableSetTimestampMap)
Set the new region server log timestamps after distributed log roll
|
void |
setPhase(BackupInfo.BackupPhase phase) |
void |
setProgress(int p)
Set progress (0-100%)
|
void |
setSnapshotName(TableName table,
String snapshotName) |
void |
setStartTs(long startTs) |
void |
setState(BackupInfo.BackupState flag) |
void |
setTables(List<TableName> tables) |
private void |
setTableSetTimestampMap(org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo.Builder builder) |
void |
setTableSetTimestampMap(Map<TableName,Map<String,Long>> tableSetTimestampMap) |
void |
setTotalBytesCopied(long totalBytesCopied) |
void |
setType(BackupType type) |
void |
setWorkers(int workers) |
byte[] |
toByteArray() |
private static Map<TableName,BackupTableInfo> |
toMap(List<org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupTableInfo> list) |
org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo |
toProtosBackupInfo() |
String |
toString() |
private static final org.slf4j.Logger LOG
private BackupType type
private String backupRootDir
private BackupInfo.BackupState state
private BackupInfo.BackupPhase phase
private Map<TableName,BackupTableInfo> backupTableInfoMap
private long startTs
private long completeTs
private long totalBytesCopied
private String hlogTargetDir
private List<String> incrBackupFileList
private Map<TableName,Map<String,Long>> tableSetTimestampMap
private Map<TableName,Map<String,Long>> incrTimestampMap
private int progress
private int workers
private long bandwidth
public BackupInfo()
public BackupInfo(String backupId, BackupType type, TableName[] tables, String targetRootDir)
public int getWorkers()
public void setWorkers(int workers)
public long getBandwidth()
public void setBandwidth(long bandwidth)
public void setBackupTableInfoMap(Map<TableName,BackupTableInfo> backupTableInfoMap)
public void setTableSetTimestampMap(Map<TableName,Map<String,Long>> tableSetTimestampMap)
public void setType(BackupType type)
public void setBackupRootDir(String targetRootDir)
public void setTotalBytesCopied(long totalBytesCopied)
public void setProgress(int p)
p
- progress valuepublic int getProgress()
public String getBackupId()
public void setBackupId(String backupId)
public BackupTableInfo getBackupTableInfo(TableName table)
public String getFailedMsg()
public void setFailedMsg(String failedMsg)
public long getStartTs()
public void setStartTs(long startTs)
public long getCompleteTs()
public void setCompleteTs(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, String snapshotName)
public String getSnapshotName(TableName table)
public List<String> getSnapshotNames()
public List<TableName> getTableNames()
public String getBackupRootDir()
public String getTableBackupDir(TableName tableName)
public void setHLogTargetDir(String hlogTagetDir)
public String getHLogTargetDir()
public List<String> getIncrBackupFileList()
public void setIncrBackupFileList(List<String> incrBackupFileList)
public void setIncrTimestampMap(Map<TableName,Map<String,Long>> prevTableSetTimestampMap)
prevTableSetTimestampMap
- table timestamp mappublic Map<TableName,Map<String,Long>> getIncrTimestampMap()
public TableName getTableBySnapshot(String snapshotName)
public org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo toProtosBackupInfo()
public byte[] toByteArray() throws IOException
IOException
private void setBackupTableInfoMap(org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo.Builder builder)
private void setTableSetTimestampMap(org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo.Builder builder)
public static BackupInfo fromByteArray(byte[] data) throws IOException
IOException
public static BackupInfo fromStream(InputStream stream) throws IOException
IOException
public static BackupInfo fromProto(org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo proto)
private static Map<TableName,BackupTableInfo> toMap(List<org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupTableInfo> list)
private static Map<TableName,Map<String,Long>> getTableSetTimestampMap(Map<String,org.apache.hadoop.hbase.shaded.protobuf.generated.BackupProtos.BackupInfo.RSTimestampMap> map)
public String getShortDescription()
public String getStatusAndProgressAsString()
public String getTableListAsString()
public int compareTo(BackupInfo o)
compareTo
in interface Comparable<BackupInfo>
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.