本文整理了Java中org.apache.parquet.io.api.Binary.fromConstantByteBuffer()
方法的一些代码示例,展示了Binary.fromConstantByteBuffer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Binary.fromConstantByteBuffer()
方法的具体详情如下:
包路径:org.apache.parquet.io.api.Binary
类名称:Binary
方法名:fromConstantByteBuffer
暂无
代码示例来源:origin: org.apache.parquet/parquet-column
public Binary toBinary() {
ByteBuffer buf = ByteBuffer.allocate(12);
buf.order(ByteOrder.LITTLE_ENDIAN);
buf.putLong(timeOfDayNanos);
buf.putInt(julianDay);
buf.flip();
return Binary.fromConstantByteBuffer(buf);
}
代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column
public Binary toBinary() {
ByteBuffer buf = ByteBuffer.allocate(12);
buf.order(ByteOrder.LITTLE_ENDIAN);
buf.putLong(timeOfDayNanos);
buf.putInt(julianDay);
buf.flip();
return Binary.fromConstantByteBuffer(buf);
}
代码示例来源:origin: org.apache.parquet/parquet-column
@Override
public Binary readBytes() {
try {
return Binary.fromConstantByteBuffer(in.slice(length));
} catch (IOException | RuntimeException e) {
throw new ParquetDecodingException("could not read bytes at offset " + in.position(), e);
}
}
代码示例来源:origin: org.apache.parquet/parquet-column
@Override
public Binary readBytes() {
int length = lengthReader.readInteger();
try {
return Binary.fromConstantByteBuffer(in.slice(length));
} catch (IOException e) {
throw new ParquetDecodingException("Failed to read " + length + " bytes");
}
}
代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column
@Override
public Binary readBytes() {
try {
return Binary.fromConstantByteBuffer(in.slice(length));
} catch (IOException | RuntimeException e) {
throw new ParquetDecodingException("could not read bytes at offset " + in.position(), e);
}
}
代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column
@Override
public Binary readBytes() {
int length = lengthReader.readInteger();
try {
return Binary.fromConstantByteBuffer(in.slice(length));
} catch (IOException e) {
throw new ParquetDecodingException("Failed to read " + length + " bytes");
}
}
代码示例来源:origin: org.apache.parquet/parquet-column
binaryDictionaryContent[i] = Binary.fromConstantByteBuffer(dictionaryBytes, offset, len);
for (int i = 0; i < binaryDictionaryContent.length; i++) {
binaryDictionaryContent[i] = Binary.fromConstantByteBuffer(
dictionaryBytes, offset, length);
代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column
binaryDictionaryContent[i] = Binary.fromConstantByteBuffer(dictionaryBytes, offset, len);
for (int i = 0; i < binaryDictionaryContent.length; i++) {
binaryDictionaryContent[i] = Binary.fromConstantByteBuffer(
dictionaryBytes, offset, length);
代码示例来源:origin: org.apache.parquet/parquet-column
@Override
public Binary readBytes() {
try {
int length = BytesUtils.readIntLittleEndian(in);
return Binary.fromConstantByteBuffer(in.slice(length));
} catch (IOException e) {
throw new ParquetDecodingException("could not read bytes at offset " + in.position(), e);
} catch (RuntimeException e) {
throw new ParquetDecodingException("could not read bytes at offset " + in.position(), e);
}
}
代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column
@Override
public Binary readBytes() {
try {
int length = BytesUtils.readIntLittleEndian(in);
return Binary.fromConstantByteBuffer(in.slice(length));
} catch (IOException e) {
throw new ParquetDecodingException("could not read bytes at offset " + in.position(), e);
} catch (RuntimeException e) {
throw new ParquetDecodingException("could not read bytes at offset " + in.position(), e);
}
}
内容来源于网络,如有侵权,请联系作者删除!