org.apache.parquet.io.api.Binary.fromReusedByteBuffer()方法的使用及代码示例

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

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

Binary.fromReusedByteBuffer介绍

暂无

代码示例

代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column

  1. private static Binary convert(ByteBuffer buffer) {
  2. return Binary.fromReusedByteBuffer(buffer);
  3. }

代码示例来源:origin: org.apache.parquet/parquet-column

  1. @Deprecated
  2. /**
  3. * @deprecated Use @link{fromReusedByteBuffer} or @link{fromConstantByteBuffer} instead
  4. */
  5. public static Binary fromByteBuffer(final ByteBuffer value) {
  6. return fromReusedByteBuffer(value); // Assume producer intends to reuse byte[]
  7. }

代码示例来源:origin: org.lasersonlab.apache.parquet/parquet-column

  1. @Deprecated
  2. /**
  3. * @deprecated Use @link{fromReusedByteBuffer} or @link{fromConstantByteBuffer} instead
  4. */
  5. public static Binary fromByteBuffer(final ByteBuffer value) {
  6. return fromReusedByteBuffer(value); // Assume producer intends to reuse byte[]
  7. }

代码示例来源:origin: Netflix/iceberg

  1. @Override
  2. public void write(int repetitionLevel, ByteBuffer buffer) {
  3. column.writeBinary(repetitionLevel, Binary.fromReusedByteBuffer(buffer));
  4. }
  5. }

代码示例来源:origin: Netflix/iceberg

  1. @SuppressWarnings("unchecked")
  2. private static <C extends Comparable<C>> C getParquetPrimitive(Literal<?> lit) {
  3. if (lit == null) {
  4. return null;
  5. }
  6. // TODO: this needs to convert to handle BigDecimal and UUID
  7. Object value = lit.value();
  8. if (value instanceof Number) {
  9. return (C) lit.value();
  10. } else if (value instanceof CharSequence) {
  11. return (C) Binary.fromString(value.toString());
  12. } else if (value instanceof ByteBuffer) {
  13. return (C) Binary.fromReusedByteBuffer((ByteBuffer) value);
  14. }
  15. throw new UnsupportedOperationException(
  16. "Type not supported yet: " + value.getClass().getName());
  17. }

代码示例来源:origin: org.apache.drill.exec/drill-java-exec

  1. @Override
  2. public void writeValue(RecordConsumer consumer, DrillBuf buffer, int start, int end, int precision) {
  3. consumer.addBinary(Binary.fromReusedByteBuffer(buffer.nioBuffer(start, end - start)));
  4. }
  5. }

代码示例来源:origin: org.apache.parquet/parquet-avro

  1. recordConsumer.addBinary(Binary.fromReusedByteArray((byte[]) value));
  2. } else {
  3. recordConsumer.addBinary(Binary.fromReusedByteBuffer((ByteBuffer) value));

相关文章