Application integration is not made clear, especially if we want to apply this to both batch and streaming data sources.