com.hurence.logisland.record.Field.asString()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(10.2k)|赞(0)|评价(0)|浏览(96)

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

Field.asString介绍

暂无

代码示例

代码示例来源：origin: com.hurence.logisland/logisland-api

/**
 * retrieve record id
 *
 * @return the record id
 */
@Override
public String getId() {
  return getField(FieldDictionary.RECORD_ID).asString();
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

protected long countHasType(List<MockRecord> records, String type) {
  return records.stream()
      .filter(r -> {
        Field actualType = r.getField("source");
        return actualType != null && type.equals(actualType.asString());
      })
      .count();
}

代码示例来源：origin: com.hurence.logisland/logisland-api

/**
 * get the
 *
 * @return
 */
@Override
public String getType() {
  return getField(FieldDictionary.RECORD_TYPE).asString();
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

@Override
  public void buildId(Record record) {
    StringBuilder stb = new StringBuilder();
    for (String fieldName : fieldsForHash) {
      stb.append(record.getField(fieldName).asString());
    }
    digest.update(stb.toString().getBytes(charset));
    byte[] digested = digest.digest();
    final String hashString = new String(digested, charset);
    final String recordType = record.getField(FieldDictionary.RECORD_TYPE).asString();
    final String recordTime = record.getField(FieldDictionary.RECORD_TIME).asString();
    final String newId = String.format("%s-%s-%s", recordType, recordTime, hashString);
    record.setId(newId);
  }
};

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

/**
 * Retrieve the record field value
 * @param fieldName The name of the string field
 * @return The value of the field or null if the field is not present in the record
 */
private String getStringField(Record record, String fieldName)
{
  Field field = record.getField(fieldName);
  if (field != null)
  {
    return field.asString();
  }
  else
  {
    return null;
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

@Override
  public void buildId(Record record) {
    StringBuilder stb = new StringBuilder();
    for (String fieldName : fieldsForHash) {
      if (record.hasField(fieldName))
        stb.append(record.getField(fieldName).asString());
    }
    digest.update(stb.toString().getBytes(charset));
    byte[] digested = digest.digest();
    StringBuffer hexString = new StringBuffer();
    for (int i = 0; i < digested.length; i++) {
      hexString.append(Integer.toHexString(0xFF & digested[i]));
    }
    record.setId(hexString.toString());
  }
};

代码示例来源：origin: com.hurence.logisland/logisland-cache_key_value-service-api

@Override
public Record get(String collectionName, Record record) throws DatastoreClientServiceException {
  if (record.hasField(rowKey)) {
    return get(record.getField(rowKey).asString());
  } else {
    logger.error("field " + rowKey + " not found in record " + record.toString());
    return null;
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-cache_key_value-service-api

@Override
public void bulkPut(String collectionName, Record record) throws DatastoreClientServiceException {
  set(record.getField(rowKey).asString(), record);
}

代码示例来源：origin: com.hurence.logisland/logisland-cache_key_value-service-api

@Override
public void put(String collectionName, Record record, boolean asynchronous) throws DatastoreClientServiceException {
  set(record.getField(rowKey).asString(), record);
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

@Override
public Collection<Record> process(ProcessContext context, Collection<Record> records) {
  String fieldName = context.getPropertyValue(FIELD_NAME).asString();
  String fieldValue = context.getPropertyValue(FIELD_VALUE).asString();
  return records.stream()
      .filter(record -> record.hasField(fieldName) && record.getField(fieldName).asString().equals(fieldValue))
      .collect(Collectors.toList());
}

代码示例来源：origin: com.hurence.logisland/logisland-solr_6_4

batchBuffer.stream().collect(Collectors.groupingBy(r -> r.getField(FieldDictionary.RECORD_NAME).asString()))
    .values().forEach(list -> {
  storage.add(converter, convertToMetric(list.stream().sorted(Comparator.comparing(Record::getTime)).collect(Collectors.toList())), solr);

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

private void extractValueFields(String[] valueFields, Record outputRecord, Matcher valueMatcher, ProcessContext context) {
  String conflictPolicy = context.getPropertyValue(CONFLICT_RESOLUTION_POLICY).asString();
  for (int i = 0; i < Math.min(valueMatcher.groupCount() + 1, valueFields.length); i++) {
    String content = valueMatcher.group(i + 1);
    String fieldName = valueFields[i];
    if (content != null) {
      if (outputRecord.hasField(fieldName) &&
          (outputRecord.getField(fieldName).asString() != null) &&
          (! outputRecord.getField(fieldName).asString().isEmpty())) {
        if (conflictPolicy.equals(OVERWRITE_EXISTING.getValue())) {
          outputRecord.setStringField(fieldName, content.replaceAll("\"", ""));
        }
      }
      else {
        outputRecord.setStringField(fieldName, content.replaceAll("\"", ""));
      }
    }
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-web-analytics-plugin

String first_visited_page_field = context.getPropertyValue(FIRST_VISITED_PAGE_FIELD).asString();
if (record.hasField(first_visited_page_field)){
  String first_page = record.getField(first_visited_page_field).asString();
  URL first_page_url = null;
  try {

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

final String key = record.getField(FieldDictionary.RECORD_KEY).asString();
buffer += record.getField(FieldDictionary.RECORD_VALUE).asString();

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

for (String sourceAttr : fieldsNameMapping.keySet()){
  if (record.hasField(sourceAttr) &&
      (record.getField(sourceAttr).asString() != null) &&
      (! record.getField(sourceAttr).asString().isEmpty())){
    regexRule mappingRule = fieldsNameMapping.get(sourceAttr);
    if (mappingRule.getValueRegex() != null){
      String fieldValue = record.getField(sourceAttr).asString();
      try {
        Pattern valueRegex = mappingRule.getValueRegex();

代码示例来源：origin: com.hurence.logisland/logisland-cache_key_value-service-api

@Override
public List<MultiGetResponseRecord> multiGet(List<MultiGetQueryRecord> multiGetQueryRecords) throws DatastoreClientServiceException {
  List<MultiGetResponseRecord> results = new ArrayList<>();
  for (MultiGetQueryRecord mgqr : multiGetQueryRecords) {
    String collectionName = mgqr.getIndexName();
    String typeName = mgqr.getTypeName();
    for (String id : mgqr.getDocumentIds()) {
      Record record = get(collectionName, new StandardRecord().setStringField(rowKey, id));
      Map<String, String> retrievedFields = new HashMap<>();
      if (record != null) {
        if (mgqr.getFieldsToInclude()[0].equals("*")) {
          for (Field field : record.getAllFieldsSorted()) {
            if (!field.getName().equals(FieldDictionary.RECORD_TIME) &&
                !field.getName().equals(FieldDictionary.RECORD_TYPE) &&
                !field.getName().equals(FieldDictionary.RECORD_ID))
              retrievedFields.put(field.getName(), field.asString());
          }
        } else {
          for (String prop : mgqr.getFieldsToInclude()) {
            retrievedFields.put(prop, record.getField(prop).asString());
          }
        }
      } else {
        logger.debug("unable to retrieve record (id=" + id + ") from collection " + collectionName);
      }
      results.add(new MultiGetResponseRecord(collectionName, typeName, id, retrievedFields));
    }
  }
  return results;
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

private void extractValueFields(String valueField, Record outputRecord, String[] values, ProcessContext context) {
  String conflictPolicy = context.getPropertyValue(CONFLICT_RESOLUTION_POLICY).asString();
  String fieldName = valueField;
  if (outputRecord.hasField(fieldName) &&
      (outputRecord.getField(fieldName).asString() != null) &&
      (! outputRecord.getField(fieldName).asString().isEmpty())) {
    if (conflictPolicy.equals(OVERWRITE_EXISTING.getValue())) {
      //outputRecord.setStringField(fieldName, content.replaceAll("\"", ""));
      outputRecord.setField(fieldName, FieldType.ARRAY, values);
      if (this.isEnabledSplitCounter){
        outputRecord.setField(fieldName+this.splitCounterSuffix, FieldType.INT, values.length);
      }
    }
  }
  else {
    outputRecord.setField(fieldName, FieldType.ARRAY, values);
    //outputRecord.setStringField(fieldName, content.replaceAll("\"", ""));
    if (this.isEnabledSplitCounter){
      outputRecord.setField(fieldName+this.splitCounterSuffix, FieldType.INT, values.length);
    }
  }
}

代码示例来源：origin: com.hurence.logisland/logisland-enrichment-plugin

for (final Record record : records) {
  if (record.hasField(ipAddrField)) {
    String ipAsString = record.getField(ipAddrField).asString();
    if (ipAsString == null)

代码示例来源：origin: com.hurence.logisland/logisland-hbase-plugin

@Override
protected PutRecord createPut(final ProcessContext context, final Record record, final RecordSerializer serializer) {
  String tableName = context.getPropertyValue(TABLE_NAME_DEFAULT).asString();
  String columnFamily = context.getPropertyValue(COLUMN_FAMILY_DEFAULT).asString();
  String columnQualifier = context.getPropertyValue(COLUMN_QUALIFIER_DEFAULT).asString();
  try {
    if (!record.hasField(context.getPropertyValue(ROW_ID_FIELD).asString()))
      throw new IllegalArgumentException("record has no ROW_ID_FIELD");
    final String row = record.getField(context.getPropertyValue(ROW_ID_FIELD).asString()).asString();
    if (record.hasField(context.getPropertyValue(TABLE_NAME_FIELD).asString()))
      tableName = record.getField(context.getPropertyValue(TABLE_NAME_FIELD).asString()).asString();
    if (record.hasField(context.getPropertyValue(COLUMN_FAMILY_FIELD).asString()))
      columnFamily = record.getField(context.getPropertyValue(COLUMN_FAMILY_FIELD).asString()).asString();
    if (record.hasField(context.getPropertyValue(COLUMN_QUALIFIER_FIELD).asString()))
      columnQualifier = record.getField(context.getPropertyValue(COLUMN_QUALIFIER_FIELD).asString()).asString();
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    serializer.serialize(baos, record);
    final byte[] buffer = baos.toByteArray();
    baos.close();
    final Collection<PutColumn> columns = Collections.singletonList(new PutColumn(
        columnFamily.getBytes(StandardCharsets.UTF_8),
        columnQualifier.getBytes(StandardCharsets.UTF_8),
        buffer));
    byte[] rowKeyBytes = getRow(row, context.getPropertyValue(ROW_ID_ENCODING_STRATEGY).asString());
    return new PutRecord(tableName, rowKeyBytes, columns, record);
  } catch (Exception e) {
    logger.error(e.toString());
  }
  return new PutRecord(tableName, null, Collections.emptyList(), record);
}

代码示例来源：origin: com.hurence.logisland/logisland-common-processors-plugin

record.setField(fieldName, newFieldType, currentField.asString());
  break;
case INT:

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

Field

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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