Roll of googleapis as of 4/7/2015.

generated/googleapis_beta/lib/dataflow/v1beta3.dart

Index: generated/googleapis_beta/lib/dataflow/v1beta3.dart
diff --git a/generated/googleapis_beta/lib/dataflow/v1beta3.dart b/generated/googleapis_beta/lib/dataflow/v1beta3.dart
index 48fa4582607f7ea883fb30f86a5fa0e015e1f05e..3d6864c910787139797a55a6a292eb024745368c 100644
--- a/generated/googleapis_beta/lib/dataflow/v1beta3.dart
+++ b/generated/googleapis_beta/lib/dataflow/v1beta3.dart
@@ -1,17 +1,20 @@
+// This is a generated file (see the discoveryapis_generator project).
+
 library googleapis_beta.dataflow.v1beta3;
 
-import "dart:core" as core;
-import "dart:collection" as collection;
-import "dart:async" as async;
-import "dart:convert" as convert;
+import 'dart:core' as core;
+import 'dart:collection' as collection;
+import 'dart:async' as async;
+import 'dart:convert' as convert;
 
-import "package:crypto/crypto.dart" as crypto;
+import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
+import 'package:crypto/crypto.dart' as crypto;
 import 'package:http/http.dart' as http;
-import '../src/common_internal.dart' as common_internal;
-import '../common/common.dart' as common;
 
-export '../common/common.dart' show ApiRequestError;
-export '../common/common.dart' show DetailedApiRequestError;
+export 'package:_discoveryapis_commons/_discoveryapis_commons.dart' show
+    ApiRequestError, DetailedApiRequestError;
+
+const core.String USER_AGENT = 'dart-api-client dataflow/v1beta3';
 
 /** Google Dataflow API. */
 class DataflowApi {
@@ -22,45 +25,42 @@ class DataflowApi {
   static const UserinfoEmailScope = "https://www.googleapis.com/auth/userinfo.email";
 
 
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
   V1b3ResourceApi get v1b3 => new V1b3ResourceApi(_requester);
 
   DataflowApi(http.Client client, {core.String rootUrl: "https://www.googleapis.com/", core.String servicePath: "dataflow/v1b3/projects/"}) :
-      _requester = new common_internal.ApiRequester(client, rootUrl, servicePath);
+      _requester = new commons.ApiRequester(client, rootUrl, servicePath, USER_AGENT);
 }
 
 
-/** Not documented yet. */
 class V1b3ResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
   V1b3ProjectsResourceApi get projects => new V1b3ProjectsResourceApi(_requester);
 
-  V1b3ResourceApi(common_internal.ApiRequester client) : 
+  V1b3ResourceApi(commons.ApiRequester client) : 
       _requester = client;
 }
 
 
-/** Not documented yet. */
 class V1b3ProjectsResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
   V1b3ProjectsJobsResourceApi get jobs => new V1b3ProjectsJobsResourceApi(_requester);
 
-  V1b3ProjectsResourceApi(common_internal.ApiRequester client) : 
+  V1b3ProjectsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 }
 
 
-/** Not documented yet. */
 class V1b3ProjectsJobsResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
   V1b3ProjectsJobsMessagesResourceApi get messages => new V1b3ProjectsJobsMessagesResourceApi(_requester);
   V1b3ProjectsJobsWorkItemsResourceApi get workItems => new V1b3ProjectsJobsWorkItemsResourceApi(_requester);
 
-  V1b3ProjectsJobsResourceApi(common_internal.ApiRequester client) : 
+  V1b3ProjectsJobsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
@@ -80,7 +80,7 @@ class V1b3ProjectsJobsResourceApi {
    *
    * Completes with a [Job].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -91,7 +91,7 @@ class V1b3ProjectsJobsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
@@ -105,7 +105,7 @@ class V1b3ProjectsJobsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "POST",
@@ -134,7 +134,7 @@ class V1b3ProjectsJobsResourceApi {
    *
    * Completes with a [Job].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -145,7 +145,7 @@ class V1b3ProjectsJobsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
@@ -159,7 +159,7 @@ class V1b3ProjectsJobsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId');
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "GET",
@@ -184,7 +184,7 @@ class V1b3ProjectsJobsResourceApi {
    *
    * Completes with a [JobMetrics].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -195,7 +195,7 @@ class V1b3ProjectsJobsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
@@ -209,7 +209,7 @@ class V1b3ProjectsJobsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId') + '/metrics';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/metrics';
 
     var _response = _requester.request(_url,
                                        "GET",
@@ -240,7 +240,7 @@ class V1b3ProjectsJobsResourceApi {
    *
    * Completes with a [ListJobsResponse].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -251,7 +251,7 @@ class V1b3ProjectsJobsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
@@ -268,7 +268,7 @@ class V1b3ProjectsJobsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
@@ -294,7 +294,7 @@ class V1b3ProjectsJobsResourceApi {
    *
    * Completes with a [Job].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -305,7 +305,7 @@ class V1b3ProjectsJobsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
@@ -319,7 +319,7 @@ class V1b3ProjectsJobsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId');
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "PATCH",
@@ -344,7 +344,7 @@ class V1b3ProjectsJobsResourceApi {
    *
    * Completes with a [Job].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -355,7 +355,7 @@ class V1b3ProjectsJobsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
@@ -369,7 +369,7 @@ class V1b3ProjectsJobsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId');
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId');
 
     var _response = _requester.request(_url,
                                        "PUT",
@@ -384,11 +384,10 @@ class V1b3ProjectsJobsResourceApi {
 }
 
 
-/** Not documented yet. */
 class V1b3ProjectsJobsMessagesResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
-  V1b3ProjectsJobsMessagesResourceApi(common_internal.ApiRequester client) : 
+  V1b3ProjectsJobsMessagesResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
@@ -418,7 +417,7 @@ class V1b3ProjectsJobsMessagesResourceApi {
    *
    * Completes with a [ListJobMessagesResponse].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -429,7 +428,7 @@ class V1b3ProjectsJobsMessagesResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (projectId == null) {
@@ -455,7 +454,7 @@ class V1b3ProjectsJobsMessagesResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId') + '/messages';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/messages';
 
     var _response = _requester.request(_url,
                                        "GET",
@@ -470,11 +469,10 @@ class V1b3ProjectsJobsMessagesResourceApi {
 }
 
 
-/** Not documented yet. */
 class V1b3ProjectsJobsWorkItemsResourceApi {
-  final common_internal.ApiRequester _requester;
+  final commons.ApiRequester _requester;
 
-  V1b3ProjectsJobsWorkItemsResourceApi(common_internal.ApiRequester client) : 
+  V1b3ProjectsJobsWorkItemsResourceApi(commons.ApiRequester client) : 
       _requester = client;
 
   /**
@@ -490,7 +488,7 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
    *
    * Completes with a [LeaseWorkItemResponse].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -501,7 +499,7 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
@@ -515,7 +513,7 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId') + '/workItems:lease';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:lease';
 
     var _response = _requester.request(_url,
                                        "POST",
@@ -540,7 +538,7 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
    *
    * Completes with a [ReportWorkItemStatusResponse].
    *
-   * Completes with a [common.ApiRequestError] if the API endpoint returned an
+   * Completes with a [commons.ApiRequestError] if the API endpoint returned an
    * error.
    *
    * If the used [http.Client] completes with an error when making a REST call,
@@ -551,7 +549,7 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
     var _queryParams = new core.Map();
     var _uploadMedia = null;
     var _uploadOptions = null;
-    var _downloadOptions = common.DownloadOptions.Metadata;
+    var _downloadOptions = commons.DownloadOptions.Metadata;
     var _body = null;
 
     if (request != null) {
@@ -565,7 +563,7 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs/' + common_internal.Escaper.ecapeVariable('$jobId') + '/workItems:reportStatus';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs/' + commons.Escaper.ecapeVariable('$jobId') + '/workItems:reportStatus';
 
     var _response = _requester.request(_url,
                                        "POST",
@@ -581,15 +579,11 @@ class V1b3ProjectsJobsWorkItemsResourceApi {
 
 
 
-/** Not documented yet. */
 class ApproximateProgress {
-  /** Not documented yet. */
   core.double percentComplete;
 
-  /** Not documented yet. */
   Position position;
 
-  /** Not documented yet. */
   core.String remainingTime;
 
 
@@ -623,10 +617,9 @@ class ApproximateProgress {
 }
 
 
-/** Not documented yet. */
 class AutoscalingSettings {
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "AUTOSCALING_ALGORITHM_BASIC"
    * - "AUTOSCALING_ALGORITHM_NONE"
@@ -634,7 +627,6 @@ class AutoscalingSettings {
    */
   core.String algorithm;
 
-  /** Not documented yet. */
   core.int maxNumWorkers;
 
 
@@ -662,18 +654,13 @@ class AutoscalingSettings {
 }
 
 
-/** Not documented yet. */
 class ComputationTopology {
-  /** Not documented yet. */
   core.String computationId;
 
-  /** Not documented yet. */
   core.List<StreamLocation> inputs;
 
-  /** Not documented yet. */
   core.List<KeyRangeLocation> keyRanges;
 
-  /** Not documented yet. */
   core.List<StreamLocation> outputs;
 
 
@@ -713,12 +700,9 @@ class ComputationTopology {
 }
 
 
-/** Not documented yet. */
 class DataDiskAssignment {
-  /** Not documented yet. */
   core.List<core.String> dataDisks;
 
-  /** Not documented yet. */
   core.String vmInstance;
 
 
@@ -746,15 +730,49 @@ class DataDiskAssignment {
 }
 
 
-/** Not documented yet. */
+class DerivedSource {
+  /**
+   *
+   * Possible string values are:
+   * - "SOURCE_DERIVATION_MODE_CHILD_OF_CURRENT"
+   * - "SOURCE_DERIVATION_MODE_INDEPENDENT"
+   * - "SOURCE_DERIVATION_MODE_SIBLING_OF_CURRENT"
+   * - "SOURCE_DERIVATION_MODE_UNKNOWN"
+   */
+  core.String derivationMode;
+
+  Source source;
+
+
+  DerivedSource();
+
+  DerivedSource.fromJson(core.Map _json) {
+    if (_json.containsKey("derivationMode")) {
+      derivationMode = _json["derivationMode"];
+    }
+    if (_json.containsKey("source")) {
+      source = new Source.fromJson(_json["source"]);
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (derivationMode != null) {
+      _json["derivationMode"] = derivationMode;
+    }
+    if (source != null) {
+      _json["source"] = (source).toJson();
+    }
+    return _json;
+  }
+}
+
+
 class Disk {
-  /** Not documented yet. */
   core.String diskType;
 
-  /** Not documented yet. */
   core.String mountPoint;
 
-  /** Not documented yet. */
   core.int sizeGb;
 
 
@@ -788,30 +806,55 @@ class Disk {
 }
 
 
-/** Not documented yet. */
+class DynamicSourceSplit {
+  DerivedSource primary;
+
+  DerivedSource residual;
+
+
+  DynamicSourceSplit();
+
+  DynamicSourceSplit.fromJson(core.Map _json) {
+    if (_json.containsKey("primary")) {
+      primary = new DerivedSource.fromJson(_json["primary"]);
+    }
+    if (_json.containsKey("residual")) {
+      residual = new DerivedSource.fromJson(_json["residual"]);
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (primary != null) {
+      _json["primary"] = (primary).toJson();
+    }
+    if (residual != null) {
+      _json["residual"] = (residual).toJson();
+    }
+    return _json;
+  }
+}
+
+
 class Environment {
-  /** Not documented yet. */
   core.String clusterManagerApiService;
 
-  /** Not documented yet. */
   core.String dataset;
 
-  /** Not documented yet. */
   core.List<core.String> experiments;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> sdkPipelineOptions;
 
-  /** Not documented yet. */
   core.String tempStoragePrefix;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -819,14 +862,13 @@ class Environment {
   core.Map<core.String, core.Object> userAgent;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> version;
 
-  /** Not documented yet. */
   core.List<WorkerPool> workerPools;
 
 
@@ -890,9 +932,7 @@ class Environment {
 }
 
 
-/** Not documented yet. */
 class FlattenInstruction {
-  /** Not documented yet. */
   core.List<InstructionInput> inputs;
 
 
@@ -914,12 +954,9 @@ class FlattenInstruction {
 }
 
 
-/** Not documented yet. */
 class InstructionInput {
-  /** Not documented yet. */
   core.int outputNum;
 
-  /** Not documented yet. */
   core.int producerInstructionIndex;
 
 
@@ -947,17 +984,15 @@ class InstructionInput {
 }
 
 
-/** Not documented yet. */
 class InstructionOutput {
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> codec;
 
-  /** Not documented yet. */
   core.String name;
 
 
@@ -985,13 +1020,11 @@ class InstructionOutput {
 }
 
 
-/** Not documented yet. */
 class Job {
-  /** Not documented yet. */
   core.String createTime;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_STATE_CANCELLED"
    * - "JOB_STATE_DONE"
@@ -1002,26 +1035,20 @@ class Job {
    */
   core.String currentState;
 
-  /** Not documented yet. */
   core.String currentStateTime;
 
-  /** Not documented yet. */
   Environment environment;
 
-  /** Not documented yet. */
   JobExecutionInfo executionInfo;
 
-  /** Not documented yet. */
   core.String id;
 
-  /** Not documented yet. */
   core.String name;
 
-  /** Not documented yet. */
   core.String projectId;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_STATE_CANCELLED"
    * - "JOB_STATE_DONE"
@@ -1032,11 +1059,10 @@ class Job {
    */
   core.String requestedState;
 
-  /** Not documented yet. */
   core.List<Step> steps;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_TYPE_BATCH"
    * - "JOB_TYPE_STREAMING"
@@ -1123,9 +1149,7 @@ class Job {
 }
 
 
-/** Not documented yet. */
 class JobExecutionInfo {
-  /** Not documented yet. */
   core.Map<core.String, JobExecutionStageInfo> stages;
 
 
@@ -1133,23 +1157,21 @@ class JobExecutionInfo {
 
   JobExecutionInfo.fromJson(core.Map _json) {
     if (_json.containsKey("stages")) {
-      stages = common_internal.mapMap(_json["stages"], (item) => new JobExecutionStageInfo.fromJson(item));
+      stages = commons.mapMap(_json["stages"], (item) => new JobExecutionStageInfo.fromJson(item));
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (stages != null) {
-      _json["stages"] = common_internal.mapMap(stages, (item) => (item).toJson());
+      _json["stages"] = commons.mapMap(stages, (item) => (item).toJson());
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class JobExecutionStageInfo {
-  /** Not documented yet. */
   core.List<core.String> stepName;
 
 
@@ -1171,13 +1193,11 @@ class JobExecutionStageInfo {
 }
 
 
-/** Not documented yet. */
 class JobMessage {
-  /** Not documented yet. */
   core.String id;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_MESSAGE_DEBUG"
    * - "JOB_MESSAGE_DETAILED"
@@ -1187,10 +1207,8 @@ class JobMessage {
    */
   core.String messageImportance;
 
-  /** Not documented yet. */
   core.String messageText;
 
-  /** Not documented yet. */
   core.String time;
 
 
@@ -1230,12 +1248,9 @@ class JobMessage {
 }
 
 
-/** Not documented yet. */
 class JobMetrics {
-  /** Not documented yet. */
   core.String metricTime;
 
-  /** Not documented yet. */
   core.List<MetricUpdate> metrics;
 
 
@@ -1263,21 +1278,53 @@ class JobMetrics {
 }
 
 
-/** Not documented yet. */
+class KeyRangeDataDiskAssignment {
+  core.String dataDisk;
+
+  core.String end;
+
+  core.String start;
+
+
+  KeyRangeDataDiskAssignment();
+
+  KeyRangeDataDiskAssignment.fromJson(core.Map _json) {
+    if (_json.containsKey("dataDisk")) {
+      dataDisk = _json["dataDisk"];
+    }
+    if (_json.containsKey("end")) {
+      end = _json["end"];
+    }
+    if (_json.containsKey("start")) {
+      start = _json["start"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (dataDisk != null) {
+      _json["dataDisk"] = dataDisk;
+    }
+    if (end != null) {
+      _json["end"] = end;
+    }
+    if (start != null) {
+      _json["start"] = start;
+    }
+    return _json;
+  }
+}
+
+
 class KeyRangeLocation {
-  /** Not documented yet. */
   core.String dataDisk;
 
-  /** Not documented yet. */
   core.String deliveryEndpoint;
 
-  /** Not documented yet. */
   core.String end;
 
-  /** Not documented yet. */
   core.String persistentDirectory;
 
-  /** Not documented yet. */
   core.String start;
 
 
@@ -1323,21 +1370,15 @@ class KeyRangeLocation {
 }
 
 
-/** Not documented yet. */
 class LeaseWorkItemRequest {
-  /** Not documented yet. */
   core.String currentWorkerTime;
 
-  /** Not documented yet. */
   core.String requestedLeaseDuration;
 
-  /** Not documented yet. */
   core.List<core.String> workItemTypes;
 
-  /** Not documented yet. */
   core.List<core.String> workerCapabilities;
 
-  /** Not documented yet. */
   core.String workerId;
 
 
@@ -1383,9 +1424,7 @@ class LeaseWorkItemRequest {
 }
 
 
-/** Not documented yet. */
 class LeaseWorkItemResponse {
-  /** Not documented yet. */
   core.List<WorkItem> workItems;
 
 
@@ -1407,12 +1446,9 @@ class LeaseWorkItemResponse {
 }
 
 
-/** Not documented yet. */
 class ListJobMessagesResponse {
-  /** Not documented yet. */
   core.List<JobMessage> jobMessages;
 
-  /** Not documented yet. */
   core.String nextPageToken;
 
 
@@ -1440,12 +1476,9 @@ class ListJobMessagesResponse {
 }
 
 
-/** Not documented yet. */
 class ListJobsResponse {
-  /** Not documented yet. */
   core.List<Job> jobs;
 
-  /** Not documented yet. */
   core.String nextPageToken;
 
 
@@ -1473,15 +1506,11 @@ class ListJobsResponse {
 }
 
 
-/** Not documented yet. */
 class MapTask {
-  /** Not documented yet. */
   core.List<ParallelInstruction> instructions;
 
-  /** Not documented yet. */
   core.String stageName;
 
-  /** Not documented yet. */
   core.String systemName;
 
 
@@ -1515,15 +1544,11 @@ class MapTask {
 }
 
 
-/** Not documented yet. */
 class MetricStructuredName {
-  /** Not documented yet. */
   core.Map<core.String, core.String> context;
 
-  /** Not documented yet. */
   core.String name;
 
-  /** Not documented yet. */
   core.String origin;
 
 
@@ -1557,33 +1582,23 @@ class MetricStructuredName {
 }
 
 
-/** Not documented yet. */
 class MetricUpdate {
-  /** Not documented yet. */
   core.bool cumulative;
 
-  /** Not documented yet. */
   core.Object internal;
 
-  /** Not documented yet. */
   core.String kind;
 
-  /** Not documented yet. */
   core.Object meanCount;
 
-  /** Not documented yet. */
   core.Object meanSum;
 
-  /** Not documented yet. */
   MetricStructuredName name;
 
-  /** Not documented yet. */
   core.Object scalar;
 
-  /** Not documented yet. */
   core.Object set;
 
-  /** Not documented yet. */
   core.String updateTime;
 
 
@@ -1653,9 +1668,29 @@ class MetricUpdate {
 }
 
 
-/** Not documented yet. */
+class MountedDataDisk {
+  core.String dataDisk;
+
+
+  MountedDataDisk();
+
+  MountedDataDisk.fromJson(core.Map _json) {
+    if (_json.containsKey("dataDisk")) {
+      dataDisk = _json["dataDisk"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (dataDisk != null) {
+      _json["dataDisk"] = dataDisk;
+    }
+    return _json;
+  }
+}
+
+
 class MultiOutputInfo {
-  /** Not documented yet. */
   core.String tag;
 
 
@@ -1677,12 +1712,9 @@ class MultiOutputInfo {
 }
 
 
-/** Not documented yet. */
 class Package {
-  /** Not documented yet. */
   core.String location;
 
-  /** Not documented yet. */
   core.String name;
 
 
@@ -1710,22 +1742,17 @@ class Package {
 }
 
 
-/** Not documented yet. */
 class ParDoInstruction {
-  /** Not documented yet. */
   InstructionInput input;
 
-  /** Not documented yet. */
   core.List<MultiOutputInfo> multiOutputInfos;
 
-  /** Not documented yet. */
   core.int numOutputs;
 
-  /** Not documented yet. */
   core.List<SideInputInfo> sideInputs;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -1775,30 +1802,21 @@ class ParDoInstruction {
 }
 
 
-/** Not documented yet. */
 class ParallelInstruction {
-  /** Not documented yet. */
   FlattenInstruction flatten;
 
-  /** Not documented yet. */
   core.String name;
 
-  /** Not documented yet. */
   core.List<InstructionOutput> outputs;
 
-  /** Not documented yet. */
   ParDoInstruction parDo;
 
-  /** Not documented yet. */
   PartialGroupByKeyInstruction partialGroupByKey;
 
-  /** Not documented yet. */
   ReadInstruction read;
 
-  /** Not documented yet. */
   core.String systemName;
 
-  /** Not documented yet. */
   WriteInstruction write;
 
 
@@ -1862,19 +1880,25 @@ class ParallelInstruction {
 }
 
 
-/** Not documented yet. */
 class PartialGroupByKeyInstruction {
-  /** Not documented yet. */
   InstructionInput input;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> inputElementCodec;
 
+  /**
+   *
+   *
+   * The values for Object must be JSON objects. It can consist of `num`,
+   * `String`, `bool` and `null` as well as `Map` and `List` values.
+   */
+  core.Map<core.String, core.Object> valueCombiningFn;
+
 
   PartialGroupByKeyInstruction();
 
@@ -1885,6 +1909,9 @@ class PartialGroupByKeyInstruction {
     if (_json.containsKey("inputElementCodec")) {
       inputElementCodec = _json["inputElementCodec"];
     }
+    if (_json.containsKey("valueCombiningFn")) {
+      valueCombiningFn = _json["valueCombiningFn"];
+    }
   }
 
   core.Map toJson() {
@@ -1895,26 +1922,23 @@ class PartialGroupByKeyInstruction {
     if (inputElementCodec != null) {
       _json["inputElementCodec"] = inputElementCodec;
     }
+    if (valueCombiningFn != null) {
+      _json["valueCombiningFn"] = valueCombiningFn;
+    }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class Position {
-  /** Not documented yet. */
   core.String byteOffset;
 
-  /** Not documented yet. */
   core.bool end;
 
-  /** Not documented yet. */
   core.String key;
 
-  /** Not documented yet. */
   core.String recordIndex;
 
-  /** Not documented yet. */
   core.String shufflePosition;
 
 
@@ -1960,23 +1984,19 @@ class Position {
 }
 
 
-/** Not documented yet. */
 class PubsubLocation {
-  /** Not documented yet. */
   core.bool dropLateData;
 
-  /** Not documented yet. */
   core.String idLabel;
 
-  /** Not documented yet. */
   core.String subscription;
 
-  /** Not documented yet. */
   core.String timestampLabel;
 
-  /** Not documented yet. */
   core.String topic;
 
+  core.String trackingSubscription;
+
 
   PubsubLocation();
 
@@ -1996,6 +2016,9 @@ class PubsubLocation {
     if (_json.containsKey("topic")) {
       topic = _json["topic"];
     }
+    if (_json.containsKey("trackingSubscription")) {
+      trackingSubscription = _json["trackingSubscription"];
+    }
   }
 
   core.Map toJson() {
@@ -2015,14 +2038,15 @@ class PubsubLocation {
     if (topic != null) {
       _json["topic"] = topic;
     }
+    if (trackingSubscription != null) {
+      _json["trackingSubscription"] = trackingSubscription;
+    }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ReadInstruction {
-  /** Not documented yet. */
   Source source;
 
 
@@ -2044,15 +2068,11 @@ class ReadInstruction {
 }
 
 
-/** Not documented yet. */
 class ReportWorkItemStatusRequest {
-  /** Not documented yet. */
   core.String currentWorkerTime;
 
-  /** Not documented yet. */
   core.List<WorkItemStatus> workItemStatuses;
 
-  /** Not documented yet. */
   core.String workerId;
 
 
@@ -2086,9 +2106,7 @@ class ReportWorkItemStatusRequest {
 }
 
 
-/** Not documented yet. */
 class ReportWorkItemStatusResponse {
-  /** Not documented yet. */
   core.List<WorkItemServiceState> workItemServiceStates;
 
 
@@ -2110,25 +2128,19 @@ class ReportWorkItemStatusResponse {
 }
 
 
-/** Not documented yet. */
 class SeqMapTask {
-  /** Not documented yet. */
   core.List<SideInputInfo> inputs;
 
-  /** Not documented yet. */
   core.String name;
 
-  /** Not documented yet. */
   core.List<SeqMapTaskOutputInfo> outputInfos;
 
-  /** Not documented yet. */
   core.String stageName;
 
-  /** Not documented yet. */
   core.String systemName;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -2184,12 +2196,9 @@ class SeqMapTask {
 }
 
 
-/** Not documented yet. */
 class SeqMapTaskOutputInfo {
-  /** Not documented yet. */
   Sink sink;
 
-  /** Not documented yet. */
   core.String tag;
 
 
@@ -2217,12 +2226,9 @@ class SeqMapTaskOutputInfo {
 }
 
 
-/** Not documented yet. */
 class ShellTask {
-  /** Not documented yet. */
   core.String command;
 
-  /** Not documented yet. */
   core.int exitCode;
 
 
@@ -2250,20 +2256,17 @@ class ShellTask {
 }
 
 
-/** Not documented yet. */
 class SideInputInfo {
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> kind;
 
-  /** Not documented yet. */
   core.List<Source> sources;
 
-  /** Not documented yet. */
   core.String tag;
 
 
@@ -2297,10 +2300,9 @@ class SideInputInfo {
 }
 
 
-/** Not documented yet. */
 class Sink {
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -2308,7 +2310,7 @@ class Sink {
   core.Map<core.String, core.Object> codec;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -2340,10 +2342,9 @@ class Sink {
 }
 
 
-/** Not documented yet. */
 class Source {
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -2351,21 +2352,19 @@ class Source {
   core.List<core.Map<core.String, core.Object>> baseSpecs;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> codec;
 
-  /** Not documented yet. */
   core.bool doesNotNeedSplitting;
 
-  /** Not documented yet. */
   SourceMetadata metadata;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -2415,14 +2414,15 @@ class Source {
 }
 
 
-/** Not documented yet. */
 class SourceFork {
-  /** Not documented yet. */
   SourceSplitShard primary;
 
-  /** Not documented yet. */
+  DerivedSource primarySource;
+
   SourceSplitShard residual;
 
+  DerivedSource residualSource;
+
 
   SourceFork();
 
@@ -2430,9 +2430,15 @@ class SourceFork {
     if (_json.containsKey("primary")) {
       primary = new SourceSplitShard.fromJson(_json["primary"]);
     }
+    if (_json.containsKey("primarySource")) {
+      primarySource = new DerivedSource.fromJson(_json["primarySource"]);
+    }
     if (_json.containsKey("residual")) {
       residual = new SourceSplitShard.fromJson(_json["residual"]);
     }
+    if (_json.containsKey("residualSource")) {
+      residualSource = new DerivedSource.fromJson(_json["residualSource"]);
+    }
   }
 
   core.Map toJson() {
@@ -2440,17 +2446,21 @@ class SourceFork {
     if (primary != null) {
       _json["primary"] = (primary).toJson();
     }
+    if (primarySource != null) {
+      _json["primarySource"] = (primarySource).toJson();
+    }
     if (residual != null) {
       _json["residual"] = (residual).toJson();
     }
+    if (residualSource != null) {
+      _json["residualSource"] = (residualSource).toJson();
+    }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceGetMetadataRequest {
-  /** Not documented yet. */
   Source source;
 
 
@@ -2472,9 +2482,7 @@ class SourceGetMetadataRequest {
 }
 
 
-/** Not documented yet. */
 class SourceGetMetadataResponse {
-  /** Not documented yet. */
   SourceMetadata metadata;
 
 
@@ -2496,15 +2504,11 @@ class SourceGetMetadataResponse {
 }
 
 
-/** Not documented yet. */
 class SourceMetadata {
-  /** Not documented yet. */
   core.String estimatedSizeBytes;
 
-  /** Not documented yet. */
   core.bool infinite;
 
-  /** Not documented yet. */
   core.bool producesSortedKeys;
 
 
@@ -2538,12 +2542,9 @@ class SourceMetadata {
 }
 
 
-/** Not documented yet. */
 class SourceOperationRequest {
-  /** Not documented yet. */
   SourceGetMetadataRequest getMetadata;
 
-  /** Not documented yet. */
   SourceSplitRequest split;
 
 
@@ -2571,12 +2572,9 @@ class SourceOperationRequest {
 }
 
 
-/** Not documented yet. */
 class SourceOperationResponse {
-  /** Not documented yet. */
   SourceGetMetadataResponse getMetadata;
 
-  /** Not documented yet. */
   SourceSplitResponse split;
 
 
@@ -2604,15 +2602,18 @@ class SourceOperationResponse {
 }
 
 
-/** Not documented yet. */
 class SourceSplitOptions {
-  /** Not documented yet. */
+  core.String desiredBundleSizeBytes;
+
   core.String desiredShardSizeBytes;
 
 
   SourceSplitOptions();
 
   SourceSplitOptions.fromJson(core.Map _json) {
+    if (_json.containsKey("desiredBundleSizeBytes")) {
+      desiredBundleSizeBytes = _json["desiredBundleSizeBytes"];
+    }
     if (_json.containsKey("desiredShardSizeBytes")) {
       desiredShardSizeBytes = _json["desiredShardSizeBytes"];
     }
@@ -2620,6 +2621,9 @@ class SourceSplitOptions {
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (desiredBundleSizeBytes != null) {
+      _json["desiredBundleSizeBytes"] = desiredBundleSizeBytes;
+    }
     if (desiredShardSizeBytes != null) {
       _json["desiredShardSizeBytes"] = desiredShardSizeBytes;
     }
@@ -2628,12 +2632,9 @@ class SourceSplitOptions {
 }
 
 
-/** Not documented yet. */
 class SourceSplitRequest {
-  /** Not documented yet. */
   SourceSplitOptions options;
 
-  /** Not documented yet. */
   Source source;
 
 
@@ -2661,10 +2662,11 @@ class SourceSplitRequest {
 }
 
 
-/** Not documented yet. */
 class SourceSplitResponse {
+  core.List<DerivedSource> bundles;
+
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "SOURCE_SPLIT_OUTCOME_SPLITTING_HAPPENED"
    * - "SOURCE_SPLIT_OUTCOME_UNKNOWN"
@@ -2672,13 +2674,15 @@ class SourceSplitResponse {
    */
   core.String outcome;
 
-  /** Not documented yet. */
   core.List<SourceSplitShard> shards;
 
 
   SourceSplitResponse();
 
   SourceSplitResponse.fromJson(core.Map _json) {
+    if (_json.containsKey("bundles")) {
+      bundles = _json["bundles"].map((value) => new DerivedSource.fromJson(value)).toList();
+    }
     if (_json.containsKey("outcome")) {
       outcome = _json["outcome"];
     }
@@ -2689,6 +2693,9 @@ class SourceSplitResponse {
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (bundles != null) {
+      _json["bundles"] = bundles.map((value) => (value).toJson()).toList();
+    }
     if (outcome != null) {
       _json["outcome"] = outcome;
     }
@@ -2700,10 +2707,9 @@ class SourceSplitResponse {
 }
 
 
-/** Not documented yet. */
 class SourceSplitShard {
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "SOURCE_DERIVATION_MODE_CHILD_OF_CURRENT"
    * - "SOURCE_DERIVATION_MODE_INDEPENDENT"
@@ -2712,7 +2718,6 @@ class SourceSplitShard {
    */
   core.String derivationMode;
 
-  /** Not documented yet. */
   Source source;
 
 
@@ -2740,20 +2745,17 @@ class SourceSplitShard {
 }
 
 
-/** Not documented yet. */
 class Status {
-  /** Not documented yet. */
   core.int code;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.List<core.Map<core.String, core.Object>> details;
 
-  /** Not documented yet. */
   core.String message;
 
 
@@ -2787,16 +2789,13 @@ class Status {
 }
 
 
-/** Not documented yet. */
 class Step {
-  /** Not documented yet. */
   core.String kind;
 
-  /** Not documented yet. */
   core.String name;
 
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
@@ -2834,12 +2833,11 @@ class Step {
 }
 
 
-/** Not documented yet. */
 class StreamLocation {
-  /** Not documented yet. */
   PubsubLocation pubsubLocation;
 
-  /** Not documented yet. */
+  StreamingSideInputLocation sideInputLocation;
+
   StreamingStageLocation streamingStageLocation;
 
 
@@ -2849,6 +2847,9 @@ class StreamLocation {
     if (_json.containsKey("pubsubLocation")) {
       pubsubLocation = new PubsubLocation.fromJson(_json["pubsubLocation"]);
     }
+    if (_json.containsKey("sideInputLocation")) {
+      sideInputLocation = new StreamingSideInputLocation.fromJson(_json["sideInputLocation"]);
+    }
     if (_json.containsKey("streamingStageLocation")) {
       streamingStageLocation = new StreamingStageLocation.fromJson(_json["streamingStageLocation"]);
     }
@@ -2859,6 +2860,9 @@ class StreamLocation {
     if (pubsubLocation != null) {
       _json["pubsubLocation"] = (pubsubLocation).toJson();
     }
+    if (sideInputLocation != null) {
+      _json["sideInputLocation"] = (sideInputLocation).toJson();
+    }
     if (streamingStageLocation != null) {
       _json["streamingStageLocation"] = (streamingStageLocation).toJson();
     }
@@ -2867,15 +2871,86 @@ class StreamLocation {
 }
 
 
-/** Not documented yet. */
+class StreamingComputationRanges {
+  core.String computationId;
+
+  core.List<KeyRangeDataDiskAssignment> rangeAssignments;
+
+
+  StreamingComputationRanges();
+
+  StreamingComputationRanges.fromJson(core.Map _json) {
+    if (_json.containsKey("computationId")) {
+      computationId = _json["computationId"];
+    }
+    if (_json.containsKey("rangeAssignments")) {
+      rangeAssignments = _json["rangeAssignments"].map((value) => new KeyRangeDataDiskAssignment.fromJson(value)).toList();
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (computationId != null) {
+      _json["computationId"] = computationId;
+    }
+    if (rangeAssignments != null) {
+      _json["rangeAssignments"] = rangeAssignments.map((value) => (value).toJson()).toList();
+    }
+    return _json;
+  }
+}
+
+
+class StreamingComputationTask {
+  core.List<StreamingComputationRanges> computationRanges;
+
+  core.List<MountedDataDisk> dataDisks;
+
+  /**
+   *
+   * Possible string values are:
+   * - "STREAMING_COMPUTATION_TASK_START"
+   * - "STREAMING_COMPUTATION_TASK_STOP"
+   * - "STREAMING_COMPUTATION_TASK_UNKNOWN"
+   */
+  core.String taskType;
+
+
+  StreamingComputationTask();
+
+  StreamingComputationTask.fromJson(core.Map _json) {
+    if (_json.containsKey("computationRanges")) {
+      computationRanges = _json["computationRanges"].map((value) => new StreamingComputationRanges.fromJson(value)).toList();
+    }
+    if (_json.containsKey("dataDisks")) {
+      dataDisks = _json["dataDisks"].map((value) => new MountedDataDisk.fromJson(value)).toList();
+    }
+    if (_json.containsKey("taskType")) {
+      taskType = _json["taskType"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (computationRanges != null) {
+      _json["computationRanges"] = computationRanges.map((value) => (value).toJson()).toList();
+    }
+    if (dataDisks != null) {
+      _json["dataDisks"] = dataDisks.map((value) => (value).toJson()).toList();
+    }
+    if (taskType != null) {
+      _json["taskType"] = taskType;
+    }
+    return _json;
+  }
+}
+
+
 class StreamingSetupTask {
-  /** Not documented yet. */
   core.int receiveWorkPort;
 
-  /** Not documented yet. */
   TopologyConfig streamingComputationTopology;
 
-  /** Not documented yet. */
   core.int workerHarnessPort;
 
 
@@ -2909,9 +2984,29 @@ class StreamingSetupTask {
 }
 
 
-/** Not documented yet. */
+class StreamingSideInputLocation {
+  core.String tag;
+
+
+  StreamingSideInputLocation();
+
+  StreamingSideInputLocation.fromJson(core.Map _json) {
+    if (_json.containsKey("tag")) {
+      tag = _json["tag"];
+    }
+  }
+
+  core.Map toJson() {
+    var _json = new core.Map();
+    if (tag != null) {
+      _json["tag"] = tag;
+    }
+    return _json;
+  }
+}
+
+
 class StreamingStageLocation {
-  /** Not documented yet. */
   core.String streamId;
 
 
@@ -2933,63 +3028,43 @@ class StreamingStageLocation {
 }
 
 
-/** Not documented yet. */
 class TaskRunnerSettings {
-  /** Not documented yet. */
   core.bool alsologtostderr;
 
-  /** Not documented yet. */
   core.String baseTaskDir;
 
-  /** Not documented yet. */
   core.String baseUrl;
 
-  /** Not documented yet. */
   core.String commandlinesFileName;
 
-  /** Not documented yet. */
   core.bool continueOnException;
 
-  /** Not documented yet. */
   core.String dataflowApiVersion;
 
-  /** Not documented yet. */
   core.String harnessCommand;
 
-  /** Not documented yet. */
   core.String languageHint;
 
-  /** Not documented yet. */
   core.String logDir;
 
-  /** Not documented yet. */
   core.bool logToSerialconsole;
 
-  /** Not documented yet. */
   core.String logUploadLocation;
 
-  /** Not documented yet. */
   core.List<core.String> oauthScopes;
 
-  /** Not documented yet. */
   WorkerSettings parallelWorkerSettings;
 
-  /** Not documented yet. */
   core.String streamingWorkerMainClass;
 
-  /** Not documented yet. */
   core.String taskGroup;
 
-  /** Not documented yet. */
   core.String taskUser;
 
-  /** Not documented yet. */
   core.String tempStoragePrefix;
 
-  /** Not documented yet. */
   core.String vmId;
 
-  /** Not documented yet. */
   core.String workflowFileName;
 
 
@@ -3119,12 +3194,9 @@ class TaskRunnerSettings {
 }
 
 
-/** Not documented yet. */
 class TopologyConfig {
-  /** Not documented yet. */
   core.List<ComputationTopology> computations;
 
-  /** Not documented yet. */
   core.List<DataDiskAssignment> dataDiskAssignments;
 
 
@@ -3152,42 +3224,33 @@ class TopologyConfig {
 }
 
 
-/** Not documented yet. */
 class WorkItem {
-  /** Not documented yet. */
   core.String configuration;
 
-  /** Not documented yet. */
   core.String id;
 
-  /** Not documented yet. */
+  core.String initialReportIndex;
+
   core.String jobId;
 
-  /** Not documented yet. */
   core.String leaseExpireTime;
 
-  /** Not documented yet. */
   MapTask mapTask;
 
-  /** Not documented yet. */
   core.List<Package> packages;
 
-  /** Not documented yet. */
   core.String projectId;
 
-  /** Not documented yet. */
   core.String reportStatusInterval;
 
-  /** Not documented yet. */
   SeqMapTask seqMapTask;
 
-  /** Not documented yet. */
   ShellTask shellTask;
 
-  /** Not documented yet. */
   SourceOperationRequest sourceOperationTask;
 
-  /** Not documented yet. */
+  StreamingComputationTask streamingComputationTask;
+
   StreamingSetupTask streamingSetupTask;
 
 
@@ -3200,6 +3263,9 @@ class WorkItem {
     if (_json.containsKey("id")) {
       id = _json["id"];
     }
+    if (_json.containsKey("initialReportIndex")) {
+      initialReportIndex = _json["initialReportIndex"];
+    }
     if (_json.containsKey("jobId")) {
       jobId = _json["jobId"];
     }
@@ -3227,6 +3293,9 @@ class WorkItem {
     if (_json.containsKey("sourceOperationTask")) {
       sourceOperationTask = new SourceOperationRequest.fromJson(_json["sourceOperationTask"]);
     }
+    if (_json.containsKey("streamingComputationTask")) {
+      streamingComputationTask = new StreamingComputationTask.fromJson(_json["streamingComputationTask"]);
+    }
     if (_json.containsKey("streamingSetupTask")) {
       streamingSetupTask = new StreamingSetupTask.fromJson(_json["streamingSetupTask"]);
     }
@@ -3240,6 +3309,9 @@ class WorkItem {
     if (id != null) {
       _json["id"] = id;
     }
+    if (initialReportIndex != null) {
+      _json["initialReportIndex"] = initialReportIndex;
+    }
     if (jobId != null) {
       _json["jobId"] = jobId;
     }
@@ -3267,6 +3339,9 @@ class WorkItem {
     if (sourceOperationTask != null) {
       _json["sourceOperationTask"] = (sourceOperationTask).toJson();
     }
+    if (streamingComputationTask != null) {
+      _json["streamingComputationTask"] = (streamingComputationTask).toJson();
+    }
     if (streamingSetupTask != null) {
       _json["streamingSetupTask"] = (streamingSetupTask).toJson();
     }
@@ -3275,26 +3350,23 @@ class WorkItem {
 }
 
 
-/** Not documented yet. */
 class WorkItemServiceState {
   /**
-   * Not documented yet.
+   *
    *
    * The values for Object must be JSON objects. It can consist of `num`,
    * `String`, `bool` and `null` as well as `Map` and `List` values.
    */
   core.Map<core.String, core.Object> harnessData;
 
-  /** Not documented yet. */
   core.String leaseExpireTime;
 
-  /** Not documented yet. */
+  core.String nextReportIndex;
+
   core.String reportStatusInterval;
 
-  /** Not documented yet. */
   ApproximateProgress suggestedStopPoint;
 
-  /** Not documented yet. */
   Position suggestedStopPosition;
 
 
@@ -3307,6 +3379,9 @@ class WorkItemServiceState {
     if (_json.containsKey("leaseExpireTime")) {
       leaseExpireTime = _json["leaseExpireTime"];
     }
+    if (_json.containsKey("nextReportIndex")) {
+      nextReportIndex = _json["nextReportIndex"];
+    }
     if (_json.containsKey("reportStatusInterval")) {
       reportStatusInterval = _json["reportStatusInterval"];
     }
@@ -3326,6 +3401,9 @@ class WorkItemServiceState {
     if (leaseExpireTime != null) {
       _json["leaseExpireTime"] = leaseExpireTime;
     }
+    if (nextReportIndex != null) {
+      _json["nextReportIndex"] = nextReportIndex;
+    }
     if (reportStatusInterval != null) {
       _json["reportStatusInterval"] = reportStatusInterval;
     }
@@ -3340,36 +3418,27 @@ class WorkItemServiceState {
 }
 
 
-/** Not documented yet. */
 class WorkItemStatus {
-  /** Not documented yet. */
   core.bool completed;
 
-  /** Not documented yet. */
+  DynamicSourceSplit dynamicSourceSplit;
+
   core.List<Status> errors;
 
-  /** Not documented yet. */
   core.List<MetricUpdate> metricUpdates;
 
-  /** Not documented yet. */
   ApproximateProgress progress;
 
-  /** Not documented yet. */
   core.String reportIndex;
 
-  /** Not documented yet. */
   core.String requestedLeaseDuration;
 
-  /** Not documented yet. */
   SourceFork sourceFork;
 
-  /** Not documented yet. */
   SourceOperationResponse sourceOperationResponse;
 
-  /** Not documented yet. */
   Position stopPosition;
 
-  /** Not documented yet. */
   core.String workItemId;
 
 
@@ -3379,6 +3448,9 @@ class WorkItemStatus {
     if (_json.containsKey("completed")) {
       completed = _json["completed"];
     }
+    if (_json.containsKey("dynamicSourceSplit")) {
+      dynamicSourceSplit = new DynamicSourceSplit.fromJson(_json["dynamicSourceSplit"]);
+    }
     if (_json.containsKey("errors")) {
       errors = _json["errors"].map((value) => new Status.fromJson(value)).toList();
     }
@@ -3413,6 +3485,9 @@ class WorkItemStatus {
     if (completed != null) {
       _json["completed"] = completed;
     }
+    if (dynamicSourceSplit != null) {
+      _json["dynamicSourceSplit"] = (dynamicSourceSplit).toJson();
+    }
     if (errors != null) {
       _json["errors"] = errors.map((value) => (value).toJson()).toList();
     }
@@ -3445,16 +3520,13 @@ class WorkItemStatus {
 }
 
 
-/** Not documented yet. */
 class WorkerPool {
-  /** Not documented yet. */
   AutoscalingSettings autoscalingSettings;
 
-  /** Not documented yet. */
   core.List<Disk> dataDisks;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "DEFAULT_PACKAGE_SET_JAVA"
    * - "DEFAULT_PACKAGE_SET_NONE"
@@ -3463,35 +3535,34 @@ class WorkerPool {
    */
   core.String defaultPackageSet;
 
-  /** Not documented yet. */
   core.int diskSizeGb;
 
-  /** Not documented yet. */
   core.String diskSourceImage;
 
-  /** Not documented yet. */
   core.String kind;
 
-  /** Not documented yet. */
   core.String machineType;
 
-  /** Not documented yet. */
   core.Map<core.String, core.String> metadata;
 
-  /** Not documented yet. */
   core.int numWorkers;
 
-  /** Not documented yet. */
   core.String onHostMaintenance;
 
-  /** Not documented yet. */
   core.List<Package> packages;
 
-  /** Not documented yet. */
+  /**
+   *
+   *
+   * The values for Object must be JSON objects. It can consist of `num`,
+   * `String`, `bool` and `null` as well as `Map` and `List` values.
+   */
+  core.Map<core.String, core.Object> poolArgs;
+
   TaskRunnerSettings taskrunnerSettings;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "TEARDOWN_ALWAYS"
    * - "TEARDOWN_NEVER"
@@ -3500,7 +3571,6 @@ class WorkerPool {
    */
   core.String teardownPolicy;
 
-  /** Not documented yet. */
   core.String zone;
 
 
@@ -3540,6 +3610,9 @@ class WorkerPool {
     if (_json.containsKey("packages")) {
       packages = _json["packages"].map((value) => new Package.fromJson(value)).toList();
     }
+    if (_json.containsKey("poolArgs")) {
+      poolArgs = _json["poolArgs"];
+    }
     if (_json.containsKey("taskrunnerSettings")) {
       taskrunnerSettings = new TaskRunnerSettings.fromJson(_json["taskrunnerSettings"]);
     }
@@ -3586,6 +3659,9 @@ class WorkerPool {
     if (packages != null) {
       _json["packages"] = packages.map((value) => (value).toJson()).toList();
     }
+    if (poolArgs != null) {
+      _json["poolArgs"] = poolArgs;
+    }
     if (taskrunnerSettings != null) {
       _json["taskrunnerSettings"] = (taskrunnerSettings).toJson();
     }
@@ -3600,24 +3676,17 @@ class WorkerPool {
 }
 
 
-/** Not documented yet. */
 class WorkerSettings {
-  /** Not documented yet. */
   core.String baseUrl;
 
-  /** Not documented yet. */
   core.bool reportingEnabled;
 
-  /** Not documented yet. */
   core.String servicePath;
 
-  /** Not documented yet. */
   core.String shuffleServicePath;
 
-  /** Not documented yet. */
   core.String tempStoragePrefix;
 
-  /** Not documented yet. */
   core.String workerId;
 
 
@@ -3669,12 +3738,9 @@ class WorkerSettings {
 }
 
 
-/** Not documented yet. */
 class WriteInstruction {
-  /** Not documented yet. */
   InstructionInput input;
 
-  /** Not documented yet. */
   Sink sink;
 
 
@@ -3700,5 +3766,3 @@ class WriteInstruction {
     return _json;
   }
 }
-
-