Python 3 wrapper for Hbase REST
Project description
Hwrapper is python 3+ wrapper for hbase REST.
(pypi http://pypi.python.org/pypi/Hwrapper/0.1 )
Common Usage :
start your hbase rest $bin/hbase rest start -p 9300 (Default port is 8080)
check out wiki for more detailed tutorial.
Creating a table
----------------
hwrapper=Hwrapper()
hwrapper.connectionParameters("host","port", False) // third argument set to false if you are not using https
hwrapper.setAcceptType("json")
columnFamilies={"cf","cf1"}
hwrapper.create_table("table_name",columnFamilies)
get Row data by ID (decoded base64 values)
-------------------------------------------
hwrapper.get_RowBy_ID("0000000-120529115546748") // outputs list of dicts, dicts contain column names and values
Dropping a table
----------------
hwrapper.drop_table("table_name")
Displaying table schema
-----------------------
hwrapper.table_schema("table_name")
Listing all tables from hbase
-----------------------------
hwrapper.list_tables()
Scanner creation and deletion: (Filter by single column value)
--------------------------------------------------------------
hwrapper.get_RowBy_Column(columnvalue,"tablename")
jsonRows=json.loads(hwrapper.getNext())
while(jsonRows.get("status")!='204'):
jsonRows=json.loads(hwrapper.getNext())
if(jsonRows.get("status")=='204'):
break
print(jsonRows)
hwrapper.deleteScanner()
Deleting scanner
----------------------------
hwrapper.deleteScanner()
(pypi http://pypi.python.org/pypi/Hwrapper/0.1 )
Common Usage :
start your hbase rest $bin/hbase rest start -p 9300 (Default port is 8080)
check out wiki for more detailed tutorial.
Creating a table
----------------
hwrapper=Hwrapper()
hwrapper.connectionParameters("host","port", False) // third argument set to false if you are not using https
hwrapper.setAcceptType("json")
columnFamilies={"cf","cf1"}
hwrapper.create_table("table_name",columnFamilies)
get Row data by ID (decoded base64 values)
-------------------------------------------
hwrapper.get_RowBy_ID("0000000-120529115546748") // outputs list of dicts, dicts contain column names and values
Dropping a table
----------------
hwrapper.drop_table("table_name")
Displaying table schema
-----------------------
hwrapper.table_schema("table_name")
Listing all tables from hbase
-----------------------------
hwrapper.list_tables()
Scanner creation and deletion: (Filter by single column value)
--------------------------------------------------------------
hwrapper.get_RowBy_Column(columnvalue,"tablename")
jsonRows=json.loads(hwrapper.getNext())
while(jsonRows.get("status")!='204'):
jsonRows=json.loads(hwrapper.getNext())
if(jsonRows.get("status")=='204'):
break
print(jsonRows)
hwrapper.deleteScanner()
Deleting scanner
----------------------------
hwrapper.deleteScanner()