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.MasterNotRunningException
org.apache.hadoop.hbase.ZooKeeperConnectionException
IOException
public org.apache.hadoop.hbase.client.HTable getTable(String tableName) throws IOException
IOException
public void tableCreate(String tableName, String[] familys) throws Exception
Exception
public void tableDelete(String tableName) throws Exception
Exception
public void put(String tableName, String rowKey, String family, String qualifier, String value) throws Exception
Exception
public void put(org.apache.hadoop.hbase.client.HTable table, String rowKey, String family, String qualifier, String value) throws Exception
Exception
public void put(org.apache.hadoop.hbase.client.HTable table, String rowKey, String family, List<KeyVal<String,Float>> keyvals) throws Exception
Exception
public void putAll(List<List<KeyVal<String,Float>>> rows, String tableName, String family) throws Exception
Exception
public void putAll(List<List<KeyVal<String,Float>>> rows, String tableName, String family, Progress progress) throws Exception
Exception
public void delete(String tableName, String rowKey) throws IOException
IOException
public void get(String tableName, String rowKey) throws IOException
IOException
public void scanPrint(String tableName)
Copyright © 2016. All rights reserved.