Scaling out moving objects for geo-fence proximity determination

A system, comprising:

• a memory configured to store computer-executable instructions;
• and
• a processor configured to access the memory and execute the computer-executable instructions to perform a method for distributing a geospatial computation, the method comprising:
• determining a geo grid minimum bounding rectangle (MBR) covering a geographic area indexed by a geo grid;
• partitioning the geo grid minimum bounding rectangle to a respective processing node of a plurality of processing nodes;
• replicating a set of geo fences to the plurality of processing nodes, wherein the geo fences bound regions within the geographic area;
• receiving input events of a stream, a respective input event comprising respective location information for a location within the geographic area;
• distributing the respective input event to a respective partition on the respective processing node based at least in part on the respective location information;
• receiving, from the respective processing node, an output result corresponding to a respective partition result;
• combining the respective partition result with a second partition result to obtain a single result corresponding to a geospatial computation;
• and
• outputting the single result corresponding to the geospatial computation for a user.

A computer-readable medium storing computer-executable code that, when executed by a processor, cause the processor to perform a method for distributing a geospatial computation, the method comprising:

• determining a geo grid minimum bounding rectangle (MBR) covering a geographic area indexed by a geo grid;
• partitioning the geo grid minimum bounding rectangle to a respective processing node of a plurality of processing nodes;
• replicating a set of geo fences to the plurality of processing nodes, wherein the geo fences bound regions within the geographic area;
• receiving input events of a stream, a respective input event comprising respective location information for a location within the geographic area;
• distributing the respective input event to a respective partition on the respective processing node based at least in part on the respective location information;
• receiving, from the respective processing node, an output result corresponding to a respective partition result;
• combining the respective partition result with a second partition result to obtain a single result corresponding to a geospatial computation;
• and
• outputting the single result corresponding to the geospatial computation for a user.