wip

spotify · Dec 20, 2023 · 072ef46 · 072ef46
1 parent 9ed2c64
commit 072ef46
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/scio-core/src/main/scala/com/spotify/scio/values/SideInput.scala b/scio-core/src/main/scala/com/spotify/scio/values/SideInput.scala
@@ -130,7 +130,7 @@ private[values] class MultiMapSideInput[K, V](val view: PCollectionView[JMap[K,
 
 @deprecated(since = "0.14.0")
 private[values] class DelegatingSideInput[A, B](val si: SideInput[A], val mapper: A => B)
-  extends SideInput[B] {
+    extends SideInput[B] {
 
   // Only update the cached value (and re-run the mapper) if the underlying SI does the same.
   override protected[values] def updateCacheOnGlobalWindow: Boolean = si.updateCacheOnGlobalWindow

diff --git a/scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/SparkeyIO.scala b/scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/SparkeyIO.scala
@@ -29,10 +29,10 @@ case class SparkeyIOOutput[K, V](path: String) extends TestIO[(K, V)] {
 object SparkeyIO {
   private val logger = LoggerFactory.getLogger(this.getClass)
 
-  private[sparkey] val DefaultNumShards: Short = 1
-  private[sparkey] val DefaultSideInputNumShards: Short = 64
-  private[sparkey] val DefaultCompressionType: CompressionType = CompressionType.NONE
-  private[sparkey] val DefaultCompressionBlockSize: Int = 0
+  val DefaultNumShards: Short = 1
+  val DefaultSideInputNumShards: Short = 64
+  val DefaultCompressionType: CompressionType = CompressionType.NONE
+  val DefaultCompressionBlockSize: Int = 0
 
   def output[K, V](path: String): SparkeyIOOutput[K, V] = SparkeyIOOutput[K, V](path)