flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jia Zhai (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3979) [documentation]add missed import classes in run_example_quickstart
Date Thu, 26 May 2016 15:15:13 GMT
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
    .map(new MapFunction<Tuple2<String,Long>, String>() {
        public String map(Tuple2<String, Long> tuple) {
            return tuple.toString();
    .addSink(new FlinkKafkaProducer08<>("localhost:9092", "wiki-result", new SimpleStringSchema()));


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

This message was sent by Atlassian JIRA

View raw message