format

simerplaha · Nov 11, 2021 · 50905e8 · 50905e8
1 parent e8b48d3
commit 50905e8
Show file tree

Hide file tree

Showing 176 changed files with 343 additions and 413 deletions.
diff --git a/.github/FUNDING.yml b/.github/FUNDING.yml
@@ -1,3 +1,3 @@
 # These are supported funding model platforms
 
-github: [simerplaha]
+github: [ simerplaha ]
diff --git a/actor/src/main/scala/swaydb/test/TestActor.scala b/actor/src/main/scala/swaydb/test/TestActor.scala
@@ -17,7 +17,7 @@
 package swaydb.test
 
 import swaydb.ActorConfig.QueueOrder
-import swaydb.{Actor, ActorQueue, IO, Scheduler}
+import swaydb.{Actor, ActorQueue, Scheduler}
 
 import java.util.concurrent.ConcurrentLinkedQueue
 import scala.concurrent.duration.{FiniteDuration, _}

diff --git a/core-performance/src/test/scala/swaydb/core/level/PathsDistributorPerformanceSpec.scala b/core-performance/src/test/scala/swaydb/core/level/PathsDistributorPerformanceSpec.scala
@@ -65,8 +65,8 @@ class PathsDistributorPerformanceSpec extends TestBase {
                 effect.Dir(path5, 5)
               ),
             segments =
-              //for each Segment's request randomly distribute Segments so that there is always un-even distribution
-              //of Segments between all 5 folders.
+            //for each Segment's request randomly distribute Segments so that there is always un-even distribution
+            //of Segments between all 5 folders.
               randomlyDistributeSegments
           )
 

diff --git a/core-performance/src/test/scala/swaydb/core/segment/SegmentReadPerformanceSpec.scala b/core-performance/src/test/scala/swaydb/core/segment/SegmentReadPerformanceSpec.scala
@@ -22,12 +22,12 @@ import swaydb.core.data.Memory
 import swaydb.core.io.file.ForceSaveApplier
 import swaydb.core.level.PathsDistributor
 import swaydb.core.merge.stats.MergeStats
-import swaydb.core.segment.block.binarysearch.{BinarySearchEntryFormat, BinarySearchIndexBlock, BinarySearchIndexBlockConfig}
-import swaydb.core.segment.block.bloomfilter.{BloomFilterBlock, BloomFilterBlockConfig}
-import swaydb.core.segment.block.hashindex.{HashIndexBlock, HashIndexBlockConfig}
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockConfig}
-import swaydb.core.segment.block.sortedindex.{SortedIndexBlock, SortedIndexBlockConfig}
-import swaydb.core.segment.block.values.{ValuesBlock, ValuesBlockConfig}
+import swaydb.core.segment.block.binarysearch.{BinarySearchEntryFormat, BinarySearchIndexBlockConfig}
+import swaydb.core.segment.block.bloomfilter.BloomFilterBlockConfig
+import swaydb.core.segment.block.hashindex.HashIndexBlockConfig
+import swaydb.core.segment.block.segment.SegmentBlockConfig
+import swaydb.core.segment.block.sortedindex.SortedIndexBlockConfig
+import swaydb.core.segment.block.values.ValuesBlockConfig
 import swaydb.core.segment.entry.reader.PersistentReader
 import swaydb.core.segment.io.SegmentReadIO
 import swaydb.core.segment.ref.search.ThreadReadState
@@ -166,7 +166,7 @@ class SegmentReadPerformanceSpec extends TestBase {
         cacheBlocksOnCreate = false,
         minSize = Int.MaxValue,
         maxCount =
-          //                    keyValuesCount / 100,
+        //                    keyValuesCount / 100,
           keyValuesCount,
         segmentRefCacheLife = SegmentRefCacheLife.Temporary,
         enableHashIndexForListSegment = true,

diff --git a/core/src/main/scala/swaydb/core/CoreInitializer.scala b/core/src/main/scala/swaydb/core/CoreInitializer.scala
@@ -27,10 +27,10 @@ import swaydb.core.level.zero.LevelZero
 import swaydb.core.level.{Level, LevelCloser, NextLevel}
 import swaydb.core.segment.block
 import swaydb.core.segment.block.binarysearch.BinarySearchIndexBlockConfig
-import swaydb.core.segment.block.bloomfilter.{BloomFilterBlock, BloomFilterBlockConfig}
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockConfig}
-import swaydb.core.segment.block.sortedindex.{SortedIndexBlock, SortedIndexBlockConfig}
-import swaydb.core.segment.block.values.{ValuesBlock, ValuesBlockConfig}
+import swaydb.core.segment.block.bloomfilter.BloomFilterBlockConfig
+import swaydb.core.segment.block.segment.SegmentBlockConfig
+import swaydb.core.segment.block.sortedindex.SortedIndexBlockConfig
+import swaydb.core.segment.block.values.ValuesBlockConfig
 import swaydb.core.segment.ref.search.ThreadReadState
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.core.sweeper.{ByteBufferSweeper, FileSweeper, MemorySweeper}

diff --git a/core/src/main/scala/swaydb/core/data/KeyValue.scala b/core/src/main/scala/swaydb/core/data/KeyValue.scala
@@ -16,7 +16,6 @@
 
 package swaydb.core.data
 
-import swaydb.IO
 import swaydb.core.log.serializer.RangeValueSerializer.OptionRangeValueSerializer
 import swaydb.core.log.serializer.{RangeValueSerializer, ValueSerializer}
 import swaydb.core.segment.assigner.Assignable

diff --git a/core/src/main/scala/swaydb/core/function/FunctionStore.scala b/core/src/main/scala/swaydb/core/function/FunctionStore.scala
@@ -16,13 +16,12 @@
 
 package swaydb.core.function
 
-import java.util.concurrent.ConcurrentHashMap
-
 import swaydb.OK
 import swaydb.core.data.{SwayFunction, Value}
 import swaydb.data.order.KeyOrder
 import swaydb.data.slice.Slice
 
+import java.util.concurrent.ConcurrentHashMap
 import scala.annotation.tailrec
 import scala.collection.mutable
 import scala.jdk.CollectionConverters._

diff --git a/core/src/main/scala/swaydb/core/gc/GCStats.scala b/core/src/main/scala/swaydb/core/gc/GCStats.scala
@@ -17,7 +17,6 @@
 package swaydb.core.gc
 
 import com.sun.management.GarbageCollectionNotificationInfo
-import swaydb.utils.StorageUnits._
 
 import javax.management.{Notification, NotificationEmitter, NotificationListener}
 import scala.concurrent.{Future, Promise}

diff --git a/core/src/main/scala/swaydb/core/level/LevelRef.scala b/core/src/main/scala/swaydb/core/level/LevelRef.scala
@@ -16,7 +16,6 @@
 
 package swaydb.core.level
 
-import java.nio.file.Path
 import swaydb.core.data.KeyValue
 import swaydb.core.level.zero.LevelZero
 import swaydb.core.segment.ref.search.ThreadReadState
@@ -26,6 +25,7 @@ import swaydb.data.config.{ForceSave, MMAP}
 import swaydb.data.slice.{Slice, SliceOption}
 import swaydb.{Bag, IO}
 
+import java.nio.file.Path
 import scala.annotation.tailrec
 import scala.collection.mutable.ListBuffer
 import scala.concurrent.duration.FiniteDuration

diff --git a/core/src/main/scala/swaydb/core/level/PathsDistributor.scala b/core/src/main/scala/swaydb/core/level/PathsDistributor.scala
@@ -16,17 +16,16 @@
 
 package swaydb.core.level
 
-import java.nio.file.Path
-import java.util
-import java.util.concurrent.ConcurrentLinkedDeque
-import java.util.concurrent.atomic.AtomicBoolean
 import com.typesafe.scalalogging.LazyLogging
 import swaydb.Error.Segment.ExceptionHandler
 import swaydb.IO
 import swaydb.core.segment.Segment
 import swaydb.effect.{Dir, Reserve}
 import swaydb.utils.Options
 
+import java.nio.file.Path
+import java.util
+import java.util.concurrent.ConcurrentLinkedDeque
 import scala.annotation.tailrec
 import scala.collection.compat._
 import scala.jdk.CollectionConverters._

diff --git a/.../main/scala/swaydb/core/level/compaction/throttle/behaviour/BehaviourCompactionTask.scala b/.../main/scala/swaydb/core/level/compaction/throttle/behaviour/BehaviourCompactionTask.scala
@@ -17,7 +17,6 @@
 package swaydb.core.level.compaction.throttle.behaviour
 
 import com.typesafe.scalalogging.LazyLogging
-import swaydb.DefActor
 import swaydb.core.data.DefIO
 import swaydb.core.level._
 import swaydb.core.level.compaction.io.CompactionIO

diff --git a/core/src/main/scala/swaydb/core/log/PersistentLog.scala b/core/src/main/scala/swaydb/core/log/PersistentLog.scala
@@ -20,7 +20,7 @@ import com.typesafe.scalalogging.LazyLogging
 import swaydb.Error.Log.ExceptionHandler
 import swaydb.IO
 import swaydb.core.io.file.{DBFile, ForceSaveApplier}
-import swaydb.core.log.serializer.{LogEntrySerialiser, LogEntryReader, LogEntryWriter}
+import swaydb.core.log.serializer.{LogEntryReader, LogEntrySerialiser, LogEntryWriter}
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.core.sweeper.{ByteBufferSweeper, FileSweeper}
 import swaydb.data.config.MMAP

diff --git a/core/src/main/scala/swaydb/core/log/applied/AppliedFunctionsLog.scala b/core/src/main/scala/swaydb/core/log/applied/AppliedFunctionsLog.scala
@@ -20,8 +20,8 @@ import com.typesafe.scalalogging.LazyLogging
 import swaydb.core.function.FunctionStore
 import swaydb.core.io.file.ForceSaveApplier
 import swaydb.core.log
-import swaydb.core.log.{Log, RecoveryResult}
 import swaydb.core.log.serializer.{AppliedFunctionsLogEntryReader, AppliedFunctionsLogEntryWriter}
+import swaydb.core.log.{Log, RecoveryResult}
 import swaydb.core.sweeper.ByteBufferSweeper.ByteBufferSweeperActor
 import swaydb.core.sweeper.FileSweeper
 import swaydb.data.config.MMAP

diff --git a/core/src/main/scala/swaydb/core/log/serializer/ValueSerializer.scala b/core/src/main/scala/swaydb/core/log/serializer/ValueSerializer.scala
@@ -16,7 +16,6 @@
 
 package swaydb.core.log.serializer
 
-import swaydb.IO
 import swaydb.core.data.{Time, Value}
 import swaydb.core.io.reader.Reader
 import swaydb.core.util.Times._

diff --git a/core/src/main/scala/swaydb/core/merge/KeyValueGrouper.scala b/core/src/main/scala/swaydb/core/merge/KeyValueGrouper.scala
@@ -17,7 +17,7 @@
 package swaydb.core.merge
 
 import com.typesafe.scalalogging.LazyLogging
-import swaydb.core.data.{Memory, Persistent, Value, _}
+import swaydb.core.data._
 import swaydb.core.merge.stats.MergeStats
 
 /**

diff --git a/core/src/main/scala/swaydb/core/merge/stats/MergeStatsSizeCalculator.scala b/core/src/main/scala/swaydb/core/merge/stats/MergeStatsSizeCalculator.scala
@@ -17,8 +17,8 @@
 package swaydb.core.merge.stats
 
 import swaydb.core.data.Memory
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockConfig}
-import swaydb.core.segment.block.sortedindex.{SortedIndexBlockConfig, SortedIndexBlock}
+import swaydb.core.segment.block.segment.SegmentBlockConfig
+import swaydb.core.segment.block.sortedindex.SortedIndexBlockConfig
 
 import scala.collection.mutable.ListBuffer
 

diff --git a/core/src/main/scala/swaydb/core/segment/MemorySegment.scala b/core/src/main/scala/swaydb/core/segment/MemorySegment.scala
@@ -17,13 +17,12 @@
 package swaydb.core.segment
 
 import com.typesafe.scalalogging.LazyLogging
-import swaydb.core.data.{DefIO, Memory, _}
+import swaydb.core.data._
 import swaydb.core.function.FunctionStore
 import swaydb.core.level.PathsDistributor
 import swaydb.core.merge.stats.MergeStats
 import swaydb.core.segment.assigner.Assignable
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockConfig}
-import swaydb.core.segment.block.sortedindex.SortedIndexBlock
+import swaydb.core.segment.block.segment.SegmentBlockConfig
 import swaydb.core.segment.defrag.DefragMemorySegment
 import swaydb.core.segment.ref.search.ThreadReadState
 import swaydb.core.sweeper.FileSweeper
@@ -82,8 +81,8 @@ private[core] final case class MemorySegment(path: Path,
           removeDeletes: Boolean,
           createdInLevel: Int,
           segmentConfig: SegmentBlockConfig)(implicit idGenerator: IDGenerator,
-                                              executionContext: ExecutionContext,
-                                              compactionParallelism: CompactionParallelism): Future[DefIO[MemorySegmentOption, Iterable[MemorySegment]]] =
+                                             executionContext: ExecutionContext,
+                                             compactionParallelism: CompactionParallelism): Future[DefIO[MemorySegmentOption, Iterable[MemorySegment]]] =
     if (deleted)
       Future.failed(swaydb.Exception.NoSuchFile(path))
     else {

diff --git a/core/src/main/scala/swaydb/core/segment/PersistentSegment.scala b/core/src/main/scala/swaydb/core/segment/PersistentSegment.scala
@@ -24,11 +24,11 @@ import swaydb.core.merge.stats.MergeStats
 import swaydb.core.segment.assigner.Assignable
 import swaydb.core.segment.block.binarysearch.BinarySearchIndexBlockConfig
 import swaydb.core.segment.block.bloomfilter.BloomFilterBlockConfig
-import swaydb.core.segment.block.hashindex.{HashIndexBlock, HashIndexBlockConfig}
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockConfig}
+import swaydb.core.segment.block.hashindex.HashIndexBlockConfig
+import swaydb.core.segment.block.segment.SegmentBlockConfig
 import swaydb.core.segment.block.segment.data.TransientSegment
-import swaydb.core.segment.block.sortedindex.{SortedIndexBlock, SortedIndexBlockConfig}
-import swaydb.core.segment.block.values.{ValuesBlock, ValuesBlockConfig}
+import swaydb.core.segment.block.sortedindex.SortedIndexBlockConfig
+import swaydb.core.segment.block.values.ValuesBlockConfig
 import swaydb.core.util.IDGenerator
 import swaydb.data.compaction.CompactionConfig.CompactionParallelism
 import swaydb.data.config.{MMAP, SegmentRefCacheLife}
@@ -82,8 +82,8 @@ trait PersistentSegment extends Segment with PersistentSegmentOption {
               hashIndexConfig: HashIndexBlockConfig,
               bloomFilterConfig: BloomFilterBlockConfig,
               segmentConfig: SegmentBlockConfig)(implicit idGenerator: IDGenerator,
-                                                  ec: ExecutionContext,
-                                                  compactionParallelism: CompactionParallelism): Future[DefIO[PersistentSegment, Slice[TransientSegment.OneOrRemoteRefOrMany]]]
+                                                 ec: ExecutionContext,
+                                                 compactionParallelism: CompactionParallelism): Future[DefIO[PersistentSegment, Slice[TransientSegment.OneOrRemoteRefOrMany]]]
 
 
 }

diff --git a/core/src/main/scala/swaydb/core/segment/PersistentSegmentMany.scala b/core/src/main/scala/swaydb/core/segment/PersistentSegmentMany.scala
@@ -30,12 +30,12 @@ import swaydb.core.segment.assigner.Assignable
 import swaydb.core.segment.block.BlockCache
 import swaydb.core.segment.block.binarysearch.BinarySearchIndexBlockConfig
 import swaydb.core.segment.block.bloomfilter.BloomFilterBlockConfig
-import swaydb.core.segment.block.hashindex.{HashIndexBlock, HashIndexBlockConfig}
+import swaydb.core.segment.block.hashindex.HashIndexBlockConfig
 import swaydb.core.segment.block.reader.BlockRefReader
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockConfig, SegmentBlockOffset}
 import swaydb.core.segment.block.segment.data.{TransientSegment, TransientSegmentSerialiser}
-import swaydb.core.segment.block.sortedindex.{SortedIndexBlock, SortedIndexBlockConfig}
-import swaydb.core.segment.block.values.{ValuesBlock, ValuesBlockConfig}
+import swaydb.core.segment.block.segment.{SegmentBlockConfig, SegmentBlockOffset}
+import swaydb.core.segment.block.sortedindex.SortedIndexBlockConfig
+import swaydb.core.segment.block.values.ValuesBlockConfig
 import swaydb.core.segment.defrag.DefragPersistentSegment
 import swaydb.core.segment.io.SegmentReadIO
 import swaydb.core.segment.ref.search.ThreadReadState
@@ -871,8 +871,8 @@ protected case class PersistentSegmentMany(file: DBFile,
               hashIndexConfig: HashIndexBlockConfig,
               bloomFilterConfig: BloomFilterBlockConfig,
               segmentConfig: SegmentBlockConfig)(implicit idGenerator: IDGenerator,
-                                                  ec: ExecutionContext,
-                                                  compactionParallelism: CompactionParallelism): Future[DefIO[PersistentSegmentMany, Slice[TransientSegment.OneOrRemoteRefOrMany]]] =
+                                                 ec: ExecutionContext,
+                                                 compactionParallelism: CompactionParallelism): Future[DefIO[PersistentSegmentMany, Slice[TransientSegment.OneOrRemoteRefOrMany]]] =
     Segment.refreshForNewLevel(
       keyValues = iterator(segmentConfig.initialiseIteratorsInOneSeek),
       removeDeletes = removeDeletes,

diff --git a/core/src/main/scala/swaydb/core/segment/PersistentSegmentOne.scala b/core/src/main/scala/swaydb/core/segment/PersistentSegmentOne.scala
@@ -27,13 +27,13 @@ import swaydb.core.level.compaction.io.CompactionIO
 import swaydb.core.merge.stats.MergeStats
 import swaydb.core.segment.assigner.Assignable
 import swaydb.core.segment.block.BlockCache
-import swaydb.core.segment.block.binarysearch.{BinarySearchIndexBlock, BinarySearchIndexBlockOffset, BinarySearchIndexBlockConfig}
-import swaydb.core.segment.block.bloomfilter.{BloomFilterBlock, BloomFilterBlockOffset, BloomFilterBlockConfig}
-import swaydb.core.segment.block.hashindex.{HashIndexBlock, HashIndexBlockOffset, HashIndexBlockConfig}
+import swaydb.core.segment.block.binarysearch.{BinarySearchIndexBlock, BinarySearchIndexBlockConfig, BinarySearchIndexBlockOffset}
+import swaydb.core.segment.block.bloomfilter.{BloomFilterBlock, BloomFilterBlockConfig, BloomFilterBlockOffset}
+import swaydb.core.segment.block.hashindex.{HashIndexBlock, HashIndexBlockConfig, HashIndexBlockOffset}
 import swaydb.core.segment.block.reader.{BlockRefReader, UnblockedReader}
 import swaydb.core.segment.block.segment.data.TransientSegment
 import swaydb.core.segment.block.segment.footer.SegmentFooterBlock
-import swaydb.core.segment.block.segment.{SegmentBlock, SegmentBlockCache, SegmentBlockConfig}
+import swaydb.core.segment.block.segment.{SegmentBlockCache, SegmentBlockConfig}
 import swaydb.core.segment.block.sortedindex.{SortedIndexBlock, SortedIndexBlockConfig, SortedIndexBlockOffset}
 import swaydb.core.segment.block.values.{ValuesBlock, ValuesBlockConfig, ValuesBlockOffset}
 import swaydb.core.segment.defrag.DefragPersistentSegment
@@ -352,8 +352,8 @@ protected case class PersistentSegmentOne(file: DBFile,
               hashIndexConfig: HashIndexBlockConfig,
               bloomFilterConfig: BloomFilterBlockConfig,
               segmentConfig: SegmentBlockConfig)(implicit idGenerator: IDGenerator,
-                                                  ec: ExecutionContext,
-                                                  compactionParallelism: CompactionParallelism): Future[DefIO[PersistentSegment, Slice[TransientSegment.OneOrRemoteRefOrMany]]] = {
+                                                 ec: ExecutionContext,
+                                                 compactionParallelism: CompactionParallelism): Future[DefIO[PersistentSegment, Slice[TransientSegment.OneOrRemoteRefOrMany]]] = {
     //    val footer = ref.getFooter()
     //if it's created in the same level the required spaces for sortedIndex and values
     //will be the same as existing or less than the current sizes so there is no need to create a

diff --git a/core/src/main/scala/swaydb/core/segment/Segment.scala b/core/src/main/scala/swaydb/core/segment/Segment.scala
@@ -17,6 +17,7 @@
 package swaydb.core.segment
 
 import com.typesafe.scalalogging.LazyLogging
+import swaydb.Aggregator
 import swaydb.Error.Segment.ExceptionHandler
 import swaydb.core.data._
 import swaydb.core.function.FunctionStore
@@ -49,7 +50,6 @@ import swaydb.data.slice.{Slice, SliceOption}
 import swaydb.effect.Effect
 import swaydb.utils.Futures.FutureUnitImplicits
 import swaydb.utils.{FiniteDurations, SomeOrNone}
-import swaydb.{Aggregator, IO}
 
 import java.nio.file.Path
 import scala.annotation.tailrec

diff --git a/core/src/main/scala/swaydb/core/segment/assigner/Assigner.scala b/core/src/main/scala/swaydb/core/segment/assigner/Assigner.scala
@@ -62,7 +62,7 @@ private[core] object Assigner {
   def assignUnsafeGaps[GAP](keyValues: IterableOnce[Assignable],
                             segments: IterableOnce[Segment],
                             initialiseIteratorsInOneSeek: Boolean)(implicit keyOrder: KeyOrder[Slice[Byte]],
-                                                             gapCreator: Aggregator.Creator[Assignable, GAP]): ListBuffer[Assignment[GAP, ListBuffer[Assignable], Segment]] =
+                                                                   gapCreator: Aggregator.Creator[Assignable, GAP]): ListBuffer[Assignment[GAP, ListBuffer[Assignable], Segment]] =
     assignUnsafe[GAP, ListBuffer[Assignable], Segment](
       keyValues = keyValues.iterator,
       segmentsIterator = segments.iterator,
@@ -73,7 +73,7 @@ private[core] object Assigner {
   def assignUnsafeGapsSegmentRef[GAP](keyValues: IterableOnce[Assignable],
                                       segments: IterableOnce[SegmentRef],
                                       initialiseIteratorsInOneSeek: Boolean)(implicit keyOrder: KeyOrder[Slice[Byte]],
-                                                                          gapCreator: Aggregator.Creator[Assignable, GAP]): ListBuffer[Assignment[GAP, ListBuffer[Assignable], SegmentRef]] =
+                                                                             gapCreator: Aggregator.Creator[Assignable, GAP]): ListBuffer[Assignment[GAP, ListBuffer[Assignable], SegmentRef]] =
     assignUnsafe[GAP, ListBuffer[Assignable], SegmentRef](
       keyValues = keyValues.iterator,
       segmentsIterator = segments.iterator,
@@ -84,9 +84,9 @@ private[core] object Assigner {
   def assignUnsafeGaps[GAP, MID <: Iterable[_], SEG >: Null](keyValues: IterableOnce[Assignable],
                                                              segments: IterableOnce[SEG],
                                                              initialiseIteratorsInOneSeek: Boolean)(implicit keyOrder: KeyOrder[Slice[Byte]],
-                                                                                          midCreator: Aggregator.Creator[Assignable, MID],
-                                                                                          gapCreator: Aggregator.Creator[Assignable, GAP],
-                                                                                          assignmentTarget: AssignmentTarget[SEG]): ListBuffer[Assignment[GAP, MID, SEG]] =
+                                                                                                    midCreator: Aggregator.Creator[Assignable, MID],
+                                                                                                    gapCreator: Aggregator.Creator[Assignable, GAP],
+                                                                                                    assignmentTarget: AssignmentTarget[SEG]): ListBuffer[Assignment[GAP, MID, SEG]] =
     assignUnsafe[GAP, MID, SEG](
       keyValues = keyValues.iterator,
       segmentsIterator = segments.iterator,

diff --git a/core/src/main/scala/swaydb/core/segment/block/Block.scala b/core/src/main/scala/swaydb/core/segment/block/Block.scala
@@ -17,7 +17,6 @@
 package swaydb.core.segment.block
 
 import com.typesafe.scalalogging.LazyLogging
-import swaydb.IO
 import swaydb.compression.{CompressionInternal, DecompressorInternal}
 import swaydb.core.io.reader.Reader
 import swaydb.core.segment.block.reader.{BlockRefReader, BlockedReader, UnblockedReader}

diff --git a/core/src/main/scala/swaydb/core/segment/block/BlockOps.scala b/core/src/main/scala/swaydb/core/segment/block/BlockOps.scala
@@ -17,9 +17,11 @@
 package swaydb.core.segment.block
 
 private[core] trait BlockOps[O <: BlockOffset, B <: Block[O]] {
+
   def updateBlockOffset(block: B, start: Int, size: Int): B
 
   def createOffset(start: Int, size: Int): O
 
   def readBlock(header: BlockHeader[O]): B
+
 }
diff --git a/core/src/main/scala/swaydb/core/segment/block/reader/BlockReaderBase.scala b/core/src/main/scala/swaydb/core/segment/block/reader/BlockReaderBase.scala
@@ -17,7 +17,6 @@
 package swaydb.core.segment.block.reader
 
 import com.typesafe.scalalogging.LazyLogging
-import swaydb.IO
 import swaydb.core.segment.block.{BlockCache, BlockCacheSource, BlockOffset}
 import swaydb.data.slice.{Reader, ReaderBase, Slice, SliceOption}