小编use*_*823的帖子

对包含点的列发出 sql 请求

我有一个数据框的列名包含“。” 我想过滤列以获取包含“.”的列名。然后对其进行选择。任何帮助将不胜感激。这是数据集

//dataset
    time.1,col.1,col.2,col.3
    2015-12-06 12:40:00,2,2,3
    2015-12-07 12:41:35,3,3,4

val spark = SparkSession.builder.master("local").appName("my-spark-app").getOrCreate()
    val df1 = spark.read.option("inferSchema", "true").option("header", "true").csv("C:/Users/mhattabi/Desktop/dataTestCsvFile/dataTest2.txt")
    val columnContainingdots=df1.schema.fieldNames.filter(p=>p.contains('.'))
    df1.select(columnContainingdots)
Run Code Online (Sandbox Code Playgroud)

scala apache-spark apache-spark-sql

-1
推荐指数
1
解决办法
535
查看次数

标签 统计

apache-spark ×1

apache-spark-sql ×1

scala ×1