apache-flink

5Ciepło

1Odpowiedz

flink: zastosowanie wielu agregacji w strumieniu z okien

Mam pewne dane przychodzące jako id, float, float, float. Chcę min(), max() i sum() pola w kolejności i grupy to przez wartość id. Korzystanie flatMap Mam Tuple4 z bitami, ale nie jestem pewien, jak w

java apache-flink 2015-11-02

---

5Ciepło

1Odpowiedz

Czym różnią się funkcjaFunction i CoGroupFunction w Apache Flink?

Jaka jest różnica między JoinFunction i CoGroupFunction w Apache Flink? Czym różnią się semantyka i wykonanie?

apache-flink 2016-04-07

---

5Ciepło

1Odpowiedz

Migotanie: Wyjścia DataSource spowodowały błąd: Nie można odczytać otoki kodu użytkownika

Właśnie zaczynam migać. Napisałem następujący kod i mam „wyjścia źródła danych spowodował błąd: nie można odczytać kodu otoki użytkownika” Błąd Czy istnieje coś robię źle? wersja: Flink v 0.9.1 (Hadoo

apache-flink 2015-09-24

---

5Ciepło

1Odpowiedz

Apache Flink - używać wartości od strumienia danych do dynamicznego tworzenia strumieniowe źródło danych

próbuję zbudować przykładową aplikację przy użyciu Apache flink który wykonuje następujące czynności: Czyta strumień symboli giełdowych (np "CSCO", "FB") z kolejki Kafka. Dla każdego symbolu wykonuje

apache-flink 2016-12-18

---

8Ciepło

1Odpowiedz

Apache Flink kontra Twitter Heron?

Istnieje wiele pytań dotyczących porównania między Flink vs Spark Streaming, Flink kontra Storm i Storm vs Heron. Pochodzenie tego pytania wynika z faktu, że zarówno Apache Flink, jak i Twitter Heron

twitter apache-storm apache-flink flink-streaming 2016-06-04

---

7Ciepło

1Odpowiedz

Get elementy JSON ze wstęgi z Apache Flink

Po przeczytaniu kilku stron dokumentacji Apache Flink (official documentation, dataartisans), a także przykładów podanych w official repository, wciąż widząc przykłady gdzie oni użyć jako źródła danyc

java json apache-flink flink-streaming 2016-02-28

---

9Ciepło

2Odpowiedz

Jakie są różnice między Hazelcast Jet a Apache Flink?

W szczególności, jakie rozwiązania wykorzystują Hazelcast Jet, że Flink nie rozwiązuje problemu (równie dobrze) i na odwrót?

apache-flink hazelcast-jet 2017-02-15

---

7Ciepło

1Odpowiedz

Połączyć dwa strumienie w Apache Flink niezależnie od czasu okna

Mam dwa strumienie danych, które chcę połączyć. Problem polega na tym, że jeden strumień danych ma znacznie wyższą częstotliwość niż inne i zdarzają się sytuacje, w których jeden strumień w ogóle nie

apache join stream streaming apache-flink 2017-09-02

---

7Ciepło

1Odpowiedz

Strumień migotania: Jak zaimplementować okna zdefiniowane przez element początkowy i końcowy?

Mam dane w następującym formacie, SIP | 2405463430 | 4115474257 | 8.205142580136622E12 | Wto 08 listopada 16:58:58 IST 2016 | INVITE RTP | 2405463430 | 4115474257 | 8.205142580136622E12 | Wto 08 listo

apache-flink flink-streaming 2016-11-09

---

7Ciepło

1Odpowiedz

Kolizja wersji Akka między Flink i Play 2.5

W naszym projekcie mamy zadanie strumieniowania Flink (1.1.3), które czyta z jednej kolejki kafka, wykonuje transformację funkcji mapy i zapisuje do kolejnej kolejki. To działało dobrze, dopóki nie wp

playframework akka apache-flink playframework-2.5 flink-streaming 2017-07-25

---