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
{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)

Mime
View raw message