我有一个包含 Array[Byte] 的 Spark Dataframe。我可以使用 isin 将数据与我的 Array[Byte] 进行匹配吗？如果我尝试像这样使用它:
clientIp.isin((whitelist:_*))
它不匹配，因为whitelist:_* 未将字节数组正确格式化为IN(...)。知道如何解决这个问题吗？
最佳答案
您可以转换Array[Byte]到 Java String ，那么你可以将其与 isin(whitelist:_*) 相匹配如果您的白名单List<String>
根据文档，isin方法接受 java.lang.object 或 Seq(java.lang.object)
关于scala - Spark scala Dataframe isin，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40378510/