diff --git a/posting/rollup.go b/posting/rollup.go index af3a65f0125a601ea52ddfb804b0a5096bb4006b..464f077520d003374be2e9f3285c040c332b1990 100644 --- a/posting/rollup.go +++ b/posting/rollup.go @@ -141,44 +141,3 @@ func (l *List) Rollup() (*intern.PostingList, error) { // atomic.StoreInt32(&l.estimatedSize, l.calculateSize()) // return nil } - -func scanKeysToRoll(snapshotTs uint64, keyChan chan *intern.KVS) error { - txn := pstore.NewTransactionAt(snapshotTs, false) - defer txn.Discard() - - opts := badger.DefaultIteratorOptions - opts.AllVersions = false - opts.PrefetchValues = false - - itr := txn.NewIterator(opts) - defer itr.Close() - - kvs := new(intern.KVS) - // We just pick up the first version of each key. If it is already complete, we skip. - // If it is a delta, we add that to KVS, to be rolled up. - for itr.Rewind(); itr.Valid(); itr.Next() { - item := itr.Item() - pk := x.Parse(item.Key()) - if pk.IsSchema() { - // Skip schema. - continue - } - if item.UserMeta()&BitCompletePosting > 0 { - // First version is complete. Therefore, skip. - - } else if item.UserMeta()&BitDeltaPosting > 0 { - kvs.Kv = append(kvs.Kv, &intern.KV{Key: item.KeyCopy(nil)}) - if len(kvs.Kv) >= 100 { - keyChan <- kvs - kvs = new(intern.KVS) - } - - } else { - x.Fatalf("unexpected meta: %d", item.UserMeta()) - } - } - if len(kvs.Kv) > 0 { - keyChan <- kvs - } - return nil -} diff --git a/worker/mutation.go b/worker/mutation.go index e77af8430f826e60d178cfe9ed4b01e2868b677c..5ad46cb57bc6f5b1df724a3de2d4a7e378a96248 100644 --- a/worker/mutation.go +++ b/worker/mutation.go @@ -85,13 +85,14 @@ func runSchemaMutation(ctx context.Context, update *intern.SchemaUpdate, startTs } // Flush to disk - posting.CommitLists(func(key []byte) bool { - pk := x.Parse(key) - if pk.Attr == update.Predicate { - return true - } - return false - }) + // TODO: Figure out how to do this. + // posting.CommitLists(func(key []byte) bool { + // pk := x.Parse(key) + // if pk.Attr == update.Predicate { + // return true + // } + // return false + // }) updateSchema(update.Predicate, *update) return nil }