A system including a plurality of data units, wherein each of the plurality of data units is associated with a data thread, a plurality of storage engines configured to store the plurality of data units, and a data scheduler configured to schedule an action to perform on the plurality of data units using the data thread associated with each of the plurality of data units, wherein the data thread includes a data thread duration and a plurality of tuples, and wherein each of the plurality of tuples includes an attribute and an attribute duration.