diff --git a/src/java/org/apache/hadoop/hbase/thrift/generated/TCell.java b/src/java/org/apache/hadoop/hbase/thrift/generated/TCell.java new file mode 100644 index 00000000000..c3b4aed5533 --- /dev/null +++ b/src/java/org/apache/hadoop/hbase/thrift/generated/TCell.java @@ -0,0 +1,173 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + * Autogenerated by Thrift + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + */ +package org.apache.hadoop.hbase.thrift.generated; + +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.Set; +import java.util.HashSet; +import com.facebook.thrift.*; + +import com.facebook.thrift.protocol.*; +import com.facebook.thrift.transport.*; + +/** + * TCell - Used to transport a cell value (byte[]) and the timestamp it was + * stored with together as a result for get and getRow methods. This promotes + * 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. + */ +public class TCell implements TBase, java.io.Serializable { + public byte[] value; + public long timestamp; + + public final Isset __isset = new Isset(); + public static final class Isset implements java.io.Serializable { + public boolean value = false; + public boolean timestamp = false; + } + + public TCell() { + } + + public TCell( + byte[] value, + long timestamp) + { + this(); + this.value = value; + this.__isset.value = true; + this.timestamp = timestamp; + this.__isset.timestamp = true; + } + + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TCell) + return this.equals((TCell)that); + return false; + } + + public boolean equals(TCell that) { + if (that == null) + return false; + + boolean this_present_value = true && (this.value != null); + boolean that_present_value = true && (that.value != null); + if (this_present_value || that_present_value) { + if (!(this_present_value && that_present_value)) + return false; + if (!java.util.Arrays.equals(this.value, that.value)) + return false; + } + + boolean this_present_timestamp = true; + boolean that_present_timestamp = true; + if (this_present_timestamp || that_present_timestamp) { + if (!(this_present_timestamp && that_present_timestamp)) + return false; + if (this.timestamp != that.timestamp) + return false; + } + + return true; + } + + public int hashCode() { + return 0; + } + + public void read(TProtocol iprot) throws TException { + TField field; + iprot.readStructBegin(); + while (true) + { + field = iprot.readFieldBegin(); + if (field.type == TType.STOP) { + break; + } + switch (field.id) + { + case 1: + if (field.type == TType.STRING) { + this.value = iprot.readBinary(); + this.__isset.value = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + case 2: + if (field.type == TType.I64) { + this.timestamp = iprot.readI64(); + this.__isset.timestamp = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + default: + TProtocolUtil.skip(iprot, field.type); + break; + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + } + + public void write(TProtocol oprot) throws TException { + TStruct struct = new TStruct("TCell"); + oprot.writeStructBegin(struct); + TField field = new TField(); + if (this.value != null) { + field.name = "value"; + field.type = TType.STRING; + field.id = 1; + oprot.writeFieldBegin(field); + oprot.writeBinary(this.value); + oprot.writeFieldEnd(); + } + field.name = "timestamp"; + field.type = TType.I64; + field.id = 2; + oprot.writeFieldBegin(field); + oprot.writeI64(this.timestamp); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + public String toString() { + StringBuilder sb = new StringBuilder("TCell("); + sb.append("value:"); + sb.append(this.value); + sb.append(",timestamp:"); + sb.append(this.timestamp); + sb.append(")"); + return sb.toString(); + } + +} + diff --git a/src/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java b/src/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java new file mode 100644 index 00000000000..4e0d150946e --- /dev/null +++ b/src/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java @@ -0,0 +1,264 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + * Autogenerated by Thrift + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + */ +package org.apache.hadoop.hbase.thrift.generated; + +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.Set; +import java.util.HashSet; +import com.facebook.thrift.*; + +import com.facebook.thrift.protocol.*; +import com.facebook.thrift.transport.*; + +/** + * A TRegionInfo contains information about an HTable region. + */ +public class TRegionInfo implements TBase, java.io.Serializable { + public byte[] startKey; + public byte[] endKey; + public long id; + public byte[] name; + public byte version; + + public final Isset __isset = new Isset(); + public static final class Isset implements java.io.Serializable { + public boolean startKey = false; + public boolean endKey = false; + public boolean id = false; + public boolean name = false; + public boolean version = false; + } + + public TRegionInfo() { + } + + public TRegionInfo( + byte[] startKey, + byte[] endKey, + long id, + byte[] name, + byte version) + { + this(); + this.startKey = startKey; + this.__isset.startKey = true; + this.endKey = endKey; + this.__isset.endKey = true; + this.id = id; + this.__isset.id = true; + this.name = name; + this.__isset.name = true; + this.version = version; + this.__isset.version = true; + } + + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TRegionInfo) + return this.equals((TRegionInfo)that); + return false; + } + + public boolean equals(TRegionInfo that) { + if (that == null) + return false; + + boolean this_present_startKey = true && (this.startKey != null); + boolean that_present_startKey = true && (that.startKey != null); + if (this_present_startKey || that_present_startKey) { + if (!(this_present_startKey && that_present_startKey)) + return false; + if (!java.util.Arrays.equals(this.startKey, that.startKey)) + return false; + } + + boolean this_present_endKey = true && (this.endKey != null); + boolean that_present_endKey = true && (that.endKey != null); + if (this_present_endKey || that_present_endKey) { + if (!(this_present_endKey && that_present_endKey)) + return false; + if (!java.util.Arrays.equals(this.endKey, that.endKey)) + return false; + } + + boolean this_present_id = true; + boolean that_present_id = true; + if (this_present_id || that_present_id) { + if (!(this_present_id && that_present_id)) + return false; + if (this.id != that.id) + return false; + } + + boolean this_present_name = true && (this.name != null); + boolean that_present_name = true && (that.name != null); + if (this_present_name || that_present_name) { + if (!(this_present_name && that_present_name)) + return false; + if (!java.util.Arrays.equals(this.name, that.name)) + return false; + } + + boolean this_present_version = true; + boolean that_present_version = true; + if (this_present_version || that_present_version) { + if (!(this_present_version && that_present_version)) + return false; + if (this.version != that.version) + return false; + } + + return true; + } + + public int hashCode() { + return 0; + } + + public void read(TProtocol iprot) throws TException { + TField field; + iprot.readStructBegin(); + while (true) + { + field = iprot.readFieldBegin(); + if (field.type == TType.STOP) { + break; + } + switch (field.id) + { + case 1: + if (field.type == TType.STRING) { + this.startKey = iprot.readBinary(); + this.__isset.startKey = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + case 2: + if (field.type == TType.STRING) { + this.endKey = iprot.readBinary(); + this.__isset.endKey = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + case 3: + if (field.type == TType.I64) { + this.id = iprot.readI64(); + this.__isset.id = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + case 4: + if (field.type == TType.STRING) { + this.name = iprot.readBinary(); + this.__isset.name = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + case 5: + if (field.type == TType.BYTE) { + this.version = iprot.readByte(); + this.__isset.version = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + default: + TProtocolUtil.skip(iprot, field.type); + break; + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + } + + public void write(TProtocol oprot) throws TException { + TStruct struct = new TStruct("TRegionInfo"); + oprot.writeStructBegin(struct); + TField field = new TField(); + if (this.startKey != null) { + field.name = "startKey"; + field.type = TType.STRING; + field.id = 1; + oprot.writeFieldBegin(field); + oprot.writeBinary(this.startKey); + oprot.writeFieldEnd(); + } + if (this.endKey != null) { + field.name = "endKey"; + field.type = TType.STRING; + field.id = 2; + oprot.writeFieldBegin(field); + oprot.writeBinary(this.endKey); + oprot.writeFieldEnd(); + } + field.name = "id"; + field.type = TType.I64; + field.id = 3; + oprot.writeFieldBegin(field); + oprot.writeI64(this.id); + oprot.writeFieldEnd(); + if (this.name != null) { + field.name = "name"; + field.type = TType.STRING; + field.id = 4; + oprot.writeFieldBegin(field); + oprot.writeBinary(this.name); + oprot.writeFieldEnd(); + } + field.name = "version"; + field.type = TType.BYTE; + field.id = 5; + oprot.writeFieldBegin(field); + oprot.writeByte(this.version); + oprot.writeFieldEnd(); + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + public String toString() { + StringBuilder sb = new StringBuilder("TRegionInfo("); + sb.append("startKey:"); + sb.append(this.startKey); + sb.append(",endKey:"); + sb.append(this.endKey); + sb.append(",id:"); + sb.append(this.id); + sb.append(",name:"); + sb.append(this.name); + sb.append(",version:"); + sb.append(this.version); + sb.append(")"); + return sb.toString(); + } + +} + diff --git a/src/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java b/src/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java new file mode 100644 index 00000000000..5aa801f36e9 --- /dev/null +++ b/src/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java @@ -0,0 +1,192 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + * Autogenerated by Thrift + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + */ +package org.apache.hadoop.hbase.thrift.generated; + +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.Set; +import java.util.HashSet; +import com.facebook.thrift.*; + +import com.facebook.thrift.protocol.*; +import com.facebook.thrift.transport.*; + +/** + * Holds row name and then a map of columns to cells. + */ +public class TRowResult implements TBase, java.io.Serializable { + public byte[] row; + public Map columns; + + public final Isset __isset = new Isset(); + public static final class Isset implements java.io.Serializable { + public boolean row = false; + public boolean columns = false; + } + + public TRowResult() { + } + + public TRowResult( + byte[] row, + Map columns) + { + this(); + this.row = row; + this.__isset.row = true; + this.columns = columns; + this.__isset.columns = true; + } + + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof TRowResult) + return this.equals((TRowResult)that); + return false; + } + + public boolean equals(TRowResult that) { + if (that == null) + return false; + + boolean this_present_row = true && (this.row != null); + boolean that_present_row = true && (that.row != null); + if (this_present_row || that_present_row) { + if (!(this_present_row && that_present_row)) + return false; + if (!java.util.Arrays.equals(this.row, that.row)) + return false; + } + + boolean this_present_columns = true && (this.columns != null); + boolean that_present_columns = true && (that.columns != null); + if (this_present_columns || that_present_columns) { + if (!(this_present_columns && that_present_columns)) + return false; + if (!this.columns.equals(that.columns)) + return false; + } + + return true; + } + + public int hashCode() { + return 0; + } + + public void read(TProtocol iprot) throws TException { + TField field; + iprot.readStructBegin(); + while (true) + { + field = iprot.readFieldBegin(); + if (field.type == TType.STOP) { + break; + } + switch (field.id) + { + case 1: + if (field.type == TType.STRING) { + this.row = iprot.readBinary(); + this.__isset.row = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + case 2: + if (field.type == TType.MAP) { + { + TMap _map4 = iprot.readMapBegin(); + this.columns = new HashMap(2*_map4.size); + for (int _i5 = 0; _i5 < _map4.size; ++_i5) + { + byte[] _key6; + TCell _val7; + _key6 = iprot.readBinary(); + _val7 = new TCell(); + _val7.read(iprot); + this.columns.put(_key6, _val7); + } + iprot.readMapEnd(); + } + this.__isset.columns = true; + } else { + TProtocolUtil.skip(iprot, field.type); + } + break; + default: + TProtocolUtil.skip(iprot, field.type); + break; + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + } + + public void write(TProtocol oprot) throws TException { + TStruct struct = new TStruct("TRowResult"); + oprot.writeStructBegin(struct); + TField field = new TField(); + if (this.row != null) { + field.name = "row"; + field.type = TType.STRING; + field.id = 1; + oprot.writeFieldBegin(field); + oprot.writeBinary(this.row); + oprot.writeFieldEnd(); + } + if (this.columns != null) { + field.name = "columns"; + field.type = TType.MAP; + field.id = 2; + oprot.writeFieldBegin(field); + { + oprot.writeMapBegin(new TMap(TType.STRING, TType.STRUCT, this.columns.size())); + for (byte[] _iter8 : this.columns.keySet()) { + oprot.writeBinary(_iter8); + this.columns.get(_iter8).write(oprot); + } + oprot.writeMapEnd(); + } + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + public String toString() { + StringBuilder sb = new StringBuilder("TRowResult("); + sb.append("row:"); + sb.append(this.row); + sb.append(",columns:"); + sb.append(this.columns); + sb.append(")"); + return sb.toString(); + } + +} +