星火扇贝isin

Question

我有一个包含ArrayByte的。我可以使用isin来将数据与Array[Byte]进行匹配吗？如果我尝试像这样使用它：

clientIp.isin((whitelist:_*))

它不匹配，因为whitelist:_*没有正确地将字节数组格式化为IN(...)。知道怎么解决这个问题吗？

Answer 1

您可以将Array[Byte]转换为Java String，如果您的白名单List<String>，则可以将其与isin(whitelist:_*)匹配。

根据文档，isin方法接受java.lang.object或Seq(java.lang.object)。

https://spark.apache.org/docs/1.6.0/api/java/org/apache/spark/sql/Column.html#isin(scala.collection.Seq)

Answer 2

根据scala文档，isin方法期望变量而不是SeqString。在这种情况下，如果将数据转换为SeqString，则可以执行以下操作：

df.filter(column_name.isin(seqOfString: _*))