General Purpose Parsers

The general-purpose parser is primarily designed for lower-velocity topologies or for quickly setting up a temporary parser for a new telemetry.

General purpose parsers are defined using a config file, and you need not recompile the topology to change them. CCP supports two general purpose parsers: Grok and CSV.

Grok parser

The Grok parser class name (parserClassName) is org.apache.metron,parsers.GrokParser.

The Grok parser supports either one line to parse per incoming message, or incoming messages with multiple log lines, and will produce a json message per line

Grok has the following entries and predefined patterns for parserConfig:


The path in HDFS (or in the Jar) to the grok statement. By default attempts to load from HDFS, then falls back to the classpath, and finally throws an exception if unable to load a pattern.


The pattern label to use from the Grok statement.

The raw data passed in should be handled as a long with multiple lines, with each line to be parsed separately. This setting's valid values are true or false. The default if unset is false. When set, the parser will handle multiple lines with successfully processed lines emitted normally, and lines with errors sent to the error topic.

The field to use for timestamp. If your data does not have a field exactly named "timestamp" this field is required, otherwise the record will not pass validation. If the timestampField is included in the list of timeFields, it will first be parsed using the provided dateFormat.


A list of fields to be treated as time.


The date format to use to parse the time fields. Default is "yyyy-MM-dd HH:mm:ss.S z".


The timezone to use. UTC is the default.

CSV Parser

The CSV parser class name (parserClassName) is org.apache.metron.parsers.csv.CSVParser

CSV has the following entries and predefined patterns for parserConfig:


The date format of the timestamp to use. If unspecified, the parser assumes the timestamp is starts at UNIX epoch.


A map of column names you wish to extract from the CSV to their offsets. For example, { 'name' : 1,'profession' : 3} would be a column map for extracting the 2nd and 4th columns from a CSV.


The column separator. The default value is ",".

JSON Map Parser

The JSON parser class name (parserClassName) is org.apache.metron.parsers.csv.JSONMapParser

JSON has the following entries and predefined patterns for parserConfig:


A strategy to indicate how to handle multi-dimensional Maps. This is one of:


Drop fields which contain maps


Unfold inner maps. So { "foo" : { "bar" : 1} } would turn into {"" : 1}


Allow multidimensional maps


Throw an error when a multidimensional map is encountered


This field is expected to exist and, if it does not, then current time is inserted.

If this JSON query string is present, the result of the query will be a list of messages. This is useful if you have a JSON document that contains a list or array of messages embedded in it, and you do not have another means of splitting the message.
This setting's valid values are true or false. If jsonQuery is present and this flag is present and set to "true", the incoming message will be wrapped in a JSON entity and array. for example: {"name":"value"},{"name2","value2"} will be wrapped as {"message" : [{"name":"value"},{"name2","value2"}]}. This is using the default value for wrapEntityName if that property is not set.
Sets the name to use when wrapping JSON using wrapInEntityArray. The jsonpQuery should reference this name. Only applicable if jsonpQuery and wrapInEntityArray are specified.
A field called timestamp is expected to exist and, if it does not, then current time is inserted.
A boolean setting that will change the way original_string is handled by the parser. The default value of false uses the global functionality that will append the unmodified original raw source message as an original_string field. This is the recommended setting. Setting this option to true will use the individual substrings returned by the json query as the original_string. For example, a wrapped map such as {"foo" : [{"name":"value"},{"name2","value2"}]} that uses the jsonpQuery, $.foo, will result in 2 messages returned. Using the default global original_string strategy, the messages returned would be:
  • { "name" : "value", "original_string" : "{\"foo\" : [{\"name\":\"value\"},{\"name2\",\"value2\"}]}}
  • { "name2" : "value2", "original_string" : "{\"foo\" : [{\"name\":\"value\"},{\"name2\",\"value2\"}]}}

    Setting this value to true would result in messages with original_string set as follows:

    • { "name" : "value", "original_string" : "{\"name\":\"value\"}}
    • { "name" : "value", "original_string" : "{\"name2\":\"value2\"}}
One final important point to note, and word of caution about setting this property to true, is about how JSON PQuery handles parsing and searching the source raw message - it will NOT retain a pure raw sub-message. This is due to the JSON libraries under the hood that normalize the JSON. The resulting generated original_string values may have a different property order and spacing. For example, { "foo" :"bar" , "baz":"bang"} would end up with an original_string that looks more like { "baz" : "bang", "foo" : "bar" }.

Regular Expressions Parser

A regular expression to uniquely identify a record type.
A regular expression used to extract fields from a message part which is common across all the messages.
If this property is set to true, this parser will automatically convert all the camel case property names to underscore separated. For example, following conversions will automatically happen:
ipSrcAddr -> ip_src_addr
ipDstAddr -> ip_dst_addr
ipSrcPort -> ip_src_port
Note this property may be necessary, because java does not support underscores in the named group names. So in case your property naming conventions requires underscores in property names, use this property.
A json list of maps containing a record type to regular expression mapping.

A complete configuration example looks like:

"convertCamelCaseToUnderScore": true,
"recordTypeRegex": "kernel|syslog",
"messageHeaderRegex": "(<syslogPriority>(<=^&lt;)\\d{1,4}(?=>)).*?(<timestamp>(<=>)[A-Za-z] {3}\\s{1,2}\\d{1,2}\\s\\d{1,2}:\\d{1,2}:\\d{1,2}(?=\\s)).*?(<syslogHost>(<=\\s).*?(?=\\s))",
"fields": [
    "recordType": "kernel",
    "regex": ".*(<eventInfo>(<=\\]|\\w\\:).*?(?=$))"
    "recordType": "syslog",
    "regex": ".*(<processid>(<=PID\\s=\\s).*?(?=\\sLine)).*(<filePath>(<=64\\s)\/([A-Za-z0-9_-]+\/)+(?=\\w))        (<fileName>.*?(?=\")).*(<eventInfo>(<=\").*?(?=$))"
"messageHeaderRegex": [
  "regular expression 1",
  "regular expression 2"


regular expression 1
Valid regular expressions that may have named groups and which would be extracted into fields. This list will be evaluated in order until a matching regular expression is found.
Run on all the messages. All messages are expected to contain the fields which are being extracted using the messageHeaderRegex. messageHeaderRegex is a sort of HCF (highest common factor) in all messages.

recordTypeRegex can be a more advanced regular expression containing named groups. For example:

"recordTypeRegex": "(<process>(<=\s)\b(kernel|syslog)\b(?=\[|:))"

All the named groups will be extracted as fields.

Though having named group in recordType is completely optional, you might want to extract named groups in recordType for following reasons:

  • Because recordType regular expression is already getting matched and you are paying the price for a regular expression match already, you can extract certain fields as a by product of this match.
  • The recordType field is probably common across all the messages. So, having it extracted in the recordType (or messageHeaderRegex) would reduce the overall complexity of regular expressions in the regex field.

regex within a field can also be a list of regular expressions. In this case all regular expressions in the list will be matched. Once a full match is found, remaining regular expressions are ignored.

"regex":  [ "record type specific regular expression 1",
            "record type specific regular expression 2"]
Because this parser is a general purpose parser, it will populate the timestamp field with current UTC timestamp. Actual timestamp value can be overridden later using stellar. For example in case of syslog timestamps, you can use following stellar construct to override the timestamp value. Let us say you parsed actual timestamp from the raw log:
<38>Jun 20 15:01:17 hostName sshd[11672]: Accepted publickey for prod from port 66666 ssh2

syslogTimestamp="Jun 20 15:01:17"
Then something like the following can be used to override the timestamp:
"timestamp_str": "FORMAT('%s%s%s', YEAR(),' ',syslogTimestamp)",
"timestamp":"TO_EPOCH_TIMESTAMP(timestamp_str, 'yyyy MMM dd HH:mm:ss' )"
Or, if you want to factor in the timezone:
"timestamp":"TO_EPOCH_TIMESTAMP(timestamp_str, timestamp_format, timezone_name )"