MRQL is a query processing and optimization system for large-scale, distributed data analysis, built on top of Apache Hadoop, Hama,Spark, and Flink.
如果发生机器或软件故障,重新启动后,Flink应用程序将从最新的checkpoint点恢复处理;.
In the event of a machine or software failure and upon restart, a Flink application resumes processing from the most recent successfully-completed checkpoint;
Similarly, end users of Flink tend to run Flink-based applications rather than Flink jobs, which is the highest execution abstraction available in the project.
Apache Beam is an open-source project that provides a unified API, allowing pipelines to be ported across execution engines including Samza,Spark, or Flink.
将检查点数据写入持久存储是异步发生的,这意味着Flink应用程序在写检查点过程中可以继续处理数据。
Writing the checkpoint data to the persistent storage happens asynchronously,which means that a Flink application continues to process data during the checkpointing process.
Apache Flink(formerly called Stratosphere) features powerful programming abstractions in Java and Scala, a high-performance runtime, and automatic program optimization.
Jamie Grier, Director of applications engineering at data Artisans recently spoke at OSCON 2016 Conference aboutdata streaming architecture using Apache Flink.
The pipeline is then executed by one of Beam's supported distributed processing back-ends,which include Apache Flink, Apache Spark, and Google Cloud Dataflow.
中文
Bahasa indonesia
日本語
عربى
Български
বাংলা
Český
Dansk
Deutsch
Ελληνικά
Español
Suomi
Français
עִברִית
हिंदी
Hrvatski
Magyar
Italiano
Қазақ
한국어
മലയാളം
मराठी
Bahasa malay
Nederlands
Norsk
Polski
Português
Română
Русский
Slovenský
Slovenski
Српски
Svenska
தமிழ்
తెలుగు
ไทย
Tagalog
Turkce
Українська
اردو
Tiếng việt