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