Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
- })
Add Comment
Please, Sign In to add comment