实施我的 HbaseConnector

Question

我想实现一个 HbaseConnector。我实际上正在阅读 guide 但有一部分我不明白，我找不到任何相关信息。在指南的第 2 部分中，我们可以看到以下代码：

case class HBaseRecord(col0: String, col1: Boolean,col2: Double, col3: Float,col4: Int,       col5: Long, col6: Short, col7: String, col8: Byte)

object HBaseRecord {def apply(i: Int, t: String): HBaseRecord = { val s = s”””row${“%03d”.format(i)}”””       HBaseRecord(s, i % 2 == 0, i.toDouble, i.toFloat,  i, i.toLong, i.toShort,  s”String$i: $t”,      i.toByte) }}

val data = (0 to 255).map { i =>  HBaseRecord(i, “extra”)}

我知道他们将 future 列存储在 HbaseRecord 案例中 class 但我不明白这一行的具体用途 :

val s = s”””row${“%03d”.format(i)}”””

有人愿意解释一下吗？

Answer 1

它用于生成行 ID，例如 row001, row002 等，这些行 ID 将填充您的 table 的第 0 列。用 function

尝试更简单的方法

 def generate(i: Int): String = { s"""row${"%03d".format(i)}"""}

实施我的 HbaseConnector

Implementing my HbaseConnector

hbase

scala

dataframe

apache-spark