Skip to content

Instantly share code, notes, and snippets.

@blvp
Created May 16, 2018 11:31
Show Gist options
  • Select an option

  • Save blvp/c68ed7879e1822e52b4af212d17d1910 to your computer and use it in GitHub Desktop.

Select an option

Save blvp/c68ed7879e1822e52b4af212d17d1910 to your computer and use it in GitHub Desktop.
object VisitRateMist extends MistFn with Logging {
implicit val vmArgExt = mist.api.encoding.generic.extractor[VisitMetricsResultMessage]
implicit val vmMetricsEnc = mist.api.encoding.generic.encoder[VisitMetricsResultMessage]
override def handle: Handle = {
withArgs(arg[VisitRateArguments])
.withMistExtras
.onSparkSession((args: VisitRateArguments, extras: MistExtras, spark: SparkSession) => {
//computation
val result: VisitMetricsResultMessage = ???
result
})
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment