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)
