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

x33g5p2x  于2022-01-23 转载在 其他  
字(3.2k)|赞(0)|评价(0)|浏览(95)

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

KeyValue.isLatestTimestamp介绍

暂无

代码示例

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

/**
 * @param now Time to set into <code>this</code> IFF timestamp ==
 * {@link HConstants#LATEST_TIMESTAMP} (else, its a noop).
 * @return True is we modified this.
 */
public boolean updateLatestStamp(final byte [] now) {
 if (this.isLatestTimestamp()) {
  int tsOffset = getTimestampOffset();
  System.arraycopy(now, 0, this.bytes, tsOffset, Bytes.SIZEOF_LONG);
  // clear cache or else getTimestamp() possibly returns an old value
  return true;
 }
 return false;
}

代码示例来源:origin: harbby/presto-connectors

/**
 * @param now Time to set into <code>this</code> IFF timestamp ==
 * {@link HConstants#LATEST_TIMESTAMP} (else, its a noop).
 * @return True is we modified this.
 */
public boolean updateLatestStamp(final byte [] now) {
 if (this.isLatestTimestamp()) {
  int tsOffset = getTimestampOffset();
  System.arraycopy(now, 0, this.bytes, tsOffset, Bytes.SIZEOF_LONG);
  // clear cache or else getTimestamp() possibly returns an old value
  return true;
 }
 return false;
}

代码示例来源:origin: co.cask.hbase/hbase

/**
 * @param now Time to set into <code>this</code> IFF timestamp ==
 * {@link HConstants#LATEST_TIMESTAMP} (else, its a noop).
 * @return True is we modified this.
 */
public boolean updateLatestStamp(final byte [] now) {
 if (this.isLatestTimestamp()) {
  int tsOffset = getTimestampOffset();
  System.arraycopy(now, 0, this.bytes, tsOffset, Bytes.SIZEOF_LONG);
  // clear cache or else getTimestamp() possibly returns an old value
  return true;
 }
 return false;
}

代码示例来源:origin: org.apache.hbase/hbase-common

/**
 * @param now Time to set into <code>this</code> IFF timestamp ==
 * {@link HConstants#LATEST_TIMESTAMP} (else, its a noop).
 * @return True is we modified this.
 */
public boolean updateLatestStamp(final byte [] now) {
 if (this.isLatestTimestamp()) {
  int tsOffset = getTimestampOffset();
  System.arraycopy(now, 0, this.bytes, tsOffset, Bytes.SIZEOF_LONG);
  // clear cache or else getTimestamp() possibly returns an old value
  return true;
 }
 return false;
}

代码示例来源:origin: com.aliyun.hbase/alihbase-common

/**
 * @param now Time to set into <code>this</code> IFF timestamp ==
 * {@link HConstants#LATEST_TIMESTAMP} (else, its a noop).
 * @return True is we modified this.
 */
public boolean updateLatestStamp(final byte [] now) {
 if (this.isLatestTimestamp()) {
  int tsOffset = getTimestampOffset();
  System.arraycopy(now, 0, this.bytes, tsOffset, Bytes.SIZEOF_LONG);
  // clear cache or else getTimestamp() possibly returns an old value
  return true;
 }
 return false;
}

代码示例来源:origin: co.cask.hbase/hbase

private void checkTimestamps(final Map<byte[], List<KeyValue>> familyMap,
  long now) throws DoNotRetryIOException {
 if (timestampSlop == HConstants.LATEST_TIMESTAMP) {
  return;
 }
 long maxTs = now + timestampSlop;
 for (List<KeyValue> kvs : familyMap.values()) {
  for (KeyValue kv : kvs) {
   // see if the user-side TS is out of range. latest = server-side
   if (!kv.isLatestTimestamp() && kv.getTimestamp() > maxTs) {
    throw new DoNotRetryIOException("Timestamp for KV out of range "
      + kv + " (too.new=" + timestampSlop + ")");
   }
  }
 }
}

代码示例来源:origin: co.cask.hbase/hbase

if (kv.isLatestTimestamp() && kv.isDeleteType()) {
 byte[] qual = kv.getQualifier();
 if (qual == null) qual = HConstants.EMPTY_BYTE_ARRAY;

相关文章

微信公众号

最新文章

更多

KeyValue类方法