This commit is contained in:
温少
2012-05-21 14:57:38 +08:00
parent 5d3e0093a2
commit 43442071fc
2 changed files with 9 additions and 10 deletions
@@ -124,7 +124,6 @@ public class SingleTableQueryExecutePlan extends SingleTableExecutePlan {
HScannerResultSet resultSet = new HScannerResultSet(statement, htable, scanner);
resultSet.setMetaData(resultMetaData);
resultSet.setMapping(mapping);
return resultSet;
} catch (SQLException e) {
@@ -13,18 +13,18 @@ import org.apache.hadoop.hbase.util.Bytes;
import com.alibaba.druid.common.jdbc.ResultSetBase;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase.ColumnMetaData;
import com.alibaba.druid.hbase.mapping.HMappingTable;
import com.alibaba.druid.hbase.mapping.HMapping;
import com.alibaba.druid.util.JdbcUtils;
public class HScannerResultSet extends ResultSetBase implements HResultSet {
private HStatement statement;
private ResultScanner scanner;
private HTableInterface htable;
private Result result;
private byte[] family = Bytes.toBytes("d");
private HStatement statement;
private ResultScanner scanner;
private HTableInterface htable;
private Result result;
private byte[] family = Bytes.toBytes("d");
private HMappingTable mapping;
private HMapping mapping;
public HScannerResultSet(HStatement statement, HTableInterface htable, ResultScanner scanner){
super(statement);
@@ -33,11 +33,11 @@ public class HScannerResultSet extends ResultSetBase implements HResultSet {
this.scanner = scanner;
}
public HMappingTable getMapping() {
public HMapping getMapping() {
return mapping;
}
public void setMapping(HMappingTable mapping) {
public void setMapping(HMapping mapping) {
this.mapping = mapping;
}