1.文本输出

示例:
import org.apache.flink.api.scala.createTypeInformation
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
object sinkFileTest {
def main(args: Array[String]): Unit = {
//create env
val env = StreamExecutionEnvironment.getExecutionEnvironment
//create ds
val ls = List(1, 2, 3, 4)
val ds = env.fromCollection(ls)
//sink
ds.writeAsText("file:///C:/doc/temp/flink.txt")
//execute
env.execute()
}
}
2.kafka输出

示例:
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.api.scala.createTypeInformation
import org.apache.flink.streaming.api.scala.StreamExecutionEnvironment
import org.apache.flink.streaming.connectors.kafka.{FlinkKafkaProducer, FlinkKafkaProducer011}
object kafkaSinkTest {
def main(args: Array[String]): Unit = {
//create env
val env = StreamExecutionEnvironment.getExecutionEnvironment
//create ds
val ds = env.fromElements("hadoop", "hive", "spark", "flink")
//sink
ds.addSink(new FlinkKafkaProducer[String]("10.31.126.10:9092","wordTest",new SimpleStringSchema()))
//execute
env.execute()
}
}
输出结果:

3.输出到HDFS(未完待续)
