class Kcl::Types::RecordsInput
Container for the parameters to the IRecordProcessor's method.
Attributes
millis_behind_latest[R]
record_checkpointer[R]
records[R]
Public Class Methods
new(records, millis_behind_latest, record_checkpointer)
click to toggle source
@param [Array] records @param [Number] millis_behind_latest
@param [Kcl::Workers::RecordCheckpointer] record_checkpointer
# File lib/kcl/types/records_input.rb, line 9 def initialize(records, millis_behind_latest, record_checkpointer) @records = records @millis_behind_latest = millis_behind_latest @record_checkpointer = record_checkpointer end