Query, Process and Visualize Data Stream via a Functional Pipeline approach