BigPatents India

This invention relates to a method for fault-tolerant, reliable stream processing, where a data stream is processed by a processing means for yielding a result data stream, where before the data stream is processed, the data stream is decomposed (fission) (Dl, D2) into at least two fission sub-streams (SI.a, Sl.b, S2.a, S2.b), such that each fission sub-stream carries a partial information of said data stream, the data stream is processed by processing the at least two fission sub-streams independently (P.a, P.b) yielding at least two fission result sub-streams (RS1 .a, RSI.b, RS2.a, RS2.b), where each fission result sub-stream carries a partial information of the result data stream, and where the at least two fission result sub-streams are composable (Cl, C2) (fusion) to the result data stream, such that in case of unavailability of a part of the fission sub-streams the missing information could be interpolated. The invention also relates to an apparatus, a system and a computer software product therfor.