Suchergebnisse für Anfrage "apache-flink"
Wie verwende ich Flinks KafkaSource in Scala?
Ich versuche, ein einfaches Testprogramm mit Flinks KafkaSource auszuführen. Ich benutze folgendes: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Ich habe die Dokumentation befolgt, um KafkaSource zu testen (hinzugefügte Abhängigkeit, Bündelung des ...
Was bedeutet "Streaming" in Apache Spark und Apache Flink?
ls ich zu @ giApache Spark Streaming [https://spark.apache.org/streaming/] Website, ich habe einen Satz gesehen: Spark Streaming erleichtert das Erstellen skalierbarer fehlertoleranter Streaming-Anwendungen. Und inApache Flink ...
Was ist / sind die Hauptunterschiede zwischen Flink und Storm?
Flink war im Vergleich zu Spark [https://stackoverflow.com/questions/28082581/what-is-the-differences-between-apache-spark-and-apache-flink] , was meines Erachtens der falsche Vergleich ist, da es ein ...
Globale Sortierung in Apache Flink
ie @sortPartition-Methode eines Datasets sortiert das Dataset lokal anhand einiger angegebener Felder. Wie kann ich meinen großen Datensatz in Flink effizient global sortieren?
Flink Scala API "nicht genug Argumente"
Ich habe Probleme mit der Apache Flink Scala API Selbst wenn ich zum Beispiel die Beispiele aus der offiziellen Dokumentation entnehme, gibt mir der Scala-Compiler Unmengen von Kompilierungsfehlern. Code object TestFlink { def main(args: ...
Flink CEP Keine Ergebnisse gedruckt
Ich versuche, eine Zeichenfolge auszudrucken, wenn Hello und world mithilfe der Flink CEP-Bibliothek gefunden werden. Meine Quelle ist Kafka und ich benutze den Konsolenhersteller, um die Daten einzugeben. Dieser Teil funktioniert. Ich ...
flink - mit Dolchinjektionen - nicht serialisierbar?
Im mit Flink (neueste via Git), um von Kafka zu Cassandra zu streamen. Um das Testen von Einheiten zu vereinfachen, füge ich die Abhängigkeitsinjektion über Dagger hinzu. Der ObjectGraph scheint sich ordnungsgemäß einzurichten, aber die ...
Wie kann ich die Flink Job Manager-Weboberfläche starten, wenn Flink von einer IDE aus ausgeführt wird?
Ich möchte auf die Flink-Weboberfläche zugreifen, wenn ich sie lokal von der IDE aus starte. Ich brauche das, weil ich auf die Zähler (Akkumulatoren) von Flink zugreifen möchte.
Local Flink config läuft Standalone von IDE
Wenn ich eine Flink-App lokal direkt in Intellij ausführen möchte, aber Konfigurationsparameter angeben muss (z. B. fs.hdfs.hdfssite, um den S3-Zugriff einzurichten), können diese Konfigurationsparameter auch auf andere Weise bereitgestellt ...
Ist es möglich, Riak CS mit Apache Flink zu verwenden?
Ich möchte @ konfigurierfilesystem State Backend undzookeeper Wiederherstellungsmodus state.backend: filesystem state.backend.fs.checkpointdir: ??? recovery.mode: zookeeper recovery.zookeeper.storageDir: ??? Wie Sie sehen, sollte ich ...
Seite 1 von 2