val col : DataFrame = hiveContext.sql("show columns in dbname.table_name")
val arry = col.collectAsList().toArray
def regexpReplace(x: AnyRef): String =
return "select regexp_replace(" + x + ",[^0-9a-zA-Z]," + "' ') from dbname.tbl_name"
for( col <- arry)
{
val res = regexpReplace(col.toString.substring(1,x.toString.length-1))
sqlContext.sql(res)
}
2条答案
按热度按时间0yycz8jy1#
whhtz7ly2#
使用regexp\u替换。下面是hive regexp\u replace函数的语法。
regexp_replace(string INITIAL_STRING, string PATTERN, string REPLACEMENT);