in storehaus-hbase/src/main/scala/com/twitter/storehaus/hbase/HBaseStore.scala [85:102]
def putValue[K, V](kv: (K, Option[V]))(
implicit keyInj: Injection[K, Array[Byte]],
valueInj: Injection[V, Array[Byte]]
): Future[Unit] = {
val tbl = pool.getTable(table)
kv match {
case (k, Some(v)) => futurePool {
val p = new Put(keyInj(k))
p.add(string2BytesInj(columnFamily), string2BytesInj(column), valueInj(v))
tbl.put(p)
} ensure tbl.close
case (k, None) => futurePool {
val delete = new Delete(keyInj(k))
tbl.delete(delete)
} ensure tbl.close
}
}