Initial Pipeline Code in Scala