Archive batches Utils Path on disk: {root_path}/data/{table_name}_{shard_id}/archiving_batches/{batch_id}_{batch_version} {root_path}/data/{table_name}_{shard_id}/archiving_batches/{batch_id}_{batch_version}/{columnID}.data Note: batch_id is UTC date batch_version is the cutoff seconds in unix tim
(prefix, table string, shardID int)
| 113 | |
| 114 | // GetPathForTableArchiveBatchRootDir is used to get root directory path for archive batch given path prefix, table name and shard id. |
| 115 | func GetPathForTableArchiveBatchRootDir(prefix, table string, shardID int) string { |
| 116 | tableShardPath := getPathForTableShard(prefix, table, shardID) |
| 117 | return filepath.Join(tableShardPath, archiveBatches) |
| 118 | } |
| 119 | |
| 120 | // GetPathForTableArchiveBatchDir is used to get the dir path of an archive batch version given path prefix, table name, shard id, batch id and batch version. |
| 121 | func GetPathForTableArchiveBatchDir(prefix, table string, shardID int, batchID string, batchVersion uint32, seqNum uint32) string { |
no test coverage detected