Patent ID: 9659057
Date: 2017-05-23
CPC Classifications: G06F

Claim:
1. A method for enabling fault tolerant distributed query processing, the method comprising: executing, by a first processing node in a plurality of processing nodes, a first instance of a first query operator, wherein the first query operator is part of a query plan for a database query that is processed in a distributed manner by the plurality of processing nodes, wherein the first query operator is a select operator, a scan operator, a hash join operator, a summation operator, or a sort operator, and wherein each processing node in the plurality of processing nodes corresponds to a distinct physical or virtual machine and is responsible for executing exactly one query operator in the query plan; generating, by the first processing node, a snapshot of the first instance of the first query operator, wherein the snapshot includes state information usable for moving execution of the first query operator from the first processing node to another processing node after a failure of the first processing node, wherein the state information comprises a first portion indicating results that the first instance of the first query operator has generated so far and a second portion indicating input data that the first instance of the first query operator has yet to process, wherein the first and second portions are customized based on a type of the first query operator, and wherein: saving, by the first processing node, the snapshot to a distributed data store.