我正在处理将SQL代码转换为PySpark代码,并遇到了一些SQL语句。我不知道如何在pyspark中使用case语句?我计划创建一个RDD,然后使用rdd.map,然后做一些逻辑检查。基本上,我需要遍历RDD或DF中的每一行,并且基于某些逻辑,我需要编辑其中一个列值。 when (e."a" Like 'a%
我想使用redis来检查用户是否对网站上的某些地方有权限。
该网站允许用户创建功能有限的组。本质上有两种类型的用户(可能更多)-管理员和读者。一个用户可以参加不同的组(10-15组)。First idea -为每个用户创建redis散列,并包括他们是管理员的组和他们是读者的组。然后,我可以通过在注销时删除记录,并在登录和更改时设置权限来控制这些权限。此外,散列也可能过期。第二个想法