Guest User

Untitled

a guest
May 21st, 2018
82
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.84 KB | None | 0 0
  1. object ScalingFactorFunc extends MistFn {
  2. implicit val sfDailyOutMessageEnc = mist.api.encoding.generic.encoder[ScalingFactorDailyOutMessage]
  3. implicit val sfCommonConfigExt = mist.api.encoding.generic.extractor[CommonConfig]
  4. implicit val sfDailyInMessageExt = mist.api.encoding.generic.extractor[ScalingFactorDailyInMessage]
  5. implicit val sfConfigExt = mist.api.encoding.generic.extractor[ScalingFactorConfig]
  6.  
  7. def handle: Handle = withArgs(
  8. arg[CommonConfig]("cfg"),
  9. arg[ScalingFactorDailyInMessage]("params"),
  10. arg[ScalingFactorConfig]("sfCfg")
  11. ).withMistExtras
  12. .onSparkSession(
  13. (cfg: CommonConfig,
  14. params: ScalingFactorDailyInMessage,
  15. sfCfg: ScalingFactorConfig,
  16. extras: MistExtras,
  17. sparkSession: SparkSession) => {
  18. val result: ScalingFactorDailyOutMessage = ???
  19. result
  20. })
Add Comment
Please, Sign In to add comment