Sha256: 33f0fec9e65dde1b3472d7e796829cd73d2b86f871baf3732f7b2eea39bdceb0

Contents?: true

Size: 397 Bytes

Versions: 40

Compression:

Stored size: 397 Bytes

Contents

module ArcFurnace
  class Sink

    # The only required method to implement. #row is called for each output row and
    # a sink must handle each.
    def row(row)
      raise "Unimplemented!"
    end

    # Handle any pre-processing here.
    def prepare

    end

    # If the sink needs to perform any clean-up (closing file handles, etc),
    # do it here.
    def finalize

    end
  end
end

Version data entries

40 entries across 40 versions & 1 rubygems

Version Path
arc-furnace-0.1.42 lib/arc-furnace/sink.rb
arc-furnace-0.1.41 lib/arc-furnace/sink.rb
arc-furnace-0.1.40 lib/arc-furnace/sink.rb
arc-furnace-0.1.39 lib/arc-furnace/sink.rb
arc-furnace-0.1.38 lib/arc-furnace/sink.rb
arc-furnace-0.1.37 lib/arc-furnace/sink.rb
arc-furnace-0.1.36 lib/arc-furnace/sink.rb
arc-furnace-0.1.35 lib/arc-furnace/sink.rb
arc-furnace-0.1.34 lib/arc-furnace/sink.rb
arc-furnace-0.1.33 lib/arc-furnace/sink.rb
arc-furnace-0.1.32 lib/arc-furnace/sink.rb
arc-furnace-0.1.31 lib/arc-furnace/sink.rb
arc-furnace-0.1.30 lib/arc-furnace/sink.rb
arc-furnace-0.1.29 lib/arc-furnace/sink.rb
arc-furnace-0.1.28 lib/arc-furnace/sink.rb
arc-furnace-0.1.27 lib/arc-furnace/sink.rb
arc-furnace-0.1.26 lib/arc-furnace/sink.rb
arc-furnace-0.1.25 lib/arc-furnace/sink.rb
arc-furnace-0.1.24 lib/arc-furnace/sink.rb
arc-furnace-0.1.23 lib/arc-furnace/sink.rb