Initial commit for multi-part lists

posting/index.go

@@ -550,15 +550,18 @@ func (r *rebuild) Run(ctx context.Context) error {
 		if le == 0 {
 			continue
 		}
-		kv, err := pl.MarshalToKv()
+		kvs, err := pl.MarshalToKv()
 		if err != nil {
 			return err
 		}
-		// We choose to write the PL at r.startTs, so it won't be read by txns,
-		// which occurred before this schema mutation. Typically, we use
-		// kv.Version as the timestamp.
-		if err = writer.SetAt(kv.Key, kv.Value, kv.UserMeta[0], r.startTs); err != nil {
-			return err
+
+		for _, kv := range kvs {
+			// We choose to write the PL at r.startTs, so it won't be read by txns,
+			// which occurred before this schema mutation. Typically, we use
+			// kv.Version as the timestamp.
+			if err = writer.SetAt(kv.Key, kv.Value, kv.UserMeta[0], r.startTs); err != nil {
+				return err
+			}
 		}
 		// This locking is just to catch any future issues.  We shouldn't need
 		// to release this lock, because each posting list must only be accessed