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

ByteString.newInput介绍

暂无

代码示例

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

private static byte[] uncompressByteString(ByteString bs, Dictionary dict) throws IOException {
 InputStream in = bs.newInput();
 byte status = (byte)in.read();
 if (status == Dictionary.NOT_IN_DICTIONARY) {
  byte[] arr = new byte[StreamUtils.readRawVarint32(in)];
  int bytesRead = in.read(arr);
  if (bytesRead != arr.length) {
   throw new IOException("Cannot read; wanted " + arr.length + ", but got " + bytesRead);
  }
  if (dict != null) dict.addEntry(arr, 0, arr.length);
  return arr;
 } else {
  // Status here is the higher-order byte of index of the dictionary entry.
  short dictIdx = StreamUtils.toShort(status, (byte)in.read());
  byte[] entry = dict.getEntry(dictIdx);
  if (entry == null) {
   throw new IOException("Missing dictionary entry for index " + dictIdx);
  }
  return entry;
 }
}

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

public static Message getResponse(
  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse
   result,
  com.google.protobuf.Message responsePrototype)
throws IOException {
 Message response;
 if (result.getValue().hasValue()) {
  Message.Builder builder = responsePrototype.newBuilderForType();
  builder.mergeFrom(result.getValue().getValue().newInput());
  response = builder.build();
 } else {
  response = responsePrototype.getDefaultInstanceForType();
 }
 if (LOG.isTraceEnabled()) {
  LOG.trace("Master Result is value=" + response);
 }
 return response;
}

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

private static Key getUnwrapKey(Configuration conf, String subject,
  EncryptionProtos.WrappedKey wrappedKey, Cipher cipher) throws IOException, KeyException {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 byte[] iv = wrappedKey.hasIv() ? wrappedKey.getIv().toByteArray() : null;
 Encryption.decryptWithSubjectKey(out, wrappedKey.getData().newInput(),
  wrappedKey.getLength(), subject, conf, cipher, iv);
 byte[] keyBytes = out.toByteArray();
 if (wrappedKey.hasHash()) {
  if (!Bytes.equals(wrappedKey.getHash().toByteArray(), Encryption.hash128(keyBytes))) {
   throw new KeyException("Key was not successfully unwrapped");
  }
 }
 return new SecretKeySpec(keyBytes, wrappedKey.getAlgorithm());
}

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

public static Message getResponse(
  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse
   result,
  com.google.protobuf.Message responsePrototype)
throws IOException {
 Message response;
 if (result.getValue().hasValue()) {
  Message.Builder builder = responsePrototype.newBuilderForType();
  builder.mergeFrom(result.getValue().getValue().newInput());
  response = builder.build();
 } else {
  response = responsePrototype.getDefaultInstanceForType();
 }
 if (LOG.isTraceEnabled()) {
  LOG.trace("Master Result is value=" + response);
 }
 return response;
}

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

private static Key getUnwrapKey(Configuration conf, String subject,
  EncryptionProtos.WrappedKey wrappedKey, Cipher cipher) throws IOException, KeyException {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 byte[] iv = wrappedKey.hasIv() ? wrappedKey.getIv().toByteArray() : null;
 Encryption.decryptWithSubjectKey(out, wrappedKey.getData().newInput(),
  wrappedKey.getLength(), subject, conf, cipher, iv);
 byte[] keyBytes = out.toByteArray();
 if (wrappedKey.hasHash()) {
  if (!Bytes.equals(wrappedKey.getHash().toByteArray(), Encryption.hash128(keyBytes))) {
   throw new KeyException("Key was not successfully unwrapped");
  }
 }
 return new SecretKeySpec(keyBytes, wrappedKey.getAlgorithm());
}

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

serializer = new StateSerializer(proto.toBuilder());
} else if (proto.hasStateData()) {
 InputStream inputStream = proto.getStateData().newInput();
 serializer = new CompatStateSerializer(inputStream);

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

public static Message getResponse(
  org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse
   result,
  com.google.protobuf.Message responsePrototype)
throws IOException {
 Message response;
 if (result.getValue().hasValue()) {
  Message.Builder builder = responsePrototype.newBuilderForType();
  builder.mergeFrom(result.getValue().getValue().newInput());
  response = builder.build();
 } else {
  response = responsePrototype.getDefaultInstanceForType();
 }
 if (LOG.isTraceEnabled()) {
  LOG.trace("Master Result is value=" + response);
 }
 return response;
}

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

private static Key getUnwrapKey(Configuration conf, String subject,
  EncryptionProtos.WrappedKey wrappedKey, Cipher cipher) throws IOException, KeyException {
 ByteArrayOutputStream out = new ByteArrayOutputStream();
 byte[] iv = wrappedKey.hasIv() ? wrappedKey.getIv().toByteArray() : null;
 Encryption.decryptWithSubjectKey(out, wrappedKey.getData().newInput(),
  wrappedKey.getLength(), subject, conf, cipher, iv);
 byte[] keyBytes = out.toByteArray();
 if (wrappedKey.hasHash()) {
  if (!Bytes.equals(wrappedKey.getHash().toByteArray(), Encryption.hash128(keyBytes))) {
   throw new KeyException("Key was not successfully unwrapped");
  }
 }
 return new SecretKeySpec(keyBytes, wrappedKey.getAlgorithm());
}

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

serializer = new StateSerializer(proto.toBuilder());
} else if (proto.hasStateData()) {
 InputStream inputStream = proto.getStateData().newInput();
 serializer = new CompatStateSerializer(inputStream);

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

serializer = new StateSerializer(proto.toBuilder());
} else if (proto.hasStateData()) {
 InputStream inputStream = proto.getStateData().newInput();
 serializer = new CompatStateSerializer(inputStream);