stages_execution_details

Creates, updates, deletes, gets or lists a stages_execution_details resource.

Overview

Name	stages_execution_details
Type	Resource
Id	google.dataflow.stages_execution_details

Fields

The following fields are returned by SELECT queries:

projects_locations_jobs_stages_get_execution_details

Name	Datatype	Description
workItems	array	Work items processed by this worker, sorted by time.
workerName	string	Name of this worker

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
projects_locations_jobs_stages_get_execution_details	select	projectId, location, jobId, stageId	endTime, pageSize, pageToken, startTime	Request detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice. # IAM Permissions Requires the dataflow.metrics.get permission on the job.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

Name	Datatype	Description
jobId	string
location	string
projectId	string
stageId	string
endTime	string (google-datetime)
pageSize	integer (int32)
pageToken	string
startTime	string (google-datetime)

SELECT examples

projects_locations_jobs_stages_get_execution_details

Request detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice. # IAM Permissions Requires the dataflow.metrics.get permission on the job.

SELECT
workItems,
workerName
FROM google.dataflow.stages_execution_details
WHERE projectId = '{{ projectId }}' -- required
AND location = '{{ location }}' -- required
AND jobId = '{{ jobId }}' -- required
AND stageId = '{{ stageId }}' -- required
AND endTime = '{{ endTime }}'
AND pageSize = '{{ pageSize }}'
AND pageToken = '{{ pageToken }}'
AND startTime = '{{ startTime }}'
;