class Bricolage::StreamingLoad::IncomingChunk
a Chunk
which is not saved yet (received from SQS)
Attributes
stream_name[R]
Public Class Methods
new(message, stream_name)
click to toggle source
# File lib/bricolage/streamingload/incomingchunk.rb, line 12 def initialize(message, stream_name) @chunk = message.chunk @message = message @stream_name = stream_name end
Public Instance Methods
event_time()
click to toggle source
# File lib/bricolage/streamingload/incomingchunk.rb, line 25 def event_time @message.time end