Dezvoltat de | Apache Software Foundation |
---|---|
Prima versiune | 15 iunie 2016 și 21 decembrie 2016 |
Ultima versiune | 2.14.0 (1 st august 2019) |
Depozit | github.com/apache/beam |
Scris in | Java , Python și Go |
Sistem de operare | Multiplatform |
Licență | Licență Apache versiunea 2.0 |
Site-ul web | beam.apache.org |
Apache Beam este un model de programare unificată open source pentru definirea și rularea fluxurilor de date, inclusiv ETL , procesare batch și streaming (streaming).
Fluxurile Beam sunt definite folosind SDK-uri și executate într-unul dintre alergătorii suportați de Beam (back-end-uri de procesare distribuită), inclusiv Apache Flink , Apache Apex , Apache Samza , Apache Spark și Google Cloud Dataflow.
A fost numit uber-API pentru big data .
Apache Beam este o implementare a modelului Dataflow. Modelul Dataflow se bazează pe lucrările anterioare privind abstracțiile de procesare distribuite pe Google, în special pe FlumeJava și Millwheel.
Google a lansat o implementare SDK deschisă a modelului Dataflow în 2014 și un mediu pentru a rula fluxurile de date la nivel local (nedistribuit), precum și în serviciul Google Cloud Platform .
În 2016, Google a donat SDK-ul de bază, precum și configurarea unui runner local și un set de I / O (conectori de date) pentru a accesa serviciile de date Google Cloud Platform către Apache Software Foundation .
Alte companii și membri ai comunității au ajutat la crearea de platforme distribuite de runtime, precum și de noi I / O pentru a se integra cu Beam Runners în bazele de date existente, baza de date cheie-valoare și mesajele de sistem. În plus, au fost propuse noi DSL - uri pentru a sprijini nevoile specifice ale modelului Beam.
10 ianuarie 2017 Apache Beam devine un proiect de nivel superior.
Versiune | Data lansării inițiale | Ultima versiune | Data de lansare |
---|---|---|---|
0.6.0 | 2017-03-11 | 0.6.0 | 2017-03-11 |
0,5,0 | 02.02.2017 | 0,5,0 | 02.02.2017 |
0.4.0 | 29.12.2016 | 0.4.0 | 29.12.2016 |
0.3.0 | 31-10-2016 | 0.3.0 | 31-10-2016 |
0.2.0 | 08.08.2016 | 0.2.0 | 08.08.2016 |
0.1.0 | 15.06.2016 | 0.1.0 | 15.06.2016 |