本文整理了Java中io.protostuff.ByteString.asReadOnlyByteBuffer()
方法的一些代码示例,展示了ByteString.asReadOnlyByteBuffer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ByteString.asReadOnlyByteBuffer()
方法的具体详情如下:
包路径:io.protostuff.ByteString
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!