Permalink
Browse files

added in delete rows function

  • Loading branch information...
1 parent e710ff1 commit df2a6f5a27021fcef01cbad4221e5e705122cc78 Tristen Georgiou committed Feb 6, 2014
Showing with 3 additions and 0 deletions.
  1. +3 −0 pyaccumulo/__init__.py
@@ -210,4 +210,7 @@ def perform_scan(self, scanner, batchsize):
def create_batch_writer(self, table, max_memory=10*1024, latency_ms=30*1000, timeout_ms=5*1000, threads=10):
return BatchWriter(self, table, max_memory, latency_ms, timeout_ms, threads)
+
+ def delete_rows(self, table, srow, erow):
+ self.client.deleteRows(self.login, table, srow, erow)

0 comments on commit df2a6f5

Please sign in to comment.