公开(公告)号：DE102021129637A1

公开(公告)日：2022-06-15

申请号：DE102021129637

申请日：2021-11-15

Applicant: IBM

Inventor： CHIU HENRY ,  FAWCETT BRADLEY WILLIAM ,  SUN JINGDONG ,  NIKOLAI JASON A ,  GERVER PAUL

IPC: G06F15/16

Abstract: Computersoftware, die einen Stream-Processing-Verwaltungsknoten veranlasst, die folgenden Operationen durchzuführen: (i) Herstellen einer Datenübertragung zwischen dem Stream-Processing-Verwaltungsknoten und einer Mehrzahl von Stream-Processing-Instanzen, die in jeweiligen Datenverarbeitungsumgebungen in einem Datenverarbeitungssystem mit mehreren Umgebungen ausgeführt werden; (ii) Verteilen von einer oder mehreren Verarbeitungseinheiten eines Stream-Processing-Jobs an einen ersten Satz von Stream-Processing-Instanzen der Mehrzahl von Stream-Processing-Instanzen; (iii) Empfangen von der einen oder den mehreren Stream-Processing-Instanzen des ersten Satzes von Stream-Processing-Instanzen, von Verarbeitungsergebnissen, die zu der einen oder den mehreren Verarbeitungseinheiten des Stream-Processing-Jobs gehören; und (iv) Durchführen einer auf Machine Learning beruhenden Stream-Verwaltungsoperation, wobei das Durchführen zumindest teilweise auf den empfangenen Verarbeitungsergebnissen beruht.

公开(公告)号：DE102021130397A1

公开(公告)日：2022-06-23

申请号：DE102021130397

申请日：2021-11-22

Applicant: IBM

Inventor： GERVER PAUL ,  SUN JINGDONG ,  FAWCETT BRADLEY WILLIAM ,  NIKOLAI JASON A ,  CHIU HENRY

IPC: G06F9/48 ,  G06F9/44

Abstract: Ein Tupeldatenstrom wird überwacht, der durch eine Mehrzahl von Verarbeitungselementen verarbeitet werden soll, die auf einem oder mehreren Rechenknoten einer Datenstromanwendung betrieben werden. Jedes Verarbeitungselement verfügt über einen oder mehrere Datenstromoperatoren. Eine Programmanforderung, einen ersten Satz von Programmcode-Anweisungen auszuführen, wird empfangen. Ein Datenstromanwendungsziel des ersten Satzes von Programmcode-Anweisungen wird auf der Grundlage der Programmanforderung gekennzeichnet. Ein Teil der Datenstromanwendung wird während des Betriebs der Datenstromanwendung mit einer generischen Programmausführungsstruktur gekapselt. Die Struktur ist so konfiguriert, dass sie Programmcode-Anweisungen außerhalb eines vorkonfigurierten Betriebs der Datenstromanwendung empfängt und ausführt. Der Satz von Programmcode-Anweisungen wird während des Betriebs der Datenstromanwendung in einem Zeitraum einer Ausführung des Teils als Reaktion auf die Programmanforderung und auf der Grundlage des Datenstromanwendungsziels durch die Struktur ausgeführt.