distributed data pipeline to process log events