Method: Cosmos::WatermarkProcessor#reset
- Defined in:
- lib/cosmos/processors/watermark_processor.rb
#reset ⇒ Object
Reset any state
44 45 46 47 |
# File 'lib/cosmos/processors/watermark_processor.rb', line 44 def reset @results[:HIGH_WATER] = nil @results[:LOW_WATER] = nil end |