【雲星數據---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)

>>阅读原文<<