org.apache.hbase.thirdparty.com.google.protobuf.ByteString.copyFrom()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(8.9k)|赞(0)|评价(0)|浏览(139)

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

ByteString.copyFrom介绍

暂无

代码示例

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

public ByteString toByteString() {
 // We need this copy to create the ByteString as the byte[] 'buf' is not immutable. We reuse
 // them.
 return ByteString.copyFrom(this.buf, 0, this.count);
}

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

QualifierValue.Builder qualifierBuilder = QualifierValue.newBuilder();
qualifierBuilder.setQualifier(ByteString.copyFromUtf8("c1"));
qualifierBuilder.setValue(ByteString.copyFrom(Bytes.toBytes(11L)));
qualifierBuilder.setTimestamp(timeStamp);
valueBuilder.addQualifierValue(qualifierBuilder.build());
qualifierBuilder.setQualifier(ByteString.copyFromUtf8("c2"));
qualifierBuilder.setValue(ByteString.copyFrom(Bytes.toBytes(22L)));
valueBuilder.addQualifierValue(qualifierBuilder.build());
mutateBuilder.addColumnValue(valueBuilder.build());

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

private ByteString getByteString(byte[] bytes) {
 // return singleton to reduce object allocation
 return (bytes.length == 0) ? ByteString.EMPTY : ByteString.copyFrom(bytes);
}

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

builder.setTableName(toProtoTableName(tablePerm.getTableName()));
if (tablePerm.hasFamily()) {
 builder.setFamily(ByteString.copyFrom(tablePerm.getFamily()));
 builder.setQualifier(ByteString.copyFrom(tablePerm.getQualifier()));

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

@Override
public ByteString compress(byte[] data, Enum dictIndex) throws IOException {
 writeCompressed(data, dictIndex);
 // We need this copy to create the ByteString as the byte[] 'buf' is not immutable. We reuse
 // them.
 ByteString result = ByteString.copyFrom(this.buf, 0, this.count);
 reset(); // Only resets the count - we reuse the byte array.
 return result;
}

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

entryBuilder.setKey(entryBuilder.getKeyBuilder().
  setLogSequenceNumber(i).
  setEncodedRegionName(ByteString.copyFrom(bytes)).
  setWriteTime(i).
  setTableName(tableName).build());

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

public static HBaseProtos.TableName toProtoTableName(TableName tableName) {
 return HBaseProtos.TableName.newBuilder()
   .setNamespace(ByteString.copyFrom(tableName.getNamespace()))
   .setQualifier(ByteString.copyFrom(tableName.getQualifier())).build();
}

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

public RemoteProcedureRequest buildRequest() {
  return RemoteProcedureRequest.newBuilder().setProcId(procId)
    .setProcClass(rsProcClass.getName()).setProcData(ByteString.copyFrom(rsProcData)).build();
 }
}

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

public static ClientProtos.Cursor toCursor(Cursor cursor) {
 ClientProtos.Cursor.Builder builder = ClientProtos.Cursor.newBuilder();
 ClientProtos.Cursor.newBuilder().setRow(ByteString.copyFrom(cursor.getRow()));
 return builder.build();
}

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

FlushedRegionSequenceId.newBuilder();
flushedRegionSequenceIdBuilder.setRegionEncodedName(
  ByteString.copyFrom(entry.getKey()));
flushedRegionSequenceIdBuilder.setSeqId(entry.getValue());
ConcurrentNavigableMap<byte[], Long> storeSeqIds =
  FlushedStoreSequenceId.Builder flushedStoreSequenceIdBuilder =
    FlushedStoreSequenceId.newBuilder();
  flushedStoreSequenceIdBuilder.setFamily(ByteString.copyFrom(store.getKey()));
  flushedStoreSequenceIdBuilder.setSeqId(store.getValue());
  flushedRegionSequenceIdBuilder.addStores(flushedStoreSequenceIdBuilder);

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

public static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.
  CoprocessorServiceResponse getResponse(final Message result, final byte [] regionName) {
 org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.
  CoprocessorServiceResponse.Builder builder =
   org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse.
   newBuilder();
 builder.setRegion(RequestConverter.buildRegionSpecifier(RegionSpecifierType.REGION_NAME,
  regionName));
 // TODO: UGLY COPY IN HERE!!!!
 builder.setValue(builder.getValueBuilder().setName(result.getClass().getName())
   .setValue(org.apache.hbase.thirdparty.com.google.protobuf.ByteString.
     copyFrom(result.toByteArray())));
 return builder.build();
}

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

public static ClientProtos.Cursor toCursor(Cell cell) {
 return ClientProtos.Cursor.newBuilder()
   .setRow(ByteString.copyFrom(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength()))
   .build();
}

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

@Override
protected void serializeStateData(ProcedureStateSerializer serializer)
  throws IOException {
 ByteString byteString = ByteString.copyFrom(new byte[] { 'A' });
 BytesValue state = BytesValue.newBuilder().setValue(byteString).build();
 serializer.serialize(state);
}

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

/**
 * @return An empty region load stamped with the passed in <code>regionInfo</code>
 * region name.
 */
private RegionMetrics getEmptyRegionMetrics(final RegionInfo regionInfo) {
 return RegionMetricsBuilder.toRegionMetrics(ClusterStatusProtos.RegionLoad.newBuilder().
     setRegionSpecifier(HBaseProtos.RegionSpecifier.newBuilder().
         setType(HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME).
         setValue(ByteString.copyFrom(regionInfo.getRegionName())).build()).build());
}

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

@Override
protected void serializeStateData(ProcedureStateSerializer serializer)
  throws IOException {
 ByteString dataString = ByteString.copyFrom((data == null) ? new byte[0] : data);
 BytesValue.Builder builder = BytesValue.newBuilder().setValue(dataString);
 serializer.serialize(builder.build());
}

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

@Test
public void testException() throws IOException {
 NameBytesPair.Builder builder = NameBytesPair.newBuilder();
 final String omg = "OMG!!!";
 builder.setName("java.io.IOException");
 builder.setValue(ByteString.copyFrom(Bytes.toBytes(omg)));
 Throwable t = ProtobufUtil.toException(builder.build());
 assertEquals(omg, t.getMessage());
 builder.clear();
 builder.setName("org.apache.hadoop.ipc.RemoteException");
 builder.setValue(ByteString.copyFrom(Bytes.toBytes(omg)));
 t = ProtobufUtil.toException(builder.build());
 assertEquals(omg, t.getMessage());
}

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

@Override
public CoprocessorServiceResponse execService(final RpcController controller,
  final CoprocessorServiceRequest request) throws ServiceException {
 try {
  checkOpen();
  requestCount.increment();
  HRegion region = getRegion(request.getRegion());
  com.google.protobuf.Message result = execServiceOnRegion(region, request.getCall());
  CoprocessorServiceResponse.Builder builder = CoprocessorServiceResponse.newBuilder();
  builder.setRegion(RequestConverter.buildRegionSpecifier(
   RegionSpecifierType.REGION_NAME, region.getRegionInfo().getRegionName()));
  // TODO: COPIES!!!!!!
  builder.setValue(builder.getValueBuilder().setName(result.getClass().getName()).
   setValue(org.apache.hbase.thirdparty.com.google.protobuf.ByteString.
     copyFrom(result.toByteArray())));
  return builder.build();
 } catch (IOException ie) {
  throw new ServiceException(ie);
 }
}

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

private static void appendCompactionEvent(Writer w, RegionInfo hri, String[] inputs,
  String output) throws IOException {
 WALProtos.CompactionDescriptor.Builder desc = WALProtos.CompactionDescriptor.newBuilder();
 desc.setTableName(ByteString.copyFrom(hri.getTable().toBytes()))
   .setEncodedRegionName(ByteString.copyFrom(hri.getEncodedNameAsBytes()))
   .setRegionName(ByteString.copyFrom(hri.getRegionName()))
   .setFamilyName(ByteString.copyFrom(FAMILY))
   .setStoreHomeDir(hri.getEncodedName() + "/" + Bytes.toString(FAMILY))
   .addAllCompactionInput(Arrays.asList(inputs))
   .addCompactionOutput(output);
 WALEdit edit = WALEdit.createCompaction(hri, desc.build());
 WALKeyImpl key = new WALKeyImpl(hri.getEncodedNameAsBytes(), TABLE_NAME, 1,
   EnvironmentEdgeManager.currentTime(), HConstants.DEFAULT_CLUSTER_ID);
 w.append(new Entry(key, edit));
 w.sync(false);
}

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

edit = WALEdit.createCompaction(region.getRegionInfo(),
 CompactionDescriptor.newBuilder()
 .setTableName(ByteString.copyFrom(tableName.getName()))
 .setFamilyName(ByteString.copyFrom(regionName))
 .setEncodedRegionName(ByteString.copyFrom(regionName))
 .setStoreHomeDirBytes(ByteString.copyFrom(Bytes.toBytes(regiondir.toString())))
 .setRegionName(ByteString.copyFrom(region.getRegionInfo().getRegionName()))
 .build());
} else {

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

@Test
public void testProcedureInfo() {
 ProcedureProtos.Procedure.Builder builder = createProcedureBuilder(1);
 ByteString stateBytes = ByteString.copyFrom(new byte[] { 65 });
 BytesValue state = BytesValue.newBuilder().setValue(stateBytes).build();
 builder.addStateMessage(Any.pack(state));
 ProcedureProtos.Procedure procedure = builder.build();
 String procJson = ProtobufUtil.toProcedureJson(Lists.newArrayList(procedure));
 assertEquals("[{"
   + "\"className\":\"java.lang.Object\","
   + "\"procId\":\"1\","
   + "\"submittedTime\":\"0\","
   + "\"state\":\"RUNNABLE\","
   + "\"lastUpdate\":\"0\","
   + "\"stateMessage\":[{\"value\":\"QQ==\"}]"
   + "}]", procJson);
}

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

ByteString

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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