Java 类org.apache.hadoop.hbase.thrift.generated.TCell 实例源码

项目：ditb 文件：ThriftServerRunner.java

/**
 * Note: this public interface is slightly different from public Java APIs in regard to
 * handling of the qualifier. Here we differ from the public Java API in that null != byte[0].
 * Rather, we respect qual == null as a request for the entire column family. If you want to
 * access the entire column family, use
 * {@link #getVer(ByteBuffer, ByteBuffer, ByteBuffer, int, Map)} with a {@code column} value
 * that lacks a {@code ':'}.
 */
public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, int numVersions, Map<ByteBuffer, ByteBuffer> attributes) throws IOError {

  Table table = null;
  try {
    table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(Throwables.getStackTraceAsString(e));
  } finally{
    closeTable(table);
  }
}

项目：ditb 文件：ThriftServerRunner.java

/**
 * Note: this internal interface is slightly different from public APIs in regard to handling
 * of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather,
 * we respect qual == null as a request for the entire column family. The caller (
 * {@link #getVerTs(ByteBuffer, ByteBuffer, ByteBuffer, long, int, Map)}) interface IS
 * consistent in that the column is parse like normal.
 */
protected List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, long timestamp, int numVersions, Map<ByteBuffer, ByteBuffer> attributes)
    throws IOError {

  Table table = null;
  try {
    table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setTimeRange(0, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(Throwables.getStackTraceAsString(e));
  } finally{
    closeTable(table);
  }
}

项目：ditb 文件：HttpDoAsClient.java

private void printRow(TRowResult rowResult) {
  // copy values into a TreeMap to get them in sorted order

  TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
  for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
    sorted.put(utf8(column.getKey().array()), column.getValue());
  }

  StringBuilder rowStr = new StringBuilder();
  for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
    rowStr.append(entry.getKey());
    rowStr.append(" => ");
    rowStr.append(utf8(entry.getValue().value.array()));
    rowStr.append("; ");
  }
  System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：ditb 文件：DemoClient.java

private void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：LCIndex-HBase-0.94.16 文件：DemoClient.java

private final void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：LCIndex-HBase-0.94.16 文件：ThriftServerRunner.java

public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row,
                          byte[] family,
    byte[] qualifier, int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    get.addColumn(family, qualifier);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.raw());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：LCIndex-HBase-0.94.16 文件：ThriftServerRunner.java

@Deprecated
@Override
public List<TCell> getVerTs(ByteBuffer tableName,
                               ByteBuffer row,
    ByteBuffer column,
    long timestamp,
    int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  byte [][] famAndQf = KeyValue.parseColumn(getBytes(column));
  if(famAndQf.length == 1) {
    return getVerTs(tableName, row, famAndQf[0], new byte[0], timestamp,
        numVersions, attributes);
  }
  return getVerTs(tableName, row, famAndQf[0], famAndQf[1], timestamp,
      numVersions, attributes);
}

项目：LCIndex-HBase-0.94.16 文件：ThriftServerRunner.java

protected List<TCell> getVerTs(ByteBuffer tableName,
                               ByteBuffer row, byte [] family,
    byte [] qualifier, long timestamp, int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    get.addColumn(family, qualifier);
    get.setTimeRange(Long.MIN_VALUE, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.raw());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：pbase 文件：HttpDoAsClient.java

private void printRow(TRowResult rowResult) {
  // copy values into a TreeMap to get them in sorted order

  TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
  for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
    sorted.put(utf8(column.getKey().array()), column.getValue());
  }

  StringBuilder rowStr = new StringBuilder();
  for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
    rowStr.append(entry.getKey());
    rowStr.append(" => ");
    rowStr.append(utf8(entry.getValue().value.array()));
    rowStr.append("; ");
  }
  System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：pbase 文件：DemoClient.java

private void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：HIndex 文件：ThriftServerRunner.java

/**
 * Note: this public interface is slightly different from public Java APIs in regard to
 * handling of the qualifier. Here we differ from the public Java API in that null != byte[0].
 * Rather, we respect qual == null as a request for the entire column family. If you want to
 * access the entire column family, use
 * {@link #getVer(ByteBuffer, ByteBuffer, ByteBuffer, int, Map)} with a {@code column} value
 * that lacks a {@code ':'}.
 */
public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, int numVersions, Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：HIndex 文件：ThriftServerRunner.java

/**
 * Note: this internal interface is slightly different from public APIs in regard to handling
 * of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather,
 * we respect qual == null as a request for the entire column family. The caller (
 * {@link #getVerTs(ByteBuffer, ByteBuffer, ByteBuffer, long, int, Map)}) interface IS
 * consistent in that the column is parse like normal.
 */
protected List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, long timestamp, int numVersions, Map<ByteBuffer, ByteBuffer> attributes)
    throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setTimeRange(0, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：HIndex 文件：DemoClient.java

private void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：openyu-commons 文件：HBaseThriftDMLTest.java

/**
 * 列印TRowResult
 *
 * @param result
 */
public static void printlnResult(TRowResult result) {
    StringBuilder buff = new StringBuilder();
    Map<ByteBuffer, TCell> columns = result.getColumns();
    int size = columns.size();
    //
    buff.append(ByteHelper.toString(result.getRow()) + ", ");// rowKey
    int i = 0;
    for (Map.Entry<ByteBuffer, TCell> entry : columns.entrySet()) {
        buff.append(ByteBufferHelper.toString(entry.getKey()));
        buff.append("=");
        buff.append(ByteHelper.toString((entry.getValue().getValue())));
        //
        if (i < size - 1) {
            buff.append(", ");
        }
        i++;
    }
    System.out.println(buff);
}

项目：IRIndex 文件：DemoClient.java

private final void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：IRIndex 文件：ThriftServerRunner.java

public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row,
                          byte[] family,
    byte[] qualifier, int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    get.addColumn(family, qualifier);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.raw());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：IRIndex 文件：ThriftServerRunner.java

@Deprecated
@Override
public List<TCell> getVerTs(ByteBuffer tableName,
                               ByteBuffer row,
    ByteBuffer column,
    long timestamp,
    int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  byte [][] famAndQf = KeyValue.parseColumn(getBytes(column));
  if(famAndQf.length == 1) {
    return getVerTs(tableName, row, famAndQf[0], new byte[0], timestamp,
        numVersions, attributes);
  }
  return getVerTs(tableName, row, famAndQf[0], famAndQf[1], timestamp,
      numVersions, attributes);
}

项目：IRIndex 文件：ThriftServerRunner.java

protected List<TCell> getVerTs(ByteBuffer tableName,
                               ByteBuffer row, byte [] family,
    byte [] qualifier, long timestamp, int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    get.addColumn(family, qualifier);
    get.setTimeRange(Long.MIN_VALUE, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.raw());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：hbase 文件：ThriftServerRunner.java

/**
 * Note: this public interface is slightly different from public Java APIs in regard to
 * handling of the qualifier. Here we differ from the public Java API in that null != byte[0].
 * Rather, we respect qual == null as a request for the entire column family. If you want to
 * access the entire column family, use
 * {@link #getVer(ByteBuffer, ByteBuffer, ByteBuffer, int, Map)} with a {@code column} value
 * that lacks a {@code ':'}.
 */
public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, int numVersions, Map<ByteBuffer, ByteBuffer> attributes) throws IOError {

  Table table = null;
  try {
    table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw getIOError(e);
  } finally{
    closeTable(table);
  }
}

项目：hbase 文件：ThriftServerRunner.java

/**
 * Note: this internal interface is slightly different from public APIs in regard to handling
 * of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather,
 * we respect qual == null as a request for the entire column family. The caller (
 * {@link #getVerTs(ByteBuffer, ByteBuffer, ByteBuffer, long, int, Map)}) interface IS
 * consistent in that the column is parse like normal.
 */
protected List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, long timestamp, int numVersions, Map<ByteBuffer, ByteBuffer> attributes)
    throws IOError {

  Table table = null;
  try {
    table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setTimeRange(0, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw getIOError(e);
  } finally{
    closeTable(table);
  }
}

项目：hbase 文件：HttpDoAsClient.java

private void printRow(TRowResult rowResult) {
  // copy values into a TreeMap to get them in sorted order

  TreeMap<String, TCell> sorted = new TreeMap<>();
  for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
    sorted.put(utf8(column.getKey().array()), column.getValue());
  }

  StringBuilder rowStr = new StringBuilder();
  for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
    rowStr.append(entry.getKey());
    rowStr.append(" => ");
    rowStr.append(utf8(entry.getValue().value.array()));
    rowStr.append("; ");
  }
  System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：hbase 文件：DemoClient.java

private void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：RStore 文件：ThriftUtilities.java

/**
 * This utility method creates a list of Thrift TRowResult "struct" based on
 * an Hbase RowResult object. The empty list is returned if the input is
 * null.
 *
 * @param in
 *          Hbase RowResult object
 * @return Thrift TRowResult array
 */
static public List<TRowResult> rowResultFromHBase(Result[] in) {
  List<TRowResult> results = new ArrayList<TRowResult>();
  for ( Result result_ : in) {
      if(result_ == null || result_.isEmpty()) {
          continue;
      }
      TRowResult result = new TRowResult();
      result.row = ByteBuffer.wrap(result_.getRow());
      result.columns = new TreeMap<ByteBuffer, TCell>();
      for(KeyValue kv : result_.raw()) {
        result.columns.put(
            ByteBuffer.wrap(KeyValue.makeColumn(kv.getFamily(),
                kv.getQualifier())),
            new TCell(ByteBuffer.wrap(kv.getValue()), kv.getTimestamp()));
      }
    results.add(result);
  }
  return results;
}

项目：PyroDB 文件：ThriftServerRunner.java

/**
 * Note: this public interface is slightly different from public Java APIs in regard to
 * handling of the qualifier. Here we differ from the public Java API in that null != byte[0].
 * Rather, we respect qual == null as a request for the entire column family. If you want to
 * access the entire column family, use
 * {@link #getVer(ByteBuffer, ByteBuffer, ByteBuffer, int, Map)} with a {@code column} value
 * that lacks a {@code ':'}.
 */
public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, int numVersions, Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：PyroDB 文件：ThriftServerRunner.java

/**
 * Note: this internal interface is slightly different from public APIs in regard to handling
 * of the qualifier. Here we differ from the public Java API in that null != byte[0]. Rather,
 * we respect qual == null as a request for the entire column family. The caller (
 * {@link #getVerTs(ByteBuffer, ByteBuffer, ByteBuffer, long, int, Map)}) interface IS
 * consistent in that the column is parse like normal.
 */
protected List<TCell> getVerTs(ByteBuffer tableName, ByteBuffer row, byte[] family,
    byte[] qualifier, long timestamp, int numVersions, Map<ByteBuffer, ByteBuffer> attributes)
    throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    if (null == qualifier) {
      get.addFamily(family);
    } else {
      get.addColumn(family, qualifier);
    }
    get.setTimeRange(0, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.rawCells());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：PyroDB 文件：DemoClient.java

private void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：HBase-Research 文件：DemoClient.java

private final void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：HBase-Research 文件：ThriftUtilities.java

/**
 * This utility method creates a list of Thrift TRowResult "struct" based on
 * an Hbase RowResult object. The empty list is returned if the input is
 * null.
 *
 * @param in
 *          Hbase RowResult object
 * @return Thrift TRowResult array
 */
static public List<TRowResult> rowResultFromHBase(Result[] in) {
  List<TRowResult> results = new ArrayList<TRowResult>();
  for ( Result result_ : in) {
      if(result_ == null || result_.isEmpty()) {
          continue;
      }
      TRowResult result = new TRowResult();
      result.row = ByteBuffer.wrap(result_.getRow());
      result.columns = new TreeMap<ByteBuffer, TCell>();
      for(KeyValue kv : result_.raw()) {
        result.columns.put(
            ByteBuffer.wrap(KeyValue.makeColumn(kv.getFamily(),
                kv.getQualifier())),
            new TCell(ByteBuffer.wrap(kv.getValue()), kv.getTimestamp()));
      }
    results.add(result);
  }
  return results;
}

项目：HBase-Research 文件：ThriftServerRunner.java

public List<TCell> getVer(ByteBuffer tableName, ByteBuffer row,
                          byte[] family,
    byte[] qualifier, int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    get.addColumn(family, qualifier);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.raw());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：HBase-Research 文件：ThriftServerRunner.java

@Deprecated
@Override
public List<TCell> getVerTs(ByteBuffer tableName,
                               ByteBuffer row,
    ByteBuffer column,
    long timestamp,
    int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  byte [][] famAndQf = KeyValue.parseColumn(getBytes(column));
  if(famAndQf.length == 1) {
    return getVerTs(tableName, row, famAndQf[0], new byte[0], timestamp,
        numVersions, attributes);
  }
  return getVerTs(tableName, row, famAndQf[0], famAndQf[1], timestamp,
      numVersions, attributes);
}

项目：HBase-Research 文件：ThriftServerRunner.java

protected List<TCell> getVerTs(ByteBuffer tableName,
                               ByteBuffer row, byte [] family,
    byte [] qualifier, long timestamp, int numVersions,
    Map<ByteBuffer, ByteBuffer> attributes) throws IOError {
  try {
    HTable table = getTable(tableName);
    Get get = new Get(getBytes(row));
    addAttributes(get, attributes);
    get.addColumn(family, qualifier);
    get.setTimeRange(Long.MIN_VALUE, timestamp);
    get.setMaxVersions(numVersions);
    Result result = table.get(get);
    return ThriftUtilities.cellFromHBase(result.raw());
  } catch (IOException e) {
    LOG.warn(e.getMessage(), e);
    throw new IOError(e.getMessage());
  }
}

项目：hbase-0.94.8-qod 文件：DemoClient.java

private final void printRow(TRowResult rowResult) {
    // copy values into a TreeMap to get them in sorted order

    TreeMap<String, TCell> sorted = new TreeMap<String, TCell>();
    for (Map.Entry<ByteBuffer, TCell> column : rowResult.columns.entrySet()) {
        sorted.put(utf8(column.getKey().array()), column.getValue());
    }

    StringBuilder rowStr = new StringBuilder();
    for (SortedMap.Entry<String, TCell> entry : sorted.entrySet()) {
        rowStr.append(entry.getKey());
        rowStr.append(" => ");
        rowStr.append(utf8(entry.getValue().value.array()));
        rowStr.append("; ");
    }
    System.out.println("row: " + utf8(rowResult.row.array()) + ", cols: " + rowStr);
}

项目：hbase-0.94.8-qod 文件：ThriftUtilities.java

/**
 * This utility method creates a list of Thrift TRowResult "struct" based on
 * an Hbase RowResult object. The empty list is returned if the input is
 * null.
 *
 * @param in
 *          Hbase RowResult object
 * @return Thrift TRowResult array
 */
static public List<TRowResult> rowResultFromHBase(Result[] in) {
  List<TRowResult> results = new ArrayList<TRowResult>();
  for ( Result result_ : in) {
      if(result_ == null || result_.isEmpty()) {
          continue;
      }
      TRowResult result = new TRowResult();
      result.row = ByteBuffer.wrap(result_.getRow());
      result.columns = new TreeMap<ByteBuffer, TCell>();
      for(KeyValue kv : result_.raw()) {
        result.columns.put(
            ByteBuffer.wrap(KeyValue.makeColumn(kv.getFamily(),
                kv.getQualifier())),
            new TCell(ByteBuffer.wrap(kv.getValue()), kv.getTimestamp()));
      }
    results.add(result);
  }
  return results;
}