implementation of the streaming classification