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