class Schlepp::Sink::TableObject::Compressor::Writer

Public Class Methods

new(writer, opts = {}) click to toggle source
# File lib/schlepp/sink/filter/compressor/writer.rb, line 8
def initialize(writer, opts = {})
  @stream = Stream.new
  @writer = writer
  @written = 0
end

Public Instance Methods

finalize() click to toggle source
# File lib/schlepp/sink/filter/compressor/writer.rb, line 26
def finalize
  bits = @stream.to_s

  @writer.write(bits)
  @writer.finalize
end
rotate?() click to toggle source
# File lib/schlepp/sink/filter/compressor/writer.rb, line 22
def rotate?
  false
end
write(rows) click to toggle source
# File lib/schlepp/sink/filter/compressor/writer.rb, line 14
def write(rows)
  Array(rows).each do |row|
    @written += row.length
    @stream.write(row)
  end
end