diff --git a/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/batch/BatchedStore.scala b/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/batch/BatchedStore.scala
index ea6c1a755..da1ae913d 100644
--- a/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/batch/BatchedStore.scala
+++ b/summingbird-scalding/src/main/scala/com/twitter/summingbird/scalding/batch/BatchedStore.scala
@@ -154,7 +154,7 @@ trait BatchedStore[K, V] extends scalding.Store[K, V] { self =>
    * we are guaranteed to have sufficient input and deltas to cover these batches
    * and that the batches are given in order
    */
-  private def mergeBatched(inBatch: BatchID,
+  protected def mergeBatched(inBatch: BatchID,
     input: FlowProducer[TypedPipe[(K, V)]],
     deltas: FlowToPipe[(K, V)],
     readTimespan: Interval[Timestamp],