Skip to content

Commit

Permalink
Fix the document format in example/flink-consumer-source (#2839)
Browse files Browse the repository at this point in the history
  • Loading branch information
junjieqian authored and merlimat committed Oct 24, 2018
1 parent 0682f1c commit 33d89aa
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions examples/flink-consumer-source/README.md
Expand Up @@ -73,13 +73,13 @@ The steps to run the example:
6. You can check the flink taskexecutor `.out` file. The `.out` file will print the counts at the end of each time window as long as words are floating in, e.g.:

```shell
PulsarConsumerSourceWordCount.WordWithCount(word=hello, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=again, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=test, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=world, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=hello, count=100)
PulsarConsumerSourceWordCount.WordWithCount(word=again, count=100)
PulsarConsumerSourceWordCount.WordWithCount(word=test, count=100)
PulsarConsumerSourceWordCount.WordWithCount(word=hello, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=again, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=test, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=world, count=200)
PulsarConsumerSourceWordCount.WordWithCount(word=hello, count=100)
PulsarConsumerSourceWordCount.WordWithCount(word=again, count=100)
PulsarConsumerSourceWordCount.WordWithCount(word=test, count=100)
```

Alternatively, when you run the flink word count example at step 4, you can choose dump the result to another pulsar topic.
Expand Down

0 comments on commit 33d89aa

Please sign in to comment.