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

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

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

Binary.fromString介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-gobblin

  1. @Override
  2. BinaryValue convertField(JsonElement value) {
  3.  return new BinaryValue(Binary.fromString(value.getAsString()));
  4. }

代码示例来源：origin: prestodb/presto

  1. private static BinaryStatistics stringColumnStats(String minimum, String maximum)
  2. {
  3.   BinaryStatistics statistics = new BinaryStatistics();
  4.   statistics.setMinMax(Binary.fromString(minimum), Binary.fromString(maximum));
  5.   return statistics;
  6. }

代码示例来源：origin: apache/incubator-gobblin

  1. public void add(int fieldIndex, String value) {
  2.  this.add(fieldIndex, new BinaryValue(Binary.fromString(value)));
  3. }

代码示例来源：origin: prestodb/presto

  1. case STRING:
  2.   String v = ((StringObjectInspector) inspector).getPrimitiveJavaObject(value);
  3.   recordConsumer.addBinary(Binary.fromString(v));
  4.   break;
  5. case CHAR:
  6.   String vChar = ((HiveCharObjectInspector) inspector).getPrimitiveJavaObject(value).getStrippedValue();
  7.   recordConsumer.addBinary(Binary.fromString(vChar));
  8.   break;
  9. case VARCHAR:
  10.   String vVarchar = ((HiveVarcharObjectInspector) inspector).getPrimitiveJavaObject(value).getValue();
  11.   recordConsumer.addBinary(Binary.fromString(vVarchar));
  12.   break;
  13. case BINARY:

代码示例来源：origin: com.twitter/parquet-thrift

  1. private void writeStringToRecordConsumer(String str) {
  2.  recordConsumer.addBinary(Binary.fromString(str));
  3. }

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

  1. @Override
  2. BinaryValue convertField(JsonElement value) {
  3.  return new BinaryValue(Binary.fromString(value.getAsString()));
  4. }

代码示例来源：origin: com.facebook.presto.hive/hive-apache

  1. public Group append(String fieldName, String value) {
  2.  add(fieldName, Binary.fromString(value));
  3.  return this;
  4. }

代码示例来源：origin: asakusafw/asakusafw

  1. @Override
  2.   public void write(Object value, RecordConsumer consumer) {
  3.     consumer.addBinary(Binary.fromString(toString(value)));
  4.   }
  5. }

代码示例来源：origin: com.facebook.presto.hive/hive-apache

  1. @Override
  2. public void add(int fieldIndex, String value) {
  3.  add(fieldIndex, new BinaryValue(Binary.fromString(value)));
  4. }

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

  1. public void add(int fieldIndex, String value) {
  2.  this.add(fieldIndex, new BinaryValue(Binary.fromString(value)));
  3. }

代码示例来源：origin: com.facebook.presto.hive/hive-apache

  1. @Override
  2.  public FilterPredicate buildPredict(Operator op, Object constant,
  3.                    String columnName) throws Exception{
  4.   switch (op) {
  5.    case LESS_THAN:
  6.     return lt(binaryColumn(columnName), Binary.fromString((String) constant));
  7.    case IS_NULL:
  8.    case EQUALS:
  9.    case NULL_SAFE_EQUALS:
  10.     return eq(binaryColumn(columnName),
  11.      (constant == null) ? null : Binary.fromString((String) constant));
  12.    case LESS_THAN_EQUALS:
  13.     return ltEq(binaryColumn(columnName), Binary.fromString((String) constant));
  14.    default:
  15.     // should never be executed
  16.     throw new RuntimeException("Unknown PredicateLeaf Operator type: " + op);
  17.   }
  18.  }
  19. }

代码示例来源：origin: com.facebook.presto/presto-parquet

  1. private static BinaryStatistics stringColumnStats(String minimum, String maximum)
  2. {
  3.   BinaryStatistics statistics = new BinaryStatistics();
  4.   statistics.setMinMax(Binary.fromString(minimum), Binary.fromString(maximum));
  5.   return statistics;
  6. }

代码示例来源：origin: asakusafw/asakusafw

  1. @Override
  2.   public void write(Object value, RecordConsumer consumer) {
  3.     StringOption option = (StringOption) value;
  4.     Text text = option.get();
  5.     byte[] bytes = text.getBytes();
  6.     int length = text.getLength();
  7.     if (length > limit) {
  8.       // if byte-length > limit, the string may code-point-count >= limit
  9.       String stripped = HiveBaseChar.getPaddedValue(text.toString(), limit);
  10.       consumer.addBinary(Binary.fromString(stripped));
  11.     } else {
  12.       consumer.addBinary(Binary.fromByteArray(bytes, 0, length));
  13.     }
  14.   }
  15. }

代码示例来源：origin: uk.co.nichesolutions.presto/presto-hive

  1. private static BinaryStatistics stringColumnStats(String minimum, String maximum)
  2.   {
  3.     BinaryStatistics statistics = new BinaryStatistics();
  4.     statistics.setMinMax(Binary.fromString(minimum), Binary.fromString(maximum));
  5.     return statistics;
  6.   }
  7. }

代码示例来源：origin: com.twitter/parquet-thrift

  1. @Override
  2. public void writeI32(int i32) throws TException {
  3.  start();
  4.  EnumValue value = type.getEnumValueById(i32);
  5.  if (value == null) {
  6.   throw new ParquetEncodingException("Can not find enum value of index " + i32 + " for field:" + columnIO.toString());
  7.  }
  8.  recordConsumer.addBinary(Binary.fromString(value.getName()));
  9.  end();
  10. }

代码示例来源：origin: com.twitter/parquet-cascading

  1. private void writePrimitive(TupleEntry record, PrimitiveType field) {
  2.   switch (field.getPrimitiveTypeName()) {
  3.    case BINARY:
  4.     recordConsumer.addBinary(Binary.fromString(record.getString(field.getName())));
  5.     break;
  6.    case BOOLEAN:
  7.     recordConsumer.addBoolean(record.getBoolean(field.getName()));
  8.     break;
  9.    case INT32:
  10.     recordConsumer.addInteger(record.getInteger(field.getName()));
  11.     break;
  12.    case INT64:
  13.     recordConsumer.addLong(record.getLong(field.getName()));
  14.     break;
  15.    case DOUBLE:
  16.     recordConsumer.addDouble(record.getDouble(field.getName()));
  17.     break;
  18.    case FLOAT:
  19.     recordConsumer.addFloat(record.getFloat(field.getName()));
  20.     break;
  21.    case FIXED_LEN_BYTE_ARRAY:
  22.     throw new UnsupportedOperationException("Fixed len byte array type not implemented");
  23.    case INT96:
  24.     throw new UnsupportedOperationException("Int96 type not implemented");
  25.    default:
  26.     throw new UnsupportedOperationException(field.getName() + " type not implemented");
  27.   }
  28.  }
  29. }

代码示例来源：origin: com.facebook.presto.hive/hive-apache

  1. case STRING:
  2.  String v = ((StringObjectInspector) inspector).getPrimitiveJavaObject(value);
  3.  recordConsumer.addBinary(Binary.fromString(v));
  4.  break;
  5. case CHAR:
  6.  String vChar = ((HiveCharObjectInspector) inspector).getPrimitiveJavaObject(value).getStrippedValue();
  7.  recordConsumer.addBinary(Binary.fromString(vChar));
  8.  break;
  9. case VARCHAR:
  10.  String vVarchar = ((HiveVarcharObjectInspector) inspector).getPrimitiveJavaObject(value).getValue();
  11.  recordConsumer.addBinary(Binary.fromString(vVarchar));
  12.  break;
  13. case BINARY:

代码示例来源：origin: org.apache.tajo/tajo-storage

  1. case CHAR:
  2. case TEXT:
  3.  recordConsumer.addBinary(Binary.fromString(datum.asChars()));
  4.  break;
  5. case PROTOBUF:

代码示例来源：origin: com.facebook.presto/presto-hive

  1. case STRING:
  2.   String v = ((StringObjectInspector) inspector).getPrimitiveJavaObject(value);
  3.   recordConsumer.addBinary(Binary.fromString(v));
  4.   break;
  5. case CHAR:
  6.   String vChar = ((HiveCharObjectInspector) inspector).getPrimitiveJavaObject(value).getStrippedValue();
  7.   recordConsumer.addBinary(Binary.fromString(vChar));
  8.   break;
  9. case VARCHAR:
  10.   String vVarchar = ((HiveVarcharObjectInspector) inspector).getPrimitiveJavaObject(value).getValue();
  11.   recordConsumer.addBinary(Binary.fromString(vVarchar));
  12.   break;
  13. case BINARY:

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

Binary

相关文章

    查看更多

    热门标签

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

    最新文章

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