A synchrophasor stream processing pipeline architecture for near-real-time applications