def putValue[K, V]()

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
    }
  }