val res = three.filter(_.trim().length > 0).map(num => (num.trim.toInt, "")).partitionBy(new HashPartitioner(1)).sortByKey().map(t => { idx += 1 (idx, t._1) }).collect.foreach(x => println(x._1 + "%t" + x._2))的报错原因
时间: 2023-06-17 11:03:14 浏览: 81
关于tf.nn.dynamic_rnn返回值详解
这段代码有语法错误,应该是使用了不兼容的字符串插值符号。正确的写法应该是:
```scala
val res = three.filter(_.trim().length > 0)
.map(num => (num.trim.toInt, ""))
.partitionBy(new HashPartitioner(1))
.sortByKey()
.map(t => {
idx += 1
(idx, t._1)
})
.collect
.foreach(x => println(s"${x._1}\t${x._2}"))
```
在上述代码中,我使用了 `$` 符号来引用变量,而不是 `%t`。此外,我还使用了字符串插值符号 `s` 来插入变量,这样的写法更加简洁易读。
阅读全文