【云星数据---Apache Flink实战系列(精品版)】：Apache Flink高级特性与高级应用010-Slot和Parallelism的深刻分析005

6、设置parallelism的方法 1.在操做符级别上设置parallelism val env = StreamExecutionEnvironment.getExecutionEnvironment val text = [...] val wordCounts = text .flatMap{ _.split(" ") map { (_, 1) } } .keyBy(0)

>>阅读原文<<