class Streamingly::KV

Public Instance Methods

split(char="\t", limit=1) click to toggle source

TODO: remove .split from github.com/swipely/streamingly/blob/master/lib/streamingly/reducer.rb#L28

# File lib/streamingly/kv.rb, line 14
def split(char="\t", limit=1)
  [key, value]
end
strip() click to toggle source

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

# File lib/streamingly/kv.rb, line 9
def strip
  self
end
to_s() click to toggle source
# File lib/streamingly/kv.rb, line 4
def to_s
  [ SerDe.to_csv(key), SerDe.to_csv(value) ].join("\t")
end