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)