Revert "replaced deprecated code in Example Scala Code section"
This reverts commit 4381b18b87
.
This commit is contained in:
parent
4381b18b87
commit
0b2eb3594b
|
@ -934,33 +934,35 @@ libraryDependencies ++= Seq(
|
||||||
|
|
||||||
=== Example Scala Code
|
=== Example Scala Code
|
||||||
|
|
||||||
This example lists HBase tables, creates a new table, adds a row to it, and gets the value of the row.
|
This example lists HBase tables, creates a new table, and adds a row to it.
|
||||||
|
|
||||||
[source, scala]
|
[source, scala]
|
||||||
----
|
----
|
||||||
import org.apache.hadoop.hbase.{HBaseConfiguration, TableName}
|
import org.apache.hadoop.hbase.HBaseConfiguration
|
||||||
import org.apache.hadoop.hbase.client.{Admin, Connection, ConnectionFactory, Get, Put}
|
import org.apache.hadoop.hbase.client.{Connection,ConnectionFactory,HBaseAdmin,HTable,Put,Get}
|
||||||
import org.apache.hadoop.hbase.util.Bytes
|
import org.apache.hadoop.hbase.util.Bytes
|
||||||
|
|
||||||
val conf = HBaseConfiguration.create()
|
|
||||||
|
val conf = new HBaseConfiguration()
|
||||||
val connection = ConnectionFactory.createConnection(conf);
|
val connection = ConnectionFactory.createConnection(conf);
|
||||||
val admin = connection.getAdmin();
|
val admin = connection.getAdmin();
|
||||||
|
|
||||||
// list the tables
|
// list the tables
|
||||||
val listtables = admin.listTables()
|
val listtables=admin.listTables()
|
||||||
listtables.foreach(println)
|
listtables.foreach(println)
|
||||||
|
|
||||||
// let's insert some data in 'mytable' and get the row
|
// let's insert some data in 'mytable' and get the row
|
||||||
val table = connection.getTable(TableName.valueOf("mytable"))
|
|
||||||
|
|
||||||
val theput = new Put(Bytes.toBytes("rowkey1"))
|
val table = new HTable(conf, "mytable")
|
||||||
|
|
||||||
theput.addColumn(Bytes.toBytes("ids"),Bytes.toBytes("id1"),Bytes.toBytes("one"))
|
val theput= new Put(Bytes.toBytes("rowkey1"))
|
||||||
|
|
||||||
|
theput.add(Bytes.toBytes("ids"),Bytes.toBytes("id1"),Bytes.toBytes("one"))
|
||||||
table.put(theput)
|
table.put(theput)
|
||||||
|
|
||||||
val theget = new Get(Bytes.toBytes("rowkey1"))
|
val theget= new Get(Bytes.toBytes("rowkey1"))
|
||||||
val result = table.get(theget)
|
val result=table.get(theget)
|
||||||
val value = result.value()
|
val value=result.value()
|
||||||
println(Bytes.toString(value))
|
println(Bytes.toString(value))
|
||||||
----
|
----
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue