[FLINK-3979] [docs] Add import statements for last code sample in the quickstart docs.
This closes #2038 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ad52a5f0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ad52a5f0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ad52a5f0 Branch: refs/heads/master Commit: ad52a5f0cebe6e5d593be0ae40656b28470af106 Parents: 5b02879 Author: Zhai Jia <zhaiji...@gmail.com> Authored: Thu May 26 23:24:40 2016 +0800 Committer: Stephan Ewen <se...@apache.org> Committed: Tue May 31 16:39:56 2016 +0200 ---------------------------------------------------------------------- docs/quickstart/run_example_quickstart.md | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/ad52a5f0/docs/quickstart/run_example_quickstart.md ---------------------------------------------------------------------- diff --git a/docs/quickstart/run_example_quickstart.md b/docs/quickstart/run_example_quickstart.md index 0d5e919..0939297 100644 --- a/docs/quickstart/run_example_quickstart.md +++ b/docs/quickstart/run_example_quickstart.md @@ -315,6 +315,13 @@ result .addSink(new FlinkKafkaProducer08<>("localhost:9092", "wiki-result", new SimpleStringSchema())); {% endhighlight %} +The related classes also need to be imported: +{% highlight java %} +import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer08; +import org.apache.flink.streaming.util.serialization.SimpleStringSchema; +import org.apache.flink.api.common.functions.MapFunction; +{% endhighlight %} + Note how we first transform the Stream of `Tuple2<String, Long>` to a Stream of `String` using a MapFunction. We are doing this because it is easier to write plain strings to Kafka. Then, we create a Kafka sink. You might have to adapt the hostname and port to your setup. `"wiki-result"` @@ -382,4 +389,4 @@ and, for example, see the number of processed elements: <a href="{{ site.baseurl }}/page/img/quickstart-example/jobmanager-job.png" ><img class="img-responsive" src="{{ site.baseurl }}/page/img/quickstart-example/jobmanager-job.png" alt="Example Job View"/></a> -This concludes our little tour of Flink. If you have any questions, please don't hesitate to ask on our [Mailing Lists](http://flink.apache.org/community.html#mailing-lists). \ No newline at end of file +This concludes our little tour of Flink. If you have any questions, please don't hesitate to ask on our [Mailing Lists](http://flink.apache.org/community.html#mailing-lists).
