Explorar o código

HUE-1962 [hbase] Support int row key from Hive table

Romain Rigaux %!s(int64=11) %!d(string=hai) anos
pai
achega
f208e4ecbe
Modificáronse 1 ficheiros con 4 adicións e 0 borrados
  1. 4 0
      apps/hbase/src/hbase/api.py

+ 4 - 0
apps/hbase/src/hbase/api.py

@@ -161,6 +161,10 @@ class HbaseApi(object):
   def deleteColumn(self, cluster, tableName, row, column):
     return self.deleteColumns(cluster, tableName, smart_str(row), [smart_str(column)])
 
+  def deleteAllRow(self, cluster, tableName, row, attributes):
+    client = self.connectCluster(cluster)
+    return client.deleteAllRow(tableName, smart_str(row), attributes)
+
   def putRow(self, cluster, tableName, row, data):
     client = self.connectCluster(cluster)
     mutations = []