from hypertable.thriftclient import ThriftClient
# クライアントを作成しテーブルを開く
client = ThriftClient("localhost", 15867)
namespace = client.namespace_open("test")
table = client.hql_query("CREATE TABLE IF NOT EXISTS my_table (name, value)")
# データを挿入
client.hql_query("INSERT INTO my_table VALUES ('row1', 'name', 'Taro Yamada'), ('row1', 'value', '42')")
# データを取得
query = client.hql_query("SELECT * FROM my_table WHERE ROW='row1'")
for cell in query.cells:
print(f"Row: {cell.key.row}, Column: {cell.key.column_family}:{cell.key.column_qualifier}, Value: {cell.value}")