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