From 208d6d906878dd50ac44c3d89368f1b3ca78ea05 Mon Sep 17 00:00:00 2001 From: Erik Osheim Date: Mon, 9 Apr 2018 18:30:50 -0400 Subject: [PATCH] Make mergeBatched protected instead of private. There are reasons why particular implementations might want to override this method (for example, to support custom serialization strategies), so let's make it protected instead of private. --- .../com/twitter/summingbird/scalding/batch/BatchedStore.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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],