apache-flink

5Ciepło

1Odpowiedz

Jak korzystać flink funkcję krotny w Scala

Jest to zakaz pracy wypróbować za korzystanie flink krotnie scala anonimowej funkcji: val myFoldFunction = (x: Double, t:(Double,String,String)) => x + t._1 env.readFileStream(...). ... .groupBy(1)

10Ciepło

1Odpowiedz

Flink Scala API „nie mało argumentów”

Mam kłopoty przy użyciu Apache Flink Scala API Na przykład, nawet gdy biorę przykłady z oficjalnej dokumentacji, kompilator Scala daje mi mnóstwo błędów kompilacji. Kod: object TestFlink { def m

83Ciepło

2Odpowiedz

Jaka jest główna różnica między Flink a Storm?

Flink został compared to Spark, który, jak widzę, jest błędnym porównaniem, ponieważ porównuje okienkowany system przetwarzania zdarzeń z mikropociągiem; Podobnie, nie ma większego sensu porównywanie

7Ciepło

1Odpowiedz

Jak wyrównywać mapę Funkcja na GroupedDataSet w Apache Flink

Chcę zastosować funkcję poprzez flatMap do każdej grupy wyprodukowanej przez DataSet.groupBy. Próbuje zadzwonić flatMap pojawia się błąd kompilatora: error: value flatMap is not a member of org.apache

7Ciepło

3Odpowiedz

Jak odnieść się do zewnętrznego słoja w migawce

wszyscy. Próbowałem odwoływać się do słoja firmowego w Flink w sposób kopiowania go do $ FLINK/lib we wszystkich menedżerach zadań, ale nie udało się. I nie chcę pakować grubego słoika, który jest zby

5Ciepło

1Odpowiedz

Utknąłem z podpowiedziami typu clojure dla ogólnej klasy

Próbuję uzyskać mały przykład z migotania Apache'a działającego w clojure, ale w tej chwili utknąłem z powodu typowego podpowiedzi w clojure i dziwnego dziwactwa w migotaniu. Oto mój kod: (ns pipeline