NewMemStore creates a MemStore from the specified MetaStore.
(metaStore metaCom.MetaStore, diskStore diskstore.DiskStore, options Options)
| 111 | |
| 112 | // NewMemStore creates a MemStore from the specified MetaStore. |
| 113 | func NewMemStore(metaStore metaCom.MetaStore, diskStore diskstore.DiskStore, options Options) MemStore { |
| 114 | memStore := &memStoreImpl{ |
| 115 | TableShards: make(map[string]map[int]*TableShard), |
| 116 | TableSchemas: make(map[string]*common.TableSchema), |
| 117 | metaStore: metaStore, |
| 118 | diskStore: diskStore, |
| 119 | options: options, |
| 120 | } |
| 121 | // Create HostMemoryManager |
| 122 | memStore.HostMemManager = NewHostMemoryManager(memStore, utils.GetConfig().TotalMemorySize) |
| 123 | memStore.scheduler = newScheduler(memStore) |
| 124 | return memStore |
| 125 | } |
| 126 | |
| 127 | func (m *memStoreImpl) GetMemoryUsageDetails() (map[string]TableShardMemoryUsage, error) { |
| 128 | archiveMemoryUsageByTableShard, err := m.HostMemManager.GetArchiveMemoryUsageByTableShard() |