Apache Flink (original) (raw)
Apache Flink是由Apache软件基金会开发的开源流处理框架，其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和管道方式执行任意流数据程序，Flink的流水线运行时系统可以执行批处理和流处理程序。此外，Flink的运行时本身也支持迭代算法的执行。 Flink提供高吞吐量、低延迟的流数据引擎以及对事件-时间处理和状态管理的支持。Flink应用程序在发生机器故障时具有容错能力，并且支持exactly-once语义。程序可以用Java、Scala、Python和SQL等语言编写，并自动编译和优化到在集群或云环境中运行的数据流程序。 Flink并不提供自己的数据存储系统，但为Amazon Kinesis、Apache Kafka、Alluxio、HDFS、Apache Cassandra和Elasticsearch等系统提供了数据源和接收器。
| Property | Value |
|---|---|
| dbo:abstract | Apache Flink is an open-source, unified stream-processing and batch-processing framework developed by the Apache Software Foundation. The core of Apache Flink is a distributed streaming data-flow engine written in Java and Scala. Flink executes arbitrary dataflow programs in a data-parallel and pipelined (hence task parallel) manner. Flink's pipelined runtime system enables the execution of bulk/batch and stream processing programs. Furthermore, Flink's runtime supports the execution of iterative algorithms natively. Flink provides a high-throughput, low-latency streaming engine as well as support for event-time processing and state management. Flink applications are fault-tolerant in the event of machine failure and support exactly-once semantics. Programs can be written in Java, Scala, Python, and SQL and are automatically compiled and optimized into dataflow programs that are executed in a cluster or cloud environment. Flink does not provide its own data-storage system, but provides data-source and sink connectors to systems such as Amazon Kinesis, Apache Kafka, HDFS, Apache Cassandra, and ElasticSearch. (en) Apache Flink ist ein freies Streamprozessor-Framework, entwickelt von der Apache Software Foundation. Der Kern von Apache Flink bildet eine verteilte Datenfluss-Engine, die es erlaubt sowohl Datenströme als auch Stapeldaten zu verarbeiten. Apache Flink kann kontinuierliche Datenströme sowie Stapeldaten verarbeiten. Das Framework der Apache Software Foundation ist als Open-Source-Software verfügbar. Apache Flink hat sich aus einem Apache-Incubator-Projekt entwickelt und wurde zu einem Top-Level-Projekt. Apache Flink Version 1.0.0 wurde im Jahr 2016 veröffentlicht. Typische Anwendungsbereiche für Apache Flink sind: * die Echtzeitkontrolle von Finanztransaktionen * die Echtzeitauswertung des Kunden- oder Userverhaltens auf Internetseiten * die Echtzeitverarbeitung großer Mengen von Sensordaten der automatisierten Prozesse der Industrie 4.0 Bekannte Unternehmen, die Apache Flink einsetzen, sind beispielsweise Uber und Netflix. (de) Apache Flink est un framework open source de traitement flux développé par la Apache Software Foundation. Le noyau d'Apache Flink est un moteur distribué de flux écrit en Java et en Scala. Flink exécute des programmes de flux de données arbitraires de manière parallèle et en pipeline. Le système d'exécution en pipeline de Flink permet l'exécution de programmes de traitement en bloc / par lots et de flux. En outre, le runtime de Flink prend en charge l'exécution d'algorithmes itératifs de manière native. Flink fournit un moteur de diffusion en continu à haut débit et à faible temps de latence , ainsi qu'un support pour le traitement des événements et la gestion de l'état. Les applications Flink sont tolérantes aux pannes en cas de défaillance de la machine et prennent en charge une sémantique exacte. Les programmes peuvent être écrits en Java , Scala, Python, et SQL . Ils sont automatiquement compilés et optimisés dans des programmes de flux de données exécutés dans un cluster ou un environnement en nuage. Flink ne fournit pas son propre système de stockage de données, mais fournit des connecteurs de source et de données aux systèmes tels que Amazon Kinesis , Apache Kafka , Alluxio , HDFS , Apache Cassandra et Elasticsearch. (fr) Apache Flink — фреймворк с открытым исходным кодом для реализации обработки потоков, разработанный фондом Apache Software Foundation. В основу фреймворка положен движок для обработки процессов, написанный на языках Java и Scala. Flink поддерживает программирование потоков данных как в параллельном режиме, так и в конвейерном режиме (pipeline). В конвейерном режиме (pipeline) Flink позволяет реализовать последовательность заданий (batch) и поток заданий (stream). Flink поддерживает также итерационные алгоритмы естественным образом. Flink обладает высокой пропускной способностью и низкими задержками, потоки могут активизироваться от событий и сохранять статус. Задачи в системе Flink устойчивы к отказам и используют строго одну семантику. Программы для фреймворка можно писать на языках Java, Scala, Python, and SQL, задания автоматически компилируются и оптимизируются, работая как в кластерах, так и в облачном сервере. Flink не обладает собственной системой хранения данных, но использует источники данных и коннекторы типа Amazon Kinesis, Apache Kafka, , HDFS, Apache Cassandra и ElasticSearch. (ru) Apache Flink是由Apache软件基金会开发的开源流处理框架，其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和管道方式执行任意流数据程序，Flink的流水线运行时系统可以执行批处理和流处理程序。此外，Flink的运行时本身也支持迭代算法的执行。 Flink提供高吞吐量、低延迟的流数据引擎以及对事件-时间处理和状态管理的支持。Flink应用程序在发生机器故障时具有容错能力，并且支持exactly-once语义。程序可以用Java、Scala、Python和SQL等语言编写，并自动编译和优化到在集群或云环境中运行的数据流程序。 Flink并不提供自己的数据存储系统，但为Amazon Kinesis、Apache Kafka、Alluxio、HDFS、Apache Cassandra和Elasticsearch等系统提供了数据源和接收器。 (zh) |
| dbo:developer | dbr:Apache_Software_Foundation |
| dbo:genre | dbr:Machine_learning |
| dbo:license | dbr:Apache_License_2.0 |
| dbo:operatingSystem | dbr:Cross-platform |
| dbo:programmingLanguage | dbr:Scala_(programming_language) dbr:Java_(programming_language) |
| dbo:thumbnail | wiki-commons:Special:FilePath/Apache_Flink_logo.svg?width=300 |
| dbo:wikiPageID | 46228433 (xsd:integer) |
| dbo:wikiPageLength | 21822 (xsd:nonNegativeInteger) |
| dbo:wikiPageRevisionID | 1119626931 (xsd:integer) |
| dbo:wikiPageWikiLink | dbr:Python_(programming_language) dbr:Scala_(programming_language) dbr:Deutsche_Forschungsgemeinschaft dbr:Apache_Incubator dbc:Apache_Software_Foundation_projects dbc:Articles_with_example_Scala_code dbc:Distributed_stream_processing dbr:Humboldt_University_of_Berlin dbr:Volker_Markl dbc:Software_using_the_Apache_license dbr:Cross-platform dbr:SQL dbr:Task_parallelism dbr:Elasticsearch dbr:Apache_Beam dbr:Apache_Calcite dbr:Apache_Cassandra dbr:Apache_Kafka dbr:Apache_License dbr:Batch_processing dbr:Log4j dbr:Machine_learning dbr:Pipeline_(software) dbr:Stream_processing dbr:Data_parallelism dbr:Dataflow_programming dbr:List_of_Apache_Software_Foundation_projects dbr:Amazon_Web_Services dbr:Dataflow dbr:Iterative_method dbr:Hasso_Plattner_Institute dbr:Java_(programming_language) dbr:Technical_University_of_Berlin dbc:Free_software_programmed_in_Java_(programming_language) dbc:Free_system_software dbr:Software_framework dbr:HDFS dbr:Apache_Software_Foundation dbr:Open-source_software dbr:Apache_License_2.0 |
| dbp:developer | dbr:Apache_Software_Foundation |
| dbp:genre | (en) Data analytics (en) machine learning algorithms (en) |
| dbp:license | dbr:Apache_License_2.0 |
| dbp:logo | Apache Flink logo.svg (en) |
| dbp:name | Apache Flink (en) |
| dbp:operatingSystem | dbr:Cross-platform |
| dbp:programmingLanguage | Java and Scala (en) |
| dbp:title | Apache Flink (en) |
| dbp:wikiPageUsesTemplate | dbt:CVE dbt:Infobox_software dbt:Official_website dbt:Reflist dbt:Short_description dbt:Start_date_and_age dbt:Version dbt:Wikidata dbt:Apache_Software_Foundation |
| dcterms:subject | dbc:Apache_Software_Foundation_projects dbc:Articles_with_example_Scala_code dbc:Distributed_stream_processing dbc:Software_using_the_Apache_license dbc:Free_software_programmed_in_Java_(programming_language) dbc:Free_system_software |
| gold:hypernym | dbr:Framework |
| rdf:type | owl:Thing dbo:Software schema:CreativeWork dbo:Work wikidata:Q386724 wikidata:Q7397 |
| rdfs:comment | Apache Flink是由Apache软件基金会开发的开源流处理框架，其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和管道方式执行任意流数据程序，Flink的流水线运行时系统可以执行批处理和流处理程序。此外，Flink的运行时本身也支持迭代算法的执行。 Flink提供高吞吐量、低延迟的流数据引擎以及对事件-时间处理和状态管理的支持。Flink应用程序在发生机器故障时具有容错能力，并且支持exactly-once语义。程序可以用Java、Scala、Python和SQL等语言编写，并自动编译和优化到在集群或云环境中运行的数据流程序。 Flink并不提供自己的数据存储系统，但为Amazon Kinesis、Apache Kafka、Alluxio、HDFS、Apache Cassandra和Elasticsearch等系统提供了数据源和接收器。 (zh) Apache Flink is an open-source, unified stream-processing and batch-processing framework developed by the Apache Software Foundation. The core of Apache Flink is a distributed streaming data-flow engine written in Java and Scala. Flink executes arbitrary dataflow programs in a data-parallel and pipelined (hence task parallel) manner. Flink's pipelined runtime system enables the execution of bulk/batch and stream processing programs. Furthermore, Flink's runtime supports the execution of iterative algorithms natively. (en) Apache Flink ist ein freies Streamprozessor-Framework, entwickelt von der Apache Software Foundation. Der Kern von Apache Flink bildet eine verteilte Datenfluss-Engine, die es erlaubt sowohl Datenströme als auch Stapeldaten zu verarbeiten. Apache Flink kann kontinuierliche Datenströme sowie Stapeldaten verarbeiten. Das Framework der Apache Software Foundation ist als Open-Source-Software verfügbar. Apache Flink hat sich aus einem Apache-Incubator-Projekt entwickelt und wurde zu einem Top-Level-Projekt. Bekannte Unternehmen, die Apache Flink einsetzen, sind beispielsweise Uber und Netflix. (de) Apache Flink est un framework open source de traitement flux développé par la Apache Software Foundation. Le noyau d'Apache Flink est un moteur distribué de flux écrit en Java et en Scala. Flink exécute des programmes de flux de données arbitraires de manière parallèle et en pipeline. Le système d'exécution en pipeline de Flink permet l'exécution de programmes de traitement en bloc / par lots et de flux. En outre, le runtime de Flink prend en charge l'exécution d'algorithmes itératifs de manière native. (fr) Apache Flink — фреймворк с открытым исходным кодом для реализации обработки потоков, разработанный фондом Apache Software Foundation. В основу фреймворка положен движок для обработки процессов, написанный на языках Java и Scala. Flink поддерживает программирование потоков данных как в параллельном режиме, так и в конвейерном режиме (pipeline). В конвейерном режиме (pipeline) Flink позволяет реализовать последовательность заданий (batch) и поток заданий (stream). Flink поддерживает также итерационные алгоритмы естественным образом. (ru) |
| rdfs:label | Apache Flink (en) Apache Flink (de) Apache Flink (fr) Apache Flink (ru) Apache Flink (zh) |
| owl:sameAs | yago-res:Apache Flink wikidata:Apache Flink dbpedia-de:Apache Flink dbpedia-fr:Apache Flink dbpedia-ru:Apache Flink dbpedia-zh:Apache Flink https://global.dbpedia.org/id/y4ZU |
| prov:wasDerivedFrom | wikipedia-en:Apache_Flink?oldid=1119626931&ns=0 |
| foaf:depiction | wiki-commons:Special:FilePath/Apache_Flink_logo.svg |
| foaf:isPrimaryTopicOf | wikipedia-en:Apache_Flink |
| foaf:name | Apache Flink (en) |
| is dbo:wikiPageWikiLink of | dbr:Cascading_(software) dbr:List_of_concurrent_and_parallel_programming_languages dbr:Volker_Markl dbr:Apache_Beam dbr:Apache_Calcite dbr:Apache_Hadoop dbr:Apache_Iceberg dbr:Apache_Kafka dbr:Apache_Mahout dbr:Apache_ORC dbr:Apache_RocketMQ dbr:Apache_Spark dbr:Apache_Storm dbr:Complex_event_processing dbr:Stream_processing dbr:Dataflow_programming dbr:List_of_Apache_Software_Foundation_projects dbr:Akka_(toolkit) dbr:DriveTribe dbr:XGBoost dbr:Message_Passing_Interface dbr:Parallel_programming_model dbr:Parallelization_contract |
| is foaf:primaryTopic of | wikipedia-en:Apache_Flink |
