I'm trying to get the current dataflow job's details such as id, name, type, start time, end time etc., once the job is complete on the BlockingDataflowPipelineRunner. Similar to the details we see in the dataflow dashboard,
I have used the below code to get the status,
Pipeline p;
...
...
PipelineResult result = p.run();
switch (result.getState()) {
case CANCELLED:
break;
case DONE:
//MetadataTracker.insert(jobId, jobName, "Success", startTime, endTime);
case FAILED:
break;
case RUNNING:
break;
case STOPPED:
break;
case UNKNOWN:
break;
case UPDATED:
break;
default:
break;
}
However, the PipelineResult class doesn't have any methods to get the above mentioned details. Can anyone please help me?
