org.apache.hadoop.hbase.Cell.getTypeByte()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(165)

本文整理了Java中org.apache.hadoop.hbase.Cell.getTypeByte()方法的一些代码示例,展示了Cell.getTypeByte()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Cell.getTypeByte()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.Cell
类名称:Cell
方法名:getTypeByte

Cell.getTypeByte介绍

暂无

代码示例

代码示例来源:origin: apache/hbase

@Override
public byte getTypeByte() {
 return cell.getTypeByte();
}

代码示例来源:origin: apache/hbase

@Override
public byte getTypeByte() {
 return cell.getTypeByte();
}

代码示例来源:origin: apache/hbase

@Override
public byte getTypeByte() {
 return this.cell.getTypeByte();
}

代码示例来源:origin: apache/hbase

@Override
public byte getTypeByte() {
 return cell.getTypeByte();
}

代码示例来源:origin: apache/hbase

/**
 * @param previousCell
 * @param cell
 * @return True if we have crossed over onto a new row or type
 */
private boolean isNewRowOrType(final Cell previousCell, final Cell cell) {
 return previousCell == null || previousCell.getTypeByte() != cell.getTypeByte() ||
   !CellUtil.matchingRows(previousCell, cell);
}

代码示例来源:origin: apache/hbase

/**
 * @return True if a delete type, a {@link KeyValue.Type#Delete} or a
 *         {KeyValue.Type#DeleteFamily} or a
 *         {@link KeyValue.Type#DeleteColumn} KeyValue type.
 */
@SuppressWarnings("deprecation")
public static boolean isDelete(final Cell cell) {
 return PrivateCellUtil.isDelete(cell.getTypeByte());
}

代码示例来源:origin: apache/hbase

/**
 * @return True if this cell is a {@link KeyValue.Type#Delete} type.
 */
public static boolean isDeleteType(Cell cell) {
 return cell.getTypeByte() == KeyValue.Type.Delete.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 */
@Deprecated
public static boolean isDeleteFamily(final Cell cell) {
 return cell.getTypeByte() == Type.DeleteFamily.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 */
@Deprecated
public static boolean isDeleteColumnVersion(final Cell cell) {
 return cell.getTypeByte() == Type.Delete.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @return True if this cell is a Put.
 */
@SuppressWarnings("deprecation")
public static boolean isPut(Cell cell) {
 return cell.getTypeByte() == Type.Put.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 */
@Deprecated
public static boolean isDeleteColumns(final Cell cell) {
 return cell.getTypeByte() == Type.DeleteColumn.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @return True if this cell is a {@link KeyValue.Type#Delete} type.
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 */
@Deprecated
public static boolean isDeleteType(Cell cell) {
 return cell.getTypeByte() == Type.Delete.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 */
@Deprecated
public static boolean isDeleteFamilyVersion(final Cell cell) {
 return cell.getTypeByte() == Type.DeleteFamilyVersion.getCode();
}

代码示例来源:origin: apache/hbase

/**
 *
 * @return True if this cell is a delete family or column type.
 * @deprecated As of release 2.0.0, this will be removed in HBase 3.0.0.
 */
@Deprecated
public static boolean isDeleteColumnOrFamily(Cell cell) {
 int t = cell.getTypeByte();
 return t == Type.DeleteColumn.getCode() || t == Type.DeleteFamily.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * @return True if this cell is a delete family or column type.
 */
public static boolean isDeleteColumnOrFamily(Cell cell) {
 int t = cell.getTypeByte();
 return t == KeyValue.Type.DeleteColumn.getCode() || t == KeyValue.Type.DeleteFamily.getCode();
}

代码示例来源:origin: apache/hbase

/**
 * Record the earlest Put timestamp.
 *
 * If the timeRangeTracker is not set,
 * update TimeRangeTracker to include the timestamp of this key
 */
public void trackTimestamps(final Cell cell) {
 if (KeyValue.Type.Put.getCode() == cell.getTypeByte()) {
  earliestPutTs = Math.min(earliestPutTs, cell.getTimestamp());
 }
 timeRangeTracker.includeTimestamp(cell);
}

代码示例来源:origin: apache/hbase

private int compareTypeBytes(Cell key, Cell right) {
 if (key.getFamilyLength() + key.getQualifierLength() == 0
   && key.getTypeByte() == Type.Minimum.getCode()) {
  // left is "bigger", i.e. it appears later in the sorted order
  return 1;
 }
 if (right.getFamilyLength() + right.getQualifierLength() == 0
   && right.getTypeByte() == Type.Minimum.getCode()) {
  return -1;
 }
 return 0;
}

代码示例来源:origin: apache/hbase

public static int appendKeyTo(final Cell cell, final byte[] output,
  final int offset) {
 int nextOffset = offset;
 nextOffset = Bytes.putShort(output, nextOffset, cell.getRowLength());
 nextOffset = CellUtil.copyRowTo(cell, output, nextOffset);
 nextOffset = Bytes.putByte(output, nextOffset, cell.getFamilyLength());
 nextOffset = CellUtil.copyFamilyTo(cell, output, nextOffset);
 nextOffset = CellUtil.copyQualifierTo(cell, output, nextOffset);
 nextOffset = Bytes.putLong(output, nextOffset, cell.getTimestamp());
 nextOffset = Bytes.putByte(output, nextOffset, cell.getTypeByte());
 return nextOffset;
}

代码示例来源:origin: apache/hbase

public static int appendKeyTo(Cell cell, ByteBuffer buf, int offset) {
 offset = ByteBufferUtils.putShort(buf, offset, cell.getRowLength());// RK length
 offset = CellUtil.copyRowTo(cell, buf, offset);// Row bytes
 offset = ByteBufferUtils.putByte(buf, offset, cell.getFamilyLength());// CF length
 offset = CellUtil.copyFamilyTo(cell, buf, offset);// CF bytes
 offset = CellUtil.copyQualifierTo(cell, buf, offset);// Qualifier bytes
 offset = ByteBufferUtils.putLong(buf, offset, cell.getTimestamp());// TS
 offset = ByteBufferUtils.putByte(buf, offset, cell.getTypeByte());// Type
 return offset;
}

代码示例来源:origin: apache/hbase

public KeyValue(Cell c) {
 this(c.getRowArray(), c.getRowOffset(), c.getRowLength(),
   c.getFamilyArray(), c.getFamilyOffset(), c.getFamilyLength(),
   c.getQualifierArray(), c.getQualifierOffset(), c.getQualifierLength(),
   c.getTimestamp(), Type.codeToType(c.getTypeByte()), c.getValueArray(), c.getValueOffset(),
   c.getValueLength(), c.getTagsArray(), c.getTagsOffset(), c.getTagsLength());
 this.seqId = c.getSequenceId();
}

相关文章