From e3803b18ddfd7d7d205fd7029bfd3780cbb48499 Mon Sep 17 00:00:00 2001 From: bluemonk3y Date: Thu, 15 Jun 2017 16:30:54 +0100 Subject: [PATCH] Improve streaming and aggregation of replay events through the dashboard --- .../liquidlabs/log/search/handlers/ReplayEventsHandler.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/vs-log/src/com/liquidlabs/log/search/handlers/ReplayEventsHandler.java b/vs-log/src/com/liquidlabs/log/search/handlers/ReplayEventsHandler.java index 0166689..b5303a5 100644 --- a/vs-log/src/com/liquidlabs/log/search/handlers/ReplayEventsHandler.java +++ b/vs-log/src/com/liquidlabs/log/search/handlers/ReplayEventsHandler.java @@ -52,10 +52,8 @@ public ReplayEventsHandler(LogScanningHandler next, LogRequest request, AggSpace public void handle(FieldSet fieldSet, String[] fields, Query query, HistoEvent histo, long bucketTime, int lineNumber, long fileStartTime, long fileEndTime, long eventTime, String lineData, MatchResult matchResult, long requestStartTimeMs, long requestEndTimeMs, long bucketWidth) { - // We want to send a MAX or N items per host source try { - if (request.getHits(hostHash) < maxEventsPerHost) { query.increment(hostHash); @@ -69,7 +67,6 @@ public void handle(FieldSet fieldSet, String[] fields, Query query, HistoEvent h ReplayEvent replayEvent = new ReplayEvent(sourceURI, lineNumber, query.getSourcePos(), query.groupId(), subscriber, eventTime, lineData); replayEvent.setDefaultFieldValues(fieldSet.getId(), hostname, filenameOnly, path, tags, agentType, sourceURI, new Integer(lineData.length()).toString()); aggSpace.write(replayEvent, false, requestHash, logId, eventTime); - } } finally { if (next != null) next.handle(fieldSet, fields, query, histo, bucketTime, lineNumber, fileStartTime, fileEndTime, eventTime, lineData, matchResult, requestStartTimeMs, requestEndTimeMs, bucketWidth); }