Job constructor
Creates a new Job.
name The Pulumi resource name.
args Arguments used to configure this Job. The set of arguments for Job.
options Resource options controlling this resource's behavior.
Implementation
Job(
String name, {
JobArgs? args,
pulumi.CustomResourceOptions? options,
}) : super(
'gcp:dataproc/job:Job',
name,
pulumi.Input.mapToInputs(args?.toMap() ?? const {}),
pulumi.CustomResourceOptions(version: '9.36.1').merge(options),
additionalSecretOutputs: const ['effectiveLabels', 'pulumiLabels'],
) {
deletionPolicy = registerOutput<String>('deletionPolicy');
driverControlsFilesUri = registerOutput<String>('driverControlsFilesUri');
driverOutputResourceUri = registerOutput<String>('driverOutputResourceUri');
effectiveLabels = registerOutput<Map<String, String>>('effectiveLabels', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return (guardedValue as Map).cast<String, String>(); }, isSecret: true);
forceDelete = registerOutput<bool?>('forceDelete');
hadoopConfig = registerOutput<JobHadoopConfig?>('hadoopConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobHadoopConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
hiveConfig = registerOutput<JobHiveConfig?>('hiveConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobHiveConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
labels = registerOutput<Map<String, String>?>('labels', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return (guardedValue as Map).cast<String, String>(); });
pigConfig = registerOutput<JobPigConfig?>('pigConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobPigConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
placement = registerOutput<JobPlacement>('placement', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobPlacement.fromMap((guardedValue as Map).cast<String, dynamic>()); });
prestoConfig = registerOutput<JobPrestoConfig?>('prestoConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobPrestoConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
project = registerOutput<String>('project');
pulumiLabels = registerOutput<Map<String, String>>('pulumiLabels', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return (guardedValue as Map).cast<String, String>(); }, isSecret: true);
pysparkConfig = registerOutput<JobPysparkConfig?>('pysparkConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobPysparkConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
reference = registerOutput<JobReference>('reference', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobReference.fromMap((guardedValue as Map).cast<String, dynamic>()); });
region = registerOutput<String?>('region');
scheduling = registerOutput<JobScheduling?>('scheduling', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobScheduling.fromMap((guardedValue as Map).cast<String, dynamic>()); });
sparkConfig = registerOutput<JobSparkConfig?>('sparkConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobSparkConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
sparksqlConfig = registerOutput<JobSparksqlConfig?>('sparksqlConfig', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return JobSparksqlConfig.fromMap((guardedValue as Map).cast<String, dynamic>()); });
statuses = registerOutput<List<JobStatus>>('statuses', decoder: (raw) { final guardedValue = raw; if (guardedValue == null) return null; return pulumi.Input.decodeList<JobStatus>(guardedValue, (value) => JobStatus.fromMap((value as Map).cast<String, dynamic>())); });
waitForCompletion = registerOutput<bool?>('waitForCompletion');
}