In [1]:

    

library(jsonlite)


    

In [2]:

    

setwd("C:/Users/Johannes/Projects/results/output/20161218")
logDF <- fromJSON("20161218-logstash.json", flatten = TRUE)


    

In [3]:

    

workerStart <- logDF[grep("worker:start", logDF$"_source.message", ignore.case=T),]
workerDone <- logDF[grep("worker:done", logDF$"_source.message", ignore.case=T),]


    

In [4]:

    

workerStart$start <- 1
workerStart$timeEpoch <- as.numeric( workerStart$`fields.@timestamp`)
workerStart$time <- as.POSIXct(workerStart$timeEpoch/1000, origin="1970-01-01", tz="Europe/Amsterdam")


    

In [5]:

    

workerDone$start <- -1
workerDone$timeEpoch <- as.numeric( workerDone$`fields.@timestamp`)
workerDone$time <- as.POSIXct(workerDone$timeEpoch/1000, origin="1970-01-01", tz="Europe/Amsterdam")


    

In [6]:

    

total <- rbind(workerStart, workerDone)


    

In [7]:

    

hist(workerStart$time, breaks="mins", freq=TRUE, format="%H:%M:%S")


    

In [8]:

    

hist(workerDone$time, breaks="mins", freq=TRUE, format="%H:%M:%S")


    

In [ ]: