Implementation and study of Partitioned Stateful Operator for Data stream processing