lib/taps/data_stream.rb in taps2-0.6.6 vs lib/taps/data_stream.rb in taps2-0.6.7
- old
+ new
@@ -274,12 +274,9 @@
(chunksize * 3).ceil
end
end
def load_buffer(chunksize)
- # make sure BasicObject is not polluted by subsequent requires
- Sequel::BasicObject.remove_methods!
-
num = 0
loop do
limit = calc_limit(chunksize)
# we have to use local variables in order for the virtual row filter to work correctly
key = primary_key