io.protostuff.ByteString.asReadOnlyByteBuffer()方法的使用及代码示例

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

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

ByteString.asReadOnlyByteBuffer介绍

[英]Constructs a new read-only java.nio.ByteBuffer with the same backing byte array.
[中]构造一个新的只读java。尼奥。具有相同备份字节数组的ByteBuffer。

代码示例

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

@Override
public List<Entry<String, ByteString>> getSharedData() {
 return Collections.singletonList(
  new SimpleEntry<>(
   HIVE_ATTRIBUTE_KEY,
   ByteString.copyFrom(dataset.getReadDefinition().getExtendedProperty().asReadOnlyByteBuffer())
  )
 );
}

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

public static String[] getColumnsLowerCase(DatasetConfig datasetConfig) {
 final ByteString schemaBytes = DatasetHelper.getSchemaBytes(datasetConfig);
 if (schemaBytes != null) {
  Schema schema = Schema.getRootAsSchema(schemaBytes.asReadOnlyByteBuffer());
  org.apache.arrow.vector.types.pojo.Schema s = org.apache.arrow.vector.types.pojo.Schema.convertSchema(schema);
  return s.getFields().stream().map(input -> input.getName().toLowerCase()).toArray(String[]::new);
 } else {
  // If virtual dataset was created with view fields
  if (datasetConfig.getType() == DatasetType.VIRTUAL_DATASET) {
   final List<ViewFieldType> viewFieldTypes = datasetConfig.getVirtualDataset().getSqlFieldsList();
   if (notEmpty(viewFieldTypes)) {
    return viewFieldTypes.stream().map(input -> input.getName().toLowerCase()).toArray(String[]::new);
   }
  }
 }
 return new String[0];
}

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

private DatasetConfig update(DatasetConfig datasetConfig) {
 if (datasetConfig == null) {
  return null;
 }
 final io.protostuff.ByteString schemaBytes = DatasetHelper.getSchemaBytes(datasetConfig);
 if (schemaBytes == null) {
  return null;
 }
 try {
  OldSchema oldSchema = OldSchema.getRootAsOldSchema(schemaBytes.asReadOnlyByteBuffer());
  byte[] newschemaBytes = convertFromOldSchema(oldSchema);
  datasetConfig.setRecordSchema(ByteString.copyFrom(newschemaBytes));
  return datasetConfig;
 } catch (Exception e) {
  System.out.println("Unable to update Arrow Schema for: " + PathUtils
   .constructFullPath(Optional.ofNullable(datasetConfig.getFullPathList()).orElse(Lists.newArrayList())));
  e.printStackTrace(System.out);
  return null;
 }
}

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

public static BatchSchema deserialize(ByteString bytes) {
 Schema schema = Schema.getRootAsSchema(bytes.asReadOnlyByteBuffer());
 org.apache.arrow.vector.types.pojo.Schema s = org.apache.arrow.vector.types.pojo.Schema.convertSchema(schema);
 return new BatchSchema(SelectionVectorMode.NONE, s.getFields());
}

相关文章