http://git-wip-us.apache.org/repos/asf/hbase/blob/1bfe3879/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java ---------------------------------------------------------------------- diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java index f2a5845..e37471a 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java @@ -42,9 +42,9 @@ public class THBaseService { * * @param table the table to check on * - * @param get the TGet to check for + * @param tget the TGet to check for */ - public boolean exists(ByteBuffer table, TGet get) throws TIOError, org.apache.thrift.TException; + public boolean exists(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException; /** * Method for getting data from a row. @@ -56,9 +56,9 @@ public class THBaseService { * * @param table the table to get from * - * @param get the TGet to fetch + * @param tget the TGet to fetch */ - public TResult get(ByteBuffer table, TGet get) throws TIOError, org.apache.thrift.TException; + public TResult get(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException; /** * Method for getting multiple rows. @@ -71,20 +71,20 @@ public class THBaseService { * * @param table the table to get from * - * @param gets a list of TGets to fetch, the Result list + * @param tgets a list of TGets to fetch, the Result list * will have the Results at corresponding positions * or null if there was an error */ - public List<TResult> getMultiple(ByteBuffer table, List<TGet> gets) throws TIOError, org.apache.thrift.TException; + public List<TResult> getMultiple(ByteBuffer table, List<TGet> tgets) throws TIOError, org.apache.thrift.TException; /** * Commit a TPut to a table. * * @param table the table to put data in * - * @param put the TPut to put + * @param tput the TPut to put */ - public void put(ByteBuffer table, TPut put) throws TIOError, org.apache.thrift.TException; + public void put(ByteBuffer table, TPut tput) throws TIOError, org.apache.thrift.TException; /** * Atomically checks if a row/family/qualifier value matches the expected @@ -104,18 +104,18 @@ public class THBaseService { * check is for the non-existence of the * column in question * - * @param put the TPut to put if the check succeeds + * @param tput the TPut to put if the check succeeds */ - public boolean checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut put) throws TIOError, org.apache.thrift.TException; + public boolean checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput) throws TIOError, org.apache.thrift.TException; /** * Commit a List of Puts to the table. * * @param table the table to put data in * - * @param puts a list of TPuts to commit + * @param tputs a list of TPuts to commit */ - public void putMultiple(ByteBuffer table, List<TPut> puts) throws TIOError, org.apache.thrift.TException; + public void putMultiple(ByteBuffer table, List<TPut> tputs) throws TIOError, org.apache.thrift.TException; /** * Deletes as specified by the TDelete. @@ -125,9 +125,9 @@ public class THBaseService { * * @param table the table to delete from * - * @param deleteSingle the TDelete to delete + * @param tdelete the TDelete to delete */ - public void deleteSingle(ByteBuffer table, TDelete deleteSingle) throws TIOError, org.apache.thrift.TException; + public void deleteSingle(ByteBuffer table, TDelete tdelete) throws TIOError, org.apache.thrift.TException; /** * Bulk commit a List of TDeletes to the table. @@ -138,9 +138,9 @@ public class THBaseService { * * @param table the table to delete from * - * @param deletes list of TDeletes to delete + * @param tdeletes list of TDeletes to delete */ - public List<TDelete> deleteMultiple(ByteBuffer table, List<TDelete> deletes) throws TIOError, org.apache.thrift.TException; + public List<TDelete> deleteMultiple(ByteBuffer table, List<TDelete> tdeletes) throws TIOError, org.apache.thrift.TException; /** * Atomically checks if a row/family/qualifier value matches the expected @@ -160,13 +160,13 @@ public class THBaseService { * check is for the non-existence of the * column in question * - * @param deleteSingle the TDelete to execute if the check succeeds + * @param tdelete the TDelete to execute if the check succeeds */ - public boolean checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete deleteSingle) throws TIOError, org.apache.thrift.TException; + public boolean checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete) throws TIOError, org.apache.thrift.TException; - public TResult increment(ByteBuffer table, TIncrement increment) throws TIOError, org.apache.thrift.TException; + public TResult increment(ByteBuffer table, TIncrement tincrement) throws TIOError, org.apache.thrift.TException; - public TResult append(ByteBuffer table, TAppend append) throws TIOError, org.apache.thrift.TException; + public TResult append(ByteBuffer table, TAppend tappend) throws TIOError, org.apache.thrift.TException; /** * Get a Scanner for the provided TScan object. @@ -175,9 +175,9 @@ public class THBaseService { * * @param table the table to get the Scanner for * - * @param scan the scan object to get a Scanner for + * @param tscan the scan object to get a Scanner for */ - public int openScanner(ByteBuffer table, TScan scan) throws TIOError, org.apache.thrift.TException; + public int openScanner(ByteBuffer table, TScan tscan) throws TIOError, org.apache.thrift.TException; /** * Grabs multiple rows from a Scanner. @@ -204,9 +204,9 @@ public class THBaseService { * * @param table table to apply the mutations * - * @param rowMutations mutations to apply + * @param trowMutations mutations to apply */ - public void mutateRow(ByteBuffer table, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException; + public void mutateRow(ByteBuffer table, TRowMutations trowMutations) throws TIOError, org.apache.thrift.TException; /** * Get results for the provided TScan object. @@ -216,47 +216,72 @@ public class THBaseService { * * @param table the table to get the Scanner for * - * @param scan the scan object to get a Scanner for + * @param tscan the scan object to get a Scanner for * * @param numRows number of rows to return */ - public List<TResult> getScannerResults(ByteBuffer table, TScan scan, int numRows) throws TIOError, org.apache.thrift.TException; + public List<TResult> getScannerResults(ByteBuffer table, TScan tscan, int numRows) throws TIOError, org.apache.thrift.TException; + + /** + * Given a table and a row get the location of the region that + * would contain the given row key. + * + * reload = true means the cache will be cleared and the location + * will be fetched from meta. + * + * @param table + * @param row + * @param reload + */ + public THRegionLocation getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload) throws TIOError, org.apache.thrift.TException; + + /** + * Get all of the region locations for a given table. + * + * + * @param table + */ + public List<THRegionLocation> getAllRegionLocations(ByteBuffer table) throws TIOError, org.apache.thrift.TException; } public interface AsyncIface { - public void exists(ByteBuffer table, TGet get, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.exists_call> resultHandler) throws org.apache.thrift.TException; + public void exists(ByteBuffer table, TGet tget, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.exists_call> resultHandler) throws org.apache.thrift.TException; - public void get(ByteBuffer table, TGet get, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws org.apache.thrift.TException; + public void get(ByteBuffer table, TGet tget, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.get_call> resultHandler) throws org.apache.thrift.TException; - public void getMultiple(ByteBuffer table, List<TGet> gets, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getMultiple_call> resultHandler) throws org.apache.thrift.TException; + public void getMultiple(ByteBuffer table, List<TGet> tgets, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getMultiple_call> resultHandler) throws org.apache.thrift.TException; - public void put(ByteBuffer table, TPut put, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.put_call> resultHandler) throws org.apache.thrift.TException; + public void put(ByteBuffer table, TPut tput, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.put_call> resultHandler) throws org.apache.thrift.TException; - public void checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut put, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndPut_call> resultHandler) throws org.apache.thrift.TException; + public void checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndPut_call> resultHandler) throws org.apache.thrift.TException; - public void putMultiple(ByteBuffer table, List<TPut> puts, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.putMultiple_call> resultHandler) throws org.apache.thrift.TException; + public void putMultiple(ByteBuffer table, List<TPut> tputs, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.putMultiple_call> resultHandler) throws org.apache.thrift.TException; - public void deleteSingle(ByteBuffer table, TDelete deleteSingle, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteSingle_call> resultHandler) throws org.apache.thrift.TException; + public void deleteSingle(ByteBuffer table, TDelete tdelete, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteSingle_call> resultHandler) throws org.apache.thrift.TException; - public void deleteMultiple(ByteBuffer table, List<TDelete> deletes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteMultiple_call> resultHandler) throws org.apache.thrift.TException; + public void deleteMultiple(ByteBuffer table, List<TDelete> tdeletes, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteMultiple_call> resultHandler) throws org.apache.thrift.TException; - public void checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete deleteSingle, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndDelete_call> resultHandler) throws org.apache.thrift.TException; + public void checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.checkAndDelete_call> resultHandler) throws org.apache.thrift.TException; - public void increment(ByteBuffer table, TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.increment_call> resultHandler) throws org.apache.thrift.TException; + public void increment(ByteBuffer table, TIncrement tincrement, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.increment_call> resultHandler) throws org.apache.thrift.TException; - public void append(ByteBuffer table, TAppend append, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.append_call> resultHandler) throws org.apache.thrift.TException; + public void append(ByteBuffer table, TAppend tappend, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.append_call> resultHandler) throws org.apache.thrift.TException; - public void openScanner(ByteBuffer table, TScan scan, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openScanner_call> resultHandler) throws org.apache.thrift.TException; + public void openScanner(ByteBuffer table, TScan tscan, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.openScanner_call> resultHandler) throws org.apache.thrift.TException; public void getScannerRows(int scannerId, int numRows, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getScannerRows_call> resultHandler) throws org.apache.thrift.TException; public void closeScanner(int scannerId, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.closeScanner_call> resultHandler) throws org.apache.thrift.TException; - public void mutateRow(ByteBuffer table, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRow_call> resultHandler) throws org.apache.thrift.TException; + public void mutateRow(ByteBuffer table, TRowMutations trowMutations, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.mutateRow_call> resultHandler) throws org.apache.thrift.TException; + + public void getScannerResults(ByteBuffer table, TScan tscan, int numRows, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getScannerResults_call> resultHandler) throws org.apache.thrift.TException; + + public void getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getRegionLocation_call> resultHandler) throws org.apache.thrift.TException; - public void getScannerResults(ByteBuffer table, TScan scan, int numRows, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getScannerResults_call> resultHandler) throws org.apache.thrift.TException; + public void getAllRegionLocations(ByteBuffer table, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getAllRegionLocations_call> resultHandler) throws org.apache.thrift.TException; } @@ -280,17 +305,17 @@ public class THBaseService { super(iprot, oprot); } - public boolean exists(ByteBuffer table, TGet get) throws TIOError, org.apache.thrift.TException + public boolean exists(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException { - send_exists(table, get); + send_exists(table, tget); return recv_exists(); } - public void send_exists(ByteBuffer table, TGet get) throws org.apache.thrift.TException + public void send_exists(ByteBuffer table, TGet tget) throws org.apache.thrift.TException { exists_args args = new exists_args(); args.setTable(table); - args.setGet(get); + args.setTget(tget); sendBase("exists", args); } @@ -307,17 +332,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "exists failed: unknown result"); } - public TResult get(ByteBuffer table, TGet get) throws TIOError, org.apache.thrift.TException + public TResult get(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException { - send_get(table, get); + send_get(table, tget); return recv_get(); } - public void send_get(ByteBuffer table, TGet get) throws org.apache.thrift.TException + public void send_get(ByteBuffer table, TGet tget) throws org.apache.thrift.TException { get_args args = new get_args(); args.setTable(table); - args.setGet(get); + args.setTget(tget); sendBase("get", args); } @@ -334,17 +359,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "get failed: unknown result"); } - public List<TResult> getMultiple(ByteBuffer table, List<TGet> gets) throws TIOError, org.apache.thrift.TException + public List<TResult> getMultiple(ByteBuffer table, List<TGet> tgets) throws TIOError, org.apache.thrift.TException { - send_getMultiple(table, gets); + send_getMultiple(table, tgets); return recv_getMultiple(); } - public void send_getMultiple(ByteBuffer table, List<TGet> gets) throws org.apache.thrift.TException + public void send_getMultiple(ByteBuffer table, List<TGet> tgets) throws org.apache.thrift.TException { getMultiple_args args = new getMultiple_args(); args.setTable(table); - args.setGets(gets); + args.setTgets(tgets); sendBase("getMultiple", args); } @@ -361,17 +386,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getMultiple failed: unknown result"); } - public void put(ByteBuffer table, TPut put) throws TIOError, org.apache.thrift.TException + public void put(ByteBuffer table, TPut tput) throws TIOError, org.apache.thrift.TException { - send_put(table, put); + send_put(table, tput); recv_put(); } - public void send_put(ByteBuffer table, TPut put) throws org.apache.thrift.TException + public void send_put(ByteBuffer table, TPut tput) throws org.apache.thrift.TException { put_args args = new put_args(); args.setTable(table); - args.setPut(put); + args.setTput(tput); sendBase("put", args); } @@ -385,13 +410,13 @@ public class THBaseService { return; } - public boolean checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut put) throws TIOError, org.apache.thrift.TException + public boolean checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput) throws TIOError, org.apache.thrift.TException { - send_checkAndPut(table, row, family, qualifier, value, put); + send_checkAndPut(table, row, family, qualifier, value, tput); return recv_checkAndPut(); } - public void send_checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut put) throws org.apache.thrift.TException + public void send_checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput) throws org.apache.thrift.TException { checkAndPut_args args = new checkAndPut_args(); args.setTable(table); @@ -399,7 +424,7 @@ public class THBaseService { args.setFamily(family); args.setQualifier(qualifier); args.setValue(value); - args.setPut(put); + args.setTput(tput); sendBase("checkAndPut", args); } @@ -416,17 +441,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "checkAndPut failed: unknown result"); } - public void putMultiple(ByteBuffer table, List<TPut> puts) throws TIOError, org.apache.thrift.TException + public void putMultiple(ByteBuffer table, List<TPut> tputs) throws TIOError, org.apache.thrift.TException { - send_putMultiple(table, puts); + send_putMultiple(table, tputs); recv_putMultiple(); } - public void send_putMultiple(ByteBuffer table, List<TPut> puts) throws org.apache.thrift.TException + public void send_putMultiple(ByteBuffer table, List<TPut> tputs) throws org.apache.thrift.TException { putMultiple_args args = new putMultiple_args(); args.setTable(table); - args.setPuts(puts); + args.setTputs(tputs); sendBase("putMultiple", args); } @@ -440,17 +465,17 @@ public class THBaseService { return; } - public void deleteSingle(ByteBuffer table, TDelete deleteSingle) throws TIOError, org.apache.thrift.TException + public void deleteSingle(ByteBuffer table, TDelete tdelete) throws TIOError, org.apache.thrift.TException { - send_deleteSingle(table, deleteSingle); + send_deleteSingle(table, tdelete); recv_deleteSingle(); } - public void send_deleteSingle(ByteBuffer table, TDelete deleteSingle) throws org.apache.thrift.TException + public void send_deleteSingle(ByteBuffer table, TDelete tdelete) throws org.apache.thrift.TException { deleteSingle_args args = new deleteSingle_args(); args.setTable(table); - args.setDeleteSingle(deleteSingle); + args.setTdelete(tdelete); sendBase("deleteSingle", args); } @@ -464,17 +489,17 @@ public class THBaseService { return; } - public List<TDelete> deleteMultiple(ByteBuffer table, List<TDelete> deletes) throws TIOError, org.apache.thrift.TException + public List<TDelete> deleteMultiple(ByteBuffer table, List<TDelete> tdeletes) throws TIOError, org.apache.thrift.TException { - send_deleteMultiple(table, deletes); + send_deleteMultiple(table, tdeletes); return recv_deleteMultiple(); } - public void send_deleteMultiple(ByteBuffer table, List<TDelete> deletes) throws org.apache.thrift.TException + public void send_deleteMultiple(ByteBuffer table, List<TDelete> tdeletes) throws org.apache.thrift.TException { deleteMultiple_args args = new deleteMultiple_args(); args.setTable(table); - args.setDeletes(deletes); + args.setTdeletes(tdeletes); sendBase("deleteMultiple", args); } @@ -491,13 +516,13 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteMultiple failed: unknown result"); } - public boolean checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete deleteSingle) throws TIOError, org.apache.thrift.TException + public boolean checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete) throws TIOError, org.apache.thrift.TException { - send_checkAndDelete(table, row, family, qualifier, value, deleteSingle); + send_checkAndDelete(table, row, family, qualifier, value, tdelete); return recv_checkAndDelete(); } - public void send_checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete deleteSingle) throws org.apache.thrift.TException + public void send_checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete) throws org.apache.thrift.TException { checkAndDelete_args args = new checkAndDelete_args(); args.setTable(table); @@ -505,7 +530,7 @@ public class THBaseService { args.setFamily(family); args.setQualifier(qualifier); args.setValue(value); - args.setDeleteSingle(deleteSingle); + args.setTdelete(tdelete); sendBase("checkAndDelete", args); } @@ -522,17 +547,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "checkAndDelete failed: unknown result"); } - public TResult increment(ByteBuffer table, TIncrement increment) throws TIOError, org.apache.thrift.TException + public TResult increment(ByteBuffer table, TIncrement tincrement) throws TIOError, org.apache.thrift.TException { - send_increment(table, increment); + send_increment(table, tincrement); return recv_increment(); } - public void send_increment(ByteBuffer table, TIncrement increment) throws org.apache.thrift.TException + public void send_increment(ByteBuffer table, TIncrement tincrement) throws org.apache.thrift.TException { increment_args args = new increment_args(); args.setTable(table); - args.setIncrement(increment); + args.setTincrement(tincrement); sendBase("increment", args); } @@ -549,17 +574,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "increment failed: unknown result"); } - public TResult append(ByteBuffer table, TAppend append) throws TIOError, org.apache.thrift.TException + public TResult append(ByteBuffer table, TAppend tappend) throws TIOError, org.apache.thrift.TException { - send_append(table, append); + send_append(table, tappend); return recv_append(); } - public void send_append(ByteBuffer table, TAppend append) throws org.apache.thrift.TException + public void send_append(ByteBuffer table, TAppend tappend) throws org.apache.thrift.TException { append_args args = new append_args(); args.setTable(table); - args.setAppend(append); + args.setTappend(tappend); sendBase("append", args); } @@ -576,17 +601,17 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "append failed: unknown result"); } - public int openScanner(ByteBuffer table, TScan scan) throws TIOError, org.apache.thrift.TException + public int openScanner(ByteBuffer table, TScan tscan) throws TIOError, org.apache.thrift.TException { - send_openScanner(table, scan); + send_openScanner(table, tscan); return recv_openScanner(); } - public void send_openScanner(ByteBuffer table, TScan scan) throws org.apache.thrift.TException + public void send_openScanner(ByteBuffer table, TScan tscan) throws org.apache.thrift.TException { openScanner_args args = new openScanner_args(); args.setTable(table); - args.setScan(scan); + args.setTscan(tscan); sendBase("openScanner", args); } @@ -659,17 +684,17 @@ public class THBaseService { return; } - public void mutateRow(ByteBuffer table, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException + public void mutateRow(ByteBuffer table, TRowMutations trowMutations) throws TIOError, org.apache.thrift.TException { - send_mutateRow(table, rowMutations); + send_mutateRow(table, trowMutations); recv_mutateRow(); } - public void send_mutateRow(ByteBuffer table, TRowMutations rowMutations) throws org.apache.thrift.TException + public void send_mutateRow(ByteBuffer table, TRowMutations trowMutations) throws org.apache.thrift.TException { mutateRow_args args = new mutateRow_args(); args.setTable(table); - args.setRowMutations(rowMutations); + args.setTrowMutations(trowMutations); sendBase("mutateRow", args); } @@ -683,17 +708,17 @@ public class THBaseService { return; } - public List<TResult> getScannerResults(ByteBuffer table, TScan scan, int numRows) throws TIOError, org.apache.thrift.TException + public List<TResult> getScannerResults(ByteBuffer table, TScan tscan, int numRows) throws TIOError, org.apache.thrift.TException { - send_getScannerResults(table, scan, numRows); + send_getScannerResults(table, tscan, numRows); return recv_getScannerResults(); } - public void send_getScannerResults(ByteBuffer table, TScan scan, int numRows) throws org.apache.thrift.TException + public void send_getScannerResults(ByteBuffer table, TScan tscan, int numRows) throws org.apache.thrift.TException { getScannerResults_args args = new getScannerResults_args(); args.setTable(table); - args.setScan(scan); + args.setTscan(tscan); args.setNumRows(numRows); sendBase("getScannerResults", args); } @@ -711,6 +736,60 @@ public class THBaseService { throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getScannerResults failed: unknown result"); } + public THRegionLocation getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload) throws TIOError, org.apache.thrift.TException + { + send_getRegionLocation(table, row, reload); + return recv_getRegionLocation(); + } + + public void send_getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload) throws org.apache.thrift.TException + { + getRegionLocation_args args = new getRegionLocation_args(); + args.setTable(table); + args.setRow(row); + args.setReload(reload); + sendBase("getRegionLocation", args); + } + + public THRegionLocation recv_getRegionLocation() throws TIOError, org.apache.thrift.TException + { + getRegionLocation_result result = new getRegionLocation_result(); + receiveBase(result, "getRegionLocation"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getRegionLocation failed: unknown result"); + } + + public List<THRegionLocation> getAllRegionLocations(ByteBuffer table) throws TIOError, org.apache.thrift.TException + { + send_getAllRegionLocations(table); + return recv_getAllRegionLocations(); + } + + public void send_getAllRegionLocations(ByteBuffer table) throws org.apache.thrift.TException + { + getAllRegionLocations_args args = new getAllRegionLocations_args(); + args.setTable(table); + sendBase("getAllRegionLocations", args); + } + + public List<THRegionLocation> recv_getAllRegionLocations() throws TIOError, org.apache.thrift.TException + { + getAllRegionLocations_result result = new getAllRegionLocations_result(); + receiveBase(result, "getAllRegionLocations"); + if (result.isSetSuccess()) { + return result.success; + } + if (result.io != null) { + throw result.io; + } + throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllRegionLocations failed: unknown result"); + } + } public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { @@ -729,27 +808,27 @@ public class THBaseService { super(protocolFactory, clientManager, transport); } - public void exists(ByteBuffer table, TGet get, org.apache.thrift.async.AsyncMethodCallback<exists_call> resultHandler) throws org.apache.thrift.TException { + public void exists(ByteBuffer table, TGet tget, org.apache.thrift.async.AsyncMethodCallback<exists_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - exists_call method_call = new exists_call(table, get, resultHandler, this, ___protocolFactory, ___transport); + exists_call method_call = new exists_call(table, tget, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class exists_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TGet get; - public exists_call(ByteBuffer table, TGet get, org.apache.thrift.async.AsyncMethodCallback<exists_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TGet tget; + public exists_call(ByteBuffer table, TGet tget, org.apache.thrift.async.AsyncMethodCallback<exists_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.get = get; + this.tget = tget; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("exists", org.apache.thrift.protocol.TMessageType.CALL, 0)); exists_args args = new exists_args(); args.setTable(table); - args.setGet(get); + args.setTget(tget); args.write(prot); prot.writeMessageEnd(); } @@ -764,27 +843,27 @@ public class THBaseService { } } - public void get(ByteBuffer table, TGet get, org.apache.thrift.async.AsyncMethodCallback<get_call> resultHandler) throws org.apache.thrift.TException { + public void get(ByteBuffer table, TGet tget, org.apache.thrift.async.AsyncMethodCallback<get_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - get_call method_call = new get_call(table, get, resultHandler, this, ___protocolFactory, ___transport); + get_call method_call = new get_call(table, tget, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class get_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TGet get; - public get_call(ByteBuffer table, TGet get, org.apache.thrift.async.AsyncMethodCallback<get_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TGet tget; + public get_call(ByteBuffer table, TGet tget, org.apache.thrift.async.AsyncMethodCallback<get_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.get = get; + this.tget = tget; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("get", org.apache.thrift.protocol.TMessageType.CALL, 0)); get_args args = new get_args(); args.setTable(table); - args.setGet(get); + args.setTget(tget); args.write(prot); prot.writeMessageEnd(); } @@ -799,27 +878,27 @@ public class THBaseService { } } - public void getMultiple(ByteBuffer table, List<TGet> gets, org.apache.thrift.async.AsyncMethodCallback<getMultiple_call> resultHandler) throws org.apache.thrift.TException { + public void getMultiple(ByteBuffer table, List<TGet> tgets, org.apache.thrift.async.AsyncMethodCallback<getMultiple_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - getMultiple_call method_call = new getMultiple_call(table, gets, resultHandler, this, ___protocolFactory, ___transport); + getMultiple_call method_call = new getMultiple_call(table, tgets, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class getMultiple_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private List<TGet> gets; - public getMultiple_call(ByteBuffer table, List<TGet> gets, org.apache.thrift.async.AsyncMethodCallback<getMultiple_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private List<TGet> tgets; + public getMultiple_call(ByteBuffer table, List<TGet> tgets, org.apache.thrift.async.AsyncMethodCallback<getMultiple_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.gets = gets; + this.tgets = tgets; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getMultiple", org.apache.thrift.protocol.TMessageType.CALL, 0)); getMultiple_args args = new getMultiple_args(); args.setTable(table); - args.setGets(gets); + args.setTgets(tgets); args.write(prot); prot.writeMessageEnd(); } @@ -834,27 +913,27 @@ public class THBaseService { } } - public void put(ByteBuffer table, TPut put, org.apache.thrift.async.AsyncMethodCallback<put_call> resultHandler) throws org.apache.thrift.TException { + public void put(ByteBuffer table, TPut tput, org.apache.thrift.async.AsyncMethodCallback<put_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - put_call method_call = new put_call(table, put, resultHandler, this, ___protocolFactory, ___transport); + put_call method_call = new put_call(table, tput, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class put_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TPut put; - public put_call(ByteBuffer table, TPut put, org.apache.thrift.async.AsyncMethodCallback<put_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TPut tput; + public put_call(ByteBuffer table, TPut tput, org.apache.thrift.async.AsyncMethodCallback<put_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.put = put; + this.tput = tput; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("put", org.apache.thrift.protocol.TMessageType.CALL, 0)); put_args args = new put_args(); args.setTable(table); - args.setPut(put); + args.setTput(tput); args.write(prot); prot.writeMessageEnd(); } @@ -869,9 +948,9 @@ public class THBaseService { } } - public void checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut put, org.apache.thrift.async.AsyncMethodCallback<checkAndPut_call> resultHandler) throws org.apache.thrift.TException { + public void checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput, org.apache.thrift.async.AsyncMethodCallback<checkAndPut_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - checkAndPut_call method_call = new checkAndPut_call(table, row, family, qualifier, value, put, resultHandler, this, ___protocolFactory, ___transport); + checkAndPut_call method_call = new checkAndPut_call(table, row, family, qualifier, value, tput, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -882,15 +961,15 @@ public class THBaseService { private ByteBuffer family; private ByteBuffer qualifier; private ByteBuffer value; - private TPut put; - public checkAndPut_call(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut put, org.apache.thrift.async.AsyncMethodCallback<checkAndPut_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TPut tput; + public checkAndPut_call(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput, org.apache.thrift.async.AsyncMethodCallback<checkAndPut_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; this.row = row; this.family = family; this.qualifier = qualifier; this.value = value; - this.put = put; + this.tput = tput; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { @@ -901,7 +980,7 @@ public class THBaseService { args.setFamily(family); args.setQualifier(qualifier); args.setValue(value); - args.setPut(put); + args.setTput(tput); args.write(prot); prot.writeMessageEnd(); } @@ -916,27 +995,27 @@ public class THBaseService { } } - public void putMultiple(ByteBuffer table, List<TPut> puts, org.apache.thrift.async.AsyncMethodCallback<putMultiple_call> resultHandler) throws org.apache.thrift.TException { + public void putMultiple(ByteBuffer table, List<TPut> tputs, org.apache.thrift.async.AsyncMethodCallback<putMultiple_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - putMultiple_call method_call = new putMultiple_call(table, puts, resultHandler, this, ___protocolFactory, ___transport); + putMultiple_call method_call = new putMultiple_call(table, tputs, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class putMultiple_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private List<TPut> puts; - public putMultiple_call(ByteBuffer table, List<TPut> puts, org.apache.thrift.async.AsyncMethodCallback<putMultiple_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private List<TPut> tputs; + public putMultiple_call(ByteBuffer table, List<TPut> tputs, org.apache.thrift.async.AsyncMethodCallback<putMultiple_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.puts = puts; + this.tputs = tputs; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("putMultiple", org.apache.thrift.protocol.TMessageType.CALL, 0)); putMultiple_args args = new putMultiple_args(); args.setTable(table); - args.setPuts(puts); + args.setTputs(tputs); args.write(prot); prot.writeMessageEnd(); } @@ -951,27 +1030,27 @@ public class THBaseService { } } - public void deleteSingle(ByteBuffer table, TDelete deleteSingle, org.apache.thrift.async.AsyncMethodCallback<deleteSingle_call> resultHandler) throws org.apache.thrift.TException { + public void deleteSingle(ByteBuffer table, TDelete tdelete, org.apache.thrift.async.AsyncMethodCallback<deleteSingle_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - deleteSingle_call method_call = new deleteSingle_call(table, deleteSingle, resultHandler, this, ___protocolFactory, ___transport); + deleteSingle_call method_call = new deleteSingle_call(table, tdelete, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class deleteSingle_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TDelete deleteSingle; - public deleteSingle_call(ByteBuffer table, TDelete deleteSingle, org.apache.thrift.async.AsyncMethodCallback<deleteSingle_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TDelete tdelete; + public deleteSingle_call(ByteBuffer table, TDelete tdelete, org.apache.thrift.async.AsyncMethodCallback<deleteSingle_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.deleteSingle = deleteSingle; + this.tdelete = tdelete; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteSingle", org.apache.thrift.protocol.TMessageType.CALL, 0)); deleteSingle_args args = new deleteSingle_args(); args.setTable(table); - args.setDeleteSingle(deleteSingle); + args.setTdelete(tdelete); args.write(prot); prot.writeMessageEnd(); } @@ -986,27 +1065,27 @@ public class THBaseService { } } - public void deleteMultiple(ByteBuffer table, List<TDelete> deletes, org.apache.thrift.async.AsyncMethodCallback<deleteMultiple_call> resultHandler) throws org.apache.thrift.TException { + public void deleteMultiple(ByteBuffer table, List<TDelete> tdeletes, org.apache.thrift.async.AsyncMethodCallback<deleteMultiple_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - deleteMultiple_call method_call = new deleteMultiple_call(table, deletes, resultHandler, this, ___protocolFactory, ___transport); + deleteMultiple_call method_call = new deleteMultiple_call(table, tdeletes, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class deleteMultiple_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private List<TDelete> deletes; - public deleteMultiple_call(ByteBuffer table, List<TDelete> deletes, org.apache.thrift.async.AsyncMethodCallback<deleteMultiple_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private List<TDelete> tdeletes; + public deleteMultiple_call(ByteBuffer table, List<TDelete> tdeletes, org.apache.thrift.async.AsyncMethodCallback<deleteMultiple_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.deletes = deletes; + this.tdeletes = tdeletes; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("deleteMultiple", org.apache.thrift.protocol.TMessageType.CALL, 0)); deleteMultiple_args args = new deleteMultiple_args(); args.setTable(table); - args.setDeletes(deletes); + args.setTdeletes(tdeletes); args.write(prot); prot.writeMessageEnd(); } @@ -1021,9 +1100,9 @@ public class THBaseService { } } - public void checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete deleteSingle, org.apache.thrift.async.AsyncMethodCallback<checkAndDelete_call> resultHandler) throws org.apache.thrift.TException { + public void checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete, org.apache.thrift.async.AsyncMethodCallback<checkAndDelete_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - checkAndDelete_call method_call = new checkAndDelete_call(table, row, family, qualifier, value, deleteSingle, resultHandler, this, ___protocolFactory, ___transport); + checkAndDelete_call method_call = new checkAndDelete_call(table, row, family, qualifier, value, tdelete, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } @@ -1034,15 +1113,15 @@ public class THBaseService { private ByteBuffer family; private ByteBuffer qualifier; private ByteBuffer value; - private TDelete deleteSingle; - public checkAndDelete_call(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete deleteSingle, org.apache.thrift.async.AsyncMethodCallback<checkAndDelete_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TDelete tdelete; + public checkAndDelete_call(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete, org.apache.thrift.async.AsyncMethodCallback<checkAndDelete_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; this.row = row; this.family = family; this.qualifier = qualifier; this.value = value; - this.deleteSingle = deleteSingle; + this.tdelete = tdelete; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { @@ -1053,7 +1132,7 @@ public class THBaseService { args.setFamily(family); args.setQualifier(qualifier); args.setValue(value); - args.setDeleteSingle(deleteSingle); + args.setTdelete(tdelete); args.write(prot); prot.writeMessageEnd(); } @@ -1068,27 +1147,27 @@ public class THBaseService { } } - public void increment(ByteBuffer table, TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<increment_call> resultHandler) throws org.apache.thrift.TException { + public void increment(ByteBuffer table, TIncrement tincrement, org.apache.thrift.async.AsyncMethodCallback<increment_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - increment_call method_call = new increment_call(table, increment, resultHandler, this, ___protocolFactory, ___transport); + increment_call method_call = new increment_call(table, tincrement, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class increment_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TIncrement increment; - public increment_call(ByteBuffer table, TIncrement increment, org.apache.thrift.async.AsyncMethodCallback<increment_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TIncrement tincrement; + public increment_call(ByteBuffer table, TIncrement tincrement, org.apache.thrift.async.AsyncMethodCallback<increment_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.increment = increment; + this.tincrement = tincrement; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("increment", org.apache.thrift.protocol.TMessageType.CALL, 0)); increment_args args = new increment_args(); args.setTable(table); - args.setIncrement(increment); + args.setTincrement(tincrement); args.write(prot); prot.writeMessageEnd(); } @@ -1103,27 +1182,27 @@ public class THBaseService { } } - public void append(ByteBuffer table, TAppend append, org.apache.thrift.async.AsyncMethodCallback<append_call> resultHandler) throws org.apache.thrift.TException { + public void append(ByteBuffer table, TAppend tappend, org.apache.thrift.async.AsyncMethodCallback<append_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - append_call method_call = new append_call(table, append, resultHandler, this, ___protocolFactory, ___transport); + append_call method_call = new append_call(table, tappend, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class append_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TAppend append; - public append_call(ByteBuffer table, TAppend append, org.apache.thrift.async.AsyncMethodCallback<append_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TAppend tappend; + public append_call(ByteBuffer table, TAppend tappend, org.apache.thrift.async.AsyncMethodCallback<append_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.append = append; + this.tappend = tappend; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("append", org.apache.thrift.protocol.TMessageType.CALL, 0)); append_args args = new append_args(); args.setTable(table); - args.setAppend(append); + args.setTappend(tappend); args.write(prot); prot.writeMessageEnd(); } @@ -1138,27 +1217,27 @@ public class THBaseService { } } - public void openScanner(ByteBuffer table, TScan scan, org.apache.thrift.async.AsyncMethodCallback<openScanner_call> resultHandler) throws org.apache.thrift.TException { + public void openScanner(ByteBuffer table, TScan tscan, org.apache.thrift.async.AsyncMethodCallback<openScanner_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - openScanner_call method_call = new openScanner_call(table, scan, resultHandler, this, ___protocolFactory, ___transport); + openScanner_call method_call = new openScanner_call(table, tscan, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class openScanner_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TScan scan; - public openScanner_call(ByteBuffer table, TScan scan, org.apache.thrift.async.AsyncMethodCallback<openScanner_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TScan tscan; + public openScanner_call(ByteBuffer table, TScan tscan, org.apache.thrift.async.AsyncMethodCallback<openScanner_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.scan = scan; + this.tscan = tscan; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("openScanner", org.apache.thrift.protocol.TMessageType.CALL, 0)); openScanner_args args = new openScanner_args(); args.setTable(table); - args.setScan(scan); + args.setTscan(tscan); args.write(prot); prot.writeMessageEnd(); } @@ -1240,27 +1319,27 @@ public class THBaseService { } } - public void mutateRow(ByteBuffer table, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<mutateRow_call> resultHandler) throws org.apache.thrift.TException { + public void mutateRow(ByteBuffer table, TRowMutations trowMutations, org.apache.thrift.async.AsyncMethodCallback<mutateRow_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - mutateRow_call method_call = new mutateRow_call(table, rowMutations, resultHandler, this, ___protocolFactory, ___transport); + mutateRow_call method_call = new mutateRow_call(table, trowMutations, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class mutateRow_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TRowMutations rowMutations; - public mutateRow_call(ByteBuffer table, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<mutateRow_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + private TRowMutations trowMutations; + public mutateRow_call(ByteBuffer table, TRowMutations trowMutations, org.apache.thrift.async.AsyncMethodCallback<mutateRow_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.rowMutations = rowMutations; + this.trowMutations = trowMutations; } public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("mutateRow", org.apache.thrift.protocol.TMessageType.CALL, 0)); mutateRow_args args = new mutateRow_args(); args.setTable(table); - args.setRowMutations(rowMutations); + args.setTrowMutations(trowMutations); args.write(prot); prot.writeMessageEnd(); } @@ -1275,21 +1354,21 @@ public class THBaseService { } } - public void getScannerResults(ByteBuffer table, TScan scan, int numRows, org.apache.thrift.async.AsyncMethodCallback<getScannerResults_call> resultHandler) throws org.apache.thrift.TException { + public void getScannerResults(ByteBuffer table, TScan tscan, int numRows, org.apache.thrift.async.AsyncMethodCallback<getScannerResults_call> resultHandler) throws org.apache.thrift.TException { checkReady(); - getScannerResults_call method_call = new getScannerResults_call(table, scan, numRows, resultHandler, this, ___protocolFactory, ___transport); + getScannerResults_call method_call = new getScannerResults_call(table, tscan, numRows, resultHandler, this, ___protocolFactory, ___transport); this.___currentMethod = method_call; ___manager.call(method_call); } public static class getScannerResults_call extends org.apache.thrift.async.TAsyncMethodCall { private ByteBuffer table; - private TScan scan; + private TScan tscan; private int numRows; - public getScannerResults_call(ByteBuffer table, TScan scan, int numRows, org.apache.thrift.async.AsyncMethodCallback<getScannerResults_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + public getScannerResults_call(ByteBuffer table, TScan tscan, int numRows, org.apache.thrift.async.AsyncMethodCallback<getScannerResults_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { super(client, protocolFactory, transport, resultHandler, false); this.table = table; - this.scan = scan; + this.tscan = tscan; this.numRows = numRows; } @@ -1297,7 +1376,7 @@ public class THBaseService { prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getScannerResults", org.apache.thrift.protocol.TMessageType.CALL, 0)); getScannerResults_args args = new getScannerResults_args(); args.setTable(table); - args.setScan(scan); + args.setTscan(tscan); args.setNumRows(numRows); args.write(prot); prot.writeMessageEnd(); @@ -1313,6 +1392,76 @@ public class THBaseService { } } + public void getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload, org.apache.thrift.async.AsyncMethodCallback<getRegionLocation_call> resultHandler) throws org.apache.thrift.TException { + checkReady(); + getRegionLocation_call method_call = new getRegionLocation_call(table, row, reload, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getRegionLocation_call extends org.apache.thrift.async.TAsyncMethodCall { + private ByteBuffer table; + private ByteBuffer row; + private boolean reload; + public getRegionLocation_call(ByteBuffer table, ByteBuffer row, boolean reload, org.apache.thrift.async.AsyncMethodCallback<getRegionLocation_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.table = table; + this.row = row; + this.reload = reload; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getRegionLocation", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getRegionLocation_args args = new getRegionLocation_args(); + args.setTable(table); + args.setRow(row); + args.setReload(reload); + args.write(prot); + prot.writeMessageEnd(); + } + + public THRegionLocation getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_getRegionLocation(); + } + } + + public void getAllRegionLocations(ByteBuffer table, org.apache.thrift.async.AsyncMethodCallback<getAllRegionLocations_call> resultHandler) throws org.apache.thrift.TException { + checkReady(); + getAllRegionLocations_call method_call = new getAllRegionLocations_call(table, resultHandler, this, ___protocolFactory, ___transport); + this.___currentMethod = method_call; + ___manager.call(method_call); + } + + public static class getAllRegionLocations_call extends org.apache.thrift.async.TAsyncMethodCall { + private ByteBuffer table; + public getAllRegionLocations_call(ByteBuffer table, org.apache.thrift.async.AsyncMethodCallback<getAllRegionLocations_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { + super(client, protocolFactory, transport, resultHandler, false); + this.table = table; + } + + public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { + prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllRegionLocations", org.apache.thrift.protocol.TMessageType.CALL, 0)); + getAllRegionLocations_args args = new getAllRegionLocations_args(); + args.setTable(table); + args.write(prot); + prot.writeMessageEnd(); + } + + public List<THRegionLocation> getResult() throws TIOError, org.apache.thrift.TException { + if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { + throw new IllegalStateException("Method call not finished!"); + } + org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); + org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); + return (new Client(prot)).recv_getAllRegionLocations(); + } + } + } public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { @@ -1342,6 +1491,8 @@ public class THBaseService { processMap.put("closeScanner", new closeScanner()); processMap.put("mutateRow", new mutateRow()); processMap.put("getScannerResults", new getScannerResults()); + processMap.put("getRegionLocation", new getRegionLocation()); + processMap.put("getAllRegionLocations", new getAllRegionLocations()); return processMap; } @@ -1361,7 +1512,7 @@ public class THBaseService { public exists_result getResult(I iface, exists_args args) throws org.apache.thrift.TException { exists_result result = new exists_result(); try { - result.success = iface.exists(args.table, args.get); + result.success = iface.exists(args.table, args.tget); result.setSuccessIsSet(true); } catch (TIOError io) { result.io = io; @@ -1386,7 +1537,7 @@ public class THBaseService { public get_result getResult(I iface, get_args args) throws org.apache.thrift.TException { get_result result = new get_result(); try { - result.success = iface.get(args.table, args.get); + result.success = iface.get(args.table, args.tget); } catch (TIOError io) { result.io = io; } @@ -1410,7 +1561,7 @@ public class THBaseService { public getMultiple_result getResult(I iface, getMultiple_args args) throws org.apache.thrift.TException { getMultiple_result result = new getMultiple_result(); try { - result.success = iface.getMultiple(args.table, args.gets); + result.success = iface.getMultiple(args.table, args.tgets); } catch (TIOError io) { result.io = io; } @@ -1434,7 +1585,7 @@ public class THBaseService { public put_result getResult(I iface, put_args args) throws org.apache.thrift.TException { put_result result = new put_result(); try { - iface.put(args.table, args.put); + iface.put(args.table, args.tput); } catch (TIOError io) { result.io = io; } @@ -1458,7 +1609,7 @@ public class THBaseService { public checkAndPut_result getResult(I iface, checkAndPut_args args) throws org.apache.thrift.TException { checkAndPut_result result = new checkAndPut_result(); try { - result.success = iface.checkAndPut(args.table, args.row, args.family, args.qualifier, args.value, args.put); + result.success = iface.checkAndPut(args.table, args.row, args.family, args.qualifier, args.value, args.tput); result.setSuccessIsSet(true); } catch (TIOError io) { result.io = io; @@ -1483,7 +1634,7 @@ public class THBaseService { public putMultiple_result getResult(I iface, putMultiple_args args) throws org.apache.thrift.TException { putMultiple_result result = new putMultiple_result(); try { - iface.putMultiple(args.table, args.puts); + iface.putMultiple(args.table, args.tputs); } catch (TIOError io) { result.io = io; } @@ -1507,7 +1658,7 @@ public class THBaseService { public deleteSingle_result getResult(I iface, deleteSingle_args args) throws org.apache.thrift.TException { deleteSingle_result result = new deleteSingle_result(); try { - iface.deleteSingle(args.table, args.deleteSingle); + iface.deleteSingle(args.table, args.tdelete); } catch (TIOError io) { result.io = io; } @@ -1531,7 +1682,7 @@ public class THBaseService { public deleteMultiple_result getResult(I iface, deleteMultiple_args args) throws org.apache.thrift.TException { deleteMultiple_result result = new deleteMultiple_result(); try { - result.success = iface.deleteMultiple(args.table, args.deletes); + result.success = iface.deleteMultiple(args.table, args.tdeletes); } catch (TIOError io) { result.io = io; } @@ -1555,7 +1706,7 @@ public class THBaseService { public checkAndDelete_result getResult(I iface, checkAndDelete_args args) throws org.apache.thrift.TException { checkAndDelete_result result = new checkAndDelete_result(); try { - result.success = iface.checkAndDelete(args.table, args.row, args.family, args.qualifier, args.value, args.deleteSingle); + result.success = iface.checkAndDelete(args.table, args.row, args.family, args.qualifier, args.value, args.tdelete); result.setSuccessIsSet(true); } catch (TIOError io) { result.io = io; @@ -1580,7 +1731,7 @@ public class THBaseService { public increment_result getResult(I iface, increment_args args) throws org.apache.thrift.TException { increment_result result = new increment_result(); try { - result.success = iface.increment(args.table, args.increment); + result.success = iface.increment(args.table, args.tincrement); } catch (TIOError io) { result.io = io; } @@ -1604,7 +1755,7 @@ public class THBaseService { public append_result getResult(I iface, append_args args) throws org.apache.thrift.TException { append_result result = new append_result(); try { - result.success = iface.append(args.table, args.append); + result.success = iface.append(args.table, args.tappend); } catch (TIOError io) { result.io = io; } @@ -1628,7 +1779,7 @@ public class THBaseService { public openScanner_result getResult(I iface, openScanner_args args) throws org.apache.thrift.TException { openScanner_result result = new openScanner_result(); try { - result.success = iface.openScanner(args.table, args.scan); + result.success = iface.openScanner(args.table, args.tscan); result.setSuccessIsSet(true); } catch (TIOError io) { result.io = io; @@ -1705,7 +1856,7 @@ public class THBaseService { public mutateRow_result getResult(I iface, mutateRow_args args) throws org.apache.thrift.TException { mutateRow_result result = new mutateRow_result(); try { - iface.mutateRow(args.table, args.rowMutations); + iface.mutateRow(args.table, args.trowMutations); } catch (TIOError io) { result.io = io; } @@ -1729,7 +1880,55 @@ public class THBaseService { public getScannerResults_result getResult(I iface, getScannerResults_args args) throws org.apache.thrift.TException { getScannerResults_result result = new getScannerResults_result(); try { - result.success = iface.getScannerResults(args.table, args.scan, args.numRows); + result.success = iface.getScannerResults(args.table, args.tscan, args.numRows); + } catch (TIOError io) { + result.io = io; + } + return result; + } + } + + public static class getRegionLocation<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getRegionLocation_args> { + public getRegionLocation() { + super("getRegionLocation"); + } + + public getRegionLocation_args getEmptyArgsInstance() { + return new getRegionLocation_args(); + } + + protected boolean isOneway() { + return false; + } + + public getRegionLocation_result getResult(I iface, getRegionLocation_args args) throws org.apache.thrift.TException { + getRegionLocation_result result = new getRegionLocation_result(); + try { + result.success = iface.getRegionLocation(args.table, args.row, args.reload); + } catch (TIOError io) { + result.io = io; + } + return result; + } + } + + public static class getAllRegionLocations<I extends Iface> extends org.apache.thrift.ProcessFunction<I, getAllRegionLocations_args> { + public getAllRegionLocations() { + super("getAllRegionLocations"); + } + + public getAllRegionLocations_args getEmptyArgsInstance() { + return new getAllRegionLocations_args(); + } + + protected boolean isOneway() { + return false; + } + + public getAllRegionLocations_result getResult(I iface, getAllRegionLocations_args args) throws org.apache.thrift.TException { + getAllRegionLocations_result result = new getAllRegionLocations_result(); + try { + result.success = iface.getAllRegionLocations(args.table); } catch (TIOError io) { result.io = io; } @@ -1743,7 +1942,7 @@ public class THBaseService { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("exists_args"); private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField GET_FIELD_DESC = new org.apache.thrift.protocol.TField("get", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField TGET_FIELD_DESC = new org.apache.thrift.protocol.TField("tget", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -1758,7 +1957,7 @@ public class THBaseService { /** * the TGet to check for */ - public TGet get; // required + public TGet tget; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -1769,7 +1968,7 @@ public class THBaseService { /** * the TGet to check for */ - GET((short)2, "get"); + TGET((short)2, "tget"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -1786,8 +1985,8 @@ public class THBaseService { switch(fieldId) { case 1: // TABLE return TABLE; - case 2: // GET - return GET; + case 2: // TGET + return TGET; default: return null; } @@ -1833,7 +2032,7 @@ public class THBaseService { Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); tmpMap.put(_Fields.TABLE, new org.apache.thrift.meta_data.FieldMetaData("table", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true))); - tmpMap.put(_Fields.GET, new org.apache.thrift.meta_data.FieldMetaData("get", org.apache.thrift.TFieldRequirementType.REQUIRED, + tmpMap.put(_Fields.TGET, new org.apache.thrift.meta_data.FieldMetaData("tget", org.apache.thrift.TFieldRequirementType.REQUIRED, new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TGet.class))); metaDataMap = Collections.unmodifiableMap(tmpMap); org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(exists_args.class, metaDataMap); @@ -1844,11 +2043,11 @@ public class THBaseService { public exists_args( ByteBuffer table, - TGet get) + TGet tget) { this(); this.table = table; - this.get = get; + this.tget = tget; } /** @@ -1859,8 +2058,8 @@ public class THBaseService { this.table = org.apache.thrift.TBaseHelper.copyBinary(other.table); ; } - if (other.isSetGet()) { - this.get = new TGet(other.get); + if (other.isSetTget()) { + this.tget = new TGet(other.tget); } } @@ -1871,7 +2070,7 @@ public class THBaseService { @Override public void clear() { this.table = null; - this.get = null; + this.tget = null; } /** @@ -1917,30 +2116,30 @@ public class THBaseService { /** * the TGet to check for */ - public TGet getGet() { - return this.get; + public TGet getTget() { + return this.tget; } /** * the TGet to check for */ - public exists_args setGet(TGet get) { - this.get = get; + public exists_args setTget(TGet tget) { + this.tget = tget; return this; } - public void unsetGet() { - this.get = null; + public void unsetTget() { + this.tget = null; } - /** Returns true if field get is set (has been assigned a value) and false otherwise */ - public boolean isSetGet() { - return this.get != null; + /** Returns true if field tget is set (has been assigned a value) and false otherwise */ + public boolean isSetTget() { + return this.tget != null; } - public void setGetIsSet(boolean value) { + public void setTgetIsSet(boolean value) { if (!value) { - this.get = null; + this.tget = null; } } @@ -1954,11 +2153,11 @@ public class THBaseService { } break; - case GET: + case TGET: if (value == null) { - unsetGet(); + unsetTget(); } else { - setGet((TGet)value); + setTget((TGet)value); } break; @@ -1970,8 +2169,8 @@ public class THBaseService { case TABLE: return getTable(); - case GET: - return getGet(); + case TGET: + return getTget(); } throw new IllegalStateException(); @@ -1986,8 +2185,8 @@ public class THBaseService { switch (field) { case TABLE: return isSetTable(); - case GET: - return isSetGet(); + case TGET: + return isSetTget(); } throw new IllegalStateException(); } @@ -2014,12 +2213,12 @@ public class THBaseService { return false; } - boolean this_present_get = true && this.isSetGet(); - boolean that_present_get = true && that.isSetGet(); - if (this_present_get || that_present_get) { - if (!(this_present_get && that_present_get)) + boolean this_present_tget = true && this.isSetTget(); + boolean that_present_tget = true && that.isSetTget(); + if (this_present_tget || that_present_tget) { + if (!(this_present_tget && that_present_tget)) return false; - if (!this.get.equals(that.get)) + if (!this.tget.equals(that.tget)) return false; } @@ -2035,10 +2234,10 @@ public class THBaseService { if (present_table) builder.append(table); - boolean present_get = true && (isSetGet()); - builder.append(present_get); - if (present_get) - builder.append(get); + boolean present_tget = true && (isSetTget()); + builder.append(present_tget); + if (present_tget) + builder.append(tget); return builder.toHashCode(); } @@ -2061,12 +2260,12 @@ public class THBaseService { return lastComparison; } } - lastComparison = Boolean.valueOf(isSetGet()).compareTo(typedOther.isSetGet()); + lastComparison = Boolean.valueOf(isSetTget()).compareTo(typedOther.isSetTget()); if (lastComparison != 0) { return lastComparison; } - if (isSetGet()) { - lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.get, typedOther.get); + if (isSetTget()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tget, typedOther.tget); if (lastComparison != 0) { return lastComparison; } @@ -2099,11 +2298,11 @@ public class THBaseService { } first = false; if (!first) sb.append(", "); - sb.append("get:"); - if (this.get == null) { + sb.append("tget:"); + if (this.tget == null) { sb.append("null"); } else { - sb.append(this.get); + sb.append(this.tget); } first = false; sb.append(")"); @@ -2115,12 +2314,12 @@ public class THBaseService { if (table == null) { throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString()); } - if (get == null) { - throw new org.apache.thrift.protocol.TProtocolException("Required field 'get' was not present! Struct: " + toString()); + if (tget == null) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'tget' was not present! Struct: " + toString()); } // check for sub-struct validity - if (get != null) { - get.validate(); + if (tget != null) { + tget.validate(); } } @@ -2166,11 +2365,11 @@ public class THBaseService { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } break; - case 2: // GET + case 2: // TGET if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { - struct.get = new TGet(); - struct.get.read(iprot); - struct.setGetIsSet(true); + struct.tget = new TGet(); + struct.tget.read(iprot); + struct.setTgetIsSet(true); } else { org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); } @@ -2195,9 +2394,9 @@ public class THBaseService { oprot.writeBinary(struct.table); oprot.writeFieldEnd(); } - if (struct.get != null) { - oprot.writeFieldBegin(GET_FIELD_DESC); - struct.get.write(oprot); + if (struct.tget != null) { + oprot.writeFieldBegin(TGET_FIELD_DESC); + struct.tget.write(oprot); oprot.writeFieldEnd(); } oprot.writeFieldStop(); @@ -2218,7 +2417,7 @@ public class THBaseService { public void write(org.apache.thrift.protocol.TProtocol prot, exists_args struct) throws org.apache.thrift.TException { TTupleProtocol oprot = (TTupleProtocol) prot; oprot.writeBinary(struct.table); - struct.get.write(oprot); + struct.tget.write(oprot); } @Override @@ -2226,9 +2425,9 @@ public class THBaseService { TTupleProtocol iprot = (TTupleProtocol) prot; struct.table = iprot.readBinary(); struct.setTableIsSet(true); - struct.get = new TGet(); - struct.get.read(iprot); - struct.setGetIsSet(true); + struct.tget = new TGet(); + struct.tget.read(iprot); + struct.setTgetIsSet(true); } } @@ -2706,7 +2905,7 @@ public class THBaseService { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("get_args"); private static final org.apache.thrift.protocol.TField TABLE_FIELD_DESC = new org.apache.thrift.protocol.TField("table", org.apache.thrift.protocol.TType.STRING, (short)1); - private static final org.apache.thrift.protocol.TField GET_FIELD_DESC = new org.apache.thrift.protocol.TField("get", org.apache.thrift.protocol.TType.STRUCT, (short)2); + private static final org.apache.thrift.protocol.TField TGET_FIELD_DESC = new org.apache.thrift.protocol.TField("tget", org.apache.thrift.protocol.TType.STRUCT, (short)2); private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); static { @@ -2721,7 +2920,7 @@ public class THBaseService { /** * the TGet to fetch */ - public TGet get; // required + public TGet tget; // required /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ public enum _Fields implements org.apache.thrift.TFieldIdEnum { @@ -2732,7 +2931,7 @@ public class THBaseService { /** * the TGet to fetch */ - GET((short)2, "get"); + TGET((short)2, "tget"); private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); @@ -2749,8 +2948,8 @@ public class T
<TRUNCATED>
