[scala] [streaming] Extended scala data stream functionality to include simple operators