From bb1448a129c699820bfd0194d98fd458adb41af7 Mon Sep 17 00:00:00 2001 From: Ram Nad Date: Sat, 13 Jul 2024 08:54:01 +0000 Subject: [PATCH] Fix Typo in local_diskstore --- diskstore/local_diskstore.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/diskstore/local_diskstore.go b/diskstore/local_diskstore.go index 2429c6c2..efc1f370 100644 --- a/diskstore/local_diskstore.go +++ b/diskstore/local_diskstore.go @@ -164,10 +164,10 @@ func (l LocalDiskStore) ListSnapshotVectorPartyFiles(table string, shard int, redoLogFile int64, offset uint32, batchID int) (columnIDs []int, err error) { snapshotBatchDir := GetPathForTableSnapshotBatchDir(l.rootPath, table, shard, redoLogFile, offset, batchID) - return l.readVectoryPartyFiles(snapshotBatchDir) + return l.readVectorPartyFiles(snapshotBatchDir) } -func (l LocalDiskStore) readVectoryPartyFiles(dir string) (columnIDs []int, err error) { +func (l LocalDiskStore) readVectorPartyFiles(dir string) (columnIDs []int, err error) { vpFiles, err := ioutil.ReadDir(dir) if os.IsNotExist(err) { @@ -289,7 +289,7 @@ func (l LocalDiskStore) ListArchiveBatchVectorPartyFiles(table string, shard, ba batchVersion uint32, seqNum uint32) ([]int, error) { batchIDTimeStr := daysSinceEpochToTimeStr(batchID) tableArchiveBatchDir := GetPathForTableArchiveBatchDir(l.rootPath, table, shard, batchIDTimeStr, batchVersion, seqNum) - return l.readVectoryPartyFiles(tableArchiveBatchDir) + return l.readVectorPartyFiles(tableArchiveBatchDir) } // OpenVectorPartyFileForRead : Opens the vector party file at the specified batchVersion for read.