HBASE-3942 The thrift scannerOpen functions should support row caching
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1130275 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack
parent
ce75265812
commit
fe8dce6636
|
|
@ -234,6 +234,8 @@ Release 0.91.0 - Unreleased
|
|||
HBASE-2937 Facilitate Timeouts In HBase Client (Karthick Sankarachary)
|
||||
HBASE-3921 Allow adding arbitrary blobs to Put (dhruba borthakur)
|
||||
HBASE-3931 Allow adding attributes to Get
|
||||
HBASE-3942 The thrift scannerOpen functions should support row caching
|
||||
(Adam Worthington)
|
||||
|
||||
TASKS
|
||||
HBASE-3559 Move report of split to master OFF the heartbeat channel
|
||||
|
|
|
|||
|
|
@ -68,6 +68,7 @@ import org.apache.hadoop.hbase.thrift.generated.Mutation;
|
|||
import org.apache.hadoop.hbase.thrift.generated.TCell;
|
||||
import org.apache.hadoop.hbase.thrift.generated.TRegionInfo;
|
||||
import org.apache.hadoop.hbase.thrift.generated.TRowResult;
|
||||
import org.apache.hadoop.hbase.thrift.generated.TScan;
|
||||
import org.apache.hadoop.hbase.util.Bytes;
|
||||
import org.apache.thrift.TException;
|
||||
import org.apache.thrift.protocol.TBinaryProtocol;
|
||||
|
|
@ -720,6 +721,39 @@ public class ThriftServer {
|
|||
public List<TRowResult> scannerGet(int id) throws IllegalArgument, IOError {
|
||||
return scannerGetList(id,1);
|
||||
}
|
||||
|
||||
public int scannerOpenWithScan(ByteBuffer tableName, TScan tScan) throws IOError {
|
||||
try {
|
||||
HTable table = getTable(tableName);
|
||||
Scan scan = new Scan();
|
||||
if (tScan.isSetStartRow()) {
|
||||
scan.setStartRow(tScan.getStartRow());
|
||||
}
|
||||
if (tScan.isSetStopRow()) {
|
||||
scan.setStopRow(tScan.getStopRow());
|
||||
}
|
||||
if (tScan.isSetTimestamp()) {
|
||||
scan.setTimeRange(Long.MIN_VALUE, tScan.getTimestamp());
|
||||
}
|
||||
if (tScan.isSetCaching()) {
|
||||
scan.setCaching(tScan.getCaching());
|
||||
}
|
||||
if(tScan.isSetColumns() && tScan.getColumns().size() != 0) {
|
||||
for(ByteBuffer column : tScan.getColumns()) {
|
||||
byte [][] famQf = KeyValue.parseColumn(getBytes(column));
|
||||
if(famQf.length == 1) {
|
||||
scan.addFamily(famQf[0]);
|
||||
} else {
|
||||
scan.addColumn(famQf[0], famQf[1]);
|
||||
}
|
||||
}
|
||||
}
|
||||
return addScanner(table.getScanner(scan));
|
||||
} catch (IOException e) {
|
||||
throw new IOError(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public int scannerOpen(ByteBuffer tableName, ByteBuffer startRow,
|
||||
List<ByteBuffer> columns) throws IOError {
|
||||
|
|
|
|||
File diff suppressed because it is too large
Load Diff
|
|
@ -0,0 +1,733 @@
|
|||
/**
|
||||
* 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.EnumMap;
|
||||
import java.util.Set;
|
||||
import java.util.HashSet;
|
||||
import java.util.EnumSet;
|
||||
import java.util.Collections;
|
||||
import java.util.BitSet;
|
||||
import java.nio.ByteBuffer;
|
||||
import java.util.Arrays;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
/**
|
||||
* A Scan object is used to specify scanner parameters when opening a scanner.
|
||||
*/
|
||||
public class TScan implements org.apache.thrift.TBase<TScan, TScan._Fields>, java.io.Serializable, Cloneable {
|
||||
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TScan");
|
||||
|
||||
private static final org.apache.thrift.protocol.TField START_ROW_FIELD_DESC = new org.apache.thrift.protocol.TField("startRow", org.apache.thrift.protocol.TType.STRING, (short)1);
|
||||
private static final org.apache.thrift.protocol.TField STOP_ROW_FIELD_DESC = new org.apache.thrift.protocol.TField("stopRow", org.apache.thrift.protocol.TType.STRING, (short)2);
|
||||
private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp", org.apache.thrift.protocol.TType.I64, (short)3);
|
||||
private static final org.apache.thrift.protocol.TField COLUMNS_FIELD_DESC = new org.apache.thrift.protocol.TField("columns", org.apache.thrift.protocol.TType.LIST, (short)4);
|
||||
private static final org.apache.thrift.protocol.TField CACHING_FIELD_DESC = new org.apache.thrift.protocol.TField("caching", org.apache.thrift.protocol.TType.I32, (short)5);
|
||||
|
||||
public ByteBuffer startRow;
|
||||
public ByteBuffer stopRow;
|
||||
public long timestamp;
|
||||
public List<ByteBuffer> columns;
|
||||
public int caching;
|
||||
|
||||
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
|
||||
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
|
||||
START_ROW((short)1, "startRow"),
|
||||
STOP_ROW((short)2, "stopRow"),
|
||||
TIMESTAMP((short)3, "timestamp"),
|
||||
COLUMNS((short)4, "columns"),
|
||||
CACHING((short)5, "caching");
|
||||
|
||||
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
|
||||
|
||||
static {
|
||||
for (_Fields field : EnumSet.allOf(_Fields.class)) {
|
||||
byName.put(field.getFieldName(), field);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Find the _Fields constant that matches fieldId, or null if its not found.
|
||||
*/
|
||||
public static _Fields findByThriftId(int fieldId) {
|
||||
switch(fieldId) {
|
||||
case 1: // START_ROW
|
||||
return START_ROW;
|
||||
case 2: // STOP_ROW
|
||||
return STOP_ROW;
|
||||
case 3: // TIMESTAMP
|
||||
return TIMESTAMP;
|
||||
case 4: // COLUMNS
|
||||
return COLUMNS;
|
||||
case 5: // CACHING
|
||||
return CACHING;
|
||||
default:
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Find the _Fields constant that matches fieldId, throwing an exception
|
||||
* if it is not found.
|
||||
*/
|
||||
public static _Fields findByThriftIdOrThrow(int fieldId) {
|
||||
_Fields fields = findByThriftId(fieldId);
|
||||
if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");
|
||||
return fields;
|
||||
}
|
||||
|
||||
/**
|
||||
* Find the _Fields constant that matches name, or null if its not found.
|
||||
*/
|
||||
public static _Fields findByName(String name) {
|
||||
return byName.get(name);
|
||||
}
|
||||
|
||||
private final short _thriftId;
|
||||
private final String _fieldName;
|
||||
|
||||
_Fields(short thriftId, String fieldName) {
|
||||
_thriftId = thriftId;
|
||||
_fieldName = fieldName;
|
||||
}
|
||||
|
||||
public short getThriftFieldId() {
|
||||
return _thriftId;
|
||||
}
|
||||
|
||||
public String getFieldName() {
|
||||
return _fieldName;
|
||||
}
|
||||
}
|
||||
|
||||
// isset id assignments
|
||||
private static final int __TIMESTAMP_ISSET_ID = 0;
|
||||
private static final int __CACHING_ISSET_ID = 1;
|
||||
private BitSet __isset_bit_vector = new BitSet(2);
|
||||
|
||||
public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
|
||||
static {
|
||||
Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
|
||||
tmpMap.put(_Fields.START_ROW, new org.apache.thrift.meta_data.FieldMetaData("startRow", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Text")));
|
||||
tmpMap.put(_Fields.STOP_ROW, new org.apache.thrift.meta_data.FieldMetaData("stopRow", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Text")));
|
||||
tmpMap.put(_Fields.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
|
||||
tmpMap.put(_Fields.COLUMNS, new org.apache.thrift.meta_data.FieldMetaData("columns", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING , "Text"))));
|
||||
tmpMap.put(_Fields.CACHING, new org.apache.thrift.meta_data.FieldMetaData("caching", org.apache.thrift.TFieldRequirementType.OPTIONAL,
|
||||
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32)));
|
||||
metaDataMap = Collections.unmodifiableMap(tmpMap);
|
||||
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TScan.class, metaDataMap);
|
||||
}
|
||||
|
||||
public TScan() {
|
||||
}
|
||||
|
||||
/**
|
||||
* Performs a deep copy on <i>other</i>.
|
||||
*/
|
||||
public TScan(TScan other) {
|
||||
__isset_bit_vector.clear();
|
||||
__isset_bit_vector.or(other.__isset_bit_vector);
|
||||
if (other.isSetStartRow()) {
|
||||
this.startRow = other.startRow;
|
||||
}
|
||||
if (other.isSetStopRow()) {
|
||||
this.stopRow = other.stopRow;
|
||||
}
|
||||
this.timestamp = other.timestamp;
|
||||
if (other.isSetColumns()) {
|
||||
List<ByteBuffer> __this__columns = new ArrayList<ByteBuffer>();
|
||||
for (ByteBuffer other_element : other.columns) {
|
||||
__this__columns.add(other_element);
|
||||
}
|
||||
this.columns = __this__columns;
|
||||
}
|
||||
this.caching = other.caching;
|
||||
}
|
||||
|
||||
public TScan deepCopy() {
|
||||
return new TScan(this);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void clear() {
|
||||
this.startRow = null;
|
||||
this.stopRow = null;
|
||||
setTimestampIsSet(false);
|
||||
this.timestamp = 0;
|
||||
this.columns = null;
|
||||
setCachingIsSet(false);
|
||||
this.caching = 0;
|
||||
}
|
||||
|
||||
public byte[] getStartRow() {
|
||||
setStartRow(org.apache.thrift.TBaseHelper.rightSize(startRow));
|
||||
return startRow == null ? null : startRow.array();
|
||||
}
|
||||
|
||||
public ByteBuffer bufferForStartRow() {
|
||||
return startRow;
|
||||
}
|
||||
|
||||
public TScan setStartRow(byte[] startRow) {
|
||||
setStartRow(startRow == null ? (ByteBuffer)null : ByteBuffer.wrap(startRow));
|
||||
return this;
|
||||
}
|
||||
|
||||
public TScan setStartRow(ByteBuffer startRow) {
|
||||
this.startRow = startRow;
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetStartRow() {
|
||||
this.startRow = null;
|
||||
}
|
||||
|
||||
/** Returns true if field startRow is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetStartRow() {
|
||||
return this.startRow != null;
|
||||
}
|
||||
|
||||
public void setStartRowIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.startRow = null;
|
||||
}
|
||||
}
|
||||
|
||||
public byte[] getStopRow() {
|
||||
setStopRow(org.apache.thrift.TBaseHelper.rightSize(stopRow));
|
||||
return stopRow == null ? null : stopRow.array();
|
||||
}
|
||||
|
||||
public ByteBuffer bufferForStopRow() {
|
||||
return stopRow;
|
||||
}
|
||||
|
||||
public TScan setStopRow(byte[] stopRow) {
|
||||
setStopRow(stopRow == null ? (ByteBuffer)null : ByteBuffer.wrap(stopRow));
|
||||
return this;
|
||||
}
|
||||
|
||||
public TScan setStopRow(ByteBuffer stopRow) {
|
||||
this.stopRow = stopRow;
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetStopRow() {
|
||||
this.stopRow = null;
|
||||
}
|
||||
|
||||
/** Returns true if field stopRow is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetStopRow() {
|
||||
return this.stopRow != null;
|
||||
}
|
||||
|
||||
public void setStopRowIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.stopRow = null;
|
||||
}
|
||||
}
|
||||
|
||||
public long getTimestamp() {
|
||||
return this.timestamp;
|
||||
}
|
||||
|
||||
public TScan setTimestamp(long timestamp) {
|
||||
this.timestamp = timestamp;
|
||||
setTimestampIsSet(true);
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetTimestamp() {
|
||||
__isset_bit_vector.clear(__TIMESTAMP_ISSET_ID);
|
||||
}
|
||||
|
||||
/** Returns true if field timestamp is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetTimestamp() {
|
||||
return __isset_bit_vector.get(__TIMESTAMP_ISSET_ID);
|
||||
}
|
||||
|
||||
public void setTimestampIsSet(boolean value) {
|
||||
__isset_bit_vector.set(__TIMESTAMP_ISSET_ID, value);
|
||||
}
|
||||
|
||||
public int getColumnsSize() {
|
||||
return (this.columns == null) ? 0 : this.columns.size();
|
||||
}
|
||||
|
||||
public java.util.Iterator<ByteBuffer> getColumnsIterator() {
|
||||
return (this.columns == null) ? null : this.columns.iterator();
|
||||
}
|
||||
|
||||
public void addToColumns(ByteBuffer elem) {
|
||||
if (this.columns == null) {
|
||||
this.columns = new ArrayList<ByteBuffer>();
|
||||
}
|
||||
this.columns.add(elem);
|
||||
}
|
||||
|
||||
public List<ByteBuffer> getColumns() {
|
||||
return this.columns;
|
||||
}
|
||||
|
||||
public TScan setColumns(List<ByteBuffer> columns) {
|
||||
this.columns = columns;
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetColumns() {
|
||||
this.columns = null;
|
||||
}
|
||||
|
||||
/** Returns true if field columns is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetColumns() {
|
||||
return this.columns != null;
|
||||
}
|
||||
|
||||
public void setColumnsIsSet(boolean value) {
|
||||
if (!value) {
|
||||
this.columns = null;
|
||||
}
|
||||
}
|
||||
|
||||
public int getCaching() {
|
||||
return this.caching;
|
||||
}
|
||||
|
||||
public TScan setCaching(int caching) {
|
||||
this.caching = caching;
|
||||
setCachingIsSet(true);
|
||||
return this;
|
||||
}
|
||||
|
||||
public void unsetCaching() {
|
||||
__isset_bit_vector.clear(__CACHING_ISSET_ID);
|
||||
}
|
||||
|
||||
/** Returns true if field caching is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSetCaching() {
|
||||
return __isset_bit_vector.get(__CACHING_ISSET_ID);
|
||||
}
|
||||
|
||||
public void setCachingIsSet(boolean value) {
|
||||
__isset_bit_vector.set(__CACHING_ISSET_ID, value);
|
||||
}
|
||||
|
||||
public void setFieldValue(_Fields field, Object value) {
|
||||
switch (field) {
|
||||
case START_ROW:
|
||||
if (value == null) {
|
||||
unsetStartRow();
|
||||
} else {
|
||||
setStartRow((ByteBuffer)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case STOP_ROW:
|
||||
if (value == null) {
|
||||
unsetStopRow();
|
||||
} else {
|
||||
setStopRow((ByteBuffer)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case TIMESTAMP:
|
||||
if (value == null) {
|
||||
unsetTimestamp();
|
||||
} else {
|
||||
setTimestamp((Long)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case COLUMNS:
|
||||
if (value == null) {
|
||||
unsetColumns();
|
||||
} else {
|
||||
setColumns((List<ByteBuffer>)value);
|
||||
}
|
||||
break;
|
||||
|
||||
case CACHING:
|
||||
if (value == null) {
|
||||
unsetCaching();
|
||||
} else {
|
||||
setCaching((Integer)value);
|
||||
}
|
||||
break;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
public Object getFieldValue(_Fields field) {
|
||||
switch (field) {
|
||||
case START_ROW:
|
||||
return getStartRow();
|
||||
|
||||
case STOP_ROW:
|
||||
return getStopRow();
|
||||
|
||||
case TIMESTAMP:
|
||||
return new Long(getTimestamp());
|
||||
|
||||
case COLUMNS:
|
||||
return getColumns();
|
||||
|
||||
case CACHING:
|
||||
return new Integer(getCaching());
|
||||
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
||||
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
|
||||
public boolean isSet(_Fields field) {
|
||||
if (field == null) {
|
||||
throw new IllegalArgumentException();
|
||||
}
|
||||
|
||||
switch (field) {
|
||||
case START_ROW:
|
||||
return isSetStartRow();
|
||||
case STOP_ROW:
|
||||
return isSetStopRow();
|
||||
case TIMESTAMP:
|
||||
return isSetTimestamp();
|
||||
case COLUMNS:
|
||||
return isSetColumns();
|
||||
case CACHING:
|
||||
return isSetCaching();
|
||||
}
|
||||
throw new IllegalStateException();
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
if (that instanceof TScan)
|
||||
return this.equals((TScan)that);
|
||||
return false;
|
||||
}
|
||||
|
||||
public boolean equals(TScan that) {
|
||||
if (that == null)
|
||||
return false;
|
||||
|
||||
boolean this_present_startRow = true && this.isSetStartRow();
|
||||
boolean that_present_startRow = true && that.isSetStartRow();
|
||||
if (this_present_startRow || that_present_startRow) {
|
||||
if (!(this_present_startRow && that_present_startRow))
|
||||
return false;
|
||||
if (!this.startRow.equals(that.startRow))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_stopRow = true && this.isSetStopRow();
|
||||
boolean that_present_stopRow = true && that.isSetStopRow();
|
||||
if (this_present_stopRow || that_present_stopRow) {
|
||||
if (!(this_present_stopRow && that_present_stopRow))
|
||||
return false;
|
||||
if (!this.stopRow.equals(that.stopRow))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_timestamp = true && this.isSetTimestamp();
|
||||
boolean that_present_timestamp = true && that.isSetTimestamp();
|
||||
if (this_present_timestamp || that_present_timestamp) {
|
||||
if (!(this_present_timestamp && that_present_timestamp))
|
||||
return false;
|
||||
if (this.timestamp != that.timestamp)
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_columns = true && this.isSetColumns();
|
||||
boolean that_present_columns = true && that.isSetColumns();
|
||||
if (this_present_columns || that_present_columns) {
|
||||
if (!(this_present_columns && that_present_columns))
|
||||
return false;
|
||||
if (!this.columns.equals(that.columns))
|
||||
return false;
|
||||
}
|
||||
|
||||
boolean this_present_caching = true && this.isSetCaching();
|
||||
boolean that_present_caching = true && that.isSetCaching();
|
||||
if (this_present_caching || that_present_caching) {
|
||||
if (!(this_present_caching && that_present_caching))
|
||||
return false;
|
||||
if (this.caching != that.caching)
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
public int compareTo(TScan other) {
|
||||
if (!getClass().equals(other.getClass())) {
|
||||
return getClass().getName().compareTo(other.getClass().getName());
|
||||
}
|
||||
|
||||
int lastComparison = 0;
|
||||
TScan typedOther = (TScan)other;
|
||||
|
||||
lastComparison = Boolean.valueOf(isSetStartRow()).compareTo(typedOther.isSetStartRow());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetStartRow()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.startRow, typedOther.startRow);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetStopRow()).compareTo(typedOther.isSetStopRow());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetStopRow()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.stopRow, typedOther.stopRow);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetTimestamp()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, typedOther.timestamp);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetColumns()).compareTo(typedOther.isSetColumns());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetColumns()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.columns, typedOther.columns);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
lastComparison = Boolean.valueOf(isSetCaching()).compareTo(typedOther.isSetCaching());
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
if (isSetCaching()) {
|
||||
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.caching, typedOther.caching);
|
||||
if (lastComparison != 0) {
|
||||
return lastComparison;
|
||||
}
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
public _Fields fieldForId(int fieldId) {
|
||||
return _Fields.findByThriftId(fieldId);
|
||||
}
|
||||
|
||||
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {
|
||||
org.apache.thrift.protocol.TField field;
|
||||
iprot.readStructBegin();
|
||||
while (true)
|
||||
{
|
||||
field = iprot.readFieldBegin();
|
||||
if (field.type == org.apache.thrift.protocol.TType.STOP) {
|
||||
break;
|
||||
}
|
||||
switch (field.id) {
|
||||
case 1: // START_ROW
|
||||
if (field.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
this.startRow = iprot.readBinary();
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
case 2: // STOP_ROW
|
||||
if (field.type == org.apache.thrift.protocol.TType.STRING) {
|
||||
this.stopRow = iprot.readBinary();
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
case 3: // TIMESTAMP
|
||||
if (field.type == org.apache.thrift.protocol.TType.I64) {
|
||||
this.timestamp = iprot.readI64();
|
||||
setTimestampIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
case 4: // COLUMNS
|
||||
if (field.type == org.apache.thrift.protocol.TType.LIST) {
|
||||
{
|
||||
org.apache.thrift.protocol.TList _list9 = iprot.readListBegin();
|
||||
this.columns = new ArrayList<ByteBuffer>(_list9.size);
|
||||
for (int _i10 = 0; _i10 < _list9.size; ++_i10)
|
||||
{
|
||||
ByteBuffer _elem11;
|
||||
_elem11 = iprot.readBinary();
|
||||
this.columns.add(_elem11);
|
||||
}
|
||||
iprot.readListEnd();
|
||||
}
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
case 5: // CACHING
|
||||
if (field.type == org.apache.thrift.protocol.TType.I32) {
|
||||
this.caching = iprot.readI32();
|
||||
setCachingIsSet(true);
|
||||
} else {
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
break;
|
||||
default:
|
||||
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
|
||||
}
|
||||
iprot.readFieldEnd();
|
||||
}
|
||||
iprot.readStructEnd();
|
||||
|
||||
// check for required fields of primitive type, which can't be checked in the validate method
|
||||
validate();
|
||||
}
|
||||
|
||||
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
|
||||
validate();
|
||||
|
||||
oprot.writeStructBegin(STRUCT_DESC);
|
||||
if (this.startRow != null) {
|
||||
if (isSetStartRow()) {
|
||||
oprot.writeFieldBegin(START_ROW_FIELD_DESC);
|
||||
oprot.writeBinary(this.startRow);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
if (this.stopRow != null) {
|
||||
if (isSetStopRow()) {
|
||||
oprot.writeFieldBegin(STOP_ROW_FIELD_DESC);
|
||||
oprot.writeBinary(this.stopRow);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
if (isSetTimestamp()) {
|
||||
oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC);
|
||||
oprot.writeI64(this.timestamp);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
if (this.columns != null) {
|
||||
if (isSetColumns()) {
|
||||
oprot.writeFieldBegin(COLUMNS_FIELD_DESC);
|
||||
{
|
||||
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, this.columns.size()));
|
||||
for (ByteBuffer _iter12 : this.columns)
|
||||
{
|
||||
oprot.writeBinary(_iter12);
|
||||
}
|
||||
oprot.writeListEnd();
|
||||
}
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
}
|
||||
if (isSetCaching()) {
|
||||
oprot.writeFieldBegin(CACHING_FIELD_DESC);
|
||||
oprot.writeI32(this.caching);
|
||||
oprot.writeFieldEnd();
|
||||
}
|
||||
oprot.writeFieldStop();
|
||||
oprot.writeStructEnd();
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
StringBuilder sb = new StringBuilder("TScan(");
|
||||
boolean first = true;
|
||||
|
||||
if (isSetStartRow()) {
|
||||
sb.append("startRow:");
|
||||
if (this.startRow == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.startRow);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
if (isSetStopRow()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("stopRow:");
|
||||
if (this.stopRow == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.stopRow);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
if (isSetTimestamp()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("timestamp:");
|
||||
sb.append(this.timestamp);
|
||||
first = false;
|
||||
}
|
||||
if (isSetColumns()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("columns:");
|
||||
if (this.columns == null) {
|
||||
sb.append("null");
|
||||
} else {
|
||||
sb.append(this.columns);
|
||||
}
|
||||
first = false;
|
||||
}
|
||||
if (isSetCaching()) {
|
||||
if (!first) sb.append(", ");
|
||||
sb.append("caching:");
|
||||
sb.append(this.caching);
|
||||
first = false;
|
||||
}
|
||||
sb.append(")");
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
public void validate() throws org.apache.thrift.TException {
|
||||
// check for required fields
|
||||
}
|
||||
|
||||
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {
|
||||
try {
|
||||
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));
|
||||
} catch (org.apache.thrift.TException te) {
|
||||
throw new java.io.IOException(te);
|
||||
}
|
||||
}
|
||||
|
||||
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
|
||||
try {
|
||||
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
|
||||
__isset_bit_vector = new BitSet(1);
|
||||
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
|
||||
} catch (org.apache.thrift.TException te) {
|
||||
throw new java.io.IOException(te);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
|
@ -116,6 +116,17 @@ struct TRowResult {
|
|||
2:map<Text, TCell> columns
|
||||
}
|
||||
|
||||
/**
|
||||
* A Scan object is used to specify scanner parameters when opening a scanner.
|
||||
*/
|
||||
struct TScan {
|
||||
1:optional Text startRow,
|
||||
2:optional Text stopRow,
|
||||
3:optional i64 timestamp,
|
||||
4:optional list<Text> columns,
|
||||
5:optional i32 caching
|
||||
}
|
||||
|
||||
//
|
||||
// Exceptions
|
||||
//
|
||||
|
|
@ -573,6 +584,18 @@ service Hbase {
|
|||
3:i64 timestamp
|
||||
) throws (1:IOError io)
|
||||
|
||||
/**
|
||||
* Get a scanner on the current table, using the Scan instance
|
||||
* for the scan parameters.
|
||||
*/
|
||||
ScannerID scannerOpenWithScan(
|
||||
/** name of table */
|
||||
1:Text tableName,
|
||||
|
||||
/** Scan instance */
|
||||
2:TScan scan
|
||||
) throws (1:IOError io)
|
||||
|
||||
/**
|
||||
* Get a scanner on the current table starting at the specified row and
|
||||
* ending at the last row in the table. Return the specified columns.
|
||||
|
|
|
|||
Loading…
Reference in New Issue