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

Record.setStringField介绍

暂无

代码示例

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

public static Record getKeyValueRecord(String key, String value) {
  final Record record = new StandardRecord("kv_record");
  record.setStringField(FieldDictionary.RECORD_KEY, key);
  record.setStringField(FieldDictionary.RECORD_VALUE, value);
  return record;
}

代码示例来源：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-querymatcher-plugin

@Override
public void handleMatch(final Record record,
            final ProcessContext context,
            final MatchingRule matchingRule,
            MatchQuery.RecordTypeUpdatePolicy recordTypeUpdatePolicy) {
  this.outRecords.add(
      new StandardRecord(record)
          .setType(
            (recordTypeUpdatePolicy == MatchQuery.RecordTypeUpdatePolicy.overwrite) ?
                context.getPropertyValue(MatchQuery.OUTPUT_RECORD_TYPE).asString() : record.getType()
          )
          .setStringField(ALERT_MATCH_NAME, matchingRule.getName())
          .setStringField(ALERT_MATCH_QUERY, matchingRule.getLegacyQuery()));
}

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

String content = matcher.group(i);
if (content != null) {
  record.setStringField(fields[i], matcher.group(i).replaceAll("\"", ""));

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

String content = SmallFileUtil.getContent(file);
Record record = new StandardRecord(file.getName());
record.setStringField("name", file.getName());
record.setStringField("content", content);
ByteArrayOutputStream baos = new ByteArrayOutputStream();
kryoSerializer.serialize(baos, record);

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

for (String k : rule.keySet()) record.setStringField(k, rule.get(k));

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

private void updateRecord(ProcessContext context, Record record, Map<String, String> fieldsNameMapping) {
  String conflictPolicy = context.getPropertyValue(CONFLICT_RESOLUTION_POLICY).asString();
  if ((fieldsNameMapping == null) || (fieldsNameMapping.keySet() == null)) {
    return;
  }
  fieldsNameMapping.keySet().forEach(addedFieldName -> {
    final String defaultValueToAdd = context.getPropertyValue(addedFieldName).evaluate(record).asString();
    // field is already here
    if (record.hasField(addedFieldName)) {
      if (conflictPolicy.equals(OVERWRITE_EXISTING.getValue())) {
        overwriteObsoleteFieldValue(record, addedFieldName, defaultValueToAdd);
      }
    } else {
      record.setStringField(addedFieldName, defaultValueToAdd);
    }
  });
}

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

Record alertRecord = new StandardRecord(outputRecordType)
    .setId(entry.getKey())
    .setStringField(FieldDictionary.RECORD_VALUE, context.getPropertyValue(entry.getKey()).asString());
outputRecords.add(alertRecord);

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

} else if (!Objects.equals(fieldName, FieldDictionary.RECORD_TYPE)) {
  if (fieldValue instanceof org.apache.avro.util.Utf8) {
    record.setStringField(fieldName, fieldValue.toString());
  } else if (fieldValue instanceof GenericData.Array) {
    GenericData.Array avroArray = (GenericData.Array) fieldValue;

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

record.setStringField(FIELD_VERSION, value.toString());
  return true;
} else if (value instanceof Integer)

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

includesFieldName = context.getPropertyValue(ES_INCLUDES_FIELD).evaluate(record).asString();
} catch (Throwable t) {
  record.setStringField(FieldDictionary.RECORD_ERRORS, "Failure in executing EL. Error: " + t.getMessage());
  logger.error("Cannot interpret EL : " + record, t);
    recordsToEnrich.add(new ImmutableTriple(record, asUniqueKey(indexName, typeName, recordKeyName), includeFields));
  } catch (Throwable t) {
    record.setStringField(FieldDictionary.RECORD_ERRORS, "Can not request ElasticSearch with " + indexName + " "  + typeName + " " + recordKeyName);
    outputRecords.add(record);
        String mappedAttributeName = includeFields.getAttributeToMap(fieldName);
        outputRecord.setStringField(mappedAttributeName, v.toString());
        outputRecord.setStringField(fieldName, v.toString());

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

String value = agent.getValue(field);
  if (value != null && !value.isEmpty()) {
    record.setStringField(field, value);
record.setStringField(FieldDictionary.RECORD_ERRORS, "Failure in User-agent decoding");
logger.error("Cannot parse User-Agent content: " + record);
continue;

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

record.setStringField(FieldDictionary.RECORD_TYPE, broEventType);

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

includesFieldName = context.getPropertyValue(INCLUDES_FIELD).evaluate(record).asString();
} catch (Throwable t) {
  record.setStringField(FieldDictionary.RECORD_ERRORS, "Failure in executing EL. Error: " + t.getMessage());
  logger.error("Cannot interpret EL : " + record, t);
    record.setStringField(FieldDictionary.RECORD_ERRORS, "Can not request datastore with " + indexName + " " + typeName + " " + recordKeyName);
    outputRecords.add(record);
        String mappedAttributeName = includeFields.getAttributeToMap(fieldName);
        outputRecord.setStringField(mappedAttributeName, v.toString());
      } else {
        outputRecord.setStringField(fieldName, v.toString());

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

.setType(outputRecordType)
        .setTime(new Date(timestamp))
        .setStringField("outlier_severity", "severe")
        .setField("outlier_score", FieldType.DOUBLE, outlier.getScore())
        .setField("outlier_num_points", FieldType.INT, outlier.getNumPts());
list.add(new StandardRecord(OUTLIER_PROCESSING_EXCEPTION_TYPE)
    .setStringField(FieldDictionary.RECORD_ERRORS, ProcessError.RUNTIME_ERROR.toString())
    .setStringField(FieldDictionary.RECORD_VALUE, e.getMessage())
    .setStringField(FieldDictionary.PROCESSOR_NAME, DetectOutliers.class.getName())
);

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

record.setStringField(key, value.toString());
} else if (value instanceof Integer)
  record.setStringField(key, JsonUtil.convertToJson(value));

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

flattenRecord.setStringField(concatFieldName,
    rootField.asString() + concatSeparator +
        flattenRecord.getField(rootField.getName()).asString());

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

Record threshold = new StandardRecord(outputRecordType)
    .setId(key)
    .setStringField(FieldDictionary.RECORD_VALUE, context.getPropertyValue(key).asString())
    .setField(FieldDictionary.RECORD_COUNT, FieldType.LONG, 1L)
    .setField(FieldDictionary.RECORD_LAST_UPDATE_TIME, FieldType.LONG, System.currentTimeMillis());

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

logislandRecord.setStringField(column, record.get(column));