Adding distributed stream opener stuff