Hbase-remote 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388
  1. #!/usr/bin/env python
  2. #
  3. # Autogenerated by Thrift Compiler (0.9.3)
  4. #
  5. # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  6. #
  7. # options string: py:new_style
  8. #
  9. import sys
  10. import pprint
  11. from urlparse import urlparse
  12. from thrift.transport import TTransport
  13. from thrift.transport import TSocket
  14. from thrift.transport import TSSLSocket
  15. from thrift.transport import THttpClient
  16. from thrift.protocol import TBinaryProtocol
  17. from hbased import Hbase
  18. from hbased.ttypes import *
  19. if len(sys.argv) <= 1 or sys.argv[1] == '--help':
  20. print('')
  21. print('Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] [-s[sl]] function [arg1 [arg2...]]')
  22. print('')
  23. print('Functions:')
  24. print(' void enableTable(Bytes tableName)')
  25. print(' void disableTable(Bytes tableName)')
  26. print(' bool isTableEnabled(Bytes tableName)')
  27. print(' void compact(Bytes tableNameOrRegionName)')
  28. print(' void majorCompact(Bytes tableNameOrRegionName)')
  29. print(' getTableNames()')
  30. print(' getColumnDescriptors(Text tableName)')
  31. print(' getTableRegions(Text tableName)')
  32. print(' void createTable(Text tableName, columnFamilies)')
  33. print(' void deleteTable(Text tableName)')
  34. print(' get(Text tableName, Text row, Text column, attributes)')
  35. print(' getVer(Text tableName, Text row, Text column, i32 numVersions, attributes)')
  36. print(' getVerTs(Text tableName, Text row, Text column, i64 timestamp, i32 numVersions, attributes)')
  37. print(' getRow(Text tableName, Text row, attributes)')
  38. print(' getRowWithColumns(Text tableName, Text row, columns, attributes)')
  39. print(' getRowTs(Text tableName, Text row, i64 timestamp, attributes)')
  40. print(' getRowWithColumnsTs(Text tableName, Text row, columns, i64 timestamp, attributes)')
  41. print(' getRows(Text tableName, rows, attributes)')
  42. print(' getRowsWithColumns(Text tableName, rows, columns, attributes)')
  43. print(' getRowsTs(Text tableName, rows, i64 timestamp, attributes)')
  44. print(' getRowsWithColumnsTs(Text tableName, rows, columns, i64 timestamp, attributes)')
  45. print(' void mutateRow(Text tableName, Text row, mutations, attributes)')
  46. print(' void mutateRowTs(Text tableName, Text row, mutations, i64 timestamp, attributes)')
  47. print(' void mutateRows(Text tableName, rowBatches, attributes)')
  48. print(' void mutateRowsTs(Text tableName, rowBatches, i64 timestamp, attributes)')
  49. print(' i64 atomicIncrement(Text tableName, Text row, Text column, i64 value)')
  50. print(' void deleteAll(Text tableName, Text row, Text column, attributes)')
  51. print(' void deleteAllTs(Text tableName, Text row, Text column, i64 timestamp, attributes)')
  52. print(' void deleteAllRow(Text tableName, Text row, attributes)')
  53. print(' void increment(TIncrement increment)')
  54. print(' void incrementRows( increments)')
  55. print(' void deleteAllRowTs(Text tableName, Text row, i64 timestamp, attributes)')
  56. print(' ScannerID scannerOpenWithScan(Text tableName, TScan scan, attributes)')
  57. print(' ScannerID scannerOpen(Text tableName, Text startRow, columns, attributes)')
  58. print(' ScannerID scannerOpenWithStop(Text tableName, Text startRow, Text stopRow, columns, attributes)')
  59. print(' ScannerID scannerOpenWithPrefix(Text tableName, Text startAndPrefix, columns, attributes)')
  60. print(' ScannerID scannerOpenTs(Text tableName, Text startRow, columns, i64 timestamp, attributes)')
  61. print(' ScannerID scannerOpenWithStopTs(Text tableName, Text startRow, Text stopRow, columns, i64 timestamp, attributes)')
  62. print(' scannerGet(ScannerID id)')
  63. print(' scannerGetList(ScannerID id, i32 nbRows)')
  64. print(' void scannerClose(ScannerID id)')
  65. print(' getRowOrBefore(Text tableName, Text row, Text family)')
  66. print(' TRegionInfo getRegionInfo(Text row)')
  67. print('')
  68. sys.exit(0)
  69. pp = pprint.PrettyPrinter(indent = 2)
  70. host = 'localhost'
  71. port = 9090
  72. uri = ''
  73. framed = False
  74. ssl = False
  75. http = False
  76. argi = 1
  77. if sys.argv[argi] == '-h':
  78. parts = sys.argv[argi+1].split(':')
  79. host = parts[0]
  80. if len(parts) > 1:
  81. port = int(parts[1])
  82. argi += 2
  83. if sys.argv[argi] == '-u':
  84. url = urlparse(sys.argv[argi+1])
  85. parts = url[1].split(':')
  86. host = parts[0]
  87. if len(parts) > 1:
  88. port = int(parts[1])
  89. else:
  90. port = 80
  91. uri = url[2]
  92. if url[4]:
  93. uri += '?%s' % url[4]
  94. http = True
  95. argi += 2
  96. if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed':
  97. framed = True
  98. argi += 1
  99. if sys.argv[argi] == '-s' or sys.argv[argi] == '-ssl':
  100. ssl = True
  101. argi += 1
  102. cmd = sys.argv[argi]
  103. args = sys.argv[argi+1:]
  104. if http:
  105. transport = THttpClient.THttpClient(host, port, uri)
  106. else:
  107. socket = TSSLSocket.TSSLSocket(host, port, validate=False) if ssl else TSocket.TSocket(host, port)
  108. if framed:
  109. transport = TTransport.TFramedTransport(socket)
  110. else:
  111. transport = TTransport.TBufferedTransport(socket)
  112. protocol = TBinaryProtocol.TBinaryProtocol(transport)
  113. client = Hbase.Client(protocol)
  114. transport.open()
  115. if cmd == 'enableTable':
  116. if len(args) != 1:
  117. print('enableTable requires 1 args')
  118. sys.exit(1)
  119. pp.pprint(client.enableTable(eval(args[0]),))
  120. elif cmd == 'disableTable':
  121. if len(args) != 1:
  122. print('disableTable requires 1 args')
  123. sys.exit(1)
  124. pp.pprint(client.disableTable(eval(args[0]),))
  125. elif cmd == 'isTableEnabled':
  126. if len(args) != 1:
  127. print('isTableEnabled requires 1 args')
  128. sys.exit(1)
  129. pp.pprint(client.isTableEnabled(eval(args[0]),))
  130. elif cmd == 'compact':
  131. if len(args) != 1:
  132. print('compact requires 1 args')
  133. sys.exit(1)
  134. pp.pprint(client.compact(eval(args[0]),))
  135. elif cmd == 'majorCompact':
  136. if len(args) != 1:
  137. print('majorCompact requires 1 args')
  138. sys.exit(1)
  139. pp.pprint(client.majorCompact(eval(args[0]),))
  140. elif cmd == 'getTableNames':
  141. if len(args) != 0:
  142. print('getTableNames requires 0 args')
  143. sys.exit(1)
  144. pp.pprint(client.getTableNames())
  145. elif cmd == 'getColumnDescriptors':
  146. if len(args) != 1:
  147. print('getColumnDescriptors requires 1 args')
  148. sys.exit(1)
  149. pp.pprint(client.getColumnDescriptors(eval(args[0]),))
  150. elif cmd == 'getTableRegions':
  151. if len(args) != 1:
  152. print('getTableRegions requires 1 args')
  153. sys.exit(1)
  154. pp.pprint(client.getTableRegions(eval(args[0]),))
  155. elif cmd == 'createTable':
  156. if len(args) != 2:
  157. print('createTable requires 2 args')
  158. sys.exit(1)
  159. pp.pprint(client.createTable(eval(args[0]),eval(args[1]),))
  160. elif cmd == 'deleteTable':
  161. if len(args) != 1:
  162. print('deleteTable requires 1 args')
  163. sys.exit(1)
  164. pp.pprint(client.deleteTable(eval(args[0]),))
  165. elif cmd == 'get':
  166. if len(args) != 4:
  167. print('get requires 4 args')
  168. sys.exit(1)
  169. pp.pprint(client.get(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  170. elif cmd == 'getVer':
  171. if len(args) != 5:
  172. print('getVer requires 5 args')
  173. sys.exit(1)
  174. pp.pprint(client.getVer(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  175. elif cmd == 'getVerTs':
  176. if len(args) != 6:
  177. print('getVerTs requires 6 args')
  178. sys.exit(1)
  179. pp.pprint(client.getVerTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),eval(args[5]),))
  180. elif cmd == 'getRow':
  181. if len(args) != 3:
  182. print('getRow requires 3 args')
  183. sys.exit(1)
  184. pp.pprint(client.getRow(eval(args[0]),eval(args[1]),eval(args[2]),))
  185. elif cmd == 'getRowWithColumns':
  186. if len(args) != 4:
  187. print('getRowWithColumns requires 4 args')
  188. sys.exit(1)
  189. pp.pprint(client.getRowWithColumns(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  190. elif cmd == 'getRowTs':
  191. if len(args) != 4:
  192. print('getRowTs requires 4 args')
  193. sys.exit(1)
  194. pp.pprint(client.getRowTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  195. elif cmd == 'getRowWithColumnsTs':
  196. if len(args) != 5:
  197. print('getRowWithColumnsTs requires 5 args')
  198. sys.exit(1)
  199. pp.pprint(client.getRowWithColumnsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  200. elif cmd == 'getRows':
  201. if len(args) != 3:
  202. print('getRows requires 3 args')
  203. sys.exit(1)
  204. pp.pprint(client.getRows(eval(args[0]),eval(args[1]),eval(args[2]),))
  205. elif cmd == 'getRowsWithColumns':
  206. if len(args) != 4:
  207. print('getRowsWithColumns requires 4 args')
  208. sys.exit(1)
  209. pp.pprint(client.getRowsWithColumns(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  210. elif cmd == 'getRowsTs':
  211. if len(args) != 4:
  212. print('getRowsTs requires 4 args')
  213. sys.exit(1)
  214. pp.pprint(client.getRowsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  215. elif cmd == 'getRowsWithColumnsTs':
  216. if len(args) != 5:
  217. print('getRowsWithColumnsTs requires 5 args')
  218. sys.exit(1)
  219. pp.pprint(client.getRowsWithColumnsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  220. elif cmd == 'mutateRow':
  221. if len(args) != 4:
  222. print('mutateRow requires 4 args')
  223. sys.exit(1)
  224. pp.pprint(client.mutateRow(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  225. elif cmd == 'mutateRowTs':
  226. if len(args) != 5:
  227. print('mutateRowTs requires 5 args')
  228. sys.exit(1)
  229. pp.pprint(client.mutateRowTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  230. elif cmd == 'mutateRows':
  231. if len(args) != 3:
  232. print('mutateRows requires 3 args')
  233. sys.exit(1)
  234. pp.pprint(client.mutateRows(eval(args[0]),eval(args[1]),eval(args[2]),))
  235. elif cmd == 'mutateRowsTs':
  236. if len(args) != 4:
  237. print('mutateRowsTs requires 4 args')
  238. sys.exit(1)
  239. pp.pprint(client.mutateRowsTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  240. elif cmd == 'atomicIncrement':
  241. if len(args) != 4:
  242. print('atomicIncrement requires 4 args')
  243. sys.exit(1)
  244. pp.pprint(client.atomicIncrement(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  245. elif cmd == 'deleteAll':
  246. if len(args) != 4:
  247. print('deleteAll requires 4 args')
  248. sys.exit(1)
  249. pp.pprint(client.deleteAll(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  250. elif cmd == 'deleteAllTs':
  251. if len(args) != 5:
  252. print('deleteAllTs requires 5 args')
  253. sys.exit(1)
  254. pp.pprint(client.deleteAllTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  255. elif cmd == 'deleteAllRow':
  256. if len(args) != 3:
  257. print('deleteAllRow requires 3 args')
  258. sys.exit(1)
  259. pp.pprint(client.deleteAllRow(eval(args[0]),eval(args[1]),eval(args[2]),))
  260. elif cmd == 'increment':
  261. if len(args) != 1:
  262. print('increment requires 1 args')
  263. sys.exit(1)
  264. pp.pprint(client.increment(eval(args[0]),))
  265. elif cmd == 'incrementRows':
  266. if len(args) != 1:
  267. print('incrementRows requires 1 args')
  268. sys.exit(1)
  269. pp.pprint(client.incrementRows(eval(args[0]),))
  270. elif cmd == 'deleteAllRowTs':
  271. if len(args) != 4:
  272. print('deleteAllRowTs requires 4 args')
  273. sys.exit(1)
  274. pp.pprint(client.deleteAllRowTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  275. elif cmd == 'scannerOpenWithScan':
  276. if len(args) != 3:
  277. print('scannerOpenWithScan requires 3 args')
  278. sys.exit(1)
  279. pp.pprint(client.scannerOpenWithScan(eval(args[0]),eval(args[1]),eval(args[2]),))
  280. elif cmd == 'scannerOpen':
  281. if len(args) != 4:
  282. print('scannerOpen requires 4 args')
  283. sys.exit(1)
  284. pp.pprint(client.scannerOpen(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  285. elif cmd == 'scannerOpenWithStop':
  286. if len(args) != 5:
  287. print('scannerOpenWithStop requires 5 args')
  288. sys.exit(1)
  289. pp.pprint(client.scannerOpenWithStop(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  290. elif cmd == 'scannerOpenWithPrefix':
  291. if len(args) != 4:
  292. print('scannerOpenWithPrefix requires 4 args')
  293. sys.exit(1)
  294. pp.pprint(client.scannerOpenWithPrefix(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),))
  295. elif cmd == 'scannerOpenTs':
  296. if len(args) != 5:
  297. print('scannerOpenTs requires 5 args')
  298. sys.exit(1)
  299. pp.pprint(client.scannerOpenTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),))
  300. elif cmd == 'scannerOpenWithStopTs':
  301. if len(args) != 6:
  302. print('scannerOpenWithStopTs requires 6 args')
  303. sys.exit(1)
  304. pp.pprint(client.scannerOpenWithStopTs(eval(args[0]),eval(args[1]),eval(args[2]),eval(args[3]),eval(args[4]),eval(args[5]),))
  305. elif cmd == 'scannerGet':
  306. if len(args) != 1:
  307. print('scannerGet requires 1 args')
  308. sys.exit(1)
  309. pp.pprint(client.scannerGet(eval(args[0]),))
  310. elif cmd == 'scannerGetList':
  311. if len(args) != 2:
  312. print('scannerGetList requires 2 args')
  313. sys.exit(1)
  314. pp.pprint(client.scannerGetList(eval(args[0]),eval(args[1]),))
  315. elif cmd == 'scannerClose':
  316. if len(args) != 1:
  317. print('scannerClose requires 1 args')
  318. sys.exit(1)
  319. pp.pprint(client.scannerClose(eval(args[0]),))
  320. elif cmd == 'getRowOrBefore':
  321. if len(args) != 3:
  322. print('getRowOrBefore requires 3 args')
  323. sys.exit(1)
  324. pp.pprint(client.getRowOrBefore(eval(args[0]),eval(args[1]),eval(args[2]),))
  325. elif cmd == 'getRegionInfo':
  326. if len(args) != 1:
  327. print('getRegionInfo requires 1 args')
  328. sys.exit(1)
  329. pp.pprint(client.getRegionInfo(eval(args[0]),))
  330. else:
  331. print('Unrecognized method %s' % cmd)
  332. sys.exit(1)
  333. transport.close()