本文整理了Java中com.hurence.logisland.record.Field.<init>()
方法的一些代码示例,展示了Field.<init>()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Field.<init>()
方法的具体详情如下:
包路径:com.hurence.logisland.record.Field
类名称: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.");
内容来源于网络,如有侵权,请联系作者删除!