[scala] [streaming] Base functionality added for streaming scala api