DieterDP-ng commented on code in PR #6134:
URL: https://github.com/apache/hbase/pull/6134#discussion_r1862341662
##########
hbase-backup/src/main/java/org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java:
##########
@@ -1579,30 +1521,8 @@ public static void deleteSnapshot(Connection conn)
throws IOException {
}
}
- /*
- * Creates Put's for bulk load resulting from running LoadIncrementalHFiles
- */
- static List<Put> createPutForPreparedBulkload(TableName table, byte[]
region, final byte[] family,
- final List<Pair<Path, Path>> pairs) {
- List<Put> puts = new ArrayList<>(pairs.size());
- for (Pair<Path, Path> pair : pairs) {
- Path path = pair.getSecond();
- String file = path.toString();
- int lastSlash = file.lastIndexOf("/");
- String filename = file.substring(lastSlash + 1);
- Put put = new Put(rowkey(BULK_LOAD_PREFIX, table.toString(),
BLK_LD_DELIM,
- Bytes.toString(region), BLK_LD_DELIM, filename));
- put.addColumn(BackupSystemTable.META_FAMILY, TBL_COL, table.getName());
- put.addColumn(BackupSystemTable.META_FAMILY, FAM_COL, family);
- put.addColumn(BackupSystemTable.META_FAMILY, PATH_COL,
Bytes.toBytes(file));
- put.addColumn(BackupSystemTable.META_FAMILY, STATE_COL, BL_PREPARE);
- puts.add(put);
- LOG.debug("writing raw bulk path " + file + " for " + table + " " +
Bytes.toString(region));
- }
- return puts;
- }
-
public static List<Delete> createDeleteForOrigBulkLoad(List<TableName> lst) {
+ // Unused???
Review Comment:
Ill deal with it in HBASE-29003.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@hbase.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
