Api-roll 43: 2016-12-13

generated/googleapis_beta/lib/dataflow/v1b3.dart

Index: generated/googleapis_beta/lib/dataflow/v1b3.dart
diff --git a/generated/googleapis_beta/lib/dataflow/v1b3.dart b/generated/googleapis_beta/lib/dataflow/v1b3.dart
index 95895b22d1dcab8d738041a799115e186a48ebfd..3231810ed4adfad550cd690227f846d7c8121ba0 100644
--- a/generated/googleapis_beta/lib/dataflow/v1b3.dart
+++ b/generated/googleapis_beta/lib/dataflow/v1b3.dart
@@ -1943,17 +1943,27 @@ class CounterUpdate {
 
 /** Request to create a Dataflow job. */
 class CreateJobFromTemplateRequest {
+  /** Runtime environment for the job. */
+  RuntimeEnvironment environment;
   /** A path to the serialized JSON representation of the job. */
   core.String gcsPath;
+  /** The job name to use for the created job.. */
+  core.String jobName;
   /** Dynamic parameterization of the job's runtime environment. */
   core.Map<core.String, core.String> parameters;
 
   CreateJobFromTemplateRequest();
 
   CreateJobFromTemplateRequest.fromJson(core.Map _json) {
+    if (_json.containsKey("environment")) {
+      environment = new RuntimeEnvironment.fromJson(_json["environment"]);
+    }
     if (_json.containsKey("gcsPath")) {
       gcsPath = _json["gcsPath"];
     }
+    if (_json.containsKey("jobName")) {
+      jobName = _json["jobName"];
+    }
     if (_json.containsKey("parameters")) {
       parameters = _json["parameters"];
     }
@@ -1961,9 +1971,15 @@ class CreateJobFromTemplateRequest {
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (environment != null) {
+      _json["environment"] = (environment).toJson();
+    }
     if (gcsPath != null) {
       _json["gcsPath"] = gcsPath;
     }
+    if (jobName != null) {
+      _json["jobName"] = jobName;
+    }
     if (parameters != null) {
       _json["parameters"] = parameters;
     }
@@ -4021,6 +4037,8 @@ class PubsubLocation {
    * custom time timestamps for watermark estimation.
    */
   core.String trackingSubscription;
+  /** If true, then the client has requested to get pubsub attributes. */
+  core.bool withAttributes;
 
   PubsubLocation();
 
@@ -4043,6 +4061,9 @@ class PubsubLocation {
     if (_json.containsKey("trackingSubscription")) {
       trackingSubscription = _json["trackingSubscription"];
     }
+    if (_json.containsKey("withAttributes")) {
+      withAttributes = _json["withAttributes"];
+    }
   }
 
   core.Map toJson() {
@@ -4065,6 +4086,9 @@ class PubsubLocation {
     if (trackingSubscription != null) {
       _json["trackingSubscription"] = trackingSubscription;
     }
+    if (withAttributes != null) {
+      _json["withAttributes"] = withAttributes;
+    }
     return _json;
   }
 }
@@ -4210,6 +4234,44 @@ class ReportedParallelism {
   }
 }
 
+/** Environment values to set at runtime. */
+class RuntimeEnvironment {
+  /** The maximum number of workers to start for the job. */
+  core.int maxWorkers;
+  /** The service account to run the job as. */
+  core.String serviceAccountEmail;
+  /** The zone to start the workers in. */
+  core.String zone;
+
+  RuntimeEnvironment();
+
+  RuntimeEnvironment.fromJson(core.Map _json) {
+    if (_json.containsKey("maxWorkers")) {
+      maxWorkers = _json["maxWorkers"];
+    }
+    if (_json.containsKey("serviceAccountEmail")) {
+      serviceAccountEmail = _json["serviceAccountEmail"];
+    }
+    if (_json.containsKey("zone")) {
+      zone = _json["zone"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (maxWorkers != null) {
+      _json["maxWorkers"] = maxWorkers;
+    }
+    if (serviceAccountEmail != null) {
+      _json["serviceAccountEmail"] = serviceAccountEmail;
+    }
+    if (zone != null) {
+      _json["zone"] = zone;
+    }
+    return _json;
+  }
+}
+
 /** Request to send encoded debug information. */
 class SendDebugCaptureRequest {
   /** The internal component id for which debug information is sent. */