Method DeleteColumn

diskstore/local_diskstore.go:396–423

DeleteColumn : Deletes all batches of the specified column.

(table string, columnID int, shard int)

// DeleteColumn : Deletes all batches of the specified column.
func (l LocalDiskStore) DeleteColumn(table string, columnID int, shard int) error {
	tableArchiveBatchRootDir := GetPathForTableArchiveBatchRootDir(l.rootPath, table, shard)
	tableArchiveBatchDirs, err := ioutil.ReadDir(tableArchiveBatchRootDir)

	if err != nil {
		if os.IsNotExist(err) {
			return nil
		}
		return utils.StackError(err, "Failed to list archive batches from table archive batch root dir: %s",
			tableArchiveBatchRootDir)
	}
	for _, f := range tableArchiveBatchDirs {
		if f.IsDir() {
			if batchID, batchVersion, seqNum, err := ParseBatchIDAndVersionName(f.Name()); err == nil {
				vectorPartyFilePath := GetPathForTableArchiveBatchColumnFile(l.rootPath, table, shard, batchID,
					batchVersion, seqNum, columnID)
				if err = os.Remove(vectorPartyFilePath); err != nil && !os.IsNotExist(err) {
					utils.GetLogger().With(
						"vectorPartyFilePath", vectorPartyFilePath,
						"err", err,
					).Warn("Failed to delete a vector party file")
					continue
				}
			}
		}
	}
	return nil
}

func daysSinceEpochToTime(daysSinceEpoch int) time.Time {
	secondsSinceEpoch := int64(daysSinceEpoch) * 86400