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

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

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

Field.<init>介绍

暂无

代码示例

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

/**
 * set a field value
 *
 * @param fieldName
 * @param value
 */
@Override
public Record setField(String fieldName, FieldType fieldType, Object value) {
  setField(new Field(fieldName, fieldType, value));
  return this;
}

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

/**
 * set a field value as a String value
 *
 * @param fieldName the name of the string field
 * @param value     the value to be added
 */
@Override
public Record setStringField(String fieldName, String value) {
  setField(new Field(fieldName, FieldType.STRING, value));
  return this;
}

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

} else if (value instanceof Integer)
  record.setField(new Field(FIELD_VERSION, FieldType.STRING, value.toString()));
  return true;
} else if (value instanceof Long)
  record.setField(new Field(FIELD_VERSION, FieldType.STRING, value.toString()));
  return true;
} else if (value instanceof Float)
  record.setField(new Field(FIELD_VERSION, FieldType.STRING, value.toString()));
  return true;
} else if (value instanceof Double)
  record.setField(new Field(FIELD_VERSION, FieldType.STRING, value.toString()));
  return true;

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

} else if (value instanceof Integer)
  record.setField(new Field(key, FieldType.INT, value));
} else if (value instanceof Long)
  record.setField(new Field(key, FieldType.LONG, value));
} else if (value instanceof ArrayList)
  record.setField(new Field(key, FieldType.ARRAY, value));
} else if (value instanceof Float)
  record.setField(new Field(key, FieldType.FLOAT, value));
} else if (value instanceof Double)
    Long longEpochMilliSeconds = (long)doubleEpochMilliSeconds;
    value = longEpochMilliSeconds;
    record.setField(new Field(key, FieldType.LONG, value));
  } else {
    record.setField(new Field(key, FieldType.DOUBLE, value));
  record.setField(new Field(key, FieldType.MAP, value));
} else if (value instanceof Boolean)
  record.setField(new Field(key, FieldType.BOOLEAN, value));
} else

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

.setField(new Field("src_ip4", FieldType.STRING, netflowRecord.get("src_ip4")))
  .setField(new Field("dst_ip4", FieldType.STRING, netflowRecord.get("dst_ip4")))
  .setField(new Field("nexthop", FieldType.STRING, netflowRecord.get("nexthop")))
  .setField(new Field("input", FieldType.INT, netflowRecord.get("input")))
  .setField(new Field("output", FieldType.INT, netflowRecord.get("output")))
  .setField(new Field("dPkts", FieldType.LONG, netflowRecord.get("dPkts")))
  .setField(new Field("dOctets", FieldType.LONG, netflowRecord.get("dOctets")))
  .setField(new Field("first", FieldType.LONG, netflowRecord.get("first")))
  .setField(new Field("last", FieldType.LONG, netflowRecord.get("last")))
  .setField(new Field("src_port", FieldType.INT, netflowRecord.get("src_port")))
  .setField(new Field("dst_port", FieldType.INT, netflowRecord.get("dst_port")))
  .setField(new Field("flags", FieldType.INT, netflowRecord.get("flags")))
  .setField(new Field("nprot", FieldType.INT, netflowRecord.get("nprot")))
  .setField(new Field("tos", FieldType.INT, netflowRecord.get("tos")))
  .setField(new Field("src_as", FieldType.INT, netflowRecord.get("src_as")))
  .setField(new Field("dst_as", FieldType.INT, netflowRecord.get("dst_as")))
  .setField(new Field("src_mask", FieldType.INT, netflowRecord.get("src_mask")))
  .setField(new Field("dst_mask", FieldType.INT, netflowRecord.get("dst_mask")));
evt.setField(new Field("duration", FieldType.LONG, duration));
try{
  String ipString = (String) netflowRecord.get("src_ip4");
  String host = ia.getCanonicalHostName();
  if (host.compareTo(ipString) != 0) {
    evt.setField(new Field("src_host", FieldType.STRING, host));
      evt.setField(new Field("src_domain", FieldType.STRING, domain));

代码示例来源:origin: com.hurence.logisland/logisland-connect-spark

private Field toFieldRecursive(String name, Schema schema, Object value, boolean isKey) {
  try {
    if (value == null) {
      return new Field(name, FieldType.NULL, null);
      case INT16:
      case INT32:
        return new Field(name, FieldType.INT, value);
      case INT64:
        return new Field(name, FieldType.LONG, value);
      case FLOAT32:
        return new Field(name, FieldType.FLOAT, value);
      case FLOAT64:
        return new Field(name, FieldType.DOUBLE, value);
      case BOOLEAN:
        return new Field(name, FieldType.BOOLEAN, value);
      case STRING:
        return new Field(name, FieldType.STRING, value);
      case BYTES:
        byte[] bytes = null;
        return new Field(name, FieldType.BYTES, bytes);
      case ARRAY: {
        return new Field(name, FieldType.ARRAY,
            ((Collection<?>) value).stream().map(item -> {
              Schema valueSchema = schema == null ? null : schema.valueSchema();
        return new Field(name, FieldType.MAP, value);
          struct.schema().fields().stream().filter(field -> !(field.schema().isOptional() && struct.get(field) == null))

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

nameField = new com.hurence.logisland.record.Field(ALERT_MATCH_NAME, FieldType.ARRAY, new String[]{matchingRule.getName()});
queryField = new com.hurence.logisland.record.Field(ALERT_MATCH_QUERY, FieldType.ARRAY, new String[]{matchingRule.getLegacyQuery()});
names = Arrays.copyOf(names, names.length+1);
names[names.length-1] = matchingRule.getName();
nameField = new com.hurence.logisland.record.Field(ALERT_MATCH_NAME, FieldType.ARRAY, names);
queryField = new com.hurence.logisland.record.Field(ALERT_MATCH_QUERY, FieldType.ARRAY, queries);

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

record.setField(new Field(FieldDictionary.RECORD_KEY, FieldType.STRING, "bro_event_raw"));
  record.setField(new Field(FieldDictionary.RECORD_VALUE, FieldType.MAP, normalizedMap));
} else

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

record.setField(new Field(field + ".confidence", FieldType.LONG, agent.getConfidence(field)));
record.setField(new Field("ambiguity", FieldType.INT, agent.getAmbiguityCount()));

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

StandardRecord outputRecord = new StandardRecord();
    outputRecord.setField(new Field(FieldDictionary.RECORD_TYPE, FieldType.STRING, "pcap_packet"));
    outputRecord.setField(new Field(FieldDictionary.PROCESSOR_NAME, FieldType.STRING, this.getClass().getSimpleName()));
      if (result.containsKey(field)) {
        outputRecord.setField(new Field(field.getName(), field.getFieldType(), result.get(field)));
StandardRecord outputRecord = new StandardRecord();
outputRecord.addError(ProcessError.INVALID_FILE_FORMAT_ERROR.getName(), e.getMessage());
outputRecord.setField(new Field(FieldDictionary.RECORD_VALUE, FieldType.BYTES, pcapRawValue));
if (debug) {
  logger.debug("InvalidPCapFileException : error record added successfully.");

相关文章