source(allowSchemaDrift: true, validateSchema: false, ignoreNoFilesFound: false, format: 'delimited', fileSystem: 'data', fileName: 'firewall-logs-20220524-113003-2022-05-24t081338-so.txt', columnDelimiter: '\t', escapeChar: '\\', quoteChar: '\"', columnNamesAsHeader: false) ~> source1 surrogateKey1 derive(splitBySpace = regexSplit(toString(byPosition(4)), ` (?=\w+\=)` )) ~> SplitBySpace SplitBySpace derive(unfoldIntoRows = unfold(splitBySpace)) ~> Unfold source1 keyGenerate(output(Surrogate as long), startAt: 1L, stepValue: 1L) ~> surrogateKey1 IsStringOrArray derive(Key = split(toString(unfoldIntoRows),`=`)[1], Value = split(toString(unfoldIntoRows),`=`)[2]) ~> SplitByEquals Unfold derive(unfoldIntoRows = toString(unfoldIntoRows)) ~> IsStringOrArray