Contents

module Streamingly

  class KV < Struct.new(:key, :value)
    def to_s
      [ SerDe.to_csv(key), SerDe.to_csv(value) ].join("\t")
    end

    # TODO: remove .strip from https://github.com/swipely/streamingly/blob/master/lib/streamingly/reducer.rb#L11
    def strip
      self
    end

    # TODO: remove .split from https://github.com/swipely/streamingly/blob/master/lib/streamingly/reducer.rb#L28
    def split(char="\t", limit=1)
      [key, value]
    end
  end

end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
streamingly-0.2.7	lib/streamingly/kv.rb
streamingly-0.2.6	lib/streamingly/kv.rb
streamingly-0.2.4	lib/streamingly/kv.rb
streamingly-0.2.3	lib/streamingly/kv.rb
streamingly-0.2.2	lib/streamingly/kv.rb
streamingly-0.2.0	lib/streamingly/kv.rb
streamingly-0.1.0	lib/streamingly/kv.rb
streamingly-0.0.8	lib/streamingly/kv.rb