如何将流数据与Dataflow / Beam中的大型历史数据集相结合

I am investigating processing logs from web user sessions via Google Dataflow/Apache Beam and need to combine the user's logs as they come in (streaming) with the history of a user's session from the last month.I am investigating processing logs from web use