Groovy script to set the roll attribute once per hour per table

Groovy Script

import groovy.time.TimeCategory

if (!state.containsKey('lastRoll')) {
  state << [lastRoll: [:]]
}

def setRollFlag(String tableName) {
  if (!state.lastRoll.containsKey(tableName)) {
    state.lastRoll[tableName] = new Date()
  }
  use (TimeCategory) {
    if (state.lastRoll[tableName] < 1.hour.ago) {
      state.lastRoll[tableName] = new Date()
      return true
      log.info("script sets roll flag for measurement")
    }
    return false
  }
}

for (record in records) {
  try {
    if(setRollFlag(record.attributes['jdbc.tables'])) {
      record.attributes['roll'] = 'yes'
    }
    output.write(record)
  } catch (e) {
    // Write a record to the error pipeline
    log.error(e.toString(), e)
    error.write(record, e.toString())
  }
}