1. A distributed data processing system for executing database operations comprising: (a) a first group including two or more host processors configured to accept queries with filtering criteria for data stored on mass storage devices of a database; (b) a second group including two or more Job Processing Units (JPUs), each JPU configured to receive requests from the two or more host processors and including a first processor and a second processor, the second processor including an interface for accessing the mass storage devices of the database; (c) a network infrastructure providing network connection of the first and second groups as network nodes, to support communication of data among network nodes, the network infrastructure using a communication protocol; (d) a communication process responsible for communicating data blocks in one or more messages communicated among network nodes; and (e) an application process for executing database operations, with portions of the application process executing on the JPUs, and portions of the application process executing on at least one of the two or more host processors, the portions executing on the JPUs including the second processor: parsing streaming data in accordance with a format of the database, wherein the streaming data is received from the mass storage devices of the database via the interface; and filtering the parsed data based on the filtering criteria of a corresponding query; wherein the parsing and filtering are performed as the streaming data is being read from the mass storage devices of the database for transference of the filtered data from the second processor to the first processor.