如何在sparksql的hive上下文对象中找到logged/connected/current用户?可以使用任何sql查询或unix命令。?我试过了!whoami;配置单元命令提示符中的命令。这是最佳解决方案吗我需要在sql查询中获取登录的用户,并希望使用sparksql将其插入表中
j5fpnvbx1#
在Pypark中,使用此sqlcontext.\u sc.sparkuser()或者sqlcontext.sql('选择当前用户()').show()
1条答案
按热度按时间j5fpnvbx1#
在Pypark中,使用此
sqlcontext.\u sc.sparkuser()
或者
sqlcontext.sql('选择当前用户()').show()