(newTableList []string)
| 117 | } |
| 118 | |
| 119 | func (m *memStoreImpl) applyTableList(newTableList []string) { |
| 120 | m.Lock() |
| 121 | for tableName, tableSchema := range m.TableSchemas { |
| 122 | if utils.IndexOfStr(newTableList, tableName) < 0 { |
| 123 | // detach shards and schema from map |
| 124 | // to prevent new usage |
| 125 | tableShards := m.TableShards[tableName] |
| 126 | delete(m.TableSchemas, tableName) |
| 127 | delete(m.TableShards, tableName) |
| 128 | // only one table deletion at a time |
| 129 | m.Unlock() |
| 130 | for shardID, shard := range tableShards { |
| 131 | shard.Destruct() |
| 132 | m.diskStore.DeleteTableShard(tableName, shardID) |
| 133 | } |
| 134 | m.scheduler.DeleteTable(tableName, tableSchema.Schema.IsFactTable) |
| 135 | return |
| 136 | } |
| 137 | } |
| 138 | m.Unlock() |
| 139 | } |
| 140 | |
| 141 | // handleTableSchemaChange handles table schema change event from metaStore including new table schema. |
| 142 | func (m *memStoreImpl) handleTableSchemaChange(tableSchemaChangeEvents <-chan *metaCom.Table, done chan<- struct{}) { |
no test coverage detected