STORAGE ENGINE FOR HYBRID DATA PROCESSING
    1.
    发明申请

    公开(公告)号:WO2023033721A2

    公开(公告)日:2023-03-09

    申请号:PCT/SG2022/050550

    申请日:2022-08-02

    Applicant: LEMON INC.

    Abstract: The present disclosure describes storage techniques for hybrid transactional and analytical processing. Data captured by a first processing engine may be received. The first processing engine may be configured to perform online transactional processing). Multiple replicas of logical logs generated based on the data may be distributed to a Delta Store by applying a quorum protocol on the multiple replicas. Data in the Delta Store are stored in a row format and are visible to a query for online analytical processing performed by a second processing engine. Data may be flushed from the Delta Store to a Base Store based on one or more predetermined rules. Data in the Base Store are stored in a columnar format and may be accessible by the second processing engine.

    DATABASE-BASED DATA PROCESSING METHOD, DEVICE, MEDIUM AND ELECTRONIC APPARATUS

    公开(公告)号:EP4492233A1

    公开(公告)日:2025-01-15

    申请号:EP24184385.3

    申请日:2024-06-25

    Abstract: The present disclosure relates to a database-based data processing method, device, medium and electronic apparatus, the method comprising: receiving a query request task to be executed, and determining a plurality of coroutine tasks corresponding to the query request task, wherein the coroutine tasks are first added to a global task queue shared by a plurality of threads, and then distributed to a local task queue of a corresponding thread from the global task queue; in each thread, determining a target coroutine task to be executed according to time information of each coroutine task in the local task queue of the thread; interrupting the target coroutine task and adding the target coroutine task to the global task queue when execution of the target coroutine task is not completed and the target coroutine task has been executed in the thread for a current time slice; according to the global task queue, and the local task queue of the thread, determining a new target coroutine task for the thread, and executing the new target coroutine task in a next time slice.

Patent Agency Ranking