package Ġat . h ann esm oser . gle am . flow . other Ċ Ċ import Ġorg . apache . beam . sdk . transforms . Partition Ċ import Ġorg . apache . beam . sdk . transforms . window ing . Window Ċ import Ġorg . apache . beam . sdk . transforms . window ing . Window Fn Ċ import Ġorg . apache . beam . sdk . values . P Collection Ċ Ċ fun Ġ< T > ĠP Collection < T >. window ( ĊĠĠĠ Ġfn : ĠWindow Fn < in ĠT , Ġ* >, ĊĠĠĠ Ġconfigure : Ġ( window : ĠWindow < T >) Ġ-> ĠWindow < T > Ġ= Ġ{ Ġit Ġ} Ċ ): ĠP Collection < T > Ġ= Ġapply ( configure ( Window . into ( fn ))) Ċ Ċ fun Ġ< T > ĠP Collection < T >. partition ( num Partitions : ĠInt , Ġpartition Fn : ĠPartition . Partition Fn < T >) Ġ= Ġapply ( ĊĠĠĠ ĠPartition . of ( num Partitions , Ġpartition Fn ) Ċ ) Ċ