class Schlepp::Sink::Filter::Chunker
Public Class Methods
new(opts = {})
click to toggle source
# File lib/schlepp/sink/filter/chunker.rb, line 16 def initialize(opts = {}) @chunk = 0 @chunk_size = opts[:chunk_size] || 100000 @observer = Schlepp::Sink::TableObject::Filter::Observer.new end
Public Instance Methods
extension()
click to toggle source
# File lib/schlepp/sink/filter/chunker.rb, line 22 def extension @chunk.to_s end
rotate()
click to toggle source
# File lib/schlepp/sink/filter/chunker.rb, line 30 def rotate @chunk += 1 end
should_rotate?()
click to toggle source
# File lib/schlepp/sink/filter/chunker.rb, line 26 def should_rotate? @observer.count > @chunk_size end
writer()
click to toggle source
# File lib/schlepp/sink/filter/chunker.rb, line 34 def writer @builder ||= Builder.new(@observer) end