package Ġno . ve g ves en . saga . modules . beam Ċ Ċ import Ġorg . apache . beam . sdk . testing . P Assert Ċ import Ġorg . apache . beam . sdk . testing . Test Pipeline Ċ import Ġorg . apache . beam . sdk . values . KV Ċ import Ġorg . junit . jupiter . api . Test Ċ Ċ class ĠMin imal Word Count Test Ġ{ ĊĠĠĠ Ġprivate Ġval Ġpipeline : ĠTest Pipeline Ġ= ĠTest Pipeline ĊĠĠĠĠĠĠĠ Ġ. create () ĊĠĠĠĠĠĠĠ Ġ. enable Ab and oned Node En forcement ( false ) ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Spaces () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġres Ġ= Ġpipeline . from Elements ( listOf (" test 1 Ġtest 2 ", Ġ" Ġtest 3 Ġtest 2 ")). let Ġ{ Ġpipe Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ ĠMin imal Word Count . pipeline Steps ( pipe ) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ ĠP Assert . that ( res ). contains In Any Order ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠK V . of (" test 1 ", Ġ 1 ), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠK V . of (" test 2 ", Ġ 2 ), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠK V . of (" test 3 ", Ġ 1 ), ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ Ġpipeline . run () ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Test ĊĠĠĠ Ġfun Ġtest Com mas () Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġres Ġ= Ġpipeline . from Elements ( listOf (" test 1 , test 2 ", Ġ" Ġtest 3 , Ġtest 2 ")). let Ġ{ Ġpipe Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ ĠMin imal Word Count . pipeline Steps ( pipe ) ĊĠĠĠĠĠĠĠ Ġ} ĊĊĠĠĠĠĠĠĠ ĠP Assert . that ( res ). contains In Any Order ( ĊĠĠĠĠĠĠĠĠĠĠĠ ĠK V . of (" test 1 ", Ġ 1 ), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠK V . of (" test 2 ", Ġ 2 ), ĊĠĠĠĠĠĠĠĠĠĠĠ ĠK V . of (" test 3 ", Ġ 1 ), ĊĠĠĠĠĠĠĠ Ġ) ĊĊĠĠĠĠĠĠĠ Ġpipeline . run () ĊĠĠĠ Ġ} Ċ } Ċ