1. At least one computing device implementing a large-scale real-time multistaged analytic system, each of the at least one computing device comprising: at least processor; and a memory operatively connected with the at least one processor, the memory having instructions for the at least one processor to perform a method comprising: executing a plurality of processing stages of a pipeline for analyzing data, each processing stage of the plurality of processing stages using a respective data contract that specifies a description of inter-stage data to be exchanged across a respective processing stage boundary of the each processing stage, such that the each processing stage is completely agnostic with respect to a data schema and semantics of the inter-stage data consumed by the each processing stage, wherein when a change occurs with respect to data provided to a processing stage of the pipeline, in order to accommodate the change, a data contract that specifies a description of the data to be provided to the processing stage is changed and processing logic of the processing stage of the pipeline remains unchanged.