Apache Beam - Unified model for defining both batch and streaming data-parallel processing pipelines