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

WALKeyImpl.getMvcc介绍

暂无

代码示例

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

@Override
     public Object answer(InvocationOnMock invocation) {
      WALKeyImpl walKey = invocation.getArgument(1);
      MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
      if (mvcc != null) {
       MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
       walKey.setWriteEntry(we);
      }
      return 01L;
     }
});

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

@Override
     public Object answer(InvocationOnMock invocation) {
      WALKeyImpl walKey = invocation.getArgument(1);
      MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
      if (mvcc != null) {
       MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
       walKey.setWriteEntry(we);
      }
      return 01L;
     }
});

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

@Override
 public Object answer(InvocationOnMock invocation) {
  WALKeyImpl walKey = invocation.getArgument(1);
  MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
  if (mvcc != null) {
   MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
   walKey.setWriteEntry(we);
  }
  return 01L;
 }
});

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

@Override
     public Object answer(InvocationOnMock invocation) {
      WALKeyImpl walKey = invocation.getArgument(1);
      MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
      if (mvcc != null) {
       MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
       walKey.setWriteEntry(we);
      }
      return 01L;
     }
});

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

@Override
public long append(RegionInfo info, WALKeyImpl key, WALEdit edits, boolean inMemstore)
  throws IOException {
 WriteEntry writeEntry = key.getMvcc().begin();
 if (!edits.isReplay()) {
  for (Cell cell : edits.getCells()) {
   PrivateCellUtil.setSequenceId(cell, writeEntry.getWriteNumber());
  }
 }
 key.setWriteEntry(writeEntry);
 if (!this.listeners.isEmpty()) {
  final long start = System.nanoTime();
  long len = 0;
  for (Cell cell : edits.getCells()) {
   len += PrivateCellUtil.estimatedSerializedSizeOf(cell);
  }
  final long elapsed = (System.nanoTime() - start) / 1000000L;
  for (WALActionsListener listener : this.listeners) {
   listener.postAppend(len, elapsed, key, edits);
  }
 }
 return -1;
}

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

protected final long stampSequenceIdAndPublishToRingBuffer(RegionInfo hri, WALKeyImpl key,
  WALEdit edits, boolean inMemstore, RingBuffer<RingBufferTruck> ringBuffer)
  throws IOException {
 if (this.closed) {
  throw new IOException(
    "Cannot append; log is closed, regionName = " + hri.getRegionNameAsString());
 }
 MutableLong txidHolder = new MutableLong();
 MultiVersionConcurrencyControl.WriteEntry we = key.getMvcc().begin(() -> {
  txidHolder.setValue(ringBuffer.next());
 });
 long txid = txidHolder.longValue();
 try (TraceScope scope = TraceUtil.createTrace(implClassName + ".append")) {
  FSWALEntry entry = new FSWALEntry(txid, key, edits, hri, inMemstore);
  entry.stampRegionSequenceId(we);
  ringBuffer.get(txid).load(entry);
 } finally {
  ringBuffer.publish(txid);
 }
 return txid;
}

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

@Override
     public Object answer(InvocationOnMock invocation) {
      WALKeyImpl walKey = invocation.getArgument(1);
      MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
      if (mvcc != null) {
       MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
       walKey.setWriteEntry(we);
      }
      return 01L;
     };
});

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

@Override
     public Object answer(InvocationOnMock invocation) {
      WALKeyImpl walKey = invocation.getArgument(1);
      MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
      if (mvcc != null) {
       MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
       walKey.setWriteEntry(we);
      }
      return 01L;
     };
});

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

@Override
     public Object answer(InvocationOnMock invocation) {
      WALKeyImpl walKey = invocation.getArgument(1);
      MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
      if (mvcc != null) {
       MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
       walKey.setWriteEntry(we);
      }
      return 01L;
     };
});

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

@Override
 public Object answer(InvocationOnMock invocation) {
  WALKeyImpl walKey = invocation.getArgument(1);
  MultiVersionConcurrencyControl mvcc = walKey.getMvcc();
  if (mvcc != null) {
   MultiVersionConcurrencyControl.WriteEntry we = mvcc.begin();
   walKey.setWriteEntry(we);
  }
  return 01L;
 };
});