HBASE-22323 Fixed broken Thrift generation
This commit is contained in:
parent
5b07ee9953
commit
882bbdb8f7
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
* An AlreadyExists exceptions signals that a table with the specified
|
||||
* name already exists
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class AlreadyExists extends org.apache.thrift.TException implements org.apache.thrift.TBase<AlreadyExists, AlreadyExists._Fields>, java.io.Serializable, Cloneable, Comparable<AlreadyExists> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyExists");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* A BatchMutation object is used to apply a number of Mutations to a single row.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class BatchMutation implements org.apache.thrift.TBase<BatchMutation, BatchMutation._Fields>, java.io.Serializable, Cloneable, Comparable<BatchMutation> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BatchMutation");
|
||||
|
||||
|
|
|
@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
* such as the number of versions, compression settings, etc. It is
|
||||
* used as input when creating a table or adding a column.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class ColumnDescriptor implements org.apache.thrift.TBase<ColumnDescriptor, ColumnDescriptor._Fields>, java.io.Serializable, Cloneable, Comparable<ColumnDescriptor> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnDescriptor");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class Hbase {
|
||||
|
||||
public interface Iface {
|
||||
|
@ -5079,7 +5079,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
enableTable_result result = new enableTable_result();
|
||||
try {
|
||||
|
@ -5143,7 +5143,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
disableTable_result result = new disableTable_result();
|
||||
try {
|
||||
|
@ -5207,7 +5207,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
isTableEnabled_result result = new isTableEnabled_result();
|
||||
result.success = o;
|
||||
|
@ -5273,7 +5273,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
compact_result result = new compact_result();
|
||||
try {
|
||||
|
@ -5337,7 +5337,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
majorCompact_result result = new majorCompact_result();
|
||||
try {
|
||||
|
@ -5401,7 +5401,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<java.nio.ByteBuffer>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<java.nio.ByteBuffer>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<java.nio.ByteBuffer>>() {
|
||||
public void onComplete(java.util.List<java.nio.ByteBuffer> o) {
|
||||
getTableNames_result result = new getTableNames_result();
|
||||
result.success = o;
|
||||
|
@ -5466,7 +5466,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.Map<java.nio.ByteBuffer,ColumnDescriptor>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.Map<java.nio.ByteBuffer,ColumnDescriptor>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.Map<java.nio.ByteBuffer,ColumnDescriptor>>() {
|
||||
public void onComplete(java.util.Map<java.nio.ByteBuffer,ColumnDescriptor> o) {
|
||||
getColumnDescriptors_result result = new getColumnDescriptors_result();
|
||||
result.success = o;
|
||||
|
@ -5531,7 +5531,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRegionInfo>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRegionInfo>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRegionInfo>>() {
|
||||
public void onComplete(java.util.List<TRegionInfo> o) {
|
||||
getTableRegions_result result = new getTableRegions_result();
|
||||
result.success = o;
|
||||
|
@ -5596,7 +5596,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
createTable_result result = new createTable_result();
|
||||
try {
|
||||
|
@ -5668,7 +5668,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteTable_result result = new deleteTable_result();
|
||||
try {
|
||||
|
@ -5732,7 +5732,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
public void onComplete(java.util.List<TCell> o) {
|
||||
get_result result = new get_result();
|
||||
result.success = o;
|
||||
|
@ -5797,7 +5797,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
public void onComplete(java.util.List<TCell> o) {
|
||||
getVer_result result = new getVer_result();
|
||||
result.success = o;
|
||||
|
@ -5862,7 +5862,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
public void onComplete(java.util.List<TCell> o) {
|
||||
getVerTs_result result = new getVerTs_result();
|
||||
result.success = o;
|
||||
|
@ -5927,7 +5927,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRow_result result = new getRow_result();
|
||||
result.success = o;
|
||||
|
@ -5992,7 +5992,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRowWithColumns_result result = new getRowWithColumns_result();
|
||||
result.success = o;
|
||||
|
@ -6057,7 +6057,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRowTs_result result = new getRowTs_result();
|
||||
result.success = o;
|
||||
|
@ -6122,7 +6122,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRowWithColumnsTs_result result = new getRowWithColumnsTs_result();
|
||||
result.success = o;
|
||||
|
@ -6187,7 +6187,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRows_result result = new getRows_result();
|
||||
result.success = o;
|
||||
|
@ -6252,7 +6252,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRowsWithColumns_result result = new getRowsWithColumns_result();
|
||||
result.success = o;
|
||||
|
@ -6317,7 +6317,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRowsTs_result result = new getRowsTs_result();
|
||||
result.success = o;
|
||||
|
@ -6382,7 +6382,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
getRowsWithColumnsTs_result result = new getRowsWithColumnsTs_result();
|
||||
result.success = o;
|
||||
|
@ -6447,7 +6447,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
mutateRow_result result = new mutateRow_result();
|
||||
try {
|
||||
|
@ -6515,7 +6515,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
mutateRowTs_result result = new mutateRowTs_result();
|
||||
try {
|
||||
|
@ -6583,7 +6583,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
mutateRows_result result = new mutateRows_result();
|
||||
try {
|
||||
|
@ -6651,7 +6651,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
mutateRowsTs_result result = new mutateRowsTs_result();
|
||||
try {
|
||||
|
@ -6719,7 +6719,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Long> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Long>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Long>() {
|
||||
public void onComplete(java.lang.Long o) {
|
||||
atomicIncrement_result result = new atomicIncrement_result();
|
||||
result.success = o;
|
||||
|
@ -6789,7 +6789,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteAll_result result = new deleteAll_result();
|
||||
try {
|
||||
|
@ -6853,7 +6853,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteAllTs_result result = new deleteAllTs_result();
|
||||
try {
|
||||
|
@ -6917,7 +6917,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteAllRow_result result = new deleteAllRow_result();
|
||||
try {
|
||||
|
@ -6981,7 +6981,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
increment_result result = new increment_result();
|
||||
try {
|
||||
|
@ -7045,7 +7045,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
incrementRows_result result = new incrementRows_result();
|
||||
try {
|
||||
|
@ -7109,7 +7109,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteAllRowTs_result result = new deleteAllRowTs_result();
|
||||
try {
|
||||
|
@ -7173,7 +7173,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
scannerOpenWithScan_result result = new scannerOpenWithScan_result();
|
||||
result.success = o;
|
||||
|
@ -7239,7 +7239,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
scannerOpen_result result = new scannerOpen_result();
|
||||
result.success = o;
|
||||
|
@ -7305,7 +7305,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
scannerOpenWithStop_result result = new scannerOpenWithStop_result();
|
||||
result.success = o;
|
||||
|
@ -7371,7 +7371,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
scannerOpenWithPrefix_result result = new scannerOpenWithPrefix_result();
|
||||
result.success = o;
|
||||
|
@ -7437,7 +7437,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
scannerOpenTs_result result = new scannerOpenTs_result();
|
||||
result.success = o;
|
||||
|
@ -7503,7 +7503,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
scannerOpenWithStopTs_result result = new scannerOpenWithStopTs_result();
|
||||
result.success = o;
|
||||
|
@ -7569,7 +7569,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
scannerGet_result result = new scannerGet_result();
|
||||
result.success = o;
|
||||
|
@ -7638,7 +7638,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TRowResult>>() {
|
||||
public void onComplete(java.util.List<TRowResult> o) {
|
||||
scannerGetList_result result = new scannerGetList_result();
|
||||
result.success = o;
|
||||
|
@ -7707,7 +7707,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
scannerClose_result result = new scannerClose_result();
|
||||
try {
|
||||
|
@ -7775,7 +7775,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<TRegionInfo> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TRegionInfo>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TRegionInfo>() {
|
||||
public void onComplete(TRegionInfo o) {
|
||||
getRegionInfo_result result = new getRegionInfo_result();
|
||||
result.success = o;
|
||||
|
@ -7840,7 +7840,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TCell>>() {
|
||||
public void onComplete(java.util.List<TCell> o) {
|
||||
append_result result = new append_result();
|
||||
result.success = o;
|
||||
|
@ -7905,7 +7905,7 @@ public class Hbase {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
checkAndPut_result result = new checkAndPut_result();
|
||||
result.success = o;
|
||||
|
|
|
@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
* to the Hbase master or an Hbase region server. Also used to return
|
||||
* more general Hbase error conditions.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class IOError extends org.apache.thrift.TException implements org.apache.thrift.TBase<IOError, IOError._Fields>, java.io.Serializable, Cloneable, Comparable<IOError> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("IOError");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
* An IllegalArgument exception indicates an illegal or invalid
|
||||
* argument was passed into a procedure.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class IllegalArgument extends org.apache.thrift.TException implements org.apache.thrift.TBase<IllegalArgument, IllegalArgument._Fields>, java.io.Serializable, Cloneable, Comparable<IllegalArgument> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("IllegalArgument");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* A Mutation object is used to either update or delete a column-value.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class Mutation implements org.apache.thrift.TBase<Mutation, Mutation._Fields>, java.io.Serializable, Cloneable, Comparable<Mutation> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Mutation");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* An Append object is used to specify the parameters for performing the append operation.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TAppend implements org.apache.thrift.TBase<TAppend, TAppend._Fields>, java.io.Serializable, Cloneable, Comparable<TAppend> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAppend");
|
||||
|
||||
|
|
|
@ -13,7 +13,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
* the timestamp of a cell to a first-class value, making it easy to take
|
||||
* note of temporal data. Cell is used all the way from HStore up to HTable.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TCell implements org.apache.thrift.TBase<TCell, TCell._Fields>, java.io.Serializable, Cloneable, Comparable<TCell> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TCell");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* Holds column name and the cell.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TColumn implements org.apache.thrift.TBase<TColumn, TColumn._Fields>, java.io.Serializable, Cloneable, Comparable<TColumn> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumn");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
* For increments that are not incrementColumnValue
|
||||
* equivalents.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TIncrement implements org.apache.thrift.TBase<TIncrement, TIncrement._Fields>, java.io.Serializable, Cloneable, Comparable<TIncrement> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIncrement");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* A TRegionInfo contains information about an HTable region.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TRegionInfo implements org.apache.thrift.TBase<TRegionInfo, TRegionInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TRegionInfo> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRegionInfo");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* Holds row name and then a map of columns to cells.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TRowResult implements org.apache.thrift.TBase<TRowResult, TRowResult._Fields>, java.io.Serializable, Cloneable, Comparable<TRowResult> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRowResult");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated;
|
|||
/**
|
||||
* A Scan object is used to specify scanner parameters when opening a scanner.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TScan implements org.apache.thrift.TBase<TScan, TScan._Fields>, java.io.Serializable, Cloneable, Comparable<TScan> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TScan");
|
||||
|
||||
|
|
|
@ -69,7 +69,7 @@ import org.apache.hadoop.hbase.security.UserProvider;
|
|||
import org.apache.hadoop.hbase.thrift.HBaseServiceHandler;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TAppend;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOp;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOperator;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TDelete;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TGet;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.THBaseService;
|
||||
|
@ -340,7 +340,8 @@ public class ThriftHBaseServiceHandler extends HBaseServiceHandler implements TH
|
|||
|
||||
@Override
|
||||
public boolean checkAndMutate(ByteBuffer table, ByteBuffer row, ByteBuffer family,
|
||||
ByteBuffer qualifier, TCompareOp compareOp, ByteBuffer value, TRowMutations rowMutations)
|
||||
ByteBuffer qualifier, TCompareOperator compareOp, ByteBuffer value,
|
||||
TRowMutations rowMutations)
|
||||
throws TIOError, TException {
|
||||
checkReadOnlyMode();
|
||||
try (final Table htable = getTable(table)) {
|
||||
|
|
|
@ -77,7 +77,7 @@ import org.apache.hadoop.hbase.thrift2.generated.TColumn;
|
|||
import org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnIncrement;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnValue;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOp;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOperator;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompressionAlgorithm;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TConsistency;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding;
|
||||
|
@ -783,7 +783,7 @@ public final class ThriftUtilities {
|
|||
}
|
||||
}
|
||||
|
||||
public static CompareOperator compareOpFromThrift(TCompareOp tCompareOp) {
|
||||
public static CompareOperator compareOpFromThrift(TCompareOperator tCompareOp) {
|
||||
switch (tCompareOp.getValue()) {
|
||||
case 0: return CompareOperator.LESS;
|
||||
case 1: return CompareOperator.LESS_OR_EQUAL;
|
||||
|
@ -1432,15 +1432,15 @@ public final class ThriftUtilities {
|
|||
return tRowMutations;
|
||||
}
|
||||
|
||||
public static TCompareOp compareOpFromHBase(CompareOperator compareOp) {
|
||||
public static TCompareOperator compareOpFromHBase(CompareOperator compareOp) {
|
||||
switch (compareOp) {
|
||||
case LESS: return TCompareOp.LESS;
|
||||
case LESS_OR_EQUAL: return TCompareOp.LESS_OR_EQUAL;
|
||||
case EQUAL: return TCompareOp.EQUAL;
|
||||
case NOT_EQUAL: return TCompareOp.NOT_EQUAL;
|
||||
case GREATER_OR_EQUAL: return TCompareOp.GREATER_OR_EQUAL;
|
||||
case GREATER: return TCompareOp.GREATER;
|
||||
case NO_OP: return TCompareOp.NO_OP;
|
||||
case LESS: return TCompareOperator.LESS;
|
||||
case LESS_OR_EQUAL: return TCompareOperator.LESS_OR_EQUAL;
|
||||
case EQUAL: return TCompareOperator.EQUAL;
|
||||
case NOT_EQUAL: return TCompareOperator.NOT_EQUAL;
|
||||
case GREATER_OR_EQUAL: return TCompareOperator.GREATER_OR_EQUAL;
|
||||
case GREATER: return TCompareOperator.GREATER;
|
||||
case NO_OP: return TCompareOperator.NO_OP;
|
||||
default: return null;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TAppend implements org.apache.thrift.TBase<TAppend, TAppend._Fields>, java.io.Serializable, Cloneable, Comparable<TAppend> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAppend");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TAuthorization implements org.apache.thrift.TBase<TAuthorization, TAuthorization._Fields>, java.io.Serializable, Cloneable, Comparable<TAuthorization> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAuthorization");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.regionserver.BloomType
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TBloomFilterType implements org.apache.thrift.TEnum {
|
||||
/**
|
||||
* Bloomfilters disabled
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TCellVisibility implements org.apache.thrift.TBase<TCellVisibility, TCellVisibility._Fields>, java.io.Serializable, Cloneable, Comparable<TCellVisibility> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TCellVisibility");
|
||||
|
||||
|
|
|
@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* in a HBase table by column family and optionally
|
||||
* a column qualifier and timestamp
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TColumn implements org.apache.thrift.TBase<TColumn, TColumn._Fields>, java.io.Serializable, Cloneable, Comparable<TColumn> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumn");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.client.ColumnFamilyDescriptor
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TColumnFamilyDescriptor implements org.apache.thrift.TBase<TColumnFamilyDescriptor, TColumnFamilyDescriptor._Fields>, java.io.Serializable, Cloneable, Comparable<TColumnFamilyDescriptor> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumnFamilyDescriptor");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
/**
|
||||
* Represents a single cell and the amount to increment it by
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TColumnIncrement implements org.apache.thrift.TBase<TColumnIncrement, TColumnIncrement._Fields>, java.io.Serializable, Cloneable, Comparable<TColumnIncrement> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumnIncrement");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
/**
|
||||
* Represents a single cell and its value.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TColumnValue implements org.apache.thrift.TBase<TColumnValue, TColumnValue._Fields>, java.io.Serializable, Cloneable, Comparable<TColumnValue> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumnValue");
|
||||
|
||||
|
|
|
@ -9,10 +9,10 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
|
||||
/**
|
||||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.filter.CompareFilter$CompareOp.
|
||||
* org.apache.hadoop.hbase.CompareOperator.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
public enum TCompareOp implements org.apache.thrift.TEnum {
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TCompareOperator implements org.apache.thrift.TEnum {
|
||||
LESS(0),
|
||||
LESS_OR_EQUAL(1),
|
||||
EQUAL(2),
|
||||
|
@ -23,7 +23,7 @@ public enum TCompareOp implements org.apache.thrift.TEnum {
|
|||
|
||||
private final int value;
|
||||
|
||||
private TCompareOp(int value) {
|
||||
private TCompareOperator(int value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
|
@ -39,7 +39,7 @@ public enum TCompareOp implements org.apache.thrift.TEnum {
|
|||
* @return null if the value is not found.
|
||||
*/
|
||||
@org.apache.thrift.annotation.Nullable
|
||||
public static TCompareOp findByValue(int value) {
|
||||
public static TCompareOperator findByValue(int value) {
|
||||
switch (value) {
|
||||
case 0:
|
||||
return LESS;
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.io.compress.Algorithm
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TCompressionAlgorithm implements org.apache.thrift.TEnum {
|
||||
LZO(0),
|
||||
GZ(1),
|
||||
|
|
|
@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* - STRONG means reads only from primary region
|
||||
* - TIMELINE means reads might return values from secondary region replicas
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TConsistency implements org.apache.thrift.TEnum {
|
||||
STRONG(1),
|
||||
TIMELINE(2);
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.io.encoding.DataBlockEncoding
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TDataBlockEncoding implements org.apache.thrift.TEnum {
|
||||
/**
|
||||
* Disable data block encoding.
|
||||
|
|
|
@ -33,7 +33,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* by changing the durability. If you don't provide durability, it defaults to
|
||||
* column family's default setting for durability.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TDelete implements org.apache.thrift.TBase<TDelete, TDelete._Fields>, java.io.Serializable, Cloneable, Comparable<TDelete> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TDelete");
|
||||
|
||||
|
|
|
@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* - DELETE_COLUMN means exactly one version will be removed,
|
||||
* - DELETE_COLUMNS means previous versions will also be removed.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TDeleteType implements org.apache.thrift.TEnum {
|
||||
DELETE_COLUMN(0),
|
||||
DELETE_COLUMNS(1),
|
||||
|
|
|
@ -14,7 +14,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* - SYNC_WAL means write the Mutation to the WAL synchronously,
|
||||
* - FSYNC_WAL means Write the Mutation to the WAL synchronously and force the entries to disk.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TDurability implements org.apache.thrift.TEnum {
|
||||
USE_DEFAULT(0),
|
||||
SKIP_WAL(1),
|
||||
|
|
|
@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* If you specify a time range and a timestamp the range is ignored.
|
||||
* Timestamps on TColumns are ignored.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TGet implements org.apache.thrift.TBase<TGet, TGet._Fields>, java.io.Serializable, Cloneable, Comparable<TGet> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TGet");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class THBaseService {
|
||||
|
||||
public interface Iface {
|
||||
|
@ -246,14 +246,14 @@ public class THBaseService {
|
|||
*
|
||||
* @param qualifier column qualifier to check
|
||||
*
|
||||
* @param compareOp comparison to make on the value
|
||||
* @param compareOperator comparison to make on the value
|
||||
*
|
||||
* @param value the expected value to be compared against, if not provided the
|
||||
* check is for the non-existence of the column in question
|
||||
*
|
||||
* @param rowMutations row mutations to execute if the value matches
|
||||
*/
|
||||
public boolean checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOp compareOp, java.nio.ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException;
|
||||
public boolean checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOperator compareOperator, java.nio.ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException;
|
||||
|
||||
/**
|
||||
* Get a table descriptor.
|
||||
|
@ -532,7 +532,7 @@ public class THBaseService {
|
|||
|
||||
public void getAllRegionLocations(java.nio.ByteBuffer table, org.apache.thrift.async.AsyncMethodCallback<java.util.List<THRegionLocation>> resultHandler) throws org.apache.thrift.TException;
|
||||
|
||||
public void checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOp compareOp, java.nio.ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException;
|
||||
public void checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOperator compareOperator, java.nio.ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException;
|
||||
|
||||
public void getTableDescriptor(TTableName table, org.apache.thrift.async.AsyncMethodCallback<TTableDescriptor> resultHandler) throws org.apache.thrift.TException;
|
||||
|
||||
|
@ -1118,20 +1118,20 @@ public class THBaseService {
|
|||
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getAllRegionLocations failed: unknown result");
|
||||
}
|
||||
|
||||
public boolean checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOp compareOp, java.nio.ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException
|
||||
public boolean checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOperator compareOperator, java.nio.ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException
|
||||
{
|
||||
send_checkAndMutate(table, row, family, qualifier, compareOp, value, rowMutations);
|
||||
send_checkAndMutate(table, row, family, qualifier, compareOperator, value, rowMutations);
|
||||
return recv_checkAndMutate();
|
||||
}
|
||||
|
||||
public void send_checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOp compareOp, java.nio.ByteBuffer value, TRowMutations rowMutations) throws org.apache.thrift.TException
|
||||
public void send_checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOperator compareOperator, java.nio.ByteBuffer value, TRowMutations rowMutations) throws org.apache.thrift.TException
|
||||
{
|
||||
checkAndMutate_args args = new checkAndMutate_args();
|
||||
args.setTable(table);
|
||||
args.setRow(row);
|
||||
args.setFamily(family);
|
||||
args.setQualifier(qualifier);
|
||||
args.setCompareOp(compareOp);
|
||||
args.setCompareOperator(compareOperator);
|
||||
args.setValue(value);
|
||||
args.setRowMutations(rowMutations);
|
||||
sendBase("checkAndMutate", args);
|
||||
|
@ -2478,9 +2478,9 @@ public class THBaseService {
|
|||
}
|
||||
}
|
||||
|
||||
public void checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOp compareOp, java.nio.ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException {
|
||||
public void checkAndMutate(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOperator compareOperator, java.nio.ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException {
|
||||
checkReady();
|
||||
checkAndMutate_call method_call = new checkAndMutate_call(table, row, family, qualifier, compareOp, value, rowMutations, resultHandler, this, ___protocolFactory, ___transport);
|
||||
checkAndMutate_call method_call = new checkAndMutate_call(table, row, family, qualifier, compareOperator, value, rowMutations, resultHandler, this, ___protocolFactory, ___transport);
|
||||
this.___currentMethod = method_call;
|
||||
___manager.call(method_call);
|
||||
}
|
||||
|
@ -2490,16 +2490,16 @@ public class THBaseService {
|
|||
private java.nio.ByteBuffer row;
|
||||
private java.nio.ByteBuffer family;
|
||||
private java.nio.ByteBuffer qualifier;
|
||||
private TCompareOp compareOp;
|
||||
private TCompareOperator compareOperator;
|
||||
private java.nio.ByteBuffer value;
|
||||
private TRowMutations rowMutations;
|
||||
public checkAndMutate_call(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOp compareOp, java.nio.ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> 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 checkAndMutate_call(java.nio.ByteBuffer table, java.nio.ByteBuffer row, java.nio.ByteBuffer family, java.nio.ByteBuffer qualifier, TCompareOperator compareOperator, java.nio.ByteBuffer value, TRowMutations rowMutations, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> 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.compareOp = compareOp;
|
||||
this.compareOperator = compareOperator;
|
||||
this.value = value;
|
||||
this.rowMutations = rowMutations;
|
||||
}
|
||||
|
@ -2511,7 +2511,7 @@ public class THBaseService {
|
|||
args.setRow(row);
|
||||
args.setFamily(family);
|
||||
args.setQualifier(qualifier);
|
||||
args.setCompareOp(compareOp);
|
||||
args.setCompareOperator(compareOperator);
|
||||
args.setValue(value);
|
||||
args.setRowMutations(rowMutations);
|
||||
args.write(prot);
|
||||
|
@ -3990,7 +3990,7 @@ public class THBaseService {
|
|||
public checkAndMutate_result getResult(I iface, checkAndMutate_args args) throws org.apache.thrift.TException {
|
||||
checkAndMutate_result result = new checkAndMutate_result();
|
||||
try {
|
||||
result.success = iface.checkAndMutate(args.table, args.row, args.family, args.qualifier, args.compareOp, args.value, args.rowMutations);
|
||||
result.success = iface.checkAndMutate(args.table, args.row, args.family, args.qualifier, args.compareOperator, args.value, args.rowMutations);
|
||||
result.setSuccessIsSet(true);
|
||||
} catch (TIOError io) {
|
||||
result.io = io;
|
||||
|
@ -4801,7 +4801,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
exists_result result = new exists_result();
|
||||
result.success = o;
|
||||
|
@ -4867,7 +4867,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<java.lang.Boolean>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<java.lang.Boolean>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<java.lang.Boolean>>() {
|
||||
public void onComplete(java.util.List<java.lang.Boolean> o) {
|
||||
existsAll_result result = new existsAll_result();
|
||||
result.success = o;
|
||||
|
@ -4932,7 +4932,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<TResult> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TResult>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TResult>() {
|
||||
public void onComplete(TResult o) {
|
||||
get_result result = new get_result();
|
||||
result.success = o;
|
||||
|
@ -4997,7 +4997,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>>() {
|
||||
public void onComplete(java.util.List<TResult> o) {
|
||||
getMultiple_result result = new getMultiple_result();
|
||||
result.success = o;
|
||||
|
@ -5062,7 +5062,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
put_result result = new put_result();
|
||||
try {
|
||||
|
@ -5126,7 +5126,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
checkAndPut_result result = new checkAndPut_result();
|
||||
result.success = o;
|
||||
|
@ -5192,7 +5192,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
putMultiple_result result = new putMultiple_result();
|
||||
try {
|
||||
|
@ -5256,7 +5256,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteSingle_result result = new deleteSingle_result();
|
||||
try {
|
||||
|
@ -5320,7 +5320,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TDelete>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TDelete>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TDelete>>() {
|
||||
public void onComplete(java.util.List<TDelete> o) {
|
||||
deleteMultiple_result result = new deleteMultiple_result();
|
||||
result.success = o;
|
||||
|
@ -5385,7 +5385,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
checkAndDelete_result result = new checkAndDelete_result();
|
||||
result.success = o;
|
||||
|
@ -5451,7 +5451,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<TResult> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TResult>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TResult>() {
|
||||
public void onComplete(TResult o) {
|
||||
increment_result result = new increment_result();
|
||||
result.success = o;
|
||||
|
@ -5516,7 +5516,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<TResult> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TResult>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TResult>() {
|
||||
public void onComplete(TResult o) {
|
||||
append_result result = new append_result();
|
||||
result.success = o;
|
||||
|
@ -5581,7 +5581,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Integer>() {
|
||||
public void onComplete(java.lang.Integer o) {
|
||||
openScanner_result result = new openScanner_result();
|
||||
result.success = o;
|
||||
|
@ -5647,7 +5647,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>>() {
|
||||
public void onComplete(java.util.List<TResult> o) {
|
||||
getScannerRows_result result = new getScannerRows_result();
|
||||
result.success = o;
|
||||
|
@ -5716,7 +5716,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
closeScanner_result result = new closeScanner_result();
|
||||
try {
|
||||
|
@ -5784,7 +5784,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
mutateRow_result result = new mutateRow_result();
|
||||
try {
|
||||
|
@ -5848,7 +5848,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TResult>>() {
|
||||
public void onComplete(java.util.List<TResult> o) {
|
||||
getScannerResults_result result = new getScannerResults_result();
|
||||
result.success = o;
|
||||
|
@ -5913,7 +5913,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<THRegionLocation> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<THRegionLocation>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<THRegionLocation>() {
|
||||
public void onComplete(THRegionLocation o) {
|
||||
getRegionLocation_result result = new getRegionLocation_result();
|
||||
result.success = o;
|
||||
|
@ -5978,7 +5978,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<THRegionLocation>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<THRegionLocation>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<THRegionLocation>>() {
|
||||
public void onComplete(java.util.List<THRegionLocation> o) {
|
||||
getAllRegionLocations_result result = new getAllRegionLocations_result();
|
||||
result.success = o;
|
||||
|
@ -6043,7 +6043,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
checkAndMutate_result result = new checkAndMutate_result();
|
||||
result.success = o;
|
||||
|
@ -6094,7 +6094,7 @@ public class THBaseService {
|
|||
}
|
||||
|
||||
public void start(I iface, checkAndMutate_args args, org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> resultHandler) throws org.apache.thrift.TException {
|
||||
iface.checkAndMutate(args.table, args.row, args.family, args.qualifier, args.compareOp, args.value, args.rowMutations,resultHandler);
|
||||
iface.checkAndMutate(args.table, args.row, args.family, args.qualifier, args.compareOperator, args.value, args.rowMutations,resultHandler);
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -6109,7 +6109,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<TTableDescriptor> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TTableDescriptor>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TTableDescriptor>() {
|
||||
public void onComplete(TTableDescriptor o) {
|
||||
getTableDescriptor_result result = new getTableDescriptor_result();
|
||||
result.success = o;
|
||||
|
@ -6174,7 +6174,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>>() {
|
||||
public void onComplete(java.util.List<TTableDescriptor> o) {
|
||||
getTableDescriptors_result result = new getTableDescriptors_result();
|
||||
result.success = o;
|
||||
|
@ -6239,7 +6239,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
tableExists_result result = new tableExists_result();
|
||||
result.success = o;
|
||||
|
@ -6305,7 +6305,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>>() {
|
||||
public void onComplete(java.util.List<TTableDescriptor> o) {
|
||||
getTableDescriptorsByPattern_result result = new getTableDescriptorsByPattern_result();
|
||||
result.success = o;
|
||||
|
@ -6370,7 +6370,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableDescriptor>>() {
|
||||
public void onComplete(java.util.List<TTableDescriptor> o) {
|
||||
getTableDescriptorsByNamespace_result result = new getTableDescriptorsByNamespace_result();
|
||||
result.success = o;
|
||||
|
@ -6435,7 +6435,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableName>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableName>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableName>>() {
|
||||
public void onComplete(java.util.List<TTableName> o) {
|
||||
getTableNamesByPattern_result result = new getTableNamesByPattern_result();
|
||||
result.success = o;
|
||||
|
@ -6500,7 +6500,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableName>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableName>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TTableName>>() {
|
||||
public void onComplete(java.util.List<TTableName> o) {
|
||||
getTableNamesByNamespace_result result = new getTableNamesByNamespace_result();
|
||||
result.success = o;
|
||||
|
@ -6565,7 +6565,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
createTable_result result = new createTable_result();
|
||||
try {
|
||||
|
@ -6629,7 +6629,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteTable_result result = new deleteTable_result();
|
||||
try {
|
||||
|
@ -6693,7 +6693,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
truncateTable_result result = new truncateTable_result();
|
||||
try {
|
||||
|
@ -6757,7 +6757,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
enableTable_result result = new enableTable_result();
|
||||
try {
|
||||
|
@ -6821,7 +6821,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
disableTable_result result = new disableTable_result();
|
||||
try {
|
||||
|
@ -6885,7 +6885,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
isTableEnabled_result result = new isTableEnabled_result();
|
||||
result.success = o;
|
||||
|
@ -6951,7 +6951,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
isTableDisabled_result result = new isTableDisabled_result();
|
||||
result.success = o;
|
||||
|
@ -7017,7 +7017,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
isTableAvailable_result result = new isTableAvailable_result();
|
||||
result.success = o;
|
||||
|
@ -7083,7 +7083,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.lang.Boolean>() {
|
||||
public void onComplete(java.lang.Boolean o) {
|
||||
isTableAvailableWithSplit_result result = new isTableAvailableWithSplit_result();
|
||||
result.success = o;
|
||||
|
@ -7149,7 +7149,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
addColumnFamily_result result = new addColumnFamily_result();
|
||||
try {
|
||||
|
@ -7213,7 +7213,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteColumnFamily_result result = new deleteColumnFamily_result();
|
||||
try {
|
||||
|
@ -7277,7 +7277,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
modifyColumnFamily_result result = new modifyColumnFamily_result();
|
||||
try {
|
||||
|
@ -7341,7 +7341,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
modifyTable_result result = new modifyTable_result();
|
||||
try {
|
||||
|
@ -7405,7 +7405,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
createNamespace_result result = new createNamespace_result();
|
||||
try {
|
||||
|
@ -7469,7 +7469,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
modifyNamespace_result result = new modifyNamespace_result();
|
||||
try {
|
||||
|
@ -7533,7 +7533,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<Void> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<Void>() {
|
||||
public void onComplete(Void o) {
|
||||
deleteNamespace_result result = new deleteNamespace_result();
|
||||
try {
|
||||
|
@ -7597,7 +7597,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<TNamespaceDescriptor> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TNamespaceDescriptor>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<TNamespaceDescriptor>() {
|
||||
public void onComplete(TNamespaceDescriptor o) {
|
||||
getNamespaceDescriptor_result result = new getNamespaceDescriptor_result();
|
||||
result.success = o;
|
||||
|
@ -7662,7 +7662,7 @@ public class THBaseService {
|
|||
|
||||
public org.apache.thrift.async.AsyncMethodCallback<java.util.List<TNamespaceDescriptor>> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) {
|
||||
final org.apache.thrift.AsyncProcessFunction fcall = this;
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TNamespaceDescriptor>>() {
|
||||
return new org.apache.thrift.async.AsyncMethodCallback<java.util.List<TNamespaceDescriptor>>() {
|
||||
public void onComplete(java.util.List<TNamespaceDescriptor> o) {
|
||||
listNamespaceDescriptors_result result = new listNamespaceDescriptors_result();
|
||||
result.success = o;
|
||||
|
@ -27497,7 +27497,7 @@ public class THBaseService {
|
|||
private static final org.apache.thrift.protocol.TField ROW_FIELD_DESC = new org.apache.thrift.protocol.TField("row", org.apache.thrift.protocol.TType.STRING, (short)2);
|
||||
private static final org.apache.thrift.protocol.TField FAMILY_FIELD_DESC = new org.apache.thrift.protocol.TField("family", org.apache.thrift.protocol.TType.STRING, (short)3);
|
||||
private static final org.apache.thrift.protocol.TField QUALIFIER_FIELD_DESC = new org.apache.thrift.protocol.TField("qualifier", org.apache.thrift.protocol.TType.STRING, (short)4);
|
||||
private static final org.apache.thrift.protocol.TField COMPARE_OP_FIELD_DESC = new org.apache.thrift.protocol.TField("compareOp", org.apache.thrift.protocol.TType.I32, (short)5);
|
||||
private static final org.apache.thrift.protocol.TField COMPARE_OPERATOR_FIELD_DESC = new org.apache.thrift.protocol.TField("compareOperator", org.apache.thrift.protocol.TType.I32, (short)5);
|
||||
private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.STRING, (short)6);
|
||||
private static final org.apache.thrift.protocol.TField ROW_MUTATIONS_FIELD_DESC = new org.apache.thrift.protocol.TField("rowMutations", org.apache.thrift.protocol.TType.STRUCT, (short)7);
|
||||
|
||||
|
@ -27523,9 +27523,9 @@ public class THBaseService {
|
|||
/**
|
||||
* comparison to make on the value
|
||||
*
|
||||
* @see TCompareOp
|
||||
* @see TCompareOperator
|
||||
*/
|
||||
public @org.apache.thrift.annotation.Nullable TCompareOp compareOp; // required
|
||||
public @org.apache.thrift.annotation.Nullable TCompareOperator compareOperator; // required
|
||||
/**
|
||||
* the expected value to be compared against, if not provided the
|
||||
* check is for the non-existence of the column in question
|
||||
|
@ -27557,9 +27557,9 @@ public class THBaseService {
|
|||
/**
|
||||
* comparison to make on the value
|
||||
*
|
||||
* @see TCompareOp
|
||||
* @see TCompareOperator
|
||||
*/
|
||||
COMPARE_OP((short)5, "compareOp"),
|
||||
COMPARE_OPERATOR((short)5, "compareOperator"),
|
||||
/**
|
||||
* the expected value to be compared against, if not provided the
|
||||
* check is for the non-existence of the column in question
|
||||
|
@ -27592,8 +27592,8 @@ public class THBaseService {
|
|||
return FAMILY;
|
||||
case 4: // QUALIFIER
|
||||
return QUALIFIER;
|
||||
case 5: // COMPARE_OP
|
||||
return COMPARE_OP;
|
||||
case 5: // COMPARE_OPERATOR
|
||||
return COMPARE_OPERATOR;
|
||||
case 6: // VALUE
|
||||
return VALUE;
|
||||
case 7: // ROW_MUTATIONS
|
||||
|
@ -27650,8 +27650,8 @@ public class THBaseService {
|
|||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
|
||||
tmpMap.put(_Fields.QUALIFIER, new org.apache.thrift.meta_data.FieldMetaData("qualifier", org.apache.thrift.TFieldRequirementType.REQUIRED,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
|
||||
tmpMap.put(_Fields.COMPARE_OP, new org.apache.thrift.meta_data.FieldMetaData("compareOp", org.apache.thrift.TFieldRequirementType.REQUIRED,
|
||||
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TCompareOp.class)));
|
||||
tmpMap.put(_Fields.COMPARE_OPERATOR, new org.apache.thrift.meta_data.FieldMetaData("compareOperator", org.apache.thrift.TFieldRequirementType.REQUIRED,
|
||||
new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TCompareOperator.class)));
|
||||
tmpMap.put(_Fields.VALUE, new org.apache.thrift.meta_data.FieldMetaData("value", org.apache.thrift.TFieldRequirementType.DEFAULT,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , true)));
|
||||
tmpMap.put(_Fields.ROW_MUTATIONS, new org.apache.thrift.meta_data.FieldMetaData("rowMutations", org.apache.thrift.TFieldRequirementType.REQUIRED,
|
||||
|
@ -27668,7 +27668,7 @@ public class THBaseService {
|
|||
java.nio.ByteBuffer row,
|
||||
java.nio.ByteBuffer family,
|
||||
java.nio.ByteBuffer qualifier,
|
||||
TCompareOp compareOp,
|
||||
TCompareOperator compareOperator,
|
||||
java.nio.ByteBuffer value,
|
||||
TRowMutations rowMutations)
|
||||
{
|
||||
|
@ -27677,7 +27677,7 @@ public class THBaseService {
|
|||
this.row = org.apache.thrift.TBaseHelper.copyBinary(row);
|
||||
this.family = org.apache.thrift.TBaseHelper.copyBinary(family);
|
||||
this.qualifier = org.apache.thrift.TBaseHelper.copyBinary(qualifier);
|
||||
this.compareOp = compareOp;
|
||||
this.compareOperator = compareOperator;
|
||||
this.value = org.apache.thrift.TBaseHelper.copyBinary(value);
|
||||
this.rowMutations = rowMutations;
|
||||
}
|
||||
|
@ -27698,8 +27698,8 @@ public class THBaseService {
|
|||
if (other.isSetQualifier()) {
|
||||
this.qualifier = org.apache.thrift.TBaseHelper.copyBinary(other.qualifier);
|
||||
}
|
||||
if (other.isSetCompareOp()) {
|
||||
this.compareOp = other.compareOp;
|
||||
if (other.isSetCompareOperator()) {
|
||||
this.compareOperator = other.compareOperator;
|
||||
}
|
||||
if (other.isSetValue()) {
|
||||
this.value = org.apache.thrift.TBaseHelper.copyBinary(other.value);
|
||||
|
@ -27719,7 +27719,7 @@ public class THBaseService {
|
|||
this.row = null;
|
||||
this.family = null;
|
||||
this.qualifier = null;
|
||||
this.compareOp = null;
|
||||
this.compareOperator = null;
|
||||
this.value = null;
|
||||
this.rowMutations = null;
|
||||
}
|
||||
|
@ -27887,35 +27887,35 @@ public class THBaseService {
|
|||
/**
|
||||
* comparison to make on the value
|
||||
*
|
||||
* @see TCompareOp
|
||||
* @see TCompareOperator
|
||||
*/
|
||||
@org.apache.thrift.annotation.Nullable
|
||||
public TCompareOp getCompareOp() {
|
||||
return this.compareOp;
|
||||
public TCompareOperator getCompareOperator() {
|
||||
return this.compareOperator;
|
||||
}
|
||||
|
||||
/**
|
||||
* comparison to make on the value
|
||||
*
|
||||
* @see TCompareOp
|
||||
* @see TCompareOperator
|
||||
*/
|
||||
public checkAndMutate_args setCompareOp(@org.apache.thrift.annotation.Nullable TCompareOp compareOp) {
|
||||
this.compareOp = compareOp;
|
||||
public checkAndMutate_args setCompareOperator(@org.apache.thrift.annotation.Nullable TCompareOperator compareOperator) {
|
||||
this.compareOperator = compareOperator;
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetCompareOp() {
|
||||
this.compareOp = null;
|
||||
public void unsetCompareOperator() {
|
||||
this.compareOperator = null;
|
||||
}
|
||||
|
||||
/** Returns true if field compareOp is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetCompareOp() {
|
||||
return this.compareOp != null;
|
||||
/** Returns true if field compareOperator is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetCompareOperator() {
|
||||
return this.compareOperator != null;
|
||||
}
|
||||
|
||||
public void setCompareOpIsSet(boolean value) {
|
||||
public void setCompareOperatorIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.compareOp = null;
|
||||
this.compareOperator = null;
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -28042,11 +28042,11 @@ public class THBaseService {
|
|||
}
|
||||
break;
|
||||
|
||||
case COMPARE_OP:
|
||||
case COMPARE_OPERATOR:
|
||||
if (value == null) {
|
||||
unsetCompareOp();
|
||||
unsetCompareOperator();
|
||||
} else {
|
||||
setCompareOp((TCompareOp)value);
|
||||
setCompareOperator((TCompareOperator)value);
|
||||
}
|
||||
break;
|
||||
|
||||
|
@ -28088,8 +28088,8 @@ public class THBaseService {
|
|||
case QUALIFIER:
|
||||
return getQualifier();
|
||||
|
||||
case COMPARE_OP:
|
||||
return getCompareOp();
|
||||
case COMPARE_OPERATOR:
|
||||
return getCompareOperator();
|
||||
|
||||
case VALUE:
|
||||
return getValue();
|
||||
|
@ -28116,8 +28116,8 @@ public class THBaseService {
|
|||
return isSetFamily();
|
||||
case QUALIFIER:
|
||||
return isSetQualifier();
|
||||
case COMPARE_OP:
|
||||
return isSetCompareOp();
|
||||
case COMPARE_OPERATOR:
|
||||
return isSetCompareOperator();
|
||||
case VALUE:
|
||||
return isSetValue();
|
||||
case ROW_MUTATIONS:
|
||||
|
@ -28177,12 +28177,12 @@ public class THBaseService {
|
|||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_compareOp = true && this.isSetCompareOp();
|
||||
boolean that_present_compareOp = true && that.isSetCompareOp();
|
||||
if (this_present_compareOp || that_present_compareOp) {
|
||||
if (!(this_present_compareOp && that_present_compareOp))
|
||||
boolean this_present_compareOperator = true && this.isSetCompareOperator();
|
||||
boolean that_present_compareOperator = true && that.isSetCompareOperator();
|
||||
if (this_present_compareOperator || that_present_compareOperator) {
|
||||
if (!(this_present_compareOperator && that_present_compareOperator))
|
||||
return false;
|
||||
if (!this.compareOp.equals(that.compareOp))
|
||||
if (!this.compareOperator.equals(that.compareOperator))
|
||||
return false;
|
||||
}
|
||||
|
||||
|
@ -28227,9 +28227,9 @@ public class THBaseService {
|
|||
if (isSetQualifier())
|
||||
hashCode = hashCode * 8191 + qualifier.hashCode();
|
||||
|
||||
hashCode = hashCode * 8191 + ((isSetCompareOp()) ? 131071 : 524287);
|
||||
if (isSetCompareOp())
|
||||
hashCode = hashCode * 8191 + compareOp.getValue();
|
||||
hashCode = hashCode * 8191 + ((isSetCompareOperator()) ? 131071 : 524287);
|
||||
if (isSetCompareOperator())
|
||||
hashCode = hashCode * 8191 + compareOperator.getValue();
|
||||
|
||||
hashCode = hashCode * 8191 + ((isSetValue()) ? 131071 : 524287);
|
||||
if (isSetValue())
|
||||
|
@ -28290,12 +28290,12 @@ public class THBaseService {
|
|||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = java.lang.Boolean.valueOf(isSetCompareOp()).compareTo(other.isSetCompareOp());
|
||||
lastComparison = java.lang.Boolean.valueOf(isSetCompareOperator()).compareTo(other.isSetCompareOperator());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetCompareOp()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.compareOp, other.compareOp);
|
||||
if (isSetCompareOperator()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.compareOperator, other.compareOperator);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
|
@ -28373,11 +28373,11 @@ public class THBaseService {
|
|||
}
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("compareOp:");
|
||||
if (this.compareOp == null) {
|
||||
sb.append("compareOperator:");
|
||||
if (this.compareOperator == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.compareOp);
|
||||
sb.append(this.compareOperator);
|
||||
}
|
||||
first = false;
|
||||
if (!first) sb.append(", ");
|
||||
|
@ -28414,8 +28414,8 @@ public class THBaseService {
|
|||
if (qualifier == null) {
|
||||
throw new org.apache.thrift.protocol.TProtocolException("Required field 'qualifier' was not present! Struct: " + toString());
|
||||
}
|
||||
if (compareOp == null) {
|
||||
throw new org.apache.thrift.protocol.TProtocolException("Required field 'compareOp' was not present! Struct: " + toString());
|
||||
if (compareOperator == null) {
|
||||
throw new org.apache.thrift.protocol.TProtocolException("Required field 'compareOperator' was not present! Struct: " + toString());
|
||||
}
|
||||
if (rowMutations == null) {
|
||||
throw new org.apache.thrift.protocol.TProtocolException("Required field 'rowMutations' was not present! Struct: " + toString());
|
||||
|
@ -28492,10 +28492,10 @@ public class THBaseService {
|
|||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
break;
|
||||
case 5: // COMPARE_OP
|
||||
case 5: // COMPARE_OPERATOR
|
||||
if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
|
||||
struct.compareOp = org.apache.hadoop.hbase.thrift2.generated.TCompareOp.findByValue(iprot.readI32());
|
||||
struct.setCompareOpIsSet(true);
|
||||
struct.compareOperator = org.apache.hadoop.hbase.thrift2.generated.TCompareOperator.findByValue(iprot.readI32());
|
||||
struct.setCompareOperatorIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
|
||||
}
|
||||
|
@ -28552,9 +28552,9 @@ public class THBaseService {
|
|||
oprot.writeBinary(struct.qualifier);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (struct.compareOp != null) {
|
||||
oprot.writeFieldBegin(COMPARE_OP_FIELD_DESC);
|
||||
oprot.writeI32(struct.compareOp.getValue());
|
||||
if (struct.compareOperator != null) {
|
||||
oprot.writeFieldBegin(COMPARE_OPERATOR_FIELD_DESC);
|
||||
oprot.writeI32(struct.compareOperator.getValue());
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (struct.value != null) {
|
||||
|
@ -28588,7 +28588,7 @@ public class THBaseService {
|
|||
oprot.writeBinary(struct.row);
|
||||
oprot.writeBinary(struct.family);
|
||||
oprot.writeBinary(struct.qualifier);
|
||||
oprot.writeI32(struct.compareOp.getValue());
|
||||
oprot.writeI32(struct.compareOperator.getValue());
|
||||
struct.rowMutations.write(oprot);
|
||||
java.util.BitSet optionals = new java.util.BitSet();
|
||||
if (struct.isSetValue()) {
|
||||
|
@ -28611,8 +28611,8 @@ public class THBaseService {
|
|||
struct.setFamilyIsSet(true);
|
||||
struct.qualifier = iprot.readBinary();
|
||||
struct.setQualifierIsSet(true);
|
||||
struct.compareOp = org.apache.hadoop.hbase.thrift2.generated.TCompareOp.findByValue(iprot.readI32());
|
||||
struct.setCompareOpIsSet(true);
|
||||
struct.compareOperator = org.apache.hadoop.hbase.thrift2.generated.TCompareOperator.findByValue(iprot.readI32());
|
||||
struct.setCompareOperatorIsSet(true);
|
||||
struct.rowMutations = new TRowMutations();
|
||||
struct.rowMutations.read(iprot);
|
||||
struct.setRowMutationsIsSet(true);
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class THRegionInfo implements org.apache.thrift.TBase<THRegionInfo, THRegionInfo._Fields>, java.io.Serializable, Cloneable, Comparable<THRegionInfo> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("THRegionInfo");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class THRegionLocation implements org.apache.thrift.TBase<THRegionLocation, THRegionLocation._Fields>, java.io.Serializable, Cloneable, Comparable<THRegionLocation> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("THRegionLocation");
|
||||
|
||||
|
|
|
@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* to the HBase master or a HBase region server. Also used to return
|
||||
* more general HBase error conditions.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TIOError extends org.apache.thrift.TException implements org.apache.thrift.TBase<TIOError, TIOError._Fields>, java.io.Serializable, Cloneable, Comparable<TIOError> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIOError");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* A TIllegalArgument exception indicates an illegal or invalid
|
||||
* argument was passed into a procedure.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TIllegalArgument extends org.apache.thrift.TException implements org.apache.thrift.TBase<TIllegalArgument, TIllegalArgument._Fields>, java.io.Serializable, Cloneable, Comparable<TIllegalArgument> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIllegalArgument");
|
||||
|
||||
|
|
|
@ -14,7 +14,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* by changing the durability. If you don't provide durability, it defaults to
|
||||
* column family's default setting for durability.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TIncrement implements org.apache.thrift.TBase<TIncrement, TIncrement._Fields>, java.io.Serializable, Cloneable, Comparable<TIncrement> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIncrement");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.KeepDeletedCells
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TKeepDeletedCells implements org.apache.thrift.TEnum {
|
||||
/**
|
||||
* Deleted Cells are not retained.
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
/**
|
||||
* Atomic mutation for the specified row. It can be either Put or Delete.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TMutation extends org.apache.thrift.TUnion<TMutation, TMutation._Fields> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TMutation");
|
||||
private static final org.apache.thrift.protocol.TField PUT_FIELD_DESC = new org.apache.thrift.protocol.TField("put", org.apache.thrift.protocol.TType.STRUCT, (short)1);
|
||||
|
@ -82,9 +82,9 @@ public class TMutation extends org.apache.thrift.TUnion<TMutation, TMutation._Fi
|
|||
public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
|
||||
static {
|
||||
java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
|
||||
tmpMap.put(_Fields.PUT, new org.apache.thrift.meta_data.FieldMetaData("put", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
tmpMap.put(_Fields.PUT, new org.apache.thrift.meta_data.FieldMetaData("put", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TPut.class)));
|
||||
tmpMap.put(_Fields.DELETE_SINGLE, new org.apache.thrift.meta_data.FieldMetaData("deleteSingle", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
tmpMap.put(_Fields.DELETE_SINGLE, new org.apache.thrift.meta_data.FieldMetaData("deleteSingle", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, TDelete.class)));
|
||||
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap);
|
||||
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TMutation.class, metaDataMap);
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.NamespaceDescriptor
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TNamespaceDescriptor implements org.apache.thrift.TBase<TNamespaceDescriptor, TNamespaceDescriptor._Fields>, java.io.Serializable, Cloneable, Comparable<TNamespaceDescriptor> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TNamespaceDescriptor");
|
||||
|
||||
|
|
|
@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* by changing the durability. If you don't provide durability, it defaults to
|
||||
* column family's default setting for durability.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TPut implements org.apache.thrift.TBase<TPut, TPut._Fields>, java.io.Serializable, Cloneable, Comparable<TPut> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPut");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public enum TReadType implements org.apache.thrift.TEnum {
|
||||
DEFAULT(1),
|
||||
STREAM(2),
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
/**
|
||||
* if no Result is found, row and columnValues will not be set.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TResult implements org.apache.thrift.TBase<TResult, TResult._Fields>, java.io.Serializable, Cloneable, Comparable<TResult> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TResult");
|
||||
|
||||
|
|
|
@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
/**
|
||||
* A TRowMutations object is used to apply a number of Mutations to a single row.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TRowMutations implements org.apache.thrift.TBase<TRowMutations, TRowMutations._Fields>, java.io.Serializable, Cloneable, Comparable<TRowMutations> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRowMutations");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Any timestamps in the columns are ignored but the colFamTimeRangeMap included, use timeRange to select by timestamp.
|
||||
* Max versions defaults to 1.
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TScan implements org.apache.thrift.TBase<TScan, TScan._Fields>, java.io.Serializable, Cloneable, Comparable<TScan> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TScan");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TServerName implements org.apache.thrift.TBase<TServerName, TServerName._Fields>, java.io.Serializable, Cloneable, Comparable<TServerName> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TServerName");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.client.TableDescriptor
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TTableDescriptor implements org.apache.thrift.TBase<TTableDescriptor, TTableDescriptor._Fields>, java.io.Serializable, Cloneable, Comparable<TTableDescriptor> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableDescriptor");
|
||||
|
||||
|
|
|
@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated;
|
|||
* Thrift wrapper around
|
||||
* org.apache.hadoop.hbase.TableName
|
||||
*/
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TTableName implements org.apache.thrift.TBase<TTableName, TTableName._Fields>, java.io.Serializable, Cloneable, Comparable<TTableName> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableName");
|
||||
|
||||
|
|
|
@ -7,7 +7,7 @@
|
|||
package org.apache.hadoop.hbase.thrift2.generated;
|
||||
|
||||
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"})
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22")
|
||||
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-04-29")
|
||||
public class TTimeRange implements org.apache.thrift.TBase<TTimeRange, TTimeRange._Fields>, java.io.Serializable, Cloneable, Comparable<TTimeRange> {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTimeRange");
|
||||
|
||||
|
|
|
@ -80,7 +80,7 @@ import org.apache.hadoop.hbase.thrift2.generated.TColumn;
|
|||
import org.apache.hadoop.hbase.thrift2.generated.TColumnFamilyDescriptor;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnIncrement;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnValue;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOp;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOperator;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TConsistency;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TDataBlockEncoding;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TDelete;
|
||||
|
@ -1544,7 +1544,7 @@ public class TestThriftHBaseServiceHandler {
|
|||
|
||||
// checkAndMutate -- condition should fail because the value doesn't exist.
|
||||
assertFalse("Expected condition to not pass",
|
||||
handler.checkAndMutate(table, row, family, qualifier, TCompareOp.EQUAL, value,
|
||||
handler.checkAndMutate(table, row, family, qualifier, TCompareOperator.EQUAL, value,
|
||||
tRowMutations));
|
||||
|
||||
List<TColumnValue> columnValuesA = new ArrayList<>(1);
|
||||
|
@ -1561,7 +1561,7 @@ public class TestThriftHBaseServiceHandler {
|
|||
|
||||
// checkAndMutate -- condition should pass since we added the value
|
||||
assertTrue("Expected condition to pass",
|
||||
handler.checkAndMutate(table, row, family, qualifier, TCompareOp.EQUAL, value,
|
||||
handler.checkAndMutate(table, row, family, qualifier, TCompareOperator.EQUAL, value,
|
||||
tRowMutations));
|
||||
|
||||
result = handler.get(table, new TGet(row));
|
||||
|
|
|
@ -41,7 +41,7 @@ import org.apache.hadoop.hbase.testclassification.MediumTests;
|
|||
import org.apache.hadoop.hbase.thrift2.generated.TAppend;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnIncrement;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TColumnValue;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOp;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TCompareOperator;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TDelete;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TGet;
|
||||
import org.apache.hadoop.hbase.thrift2.generated.TIOError;
|
||||
|
@ -337,7 +337,7 @@ public class TestThriftHBaseServiceHandlerWithReadOnly {
|
|||
|
||||
boolean exceptionCaught = false;
|
||||
try {
|
||||
handler.checkAndMutate(table, row, family, qualifier, TCompareOp.EQUAL, value,
|
||||
handler.checkAndMutate(table, row, family, qualifier, TCompareOperator.EQUAL, value,
|
||||
tRowMutations);
|
||||
} catch (TIOError e) {
|
||||
exceptionCaught = true;
|
||||
|
|
Loading…
Reference in New Issue