Class
Taps::DataStreamKeyed
In:
lib/taps/data_stream.rb
Parent:
DataStream
Methods
buffer_limit
calc_limit
fetch_buffered
fetch_rows
import_rows
increment
load_buffer
new
primary_key
verify_stream
Attributes
buffer
[RW]
Public Class methods
new
(db, state)
Public Instance methods
buffer_limit
()
calc_limit
(chunksize)
fetch_buffered
(chunksize)
fetch_rows
()
import_rows
(rows)
increment
(row_count)
load_buffer
(chunksize)
primary_key
()
verify_stream
()
[Validate]