Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
kellen committed Dec 20, 2023
1 parent 49d9adf commit b34a652
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ trait SideInput[T] extends Serializable {
/**
* Create a new [[SideInput]] by applying a function on the elements wrapped in this SideInput.
*/
@deprecated(since = "0.14.0")
def map[B](f: T => B): SideInput[B] = new DelegatingSideInput[T, B](this, f)

private[scio] val view: PCollectionView[_]
Expand Down Expand Up @@ -127,6 +128,7 @@ private[values] class MultiMapSideInput[K, V](val view: PCollectionView[JMap[K,
JMapWrapper.ofMultiMap(context.sideInput(view))
}

@deprecated(since = "0.14.0")
private[values] class DelegatingSideInput[A, B](val si: SideInput[A], val mapper: A => B)
extends SideInput[B] {

Expand Down

0 comments on commit b34a652

Please sign in to comment.