Golang版本详解
package main
import "github.com/apache/flink"
func main() {
env := flink.NewExecutionEnvironment()
env.SetParallelism(2)
data := env.FromElements(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
data.Map(func(i int) int {
return i * 2
}).Print()
}