apache / beam / 456903cc308b3b11204517bdaa2b4e70962245a6 / . / runners / google-cloud-dataflow-java / worker / src / test / java / org / apache / beam / runners / dataflow / worker / fn / stream