val dfResult: DataFrame = dataFame.select("vin", "collecttime", "isbf", "vehtype", "longitude", "latitude", "vecstatrdy", "vecoptmod", "vehspdavgdrvn", "batmaposrlysts", "vehodo", "ccsts", "batsoc", "tmactspd", "t2rtime") .filter(length(col("vin")).equalTo(17).and(col("collecttime").substr(0, 10).equalTo(targetDate)).and(!col("vin").equalTo("_")))
时间: 2023-02-09 11:36:52 浏览: 258
这是一段 Python 代码,它在进行一系列操作后返回一个新的 DataFrame。
具体来说,它首先使用 dataFrame 对象的 select 方法选择了几个列,然后使用 filter 方法对行进行过滤。过滤条件是:vin 列长度为 17,collecttime 列的前 10 位等于 targetDate 变量,且 vin 列不等于 "_"。
最后,它将结果赋值给变量 dfResult。
阅读全文