You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jia Zhai (JIRA)" <ji...@apache.org> on 2016/05/26 15:15:13 UTC
[jira] [Created] (FLINK-3979) [documentation]add missed import
classes in run_example_quickstart
Jia Zhai created FLINK-3979:
-------------------------------
Summary: [documentation]add missed import classes in run_example_quickstart
Key: FLINK-3979
URL: https://issues.apache.org/jira/browse/FLINK-3979
Project: Flink
Issue Type: Improvement
Components: Documentation
Reporter: Jia Zhai
The classes that need to be imported for this part of code
{code}
result
.map(new MapFunction<Tuple2<String,Long>, String>() {
@Override
public String map(Tuple2<String, Long> tuple) {
return tuple.toString();
}
})
.addSink(new FlinkKafkaProducer08<>("localhost:9092", "wiki-result", new SimpleStringSchema()));
{code}
is
{code}
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer08;
import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
import org.apache.flink.api.common.functions.MapFunction;
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)