Sha256: 5d3d6ee71a436ae04e532dd38df19af3e1ed6f064d586113fe9cfeab033d2b83
Contents?: true
Size: 258 Bytes
Versions: 1
Compression:
Stored size: 258 Bytes
Contents
# TODO: a flow with splits and stuff # parsed = map{|line| ApacheLogLine.make(line) } # # input(:default) > parsed # # parsed > split.into( # to_json > output(:dump, stdout), # to_tsv > output(:tsv, file_sink(Pathname.path_to(:tmp, 'foo.tsv'))) # )
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
wukong-3.0.0.pre | examples/dataflow/complex.rb |