You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by bu...@apache.org on 2020/02/21 21:09:49 UTC
[hbase] branch branch-2 updated: HBASE-23854 replaced deprecated
code in Example Scala Code section
This is an automated email from the ASF dual-hosted git repository.
busbey pushed a commit to branch branch-2
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2 by this push:
new cb838bc HBASE-23854 replaced deprecated code in Example Scala Code section
cb838bc is described below
commit cb838bc301083ce5a4b774a13e9ab28694123e34
Author: Michael <mi...@gmx.de>
AuthorDate: Sun Feb 16 11:59:30 2020 +0100
HBASE-23854 replaced deprecated code in Example Scala Code section
Signed-off-by: Sean Busbey <bu...@apache.org>
(cherry picked from commit 400b7ce95496e30ccdc985ad4c32ac376317990f)
---
src/main/asciidoc/_chapters/external_apis.adoc | 24 +++++++++++-------------
1 file changed, 11 insertions(+), 13 deletions(-)
diff --git a/src/main/asciidoc/_chapters/external_apis.adoc b/src/main/asciidoc/_chapters/external_apis.adoc
index b7aebb4..129094e 100644
--- a/src/main/asciidoc/_chapters/external_apis.adoc
+++ b/src/main/asciidoc/_chapters/external_apis.adoc
@@ -934,35 +934,33 @@ libraryDependencies ++= Seq(
=== Example Scala Code
-This example lists HBase tables, creates a new table, and adds a row to it.
+This example lists HBase tables, creates a new table, adds a row to it, and gets the value of the row.
[source, scala]
----
-import org.apache.hadoop.hbase.HBaseConfiguration
-import org.apache.hadoop.hbase.client.{Connection,ConnectionFactory,HBaseAdmin,HTable,Put,Get}
+import org.apache.hadoop.hbase.{HBaseConfiguration, TableName}
+import org.apache.hadoop.hbase.client.{Admin, Connection, ConnectionFactory, Get, Put}
import org.apache.hadoop.hbase.util.Bytes
-
-val conf = new HBaseConfiguration()
+val conf = HBaseConfiguration.create()
val connection = ConnectionFactory.createConnection(conf);
val admin = connection.getAdmin();
// list the tables
-val listtables=admin.listTables()
+val listtables = admin.listTables()
listtables.foreach(println)
// let's insert some data in 'mytable' and get the row
+val table = connection.getTable(TableName.valueOf("mytable"))
-val table = new HTable(conf, "mytable")
-
-val theput= new Put(Bytes.toBytes("rowkey1"))
+val theput = new Put(Bytes.toBytes("rowkey1"))
-theput.add(Bytes.toBytes("ids"),Bytes.toBytes("id1"),Bytes.toBytes("one"))
+theput.addColumn(Bytes.toBytes("ids"),Bytes.toBytes("id1"),Bytes.toBytes("one"))
table.put(theput)
-val theget= new Get(Bytes.toBytes("rowkey1"))
-val result=table.get(theget)
-val value=result.value()
+val theget = new Get(Bytes.toBytes("rowkey1"))
+val result = table.get(theget)
+val value = result.value()
println(Bytes.toString(value))
----