public class HBaseIO extends Object
| Constructor and Description |
|---|
HBaseIO() |
| Modifier and Type | Method and Description |
|---|---|
void |
delete(String tableName,
String rowKey)
Delete a row
|
void |
get(String tableName,
String rowKey)
Get a row
|
org.apache.hadoop.hbase.client.HBaseAdmin |
getAdmin() |
String[] |
getColumnsInColumnFamily(org.apache.hadoop.hbase.client.Result r,
String ColumnFamily) |
org.apache.hadoop.hbase.client.HTable |
getTable(String tableName) |
void |
put(org.apache.hadoop.hbase.client.HTable table,
String rowKey,
String family,
List<KeyVal<String,Float>> keyvals) |
void |
put(org.apache.hadoop.hbase.client.HTable table,
String rowKey,
String family,
String qualifier,
String value) |
void |
put(String tableName,
String rowKey,
String family,
String qualifier,
String value)
Put (or insert) a row
|
void |
putAll(List<List<KeyVal<String,Float>>> rows,
String tableName,
String family) |
void |
putAll(List<List<KeyVal<String,Float>>> rows,
String tableName,
String family,
Progress progress) |
List<Float> |
scanColumn(String tableName,
String family,
String columnName) |
Set<String> |
scanColumnNames(String tableName,
String family) |
void |
scanPrint(String tableName)
Scan (or list) a table
|
List<List<KeyVal<String,Float>>> |
scanRows(String tableName) |
void |
scanRows(String tableName,
List<List<KeyVal<String,Float>>> rows) |
void |
tableCreate(String tableName,
String[] familys)
Create a table
|
void |
tableDelete(String tableName)
Delete a table
|
public org.apache.hadoop.hbase.client.HBaseAdmin getAdmin()
throws org.apache.hadoop.hbase.MasterNotRunningException,
org.apache.hadoop.hbase.ZooKeeperConnectionException,
IOException
org.apache.hadoop.hbase.MasterNotRunningExceptionorg.apache.hadoop.hbase.ZooKeeperConnectionExceptionIOExceptionpublic org.apache.hadoop.hbase.client.HTable getTable(String tableName) throws IOException
IOExceptionpublic void tableCreate(String tableName, String[] familys) throws Exception
Exceptionpublic void tableDelete(String tableName) throws Exception
Exceptionpublic void put(String tableName, String rowKey, String family, String qualifier, String value) throws Exception
Exceptionpublic void put(org.apache.hadoop.hbase.client.HTable table,
String rowKey,
String family,
String qualifier,
String value)
throws Exception
Exceptionpublic void put(org.apache.hadoop.hbase.client.HTable table,
String rowKey,
String family,
List<KeyVal<String,Float>> keyvals)
throws Exception
Exceptionpublic void putAll(List<List<KeyVal<String,Float>>> rows, String tableName, String family) throws Exception
Exceptionpublic void putAll(List<List<KeyVal<String,Float>>> rows, String tableName, String family, Progress progress) throws Exception
Exceptionpublic void delete(String tableName, String rowKey) throws IOException
IOExceptionpublic void get(String tableName, String rowKey) throws IOException
IOExceptionpublic void scanPrint(String tableName)
Copyright © 2016. All rights reserved.