add support to run mapreduce queries on generic log lines, e.g. count all log lines containing a certain string, such as "ERROR"

1 files changed, 7 insertions, 2 deletions

diff --git a/internal/mapr/server/aggregate.go b/internal/mapr/server/aggregate.go
index fade689..9403aa9 100644
--- a/internal/mapr/server/aggregate.go
+++ b/internal/mapr/server/aggregate.go
@@ -44,8 +44,13 @@ func NewAggregate(queryStr string) (*Aggregate, error) {
 	}
 	s := strings.Split(fqdn, ".")
 
-	logger.Info("Creating mapr log format parser", config.Server.MapreduceLogFormat)
-	logParser, err := logformat.NewParser(config.Server.MapreduceLogFormat)
+	parserName := config.Server.MapreduceLogFormat
+	if query.Table == "" {
+		parserName = "generic"
+	}
+
+	logger.Info("Creating mapr log format parser", parserName)
+	logParser, err := logformat.NewParser(parserName)
 	if err != nil {
 		logger.FatalExit("Could not create mapr log format parser", err)
 	}