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