Method initialGlobalPriorityQueue

memstore/host_memory_manager.go:494–509

initialGlobalPriorityQueue will initialize a globalPriorityQueueWithLock and fetch one batch for each table column from batchInfosByColumn.

()

// initialGlobalPriorityQueue will initialize a globalPriorityQueueWithLock and fetch
// one batch for each table column from batchInfosByColumn.
func (h *hostMemoryManager) initialGlobalPriorityQueue() *globalPriorityQueue {
	gpq := newGlobalPriorityQueue()
	utils.GetLogger().Debugf("Trying to init priority queue to hold batch objects")
	h.RLock()
	for tableName, columnsBatchesList := range h.batchInfosByColumn {
		utils.GetLogger().Debugf("Looking at table:%s, columnsBatchesList.size() = %d", tableName, len(columnsBatchesList))
		for columnID, columnBatchInfos := range columnsBatchesList {
			columnBatchIt := columnBatchInfos.batchInfoByID.Iterator()
			if columnBatchIt.Next() {
				gpq.pushBatchIntoGlobalPriorityQueue(h, columnBatchInfos, columnID, columnBatchIt)
			}
		}
	}
	h.RUnlock()
	return gpq
}

// globalPriority is the holding struct for all the neccesarry fields to
// compare batch priority in a global view.