Method OpenVectorPartyFileForWrite

diskstore/local_diskstore.go:317–337

OpenVectorPartyFileForWrite : Creates/truncates the vector party file at the specified batchVersion for write.

(table string, columnID int, shard, batchID int, batchVersion uint32,
	seqNum uint32)

// OpenVectorPartyFileForWrite : Creates/truncates the vector party file at the specified batchVersion for write.
func (l LocalDiskStore) OpenVectorPartyFileForWrite(table string, columnID int, shard, batchID int, batchVersion uint32,
	seqNum uint32) (io.WriteCloser, error) {
	batchIDTimeStr := daysSinceEpochToTimeStr(batchID)
	batchDir := GetPathForTableArchiveBatchDir(l.rootPath, table, shard, batchIDTimeStr, batchVersion, seqNum)
	if err := os.MkdirAll(batchDir, 0755); err != nil {
		return nil, utils.StackError(err, "Failed to make dirs for path: %s", batchDir)
	}
	vectorPartyFilePath := GetPathForTableArchiveBatchColumnFile(l.rootPath, table, shard, batchIDTimeStr, batchVersion,
		seqNum, columnID)

	mode := os.O_CREATE | os.O_WRONLY
	if l.diskStoreConfig.WriteSync {
		mode |= os.O_SYNC
	}

	f, err := os.OpenFile(vectorPartyFilePath, mode, 0644)
	if err != nil {
		return nil, utils.StackError(err, "Failed to open vector party file: %s for write", vectorPartyFilePath)
	}
	return f, nil
}

// DeleteBatchVersions deletes all old batches with the specified batchID that have version lower than or equal to
// the specified batch  version. All columns of those batches will be deleted.