Java 类org.apache.hadoop.hbase.protobuf.generated.WALProtos.WALHeader.Builder 实例源码

protected WALHdrContext readHeader(Builder builder, FSDataInputStream stream)
    throws IOException {
   boolean res = builder.mergeDelimitedFrom(stream);
   if (!res) return new WALHdrContext(WALHdrResult.EOF, null);
   if (builder.hasWriterClsName() &&
       !getWriterClsNames().contains(builder.getWriterClsName())) {
     return new WALHdrContext(WALHdrResult.UNKNOWN_WRITER_CLS, null);
   }
   String clsName = null;
   if (builder.hasCellCodecClsName()) {
     clsName = builder.getCellCodecClsName();
   }
   return new WALHdrContext(WALHdrResult.SUCCESS, clsName);
}

private String initInternal(FSDataInputStream stream, boolean isFirst)
    throws IOException {
  close();
  long expectedPos = PB_WAL_MAGIC.length;
  if (stream == null) {
    stream = fs.open(path);
    stream.seek(expectedPos);
  }
  if (stream.getPos() != expectedPos) {
    throw new IOException("The stream is at invalid position: " + stream.getPos());
  }
  // Initialize metadata or, when we reset, just skip the header.
  WALProtos.WALHeader.Builder builder = WALProtos.WALHeader.newBuilder();
  WALHdrContext hdrCtxt = readHeader(builder, stream);
  WALHdrResult walHdrRes = hdrCtxt.getResult();
  if (walHdrRes == WALHdrResult.EOF) {
    throw new EOFException("Couldn't read WAL PB header");
  }
  if (walHdrRes == WALHdrResult.UNKNOWN_WRITER_CLS) {
    throw new IOException("Got unknown writer class: " + builder.getWriterClsName());
  }
  if (isFirst) {
    WALProtos.WALHeader header = builder.build();
    this.hasCompression = header.hasHasCompression() && header.getHasCompression();
    this.hasTagCompression = header.hasHasTagCompression() && header.getHasTagCompression();
  }
  this.inputStream = stream;
  this.walEditsStopOffset = this.fileLength;
  long currentPosition = stream.getPos();
  trailerPresent = setTrailerIfPresent();
  this.seekOnFs(currentPosition);
  if (LOG.isTraceEnabled()) {
    LOG.trace("After reading the trailer: walEditsStopOffset: " + this.walEditsStopOffset
        + ", fileLength: " + this.fileLength + ", " + "trailerPresent: " + trailerPresent);
  }

  codecClsName = hdrCtxt.getCellCodecClsName();

  return hdrCtxt.getCellCodecClsName();
}

protected WALHdrContext readHeader(Builder builder, FSDataInputStream stream)
    throws IOException {
   boolean res = builder.mergeDelimitedFrom(stream);
   if (!res) return new WALHdrContext(WALHdrResult.EOF, null);
   if (builder.hasWriterClsName() &&
       !getWriterClsNames().contains(builder.getWriterClsName())) {
     return new WALHdrContext(WALHdrResult.UNKNOWN_WRITER_CLS, null);
   }
   String clsName = null;
   if (builder.hasCellCodecClsName()) {
     clsName = builder.getCellCodecClsName();
   }
   return new WALHdrContext(WALHdrResult.SUCCESS, clsName);
}

private String initInternal(FSDataInputStream stream, boolean isFirst)
    throws IOException {
  close();
  long expectedPos = PB_WAL_MAGIC.length;
  if (stream == null) {
    stream = fs.open(path);
    stream.seek(expectedPos);
  }
  if (stream.getPos() != expectedPos) {
    throw new IOException("The stream is at invalid position: " + stream.getPos());
  }
  // Initialize metadata or, when we reset, just skip the header.
  WALProtos.WALHeader.Builder builder = WALProtos.WALHeader.newBuilder();
  WALHdrContext hdrCtxt = readHeader(builder, stream);
  WALHdrResult walHdrRes = hdrCtxt.getResult();
  if (walHdrRes == WALHdrResult.EOF) {
    throw new EOFException("Couldn't read WAL PB header");
  }
  if (walHdrRes == WALHdrResult.UNKNOWN_WRITER_CLS) {
    throw new IOException("Got unknown writer class: " + builder.getWriterClsName());
  }
  if (isFirst) {
    WALProtos.WALHeader header = builder.build();
    this.hasCompression = header.hasHasCompression() && header.getHasCompression();
    this.hasTagCompression = header.hasHasTagCompression() && header.getHasTagCompression();
  }
  this.inputStream = stream;
  this.walEditsStopOffset = this.fileLength;
  long currentPosition = stream.getPos();
  trailerPresent = setTrailerIfPresent();
  this.seekOnFs(currentPosition);
  if (LOG.isTraceEnabled()) {
    LOG.trace("After reading the trailer: walEditsStopOffset: " + this.walEditsStopOffset
        + ", fileLength: " + this.fileLength + ", " + "trailerPresent: " + trailerPresent);
  }
  return hdrCtxt.getCellCodecClsName();
}

private void initInternal(FSDataInputStream stream, boolean isFirst) throws IOException {
  close();
  long expectedPos = PB_WAL_MAGIC.length;
  if (stream == null) {
    stream = fs.open(path);
    stream.seek(expectedPos);
  }
  if (stream.getPos() != expectedPos) {
    throw new IOException("The stream is at invalid position: " + stream.getPos());
  }
  // Initialize metadata or, when we reset, just skip the header.
  WALProtos.WALHeader.Builder builder = WALProtos.WALHeader.newBuilder();
  boolean hasHeader = readHeader(builder, stream);
  if (!hasHeader) {
    throw new EOFException("Couldn't read WAL PB header");
  }
  if (isFirst) {
    WALProtos.WALHeader header = builder.build();
    this.hasCompression = header.hasHasCompression() && header.getHasCompression();
    this.hasTagCompression = header.hasHasTagCompression() && header.getHasTagCompression();
  }
  this.inputStream = stream;
  this.walEditsStopOffset = this.fileLength;
  long currentPosition = stream.getPos();
  trailerPresent = setTrailerIfPresent();
  this.seekOnFs(currentPosition);
  if (LOG.isTraceEnabled()) {
    LOG.trace("After reading the trailer: walEditsStopOffset: " + this.walEditsStopOffset
        + ", fileLength: " + this.fileLength + ", " + "trailerPresent: " + trailerPresent);
  }
}

private void initInternal(FSDataInputStream stream, boolean isFirst) throws IOException {
  close();
  long expectedPos = PB_WAL_MAGIC.length;
  if (stream == null) {
    stream = fs.open(path);
    stream.seek(expectedPos);
  }
  if (stream.getPos() != expectedPos) {
    throw new IOException("The stream is at invalid position: " + stream.getPos());
  }
  // Initialize metadata or, when we reset, just skip the header.
  WALProtos.WALHeader.Builder builder = WALProtos.WALHeader.newBuilder();
  boolean hasHeader = readHeader(builder, stream);
  if (!hasHeader) {
    throw new EOFException("Couldn't read WAL PB header");
  }
  if (isFirst) {
    WALProtos.WALHeader header = builder.build();
    this.hasCompression = header.hasHasCompression() && header.getHasCompression();
    this.hasTagCompression = header.hasHasTagCompression() && header.getHasTagCompression();
  }
  this.inputStream = stream;
  this.walEditsStopOffset = this.fileLength;
  long currentPosition = stream.getPos();
  trailerPresent = setTrailerIfPresent();
  this.seekOnFs(currentPosition);
  if (LOG.isTraceEnabled()) {
    LOG.trace("After reading the trailer: walEditsStopOffset: " + this.walEditsStopOffset
        + ", fileLength: " + this.fileLength + ", " + "trailerPresent: " + trailerPresent);
  }
}

protected boolean readHeader(Builder builder, FSDataInputStream stream) throws IOException {
  return builder.mergeDelimitedFrom(stream);
}

protected boolean readHeader(Builder builder, FSDataInputStream stream) throws IOException {
  return builder.mergeDelimitedFrom(stream);
}