-
公开(公告)号：US11625381B2
公开(公告)日：2023-04-11
申请号：US17238967
申请日：2021-04-23
发明人： Sandeep Bishnoi , Prabhu Thukkaram , Iuliia Shmeleva , Dmitrii Markovskii , Vitaly Vitalievich Bychkov , Gyorgy Geiszter
IPC分类号： G06F16/00 , G06F16/22 , G06F16/242 , G06F16/248 , G06F16/23 , G06F16/2455
摘要： Techniques for processing data streaming from one or more event sources in order to recreate a database table with database transactions for real-time analytics. An exemplary technique includes receiving a stream of events comprising change data for a table attribute, populating an in-memory table with the change data based on a token associated with an operation type and a mapping of a first attribute and a second attribute to a key attribute of the in-memory table, executing a continuous query on the change data for the key attribute of the in-memory table to generate events comprising data for a third attribute, and outputting the events having an output shape comprising the third attribute, where the events include the data for the third attribute.
-
公开(公告)号：US20180075108A1
公开(公告)日：2018-03-15
申请号：US15705402
申请日：2017-09-15
摘要： An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous data stream related to an application, identify an input geometry associated with the continuous data stream, generate a cluster of geometries based at least in part on the input geometry, generate an output geometry based at least in part on the cluster of geometries and a number of geometries in each cluster of the cluster of geometries, determining one or more partitions for the output geometry based on the cluster of geometries and the number of geometries in each cluster of the cluster of geometries, dynamically change a size of the one or more partitions for the output geometry, and transmitting the output geometry associated with the continuous data stream.
-
公开(公告)号：US10991134B2
公开(公告)日：2021-04-27
申请号：US16775079
申请日：2020-01-28
IPC分类号： G06F16/29 , G06T11/20 , G06T3/40 , G06F16/9537
摘要： Systems and methods described herein are directed towards controlling a level of detail for geostreaming data. In some examples, an identifying event data that includes location information. A polygon may be defined that comprises points on a map corresponding to the event data. A first level of detail may be determined and a fidelity of the polygon may be changed based at least in part on the first level of detail. Second event data may be received that identifies a location of an object. It may be identified whether the object is within the location information and a user interface may be prepared that presents whether the object is in an affected area.
-
公开(公告)号：US20180075109A1
公开(公告)日：2018-03-15
申请号：US15705406
申请日：2017-09-15
IPC分类号： G06F17/30
CPC分类号： G06F17/30516 , G06F17/30241 , G06F17/30324 , G06F17/30336 , G06F17/30371 , G06F17/30958 , H04W4/021
摘要： An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous data stream related to an application, convert geometry of the continuous data stream into a relation, track a plurality of moving objects in the continuous data stream, determine a relationship between at least a first object and a second object (e.g., a first moving object and a second moving object in the plurality of moving objects) based at least on the geometry of a continuous data stream and the relation. and perform an action based at least one the determined relationship.
-
公开(公告)号：US11016958B2
公开(公告)日：2021-05-25
申请号：US16141106
申请日：2018-09-25
发明人： Sandeep Bishnoi , Prabhu Thukkaram , Iuliia Shmeleva , Dmitrii Markovskii , Vitaly Vitalievich Bychkov , Gyorgy Geiszter
IPC分类号： G06F16/00 , G06F16/22 , G06F16/242 , G06F16/248 , G06F16/23 , G06F16/2455
摘要： Techniques for processing data streaming from one or more event sources in order to recreate a database table with database transactions for real-time analytics. An exemplary technique includes receiving a stream of events comprising change data for a table attribute, populating an in-memory table with the change data based on a token associated with an operation type and a mapping of a first attribute and a second attribute to a key attribute of the in-memory table, executing a continuous query on the change data for the key attribute of the in-memory table to generate events comprising data for a third attribute, and outputting the events having an output shape comprising the third attribute, where the events include the data for the third attribute.
-
公开(公告)号：US10831761B2
公开(公告)日：2020-11-10
申请号：US16374173
申请日：2019-04-03
IPC分类号： G06F16/2455 , G06F16/29 , G06F16/22 , G06F16/23 , G06F16/901 , H04W4/021
摘要： An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous data stream related to an application, convert geometry of the continuous data stream into a relation, track a plurality of moving objects in the continuous data stream, determine a relationship between at least a first object and a second object (e.g., a first moving object and a second moving object in the plurality of moving objects) based at least on the geometry of a continuous data stream and the relation. and perform an action based at least one the determined relationship.
-
公开(公告)号：US10275492B2
公开(公告)日：2019-04-30
申请号：US15705406
申请日：2017-09-15
摘要： An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a continuous data stream related to an application, convert geometry of the continuous data stream into a relation, track a plurality of moving objects in the continuous data stream, determine a relationship between at least a first object and a second object (e.g., a first moving object and a second moving object in the plurality of moving objects) based at least on the geometry of a continuous data stream and the relation. and perform an action based at least one the determined relationship.
-
公开(公告)号：US20200167978A1
公开(公告)日：2020-05-28
申请号：US16775079
申请日：2020-01-28
IPC分类号： G06T11/20 , G06F16/29 , G06F16/9537 , G06T3/40
摘要： Systems and methods described herein are directed towards controlling a level of detail for geostreaming data. In some examples, an identifying event data that includes location information. A polygon may be defined that comprises points on a map corresponding to the event data. A first level of detail may be determined and a fidelity of the polygon may be changed based at least in part on the first level of detail. Second event data may be received that identifies a location of an object. It may be identified whether the object is within the location information and a user interface may be prepared that presents whether the object is in an affected area.
-
公开(公告)号：US20190102431A1
公开(公告)日：2019-04-04
申请号：US16147622
申请日：2018-09-29
发明人： Sandeep Bishnoi , Hoyong Park , Iuliia Shmeleva , Vitaly Vitalievich Bychkov , Gyorgy Geiszter , Péter Gordos
摘要： Techniques for implementing logical queries in a distributed stream processing system using automatic branching and joins. An exemplary technique includes determining a query is a logical query. The logical query includes two or more summaries based on different groups configured to execute in a single query stage of a stream analytics application. The technique further includes converting the logical query into one or more physical queries. The one or more physical queries are separated into individual query stages, and each of the query stages includes a summary from the two or more summaries that is based on an associated group. The technique further includes generating a directed acyclic graph for the one or more physical queries. The directed acyclic graph includes a physical query transformation for each of the individual query stages.
-
10.发明申请公开(公告)号：US20190102415A1
公开(公告)日：2019-04-04
申请号：US16141106
申请日：2018-09-25
发明人： Sandeep Bishnoi , Prabhu Thukkaram , Iuliia Shmeleva , Dmitrii Markovskii , Vitaly Vitalievich Bychkov , Gyorgy Geiszter
IPC分类号： G06F17/30
摘要： Techniques for processing data streaming from one or more event sources in order to recreate a database table with database transactions for real-time analytics. An exemplary technique includes receiving a stream of events comprising change data for a table attribute, populating an in-memory table with the change data based on a token associated with an operation type and a mapping of a first attribute and a second attribute to a key attribute of the in-memory table, executing a continuous query on the change data for the key attribute of the in-memory table to generate events comprising data for a third attribute, and outputting the events having an output shape comprising the third attribute, where the events include the data for the third attribute.
-
-
-
-
-
-
-
-
-
搜索结果
15 条记录 (耗时 0.015 秒)
