josep2

case class Player(firstName: String, lastName: String, ppg: Double, apg: Double, rpg: Double)

val jf = Player.tupled("Jimmer", "Fredette", 1.1, 0.1, 0.2)

print(jf)
// Player(Jimmer,Fredette,1.1,0.1,0.2)

josep2

  case class Player(firstName: String, lastName: String, ppg: Double, apg: Double, rpg: Double)

  val jf = Player.curried("Jimmer")("Fredette")(1.1)(0.1)(0.2)

  print(jf)
  
  // Player(Jimmer,Fredette,1.1,0.1,0.2)

josep2

case class Player(firstName: String, lastName: String, ppg: Double, apg: Double, rpg: Double)

josep2

#!/usr/bin/env scala

import com.jowanza.ExecutePipeline
import spray.json._
import spray.json.DefaultJsonProtocol._

object JowanzaMain {

  def main(args: Array[String]): Unit = {

josep2

package com.jowanza

import ml.combust.mleap.runtime.frame.DefaultLeapFrame
import ml.combust.mleap.runtime.frame.ArrayRow
import ml.combust.bundle.BundleFile
import ml.combust.mleap.runtime.MleapSupport._
import resource._
import spray.json._
import ml.combust.mleap.core.types._

josep2

name := "mleap-spark-action"

version := "1.0"

scalaVersion := "2.11.6"

assemblyJarName := "mleap.jar"

resolvers += "Typesafe Repository" at "http://repo.typesafe.com/typesafe/releases/"

josep2

# Dockerfile for example whisk docker action
FROM openwhisk/dockerskeleton 

# Set Port for Flask Server

ENV FLASK_PROXY_PORT 8080

# Install Java 8
RUN apk add openjdk8

josep2

def convertSeq(data: Vector[JsValue]): Seq[Any] = {
    val g = Seq(data.head.convertTo[String],
      data(1).convertTo[Double],data(2).convertTo[Double],
      data(3).convertTo[Double],data(4).convertTo[Double],data(5).convertTo[Double]
      ,data(6).convertTo[Double],data(7).convertTo[Double],
      data(8).convertTo[Double],data(9).convertTo[String],data(10).convertTo[String],
      data(11).convertTo[String],data(12).convertTo[String])
    g
}

josep2

[
	{
		"paramValue": "?",
		"dataType": "STRING",
		"columnName": "endpoint",
		"field": "/endpoint",
		"defaultValue": ""
	},
	{
		"paramValue": "?",

josep2

import org.apache.spark.sql.SparkSession
import org.apache.spark.storage.StorageLevel

case class Panel(user_id: String, date_joined: String, zip_shipping: String, date_newest_receipt: String,
                 date_oldest_receipt: String, prop_30d_syncable: String, date_last_sync: String, isp: String,
                 syncable: Int)

object Demo extends App {

 import sparkSession.implicits._