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