RU2017106150A - Преобразование потоков событий - Google Patents
Преобразование потоков событий Download PDFInfo
- Publication number
- RU2017106150A RU2017106150A RU2017106150A RU2017106150A RU2017106150A RU 2017106150 A RU2017106150 A RU 2017106150A RU 2017106150 A RU2017106150 A RU 2017106150A RU 2017106150 A RU2017106150 A RU 2017106150A RU 2017106150 A RU2017106150 A RU 2017106150A
- Authority
- RU
- Russia
- Prior art keywords
- event stream
- computer
- event
- module
- stream
- Prior art date
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/25—Integrating or interfacing systems involving database management systems
- G06F16/254—Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
- G06F16/24553—Query execution of query operations
- G06F16/24558—Binary matching operations
- G06F16/2456—Join operations
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2455—Query execution
- G06F16/24568—Data stream processing; Continuous queries
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Databases & Information Systems (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computational Linguistics (AREA)
- Medical Informatics (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- General Health & Medical Sciences (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Stored Programmes (AREA)
Claims (20)
1. Компьютерный программный продукт, содержащий один или более машиночитаемых носителей, имеющих машиноисполняемые инструкции, которые при их исполнении одним или более процессорами предписывают одному или более процессорам выполнять следующее:
осуществление доступа к представлению источника потока событий, представляющему поток событий, доступный в контексте выполнения;
предоставление представления приемника потока событий, представляющего приемник потока событий, доступный в контексте выполнения;
идентификацию, посредством модуля преобразований, набора преобразований из одного или более преобразований, которые должны выполняться в отношении одного или более входных потоков событий, причем входные потоки событий ассоциированы с модулем преобразований, при этом модуль преобразований идентифицирует поток событий в качестве одного из потоков событий и модуль преобразований ассоциирован с представлением источника потока событий и представлением приемника потока событий; и
интерпретацию, посредством модуля выполнения, модуля преобразований, чтобы инструктировать выполнение набора преобразований в контексте выполнения в отношении идентифицированных входных потоков, с тем чтобы формировать по меньшей мере один выходной поток событий;
при этом контекст выполнения является одним из локального, удаленного, облака.
2. Компьютерный программный продукт по п. 1, в котором машиноисполняемые инструкции машиночитаемых носителей дополнительно содержат модуль авторской разработки, сконфигурированный с возможностью обеспечивать автору возможность выполнять авторскую разработку представления источника потока событий и модуля преобразований.
3. Компьютерный программный продукт по п. 1, в котором машиноисполняемые инструкции машиночитаемых носителей дополнительно содержат идентификацию, посредством модуля идентификации контекстов, контекста выполнения для модуля выполнения таким образом, что модуль выполнения может обеспечить выполнение набора преобразований в контексте выполнения.
4. Компьютерный программный продукт по п. 1, в котором машиноисполняемые инструкции машиночитаемых носителей дополнительно содержат элемент управления инициированием, сконфигурированный инициировать модуль выполнения при обнаружении пользовательского ввода.
5. Машинореализуемый способ обеспечения формирования результирующего потока событий посредством выполнения набора преобразований в отношении одного или более входных потоков событий, причем машинореализуемый способ осуществляется посредством одного или более процессоров, исполняющих машиноисполняемые инструкции для этого машинореализуемого способа, и машинореализуемый способ содержит этапы, на которых:
осуществляют доступ к представлению источника потока событий, представляющему конкретный поток событий, доступный в контексте выполнения,
предоставляют представление приемника потока событий, представляющее приемник потока событий, доступный в контексте выполнения;
идентифицируют, посредством модуля преобразований, набор преобразований из одного или более преобразований, которые должны выполняться в отношении одного или более входных потоков событий, ассоциированных с модулем преобразований, причем модуль преобразований идентифицирует конкретный поток событий в качестве одного из одного или более входных потоков событий и модуль преобразований ассоциирован с представлением источника потока событий и представлением приемника потока событий; и
интерпретируют, посредством модуля выполнения, модуль преобразований, чтобы инструктировать выполнение набора преобразований в контексте выполнения в отношении идентифицированных одного или более входных потоков событий, с тем чтобы сформировать по меньшей мере один выходной поток событий;
при этом контекст выполнения является одним из локального, удаленного, облака.
6. Машинореализуемый способ по п. 5, в котором упомянутый конкретный поток событий представляет собой актуальный поток событий, при этом представление источника потока событий является представлением источника актуального потока событий.
7. Машинореализуемый способ по п. 6, дополнительно содержащий этап, на котором осуществляют доступ к представлению источника статистического потока событий, представляющему статистический поток событий, доступный в контексте выполнения.
8. Машинореализуемый способ по п. 5, в котором упомянутые одно или более преобразований содержат операцию фильтрации, которая применяется к упомянутому конкретному потоку событий.
9. Машинореализуемый способ по п. 8, в котором упомянутые одно или более преобразований содержат логику формирования событий для формирования событий результирующего потока событий, причем логика формирования событий использует отфильтрованный конкретный поток событий в качестве ввода.
10. Машинореализуемый способ по п. 5, в котором упомянутые одно или более преобразований содержат логику формирования событий для формирования событий результирующего потока событий, причем логика формирования событий использует упомянутый конкретный поток событий в качестве ввода.
Applications Claiming Priority (5)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| US201462044090P | 2014-08-29 | 2014-08-29 | |
| US62/044,090 | 2014-08-29 | ||
| US14/515,382 US10235436B2 (en) | 2014-08-29 | 2014-10-15 | Event stream transformations |
| US14/515,382 | 2014-10-15 | ||
| PCT/US2015/046622 WO2016032986A1 (en) | 2014-08-29 | 2015-08-25 | Event stream transformations |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| RU2017106150A true RU2017106150A (ru) | 2018-08-28 |
Family
ID=54072990
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| RU2017106150A RU2017106150A (ru) | 2014-08-29 | 2015-08-25 | Преобразование потоков событий |
Country Status (11)
| Country | Link |
|---|---|
| US (1) | US10235436B2 (ru) |
| EP (1) | EP3186946B1 (ru) |
| JP (1) | JP2017527024A (ru) |
| KR (1) | KR102454201B1 (ru) |
| CN (1) | CN106664322B (ru) |
| AU (1) | AU2015306852A1 (ru) |
| BR (1) | BR112017002834A2 (ru) |
| CA (1) | CA2955838A1 (ru) |
| MX (1) | MX2017002593A (ru) |
| RU (1) | RU2017106150A (ru) |
| WO (1) | WO2016032986A1 (ru) |
Families Citing this family (43)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10956422B2 (en) | 2012-12-05 | 2021-03-23 | Oracle International Corporation | Integrating event processing with map-reduce |
| US10127903B2 (en) * | 2014-12-02 | 2018-11-13 | International Business Machines Corporation | Discovering windows in temporal predicates |
| US10592500B2 (en) | 2015-01-27 | 2020-03-17 | International Business Machines Corporation | Eviction stream for data joins |
| US12471153B2 (en) * | 2016-06-19 | 2025-11-11 | Platform Science, Inc. | Method and system for synchronizing events within a secure wireless network |
| US10331693B1 (en) * | 2016-09-12 | 2019-06-25 | Amazon Technologies, Inc. | Filters and event schema for categorizing and processing streaming event data |
| EP3584715B1 (en) | 2016-09-15 | 2023-08-16 | Oracle International Corporation | Managing snapshots and state with micro-batching |
| US10628424B2 (en) * | 2016-09-15 | 2020-04-21 | Oracle International Corporation | Graph generation for a distributed event processing system |
| US10496467B1 (en) | 2017-01-18 | 2019-12-03 | Amazon Technologies, Inc. | Monitoring software computations of arbitrary length and duration |
| WO2018169430A1 (en) | 2017-03-17 | 2018-09-20 | Oracle International Corporation | Integrating logic in micro batch based event processing systems |
| WO2018169429A1 (en) | 2017-03-17 | 2018-09-20 | Oracle International Corporation | Framework for the deployment of event-based applications |
| WO2018215062A1 (en) * | 2017-05-24 | 2018-11-29 | Huawei Technologies Co., Ltd. | System and method for stream processing |
| CN109542444B (zh) * | 2017-07-31 | 2022-03-25 | 华为技术有限公司 | Java应用的监控方法、装置、服务器和存储介质 |
| CN110062922B (zh) * | 2017-09-21 | 2021-12-14 | 华为技术有限公司 | 流处理系统和方法 |
| CN109614413B (zh) * | 2018-12-12 | 2023-03-24 | 上海金融期货信息技术有限公司 | 一种内存流式计算平台系统 |
| US11113270B2 (en) | 2019-01-24 | 2021-09-07 | EMC IP Holding Company LLC | Storing a non-ordered associative array of pairs using an append-only storage medium |
| US11360983B2 (en) * | 2019-03-01 | 2022-06-14 | Hitachi Vantara Llc | Techniques for processing of data in motion |
| US11461345B2 (en) * | 2019-05-31 | 2022-10-04 | Microsoft Technology Licensing, Llc | Providing access to state information associated with operators in a data processing system |
| US11604759B2 (en) | 2020-05-01 | 2023-03-14 | EMC IP Holding Company LLC | Retention management for data streams |
| US11599546B2 (en) | 2020-05-01 | 2023-03-07 | EMC IP Holding Company LLC | Stream browser for data streams |
| US11340834B2 (en) | 2020-05-22 | 2022-05-24 | EMC IP Holding Company LLC | Scaling of an ordered event stream |
| US11360992B2 (en) | 2020-06-29 | 2022-06-14 | EMC IP Holding Company LLC | Watermarking of events of an ordered event stream |
| US11599420B2 (en) | 2020-07-30 | 2023-03-07 | EMC IP Holding Company LLC | Ordered event stream event retention |
| US11340792B2 (en) | 2020-07-30 | 2022-05-24 | EMC IP Holding Company LLC | Ordered event stream merging |
| US11354444B2 (en) * | 2020-09-30 | 2022-06-07 | EMC IP Holding Company LLC | Access control for an ordered event stream storage system |
| US11513871B2 (en) | 2020-09-30 | 2022-11-29 | EMC IP Holding Company LLC | Employing triggered retention in an ordered event stream storage system |
| US11755555B2 (en) | 2020-10-06 | 2023-09-12 | EMC IP Holding Company LLC | Storing an ordered associative array of pairs using an append-only storage medium |
| US11323497B2 (en) | 2020-10-07 | 2022-05-03 | EMC IP Holding Company LLC | Expiration of data streams for application programs in a streaming data storage platform |
| US11599293B2 (en) | 2020-10-14 | 2023-03-07 | EMC IP Holding Company LLC | Consistent data stream replication and reconstruction in a streaming data storage platform |
| US11354054B2 (en) | 2020-10-28 | 2022-06-07 | EMC IP Holding Company LLC | Compaction via an event reference in an ordered event stream storage system |
| US11347568B1 (en) | 2020-12-18 | 2022-05-31 | EMC IP Holding Company LLC | Conditional appends in an ordered event stream storage system |
| US11816065B2 (en) | 2021-01-11 | 2023-11-14 | EMC IP Holding Company LLC | Event level retention management for data streams |
| US11526297B2 (en) | 2021-01-19 | 2022-12-13 | EMC IP Holding Company LLC | Framed event access in an ordered event stream storage system |
| US12099513B2 (en) | 2021-01-19 | 2024-09-24 | EMC IP Holding Company LLC | Ordered event stream event annulment in an ordered event stream storage system |
| US11740828B2 (en) | 2021-04-06 | 2023-08-29 | EMC IP Holding Company LLC | Data expiration for stream storages |
| US12001881B2 (en) | 2021-04-12 | 2024-06-04 | EMC IP Holding Company LLC | Event prioritization for an ordered event stream |
| US11954537B2 (en) | 2021-04-22 | 2024-04-09 | EMC IP Holding Company LLC | Information-unit based scaling of an ordered event stream |
| US11513714B2 (en) | 2021-04-22 | 2022-11-29 | EMC IP Holding Company LLC | Migration of legacy data into an ordered event stream |
| US11681460B2 (en) | 2021-06-03 | 2023-06-20 | EMC IP Holding Company LLC | Scaling of an ordered event stream based on a writer group characteristic |
| US11681722B2 (en) * | 2021-06-08 | 2023-06-20 | Jpmorgan Chase Bank, N.A. | System and method for configurable and automated data extraction, formatting and distribution |
| US11735282B2 (en) | 2021-07-22 | 2023-08-22 | EMC IP Holding Company LLC | Test data verification for an ordered event stream storage system |
| US11971850B2 (en) | 2021-10-15 | 2024-04-30 | EMC IP Holding Company LLC | Demoted data retention via a tiered ordered event stream data storage system |
| US12130793B2 (en) * | 2022-06-02 | 2024-10-29 | Barcelona Supercomputing Center-Centro Nacional De Supercomputacion | Method for optimizing the management of a flow of data |
| WO2024182171A1 (en) * | 2023-02-28 | 2024-09-06 | Microsoft Technology Licensing, Llc | Techniques for querying time-series based event data with a delay tolerance |
Family Cites Families (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US6567813B1 (en) * | 2000-12-29 | 2003-05-20 | Webex Communications, Inc. | Quality of service maintenance for distributed collaborative computing |
| US20070150585A1 (en) * | 2005-12-28 | 2007-06-28 | Microsoft Corporation | Multi-dimensional aggregation on event streams |
| CN1959724B (zh) * | 2006-11-24 | 2010-08-11 | 清华大学 | 泛在计算环境中工作流上下文信息的获取方法和系统 |
| US8069190B2 (en) | 2007-12-27 | 2011-11-29 | Cloudscale, Inc. | System and methodology for parallel stream processing |
| US20100131556A1 (en) | 2008-11-25 | 2010-05-27 | Microsoft Corporation | Unified event programming and queries |
| US8612983B2 (en) * | 2009-09-07 | 2013-12-17 | International Business Machines Corporation | Scheduling event streams depending on content information data |
| US9158816B2 (en) | 2009-10-21 | 2015-10-13 | Microsoft Technology Licensing, Llc | Event processing with XML query based on reusable XML query template |
| CN102096848B (zh) * | 2009-12-09 | 2015-11-25 | Sap欧洲公司 | 用于在对流事件的查询模式匹配期间进行快速响应的调度 |
| EP2348416A1 (en) * | 2010-01-21 | 2011-07-27 | Software AG | Analysis system and method for analyzing continuous queries for data streams |
| US20110314019A1 (en) | 2010-06-18 | 2011-12-22 | Universidad Politecnica De Madrid | Parallel processing of continuous queries on data streams |
| CN102340495B (zh) | 2010-07-26 | 2014-09-03 | 中国移动通信集团广东有限公司 | 一种支撑跨系统业务联动的事件中心及其事件处理方法 |
| US9166892B1 (en) * | 2012-01-20 | 2015-10-20 | Google Inc. | Systems and methods for event stream management |
-
2014
- 2014-10-15 US US14/515,382 patent/US10235436B2/en active Active
-
2015
- 2015-08-25 EP EP15762846.2A patent/EP3186946B1/en active Active
- 2015-08-25 WO PCT/US2015/046622 patent/WO2016032986A1/en not_active Ceased
- 2015-08-25 CA CA2955838A patent/CA2955838A1/en not_active Abandoned
- 2015-08-25 KR KR1020177005572A patent/KR102454201B1/ko active Active
- 2015-08-25 CN CN201580046306.3A patent/CN106664322B/zh active Active
- 2015-08-25 RU RU2017106150A patent/RU2017106150A/ru not_active Application Discontinuation
- 2015-08-25 AU AU2015306852A patent/AU2015306852A1/en not_active Abandoned
- 2015-08-25 BR BR112017002834A patent/BR112017002834A2/pt not_active Application Discontinuation
- 2015-08-25 MX MX2017002593A patent/MX2017002593A/es unknown
- 2015-08-25 JP JP2017505163A patent/JP2017527024A/ja active Pending
Also Published As
| Publication number | Publication date |
|---|---|
| CN106664322B (zh) | 2020-05-15 |
| US20160063080A1 (en) | 2016-03-03 |
| AU2015306852A1 (en) | 2017-02-16 |
| CA2955838A1 (en) | 2016-03-03 |
| WO2016032986A1 (en) | 2016-03-03 |
| EP3186946A1 (en) | 2017-07-05 |
| US10235436B2 (en) | 2019-03-19 |
| JP2017527024A (ja) | 2017-09-14 |
| CN106664322A (zh) | 2017-05-10 |
| MX2017002593A (es) | 2017-05-30 |
| KR20170048373A (ko) | 2017-05-08 |
| BR112017002834A2 (pt) | 2017-12-19 |
| EP3186946B1 (en) | 2020-08-05 |
| KR102454201B1 (ko) | 2022-10-12 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| RU2017106150A (ru) | Преобразование потоков событий | |
| Luo et al. | Dynamic maintenance of approximations in set-valued ordered decision systems under the attribute generalization | |
| Kang et al. | Rough set model based on formal concept analysis | |
| Guesmia et al. | A new approach to the stability of an abstract system in the presence of infinite history | |
| WO2020016579A3 (en) | Machine learning based methods of analysing drug-like molecules | |
| WO2014174497A3 (en) | Apparatus and method for providing musical content based on graphical user inputs | |
| WO2015001360A3 (en) | System for automating processes | |
| WO2015094871A3 (en) | Intent-based user experience | |
| BR112015000799A2 (pt) | aparelho de interface de usuário e método para terminal de usuário | |
| GB2543900A (en) | Distributed big data in a process control system | |
| RU2016124468A (ru) | Управляющее устройство, способ управления и компьютерная программа | |
| BR112015030481A2 (pt) | sistema e método para monitorar um processo | |
| EP4307295A3 (en) | Server and method for controlling server | |
| MX357793B (es) | Metodo de conversion y aparato de conversion. | |
| MX2016014224A (es) | Configuracion de flujos de trabajo en un dispositivo anfitrion que funciona en un sistema de control de procesos. | |
| MX394853B (es) | Sistemas y métodos para ejecutar una función suplementaria para una consulta de lenguaje natural. | |
| JP2016524756A5 (ru) | ||
| EP4242892A3 (en) | Code pointer authentication for hardware flow control | |
| JP2016520898A5 (ru) | ||
| MX355819B (es) | Sistema de ilustracion en pantalla para procesamiento de comandos. | |
| BR102015010606A8 (pt) | Método, e, produto de programa de computador | |
| WO2013160771A3 (en) | Method and apparatus for design of pipeline components | |
| HK1201022A2 (en) | Method and system for personalized text and illustration creation | |
| WO2017106610A8 (en) | Method and system for providing automated localized feedback for an extracted component of an electronic document file | |
| TW201611877A (en) | Computer-implemented method for determining game mechanics in business process gamification |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| FA93 | Acknowledgement of application withdrawn (no request for examination) |
Effective date: 20180827 |