com.google.protobuf.ByteString.newInput()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(147)

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

ByteString.newInput介绍

[英]Creates an InputStream which can be used to read the bytes.

The InputStream returned by this method is guaranteed to be completely non-blocking. The method InputStream#available()returns the number of bytes remaining in the stream. The methods InputStream#read(byte[]), InputStream#read(byte[],int,int)and InputStream#skip(long) will read/skip as many bytes as are available.

The methods in the returned InputStream might not be thread safe.
[中]创建可用于读取字节的InputStream。
此方法返回的InputStream保证是完全非阻塞的。方法InputStream#available（）返回流中剩余的字节数。InputStream#read（byte[]）、InputStream#read（byte[]，int，int）和InputStream#skip（long）方法将读取/跳过尽可能多的可用字节。
返回的InputStream中的方法可能不是线程安全的。

代码示例

代码示例来源：origin: googleapis/google-cloud-java

/** Returns an {@link InputStream} for this {@code ByteArray} content. */
public final InputStream asInputStream() {
 return byteString.newInput();
}

代码示例来源：origin: osmandapp/Osmand

InputStream inputStreamFrom = value.newInput();
if (offset != inputStreamFrom.skip(offset)) {
 throw new IllegalStateException("Skip failed? Should never happen.");

代码示例来源：origin: com.google.cloud/gcloud-java-core

/**
 * Returns an {@link InputStream} for this {@code ByteArray} content.
 */
public final InputStream asInputStream() {
 return byteString.newInput();
}

代码示例来源：origin: com.google.cloud/google-cloud-core

/** Returns an {@link InputStream} for this {@code ByteArray} content. */
public final InputStream asInputStream() {
 return byteString.newInput();
}

代码示例来源：origin: dremio/dremio-oss

public static InputStream toInputStream(com.google.protobuf.ByteString json, FragmentCodec codec) throws IOException {
 final FragmentCodec c = codec != null ? codec : FragmentCodec.NONE;
 final InputStream input = json.newInput();
 switch(c) {
 case NONE:
  return input;
 case SNAPPY:
  return new SnappyInputStream(input);
 default:
  throw new UnsupportedOperationException("Do not know how to uncompress using " + c + " algorithm.");
 }
}

代码示例来源：origin: org.apache.tez/tez-api

@Private
public static byte[] decompressByteStringToByteArray(ByteString byteString, Inflater inflater) throws IOException {
 inflater.reset();
 return IOUtils.toByteArray(new InflaterInputStream(byteString.newInput(), inflater));
}

代码示例来源：origin: com.google.openrtb/openrtb-core

/**
 * Desserializes a {@link BidRequest} from a JSON string, provided as a {@link ByteString}.
 */
public BidRequest readBidRequest(ByteString bs) throws IOException {
 return readBidRequest(bs.newInput());
}

代码示例来源：origin: com.google.openrtb/openrtb-core

/**
 * Desserializes a {@link NativeRequest} from a JSON string, provided as a {@link ByteString}.
 */
public NativeRequest readNativeRequest(ByteString bs) throws IOException {
 return readNativeRequest(bs.newInput());
}

代码示例来源：origin: io.vitess/vitess-client

/**
 * Returns the data at a given index as an InputStream.
 *
 * @param columnIndex 1-based column number (0 is invalid)
 */
public InputStream getBinaryInputStream(int columnIndex) throws SQLException {
 ByteString rawValue = getRawValue(columnIndex);
 if (rawValue == null) {
  return null;
 }
 return rawValue.newInput();
}

代码示例来源：origin: com.google.openrtb/openrtb-core

/**
 * Desserializes a {@link BidResponse} from a JSON string, provided as a {@link ByteString}.
 */
public BidResponse readBidResponse(ByteString bs) throws IOException {
 return readBidResponse(bs.newInput());
}

代码示例来源：origin: com.google.openrtb/openrtb-core

/**
 * Desserializes a {@link NativeResponse} from a JSON string, provided as a {@link ByteString}.
 */
public NativeResponse readNativeResponse(ByteString bs) throws IOException {
 return readNativeResponse(bs.newInput());
}

代码示例来源：origin: com.github.thinkerou/karate-grpc-core

@Override
public InputStream stream(DynamicMessage abstractMessage) {
  return abstractMessage.toByteString().newInput();
}

代码示例来源：origin: dremio/dremio-oss

/**
 * Deserialize the given byte string to an object using the given reader, employing the given codec algorithm.
 *
 * @param reader     object reader
 * @param byteString byte string to deserialize
 * @param codec      codec
 * @param logger     logger
 * @param <T>        object type of the deserialized object
 * @return deserialized object
 * @throws IOException in case of deserialization errors
 */
public static <T> T readValue(ObjectReader reader, ByteString byteString, Codec codec, Logger logger)
  throws IOException {
 if (logger.isTraceEnabled()) {
  // Costly conversion to UTF-8. Avoid if possible
  final String value = IOUtils.toString(codec.decompress(byteString.newInput()));
  logger.trace("Attempting to read {}", value);
  // Could reuse the value but to avoid so that logger level doesn't impact the program flow
  // Since level is trace, user probably doesn't care for performance right now
  // return reader.readValue(value);
 }
 try (InputStream is = codec.decompress(byteString.newInput())) {
  return reader.readValue(is);
 }
}

代码示例来源：origin: org.apache.tez/tez-api

/**
 * Convert a byte string to a Configuration object
 *
 * @param byteString byteString representation of the conf created using {@link
 *                   #createByteStringFromConf(org.apache.hadoop.conf.Configuration)}
 * @return Configuration
 * @throws java.io.IOException
 */
public static Configuration createConfFromByteString(ByteString byteString) throws IOException {
 Preconditions.checkNotNull(byteString, "ByteString must be specified");
 // SnappyInputStream uncompressIs = new
 // SnappyInputStream(byteString.newInput());
 InflaterInputStream uncompressIs = new InflaterInputStream(byteString.newInput());
 DAGProtos.ConfigurationProto confProto = DAGProtos.ConfigurationProto.parseFrom(uncompressIs);
 Configuration conf = new Configuration(false);
 readConfFromPB(confProto, conf);
 return conf;
}

代码示例来源：origin: com.powsybl/powsybl-computation-mpi

private void copyFileToWorkingDirectory(Messages.TaskResult.OutputFile outputFile, MpiJob job, String stdOutGzFileName) throws IOException {
  if (outputFile.getName().equals(stdOutGzFileName)) {
    Path path = job.getWorkingDir().resolve(outputFile.getName().substring(0, outputFile.getName().length() - 3));
    try (InputStream is = new GZIPInputStream(outputFile.getData().newInput());
       OutputStream os = Files.newOutputStream(path)) {
      ByteStreams.copy(is, os);
    }
  } else {
    Path path = job.getWorkingDir().resolve(outputFile.getName());
    try (InputStream is = outputFile.getData().newInput();
       OutputStream os = Files.newOutputStream(path)) {
      ByteStreams.copy(is, os);
    }
  }
}

代码示例来源：origin: pl.edu.icm.coansys/coansys-io-input

@Override
public boolean transform(DocumentProtos.Media media, String docNewId, 
  DocumentProtos.DocumentMetadata.Builder dmBuider,DocumentProtos.DocumentWrapper.Builder builder) {
  List<DocumentProtos.DocumentWrapperOrBuilder> dwbList = reader.read(new InputStreamReader(media.getContent().newInput()),
                            new DataciteOAIId(docNewId));
  for (DocumentProtos.DocumentWrapperOrBuilder dw: dwbList) {
    dmBuider.mergeFrom(dw.getDocumentMetadata());
  }
  dmBuider.clearCollection();
  return true;
}

代码示例来源：origin: pl.edu.icm.coansys/coansys-io-input

@Override
public boolean transform(DocumentProtos.Media media, String docNewId, 
  DocumentProtos.DocumentMetadata.Builder dmBuider,DocumentProtos.DocumentWrapper.Builder builder) {
  
  List<YExportable> yExportableList = MetadataTransformers.BTF.getReader(
      BwmetaTransformerConstants.BWMETA_2_1,
      BwmetaTransformerConstants.Y).read(
      new InputStreamReader(media.getContent().newInput()));
  for (YExportable yExportable : yExportableList) {
    DocumentProtos.DocumentMetadata dm = parser
        .yelementToDocumentMetadata((YElement) yExportable, null,
            null, "synat");
    dmBuider.mergeFrom(dm);
  }
  dmBuider.clearCollection();
  return true;
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.drools

private static void loadStrategiesIndex(MarshallerReaderContext context,
                    ProtobufMessages.Header _header) throws IOException, ClassNotFoundException {
  for ( ProtobufMessages.Header.StrategyIndex _entry : _header.getStrategyList() ) {
    ObjectMarshallingStrategy strategyObject = context.resolverStrategyFactory.getStrategyObject( _entry.getName() );
    if ( strategyObject == null ) {
      throw new IllegalStateException( "No strategy of type " + _entry.getName() + " available." );
    }
    context.usedStrategies.put( _entry.getId(), strategyObject );
    Context ctx = strategyObject.createContext();
    context.strategyContexts.put( strategyObject, ctx );
    if( _entry.hasData() && ctx != null ) {
  ClassLoader classLoader = null;
      if (context.classLoader != null ){
        classLoader = context.classLoader;
      } else if(context.ruleBase != null){
        classLoader = context.ruleBase.getRootClassLoader();
      }
      ctx.read( new DroolsObjectInputStream( _entry.getData().newInput(), classLoader) );
    }
  }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-yarn-server-nodemanager

private void recoverApplication(ContainerManagerApplicationProto p)
  throws IOException {
 ApplicationId appId = new ApplicationIdPBImpl(p.getId());
 Credentials creds = new Credentials();
 creds.readTokenStorageStream(
   new DataInputStream(p.getCredentials().newInput()));
 List<ApplicationACLMapProto> aclProtoList = p.getAclsList();
 Map<ApplicationAccessType, String> acls =
   new HashMap<ApplicationAccessType, String>(aclProtoList.size());
 for (ApplicationACLMapProto aclProto : aclProtoList) {
  acls.put(ProtoUtils.convertFromProtoFormat(aclProto.getAccessType()),
    aclProto.getAcl());
 }
 LogAggregationContext logAggregationContext = null;
 if (p.getLogAggregationContext() != null) {
  logAggregationContext =
    new LogAggregationContextPBImpl(p.getLogAggregationContext());
 }
 LOG.info("Recovering application " + appId);
 ApplicationImpl app = new ApplicationImpl(dispatcher, p.getUser(), appId,
   creds, context);
 context.getApplications().put(appId, app);
 app.handle(new ApplicationInitEvent(appId, acls, logAggregationContext));
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-yarn-server-nodemanager

private void recoverApplication(ContainerManagerApplicationProto p)
  throws IOException {
 ApplicationId appId = new ApplicationIdPBImpl(p.getId());
 Credentials creds = new Credentials();
 creds.readTokenStorageStream(
   new DataInputStream(p.getCredentials().newInput()));
 List<ApplicationACLMapProto> aclProtoList = p.getAclsList();
 Map<ApplicationAccessType, String> acls =
   new HashMap<ApplicationAccessType, String>(aclProtoList.size());
 for (ApplicationACLMapProto aclProto : aclProtoList) {
  acls.put(ProtoUtils.convertFromProtoFormat(aclProto.getAccessType()),
    aclProto.getAcl());
 }
 LogAggregationContext logAggregationContext = null;
 if (p.getLogAggregationContext() != null) {
  logAggregationContext =
    new LogAggregationContextPBImpl(p.getLogAggregationContext());
 }
 LOG.info("Recovering application " + appId);
 ApplicationImpl app = new ApplicationImpl(dispatcher, p.getUser(), appId,
   creds, context);
 context.getApplications().put(appId, app);
 app.handle(new ApplicationInitEvent(appId, acls, logAggregationContext));
}

内容来源于网络，如有侵权，请联系作者删除！

ByteString

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    ByteString类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com