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

Message.toByteString介绍

暂无

代码示例

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

public static <S extends Message, T extends Message>
 ProcessRequest getRowProcessorPB(RowProcessor<S,T> r)
   throws IOException {
  final ProcessRequest.Builder requestBuilder =
    ProcessRequest.newBuilder();
  requestBuilder.setRowProcessorClassName(r.getClass().getName());
  S s = r.getRequestData();
  if (s != null) {
   requestBuilder.setRowProcessorInitializerMessageName(s.getClass().getName());
   requestBuilder.setRowProcessorInitializerMessage(s.toByteString());
  }
  return requestBuilder.build();
 }
}

代码示例来源：origin: a2888409/face2face

public static ByteBuf pack2Server(Message msg, int ptoNum, Internal.Dest dest, String userId) {
    Internal.GTransfer.Builder gtf = Internal.GTransfer.newBuilder();
    gtf.setPtoNum(ptoNum);
    gtf.setMsg(msg.toByteString());
    gtf.setDest(dest);
    gtf.setUserId(userId);

    byte[] bytes = gtf.build().toByteArray();
    int length =bytes.length;
    int gtfNum = ParseRegistryMap.GTRANSFER;

    ByteBuf buf = Unpooled.buffer(8 + length);
    buf.writeInt(length);
    buf.writeInt(gtfNum);     //传输协议的协议号
    buf.writeBytes(bytes);

    return buf;
  }
}

代码示例来源：origin: a2888409/face2face

public static ByteBuf pack2Server(Message msg, int ptoNum, long netId, Internal.Dest dest, String userId) {
  Internal.GTransfer.Builder gtf = Internal.GTransfer.newBuilder();
  gtf.setPtoNum(ptoNum);
  gtf.setMsg(msg.toByteString());
  gtf.setNetId(netId);
  gtf.setDest(dest);
  gtf.setUserId(userId);
  byte[] bytes = gtf.build().toByteArray();
  int length =bytes.length;
  int gtfNum = ParseRegistryMap.GTRANSFER;
  ByteBuf buf = Unpooled.buffer(8 + length);
  buf.writeInt(length);
  buf.writeInt(gtfNum);     //传输协议的协议号
  buf.writeBytes(bytes);
  return buf;
}

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

static <R, S, P extends Message, Q extends Message, T extends Message> AggregateRequest
  validateArgAndGetPB(Scan scan, ColumnInterpreter<R, S, P, Q, T> ci, boolean canFamilyBeAbsent)
    throws IOException {
 validateParameters(scan, canFamilyBeAbsent);
 final AggregateRequest.Builder requestBuilder = AggregateRequest.newBuilder();
 requestBuilder.setInterpreterClassName(ci.getClass().getCanonicalName());
 P columnInterpreterSpecificData = ci.getRequestData();
 if (columnInterpreterSpecificData != null) {
  requestBuilder.setInterpreterSpecificBytes(columnInterpreterSpecificData.toByteString());
 }
 requestBuilder.setScan(ProtobufUtil.toScan(scan));
 return requestBuilder.build();
}

代码示例来源：origin: com.google.protobuf/protobuf-java

public static <T extends com.google.protobuf.Message> Any pack(
  T message) {
 return Any.newBuilder()
   .setTypeUrl(getTypeUrl("type.googleapis.com",
               message.getDescriptorForType()))
   .setValue(message.toByteString())
   .build();
}

代码示例来源：origin: com.google.protobuf/protobuf-java

/**
 * Packs a message using the given type URL prefix. The type URL will
 * be constructed by concatenating the message type's full name to the
 * prefix with an optional "/" separator if the prefix doesn't end
 * with "/" already.
 */
public static <T extends com.google.protobuf.Message> Any pack(
  T message, java.lang.String typeUrlPrefix) {
 return Any.newBuilder()
   .setTypeUrl(getTypeUrl(typeUrlPrefix,
               message.getDescriptorForType()))
   .setValue(message.toByteString())
   .build();
}

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

} while (hasMoreRows);
if (sumVal != null) {
 ByteString first = ci.getProtoForPromotedType(sumVal).toByteString();
 AggregateResponse.Builder pair = AggregateResponse.newBuilder();
 pair.addFirstPart(first);

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

} while (hasMoreRows);
if (sumVal != null) {
 ByteString first_sumVal = ci.getProtoForPromotedType(sumVal).toByteString();
 ByteString first_sumSqVal = ci.getProtoForPromotedType(sumSqVal).toByteString();
 AggregateResponse.Builder pair = AggregateResponse.newBuilder();
 pair.addFirstPart(first_sumVal);

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

if (max != null) {
 AggregateResponse.Builder builder = AggregateResponse.newBuilder();
 builder.addFirstPart(ci.getProtoForCellType(max).toByteString());
 response = builder.build();

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

if (min != null) {
 response = AggregateResponse.newBuilder().addFirstPart(
  ci.getProtoForCellType(min).toByteString()).build();

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

if (sumVal != null) {
 response = AggregateResponse.newBuilder().addFirstPart(
  ci.getProtoForPromotedType(sumVal).toByteString()).build();

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

sumWeights = ci.add(sumWeights, tempWeight);
} while (hasMoreRows);
ByteString first_sumVal = ci.getProtoForPromotedType(sumVal).toByteString();
S s = sumWeights == null ? ci.castToReturnType(ci.getMinValue()) : sumWeights;
ByteString first_sumWeights = ci.getProtoForPromotedType(s).toByteString();
AggregateResponse.Builder pair = AggregateResponse.newBuilder();
pair.addFirstPart(first_sumVal);

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

T result = processor.getResult();
 ProcessResponse.Builder b = ProcessResponse.newBuilder();
 b.setRowProcessorResult(result.toByteString());
 resultProto = b.build();
} catch (Exception e) {

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

static Any toAny(Message message) {
 return Any.newBuilder()
   .setTypeUrl("type.googleapis.com/" + message.getDescriptorForType().getFullName())
   .setValue(message.toByteString())
   .build();
}

代码示例来源：origin: sixt/ja-micro

static Envelope toKafka(Message message) {
    Envelope.Builder envelope = Envelope.newBuilder();
    Metadata meta = message.getMetadata();

    envelope.setMessageId(meta.getMessageId());

    // Correlation ids are set when building the message
    if (!Strings.isNullOrEmpty(meta.getCorrelationId())) {
      envelope.setCorrelationId(meta.getCorrelationId());
    }

    // Message exchange pattern headers
    if (meta.getReplyTo() != null) {
      envelope.setReplyTo(meta.getReplyTo().toString());
    }
    if (!Strings.isNullOrEmpty(meta.getRequestCorrelationId())) {
      envelope.setRequestCorrelationId(meta.getRequestCorrelationId());
    }

    // Payload (mandatory fields!)
    envelope.setMessageType(meta.getType().toString());
    envelope.setInnerMessage(message.getPayload().toByteString()); // Serialize the proto payload to bytes

    return envelope.build();
  }
}

代码示例来源：origin: com.twitter.elephantbird/elephant-bird-core

public void write(M message) throws IOException {
 if (message instanceof Message) {
  //a small hack to avoid extra copy, since we need a ByteString anyway.
  protoBlobs_.add(((Message) message).toByteString());
 } else {
  protoBlobs_.add(ByteString.copyFrom(binaryConverter_.toBytes(message)));
 }
 numRecordsWritten_++;
 if (protoBlobs_.size() == numRecordsPerBlock_) {
  serialize();
 }
}

代码示例来源：origin: org.apache.tajo/tajo-rpc-protobuf

public void run(Message returnValue) {
  RpcResponse.Builder builder = RpcResponse.newBuilder().setId(request.getId());
  if (returnValue != null) {
   builder.setResponseMessage(returnValue.toByteString());
  }
  if (controller.failed()) {
   builder.setErrorMessage(controller.errorText());
  }
  ctx.writeAndFlush(builder.build());
 }
};

代码示例来源：origin: com.opera/operadriver

public Response executeMessage(Message message, Builder<?> builder, long timeout) {
 ByteString payload = (builder != null) ? builder.build().toByteString() : ByteString.EMPTY;
 Command.Builder messageBuilder = buildMessage(message, payload);
 int tag = messageBuilder.getTag();
 connection.send(messageBuilder.build());
 return waitForResponse(tag, timeout);
}

代码示例来源：origin: org.apache.tajo/tajo-rpc

private Message buildRequest(int seqId,
                MethodDescriptor method,
                Message param) {
  RpcRequest.Builder requestBuilder = RpcRequest.newBuilder()
    .setId(seqId)
    .setMethodName(method.getName());
  if (param != null) {
   requestBuilder.setRequestMessage(param.toByteString());
  }
  return requestBuilder.build();
 }
}

代码示例来源：origin: kubernetes-client/java

private byte[] encode(Message msg, String apiVersion, String kind) {
 // It is unfortunate that we have to include apiVersion and kind,
 // since we should be able to extract it from the Message, but
 // for now at least, those fields are missing from the proto-buffer.
 Unknown u =
   Unknown.newBuilder()
     .setTypeMeta(TypeMeta.newBuilder().setApiVersion(apiVersion).setKind(kind))
     .setRaw(msg.toByteString())
     .build();
 return Bytes.concat(MAGIC, u.toByteArray());
}