A Signal Oriented Stream Processing System for Pipeline Monitoring