ScalingFactorFunc.scala

object ScalingFactorFunc extends MistFn {
  implicit val sfDailyOutMessageEnc = mist.api.encoding.generic.encoder[ScalingFactorDailyOutMessage]
  implicit val sfCommonConfigExt = mist.api.encoding.generic.extractor[CommonConfig]
  implicit val sfDailyInMessageExt = mist.api.encoding.generic.extractor[ScalingFactorDailyInMessage]
  implicit val sfConfigExt = mist.api.encoding.generic.extractor[ScalingFactorConfig]
  
  def handle: Handle = withArgs(
    arg[CommonConfig]("cfg"),
    arg[ScalingFactorDailyInMessage]("params"),
    arg[ScalingFactorConfig]("sfCfg")
   ).withMistExtras
    .onSparkSession(
      (cfg: CommonConfig, 
       params: ScalingFactorDailyInMessage, 
       sfCfg: ScalingFactorConfig, 
       extras: MistExtras, 
       sparkSession: SparkSession) => {
        val result: ScalingFactorDailyOutMessage = ???
        result
      })