【发布时间】:2017-01-14 05:02:30
【问题描述】:
如果我有一组从 Hive 表中检索到的电子邮件,这些电子邮件在下面的 spark 代码中称为 users:
val sparkConf = new SparkConf().setAppName("YOUR_APP_NAME").setMaster("local[10]")
val sc = new SparkContext(sparkConf)
val sqlContext = new SQLContext(sc)
val hiveContext = new HiveContext(sc)
hiveContext.setConf("hive.metastore.uris", "METASTORE_URI_NAME_HERE")
val df = hiveContext.sql("SELECT email FROM USERS")
现在 df 包含一个数据框,其中包含所有电子邮件地址的一行。在 scala 中有没有一种方法可以验证电子邮件地址,例如:(https://pypi.python.org/pypi/validate_email) 除了这个是在 python 中我需要一个在 scala 中。或者 NLP 也会是一个很好的用例吗?
我不知道如何验证这些电子邮件地址,而且我需要的不仅仅是一些正则表达式。我需要一种方法来检查电子邮件地址的域是否有 SMTP 服务器。
类似这样的东西(除了在 scala 中):
is_valid = validate_email('example@example.com',check_smtp_connection = True)
【问题讨论】:
-
问题实际上是“如何在scala中验证电子邮件”,答案与“如何在java中验证电子邮件”相同
标签: scala apache-spark hive nlp