launch_hadoop_job(in_directory IN VARCHAR2, id IN OUT NUMBER) RETURN BOOLEAN IS PRAGMA AUTONOMOUS_TRANSACTION; instance_id NUMBER; jname varchar2(4000); BEGIN if is_serial then -- Get id by mixing RETURN return_rows_t PIPELINED PARALLEL_ENABLE(PARTITION pcur BY ANY) IS PRAGMA AUTONOMOUS_TRANSACTION; cleanup BOOLEAN; payload hadoop_row_obj; id NUMBER; dopt dbms_aq.dequeue_options_t;