Skip to main content

vw_streaming_jobs

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

Overview

Namevw_streaming_jobs
TypeView
Idazure.stream_analytics.vw_streaming_jobs

Fields

See the SQL Definition (view DDL) for fields returned by this view.

SQL Definition

SELECT
location as location,
tags as tags,
identity as identity,
JSON_EXTRACT(properties, '$.sku') as "sku",
JSON_EXTRACT(properties, '$.jobId') as "job_id",
JSON_EXTRACT(properties, '$.provisioningState') as "provisioning_state",
JSON_EXTRACT(properties, '$.jobState') as "job_state",
JSON_EXTRACT(properties, '$.jobType') as "job_type",
JSON_EXTRACT(properties, '$.outputStartMode') as "output_start_mode",
JSON_EXTRACT(properties, '$.outputStartTime') as "output_start_time",
JSON_EXTRACT(properties, '$.lastOutputEventTime') as "last_output_event_time",
JSON_EXTRACT(properties, '$.eventsOutOfOrderPolicy') as "events_out_of_order_policy",
JSON_EXTRACT(properties, '$.outputErrorPolicy') as "output_error_policy",
JSON_EXTRACT(properties, '$.eventsOutOfOrderMaxDelayInSeconds') as "events_out_of_order_max_delay_in_seconds",
JSON_EXTRACT(properties, '$.eventsLateArrivalMaxDelayInSeconds') as "events_late_arrival_max_delay_in_seconds",
JSON_EXTRACT(properties, '$.dataLocale') as "data_locale",
JSON_EXTRACT(properties, '$.compatibilityLevel') as "compatibility_level",
JSON_EXTRACT(properties, '$.createdDate') as "created_date",
JSON_EXTRACT(properties, '$.inputs') as "inputs",
JSON_EXTRACT(properties, '$.transformation') as "transformation",
JSON_EXTRACT(properties, '$.outputs') as "outputs",
JSON_EXTRACT(properties, '$.functions') as "functions",
JSON_EXTRACT(properties, '$.etag') as "etag",
JSON_EXTRACT(properties, '$.jobStorageAccount') as "job_storage_account",
JSON_EXTRACT(properties, '$.contentStoragePolicy') as "content_storage_policy",
JSON_EXTRACT(properties, '$.cluster') as "cluster",
subscriptionId,
resourceGroupName,
jobName
FROM azure.stream_analytics.streaming_jobs
WHERE subscriptionId = 'replace-me';