flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [3/4] flink git commit: [FLINK-3979] [docs] Add import statements for last code sample in the quickstart docs.
Date Tue, 31 May 2016 14:41:26 GMT
[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 <zhaijia03@gmail.com>
Authored: Thu May 26 23:24:40 2016 +0800
Committer: Stephan Ewen <sewen@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).


Mime
View raw message