Run streaming through pig