中科微点-全球专利检索

  1. Login
  2. Sign Up

Search Results

98 records (took 0.034 seconds)

    Flexible event ingestion framework in an event processing system
    1.
    发明授权
    Flexible event ingestion framework in an event processing system 有权

    公开(公告)号：US11609804B2

    公开(公告)日：2023-03-21

    申请号：US17099341

    申请日：2020-11-16

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Vitaly Bychkov ,  Prabhu Thukkaram

    IPC: G06F9/54 ,  G06F8/36 ,  G06F16/2458 ,  G06F16/2455 ,  G06F16/25

    Abstract: Systems and methods described herein are directed towards a flexible event ingestion framework. In some examples, an input source comprising information that identifies a plurality of events may be identified. Additionally, in some examples, an adapter for ingesting the information of the input source may be implemented. At least one additional component for modifying the adapter may be received. The adapter may be modified by implementing the at least one additional component with a transport component and a mapper component as part of ingesting the information. Further, a tuple for at least a first event may be generated based at least in part on the modified adapter, and the tuple may be provided to an event server.

    Framework for the deployment of event-based applications
    4.
    发明授权
    Framework for the deployment of event-based applications 有权

    公开(公告)号：US10958714B2

    公开(公告)日：2021-03-23

    申请号：US16559907

    申请日：2019-09-04

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Gyorgy Geiszter ,  Dmitrii Andreevich Strizhikozin ,  Péter Gordos ,  Prabhu Thukkaram ,  Vitaly Bychkov ,  Dmitrii Markovskii

    IPC: H04L29/08 ,  G06F16/2455 ,  G06F16/955 ,  G06F16/901

    Abstract: A distributed event processing system is disclosed that receives continuous data streams, registers a continuous query against the data streams, and continuously executes the query as new data appears in the streams. In certain embodiments, the distributed event processing system deploys and executes applications (e.g., event processing applications) by distributing the execution of the application on a cluster of machines within the system. In certain embodiments, the system receive updates to an application, processes the updated application against a continuous stream of data, and continuously generates updated results to a user. In certain embodiments, the system reduces delays associated with application deployment and execution when updates to an application are received. The system enables a user to view results pertaining to an updated application quickly without experiencing the typical deployment and execution delays that occur when updates to an application are made.

    TARGET USER ESTIMATION FOR DYNAMIC ASSETS
    6.
    发明申请
    TARGET USER ESTIMATION FOR DYNAMIC ASSETS 审中-公开

    公开(公告)号：US20190102791A1

    公开(公告)日：2019-04-04

    申请号：US16022005

    申请日：2018-06-28

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Sandeep Bishnoi ,  Prabhu Thukkaram

    IPC: G06Q30/02 ,  G06F17/30

    Abstract: Techniques for processing event streams are provided that use streaming analytics to estimate a target user for dynamic assets. An exemplary technique includes receiving a batch of events that have position data for a potential target, determining one or more polygons that comprise the potential target based on the position data for the potential target, determining an approximate target viewership for the one or more polygons based on a profile or taxonomy of the potential target, associating an advertisement with the one or more polygons based on the approximate target viewership, receiving a continuous stream of events that have position data for a dynamic asset, determining that the one or more polygons include the dynamic asset based on the position data for the dynamic asset, obtaining the advertisement associated with the one or more polygons, and providing the advertisement to a sink for display on the dynamic asset.

    Event batching, output sequencing, and log based state storage in continuous query processing
    7.
    发明授权
    Event batching, output sequencing, and log based state storage in continuous query processing 有权

    公开(公告)号：US10127120B2

    公开(公告)日：2018-11-13

    申请号：US15161062

    申请日：2016-05-20

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Sandeep Bishnoi ,  Unmesh Anil Deshmukh ,  Prabhu Thukkaram

    IPC: G06F17/30 ,  G06F11/14 ,  G06F9/54

    Abstract: An event processing system is disclosed that processes events of an event stream, performs the recovery of events during system failure and preserves the state of the system reliably and accurately while achieving desired system performance. In an embodiment, the event processing system processes a first batch of events of a continuous input stream of events using a continuous query and generates an output stream of events related to an application. The event processing system identifies one or more operators of the continuous query and determines that an operator is a journaled operator. The event processing system generates a journaled snapshot of a current state of the system based on execution of the journaled operator on at least the first batch of events and stores the journaled snapshot of the current state of the system.

    AUTOMATIC PARALLELIZATION FOR GEOFENCE APPLICATIONS
    8.
    发明申请
    AUTOMATIC PARALLELIZATION FOR GEOFENCE APPLICATIONS 审中-公开

    公开(公告)号：US20180075108A1

    公开(公告)日：2018-03-15

    申请号：US15705402

    申请日：2017-09-15

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Sandeep Bishnoi ,  Prabhu Thukkaram ,  Iuliia Shmeleva

    IPC: G06F17/30 ,  H04W4/02

    Abstract: 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.

    MANAGING SNAPSHOTS AND APPLICATION STATE IN MICRO-BATCH BASED EVENT PROCESSING SYSTEMS
    9.
    发明申请
    MANAGING SNAPSHOTS AND APPLICATION STATE IN MICRO-BATCH BASED EVENT PROCESSING SYSTEMS 审中-公开

    公开(公告)号：US20180075046A1

    公开(公告)日：2018-03-15

    申请号：US15706329

    申请日：2017-09-15

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Sandeep Bishnoi ,  Prabhu Thukkaram ,  Santosh Kumar ,  Pavan Advani ,  Kunal Mulay ,  Jeffrey Toillion

    IPC: G06F17/30

    Abstract: An event processing system for processing events in an event stream is disclosed. The system can execute instructions to receive a micro-batch stream of input events, process the input events using the CQL engine to generate a set of output events, generate, using a snapshot management algorithm implemented by the CQL engine, a snapshot of a current state of a system based at least in part on the set of output events related to the application, generate a first directory structure to access snapshot information associated with the snapshot of the current state of the system, generate a second directory structure to generate a list of snapshots associated with the current state of the system, and determine based at least in part on the snapshot management algorithm, a process to get, add, or clean the list of snapshots associated with the current state of the system.

    PROCESSING TIMESTAMPS AND HEARTBEAT EVENTS FOR AUTOMATIC TIME PROGRESSION
    10.
    发明申请
    PROCESSING TIMESTAMPS AND HEARTBEAT EVENTS FOR AUTOMATIC TIME PROGRESSION 审中-公开

    公开(公告)号：US20180074856A1

    公开(公告)日：2018-03-15

    申请号：US15696501

    申请日：2017-09-06

    Applicant: Oracle International Corporation

    Inventor： Hoyong Park ,  Sandeep Bishnoi ,  Prabhu Thukkaram

    IPC: G06F9/48

    CPC classification number: G06F9/4881 ,  G06F16/24568

    Abstract: An event processing system for processing events in an event stream is disclosed. The system is configured for configuring a stream processor to micro-batch incoming events from a stream source. The system is also configured for generating a single timestamp for a micro-batch of the incoming events and/or receiving the micro-batch of the incoming events from the stream source. The system can also be configured for assigning the single timestamp to each event of the micro-batch and/or generating separate timestamp values for each respective event of the micro-batch. In some examples, the system can also be configured for assigning, for each respective event of the micro-batch, an individual one of the separate timestamp values.

Patent Agency Ranking