输入:
val input = List(1, 3, 6, 7, 12)
Run Code Online (Sandbox Code Playgroud)
输出将是:
val output = List((1, 3), (3, 6), (6, 7), (7, 12))
Run Code Online (Sandbox Code Playgroud) 我有一个使用 grpc 的 Spark 2 应用程序,以便客户端应用程序可以连接到它。
但是,我希望 grpc 代码仅在驱动程序节点上启动,而不是在工作节点上启动。
Spark 2 中是否有可能检查当前运行代码的节点是否是驱动程序节点?