apache-flink

10ısı

1cevap

Flink Scala API "yeterli argümanlar değil"

ben resmi belgelere örnekler almak bile, Örneğin Apache Flink Scala API kullanarak sorun yaşıyorum, scala derleyici bana derleme hataları ton verir. Kodu: object TestFlink { def main(args: Array

scala-ide apache-flink 2015-04-09

---

7ısı

1cevap

Nasıl Yapılır Apache Flink'te GroupedDataSet'te bir işlev oluşturma

flatMap aracılığıyla bir işlevi DataSet.groupBy tarafından üretilen her gruba uygulamak istiyorum. flatMap Ben derleyici hatası alıyorum aramaya çalışıyorum: error: value flatMap is not a member of or

scala hadoop apache-flink 2015-06-13

---

7ısı

2cevap

Apache Flink, Hadoop'ta Mapreduce ile nasıl karşılaştırılır?

Apache Flink, Hadoop'ta Mapreduce ile nasıl karşılaştırılır? Hangi yollarla daha iyi ve neden?

hadoop mapreduce apache-flink 2015-04-28

---

14ısı

1cevap

Spark vs Flink az hafıza kullanılabilir

Bir Spark ve Flink k-means uygulaması kurdum. Test durumum, 3 düğüm kümesinde 1 milyon nokta üzerinde kümelenme. Bellek içi darboğazlar başladığında, Flink diske kaynak aktarmaya başlar ve yavaş çalış

memory apache-spark apache-flink 2015-08-11

---

5ısı

1cevap

Yineleyici davranış

Ben veri büyük miktarda işlemesi gerektiğini bir sistem oluşturma ve grup operatörü azaltmak nasıl anlamamız gerekir Ben GroupBy ve sonradan bir reduceGroup uygulamak bir veri kümesi var çalışır nasıl

scala hadoop apache-flink 2015-05-11

---