Class: Bricolage::StreamingLoad::CheckPointEvent
- Inherits:
-
Event
- Object
- Bricolage::SQSMessage
- Event
- Bricolage::StreamingLoad::CheckPointEvent
- Defined in:
- lib/bricolage/streamingload/event.rb
Overview
Flushes all tables and shutdown
Constant Summary
Constants inherited from Bricolage::SQSMessage
Bricolage::SQSMessage::SQS_EVENT_SOURCE
Instance Attribute Summary
Attributes inherited from Bricolage::SQSMessage
#delay_seconds, #message_id, #name, #receipt_handle, #source, #time
Class Method Summary collapse
Instance Method Summary collapse
Methods inherited from Event
Methods inherited from Bricolage::SQSMessage
#body, for_sqs_record, for_sqs_result, get_event_time, #initialize
Constructor Details
This class inherits a constructor from Bricolage::SQSMessage
Class Method Details
.create ⇒ Object
52 53 54 |
# File 'lib/bricolage/streamingload/event.rb', line 52 def CheckPointEvent.create super name: 'checkpoint' end |
.parse_sqs_record(msg, rec) ⇒ Object
56 57 58 |
# File 'lib/bricolage/streamingload/event.rb', line 56 def CheckPointEvent.parse_sqs_record(msg, rec) {} end |
Instance Method Details
#init_message(dummy: nil) ⇒ Object
62 63 |
# File 'lib/bricolage/streamingload/event.rb', line 62 def (dummy: nil) end |