基于条件的多列总和

我想根据条件总结每行的列数。我找到了一种方法，但是当我有20多列要总结时似乎不是一个好主意，因为它会为每个列生成一个额外的列。

想要的结果是：以“_val”结尾的所有列的值总和，其中value为0或1（或<2，我只是想立即排除值3）

val df1 = Seq(
("id1", 1, 0, 3),
("id2", 0, 0, 3),
("id3", 1, 1, 3))
.toDF("id", "bla_val", "blub_val", "bli_val")
我希望的解决方案是列总和

val channelNames = df1.schema.fieldNames.filter(_.endsWith("_val"))
val ch = channelNames.map(x => col(x+"_redval"))

val df2 = df1.select(col("*") +: (channelNames.map(c =>
when(col(c) === 1, lit(1))

.otherwise(lit(0)).as(c+"_redval"))): _*) 

val df3 = df2.withColumn("sum", ch.reduce(_+_))
df3.show()
输出示例：