使用Scala客户端

简介

由于Scala也是JVM语言,可以直接调用Java实现的gRPC客户端,因此使用Scala或者Spark调用ModelService服务也是比较简单。

使用示例

之前我们提供了 https://github.com/tobegit3hub/deep_recommend_system 的Java客户端例子,这里直接引入Java实现的客户端,然后实现Scala客户端。

  1. object ScalaDensePredictClient {
  2. def main(args: Array[String]): Unit = {
  3. System.out.println("Start scala project")
  4. var host: String = "127.0.0.1"
  5. var port: Int = 9000
  6. var modelName: String = "dense"
  7. var modelVersion: Long = 1
  8. // Create dense predict client
  9. val client: DensePredictClient = new DensePredictClient(host, port)
  10. // Run predict client to send request
  11. client.predict_example(modelName, modelVersion)
  12. System.out.println("End of predict client")
  13. }
  14. }

原文: http://docs.api.xiaomi.com/cloud-ml/modelservice/0904_use_scala_client.html