Provides implementation for real time processing of data