[FLINK-3979] [documentation]add missed import classes in run_example_quickstart

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Documentation
• Assignee: Unassigned
• Reporter: Jia Zhai
• Created: 26/May/16 15:14
• Updated: 31/May/16 15:50
• Resolved: 31/May/16 15:50

Description

The classes that need to be imported for this part of 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()));

is

import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer08;
import org.apache.flink.streaming.util.serialization.SimpleStringSchema;
import org.apache.flink.api.common.functions.MapFunction;

Issue Links

• links to: GitHub Pull Request #2038