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