Refactoring of InsertingPipe in preparation for locking scheme for MERGE
Rewrite MergeConcurrencyIT