使用Scala客户端
简介
由于Scala也是JVM语言,可以直接调用Java实现的gRPC客户端,因此使用Scala或者Spark调用ModelService服务也是比较简单。
使用示例
之前我们提供了 https://github.com/tobegit3hub/deep_recommend_system 的Java客户端例子,这里直接引入Java实现的客户端,然后实现Scala客户端。
object ScalaDensePredictClient {
def main(args: Array[String]): Unit = {
System.out.println("Start scala project")
var host: String = "127.0.0.1"
var port: Int = 9000
var modelName: String = "dense"
var modelVersion: Long = 1
// Create dense predict client
val client: DensePredictClient = new DensePredictClient(host, port)
// Run predict client to send request
client.predict_example(modelName, modelVersion)
System.out.println("End of predict client")
}
}