beam: github.com/apache/beam/sdks/go/examples/streaming_wordcap Files

Command streaming_wordcap

streaming_wordcap is a toy streaming pipeline that uses PubSub. It does the following: 

(1) create a topic and publish a few messages to it
(2) start a streaming pipeline that converts the messages to
    upper case and logs the result.

NOTE: it only runs on Dataflow and must be manually cancelled.

Package Files

wordcap.go

Package main imports 12 packages (graph). Updated 2018-04-24. Refresh now. Tools for package owners. This is an inactive package (no imports and no commits in at least two years).