Roll of googleapis as of 4/7/2015.

generated/googleapis_beta/lib/dataflow/v1beta3.dart

+// 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 {
   /** View and manage your data across Google Cloud Platform services */
   static const CloudPlatformScope = "https://www.googleapis.com/auth/cloud-platform";
 
   /** View your email address */
   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;
 
   /**
    * Creates a dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [view] - null
    * Possible string values are:
    * - "JOB_VIEW_ALL"
    * - "JOB_VIEW_SUMMARY"
    * - "JOB_VIEW_UNKNOWN"
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Job> create(Job request, core.String projectId, {core.String view}) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "POST",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
    * Gets the state of the specified dataflow job.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * [view] - null
    * Possible string values are:
    * - "JOB_VIEW_ALL"
    * - "JOB_VIEW_SUMMARY"
    * - "JOB_VIEW_UNKNOWN"
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Job> get(core.String projectId, core.String jobId, {core.String view}) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * [startTime] - null
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<JobMetrics> getMetrics(core.String projectId, core.String jobId, {core.String startTime}) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new JobMetrics.fromJson(data));
   }
@@ skipping 10 matching lines @@
    * [pageToken] - null
    *
    * [view] - null
    * Possible string values are:
    * - "JOB_VIEW_ALL"
    * - "JOB_VIEW_SUMMARY"
    * - "JOB_VIEW_UNKNOWN"
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<ListJobsResponse> list(core.String projectId, {core.int pageSize, core.String pageToken, core.String view}) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (view != null) {
       _queryParams["view"] = [view];
     }
 
 
-    _url = common_internal.Escaper.ecapeVariable('$projectId') + '/jobs';
+    _url = commons.Escaper.ecapeVariable('$projectId') + '/jobs';
 
     var _response = _requester.request(_url,
                                        "GET",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobsResponse.fromJson(data));
   }
 
   /**
    * Updates the state of an existing dataflow job. This method supports patch
    * semantics.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Job> patch(Job request, core.String projectId, core.String jobId) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
   /**
    * Updates the state of an existing dataflow job.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<Job> update(Job request, core.String projectId, core.String jobId) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new Job.fromJson(data));
   }
 
 }
 
 
-/** 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;
 
   /**
    * Request the job status.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * [endTime] - null
    *
    * [minimumImportance] - null
    * Possible string values are:
    * - "JOB_MESSAGE_DEBUG"
    * - "JOB_MESSAGE_DETAILED"
    * - "JOB_MESSAGE_ERROR"
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN"
    * - "JOB_MESSAGE_WARNING"
    *
    * [pageSize] - null
    *
    * [pageToken] - null
    *
    * [startTime] - null
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<ListJobMessagesResponse> list(core.String projectId, core.String jobId, {core.String endTime, core.String minimumImportance, core.int pageSize, core.String pageToken, core.String startTime}) {
     var _url = null;
     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) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
     if (endTime != null) {
       _queryParams["endTime"] = [endTime];
     }
     if (minimumImportance != null) {
       _queryParams["minimumImportance"] = [minimumImportance];
     }
     if (pageSize != null) {
       _queryParams["pageSize"] = ["${pageSize}"];
     }
     if (pageToken != null) {
       _queryParams["pageToken"] = [pageToken];
     }
     if (startTime != null) {
       _queryParams["startTime"] = [startTime];
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ListJobMessagesResponse.fromJson(data));
   }
 
 }
 
 
-/** 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;
 
   /**
    * Leases a dataflow WorkItem to run.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<LeaseWorkItemResponse> lease(LeaseWorkItemRequest request, core.String projectId, core.String jobId) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new LeaseWorkItemResponse.fromJson(data));
   }
 
   /**
    * Reports the status of dataflow WorkItems leased by a worker.
    *
    * [request] - The metadata request object.
    *
    * Request parameters:
    *
    * [projectId] - null
    *
    * [jobId] - null
    *
    * 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,
    * this method  will complete with the same error.
    */
   async.Future<ReportWorkItemStatusResponse> reportStatus(ReportWorkItemStatusRequest request, core.String projectId, core.String jobId) {
     var _url = null;
     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) {
       _body = convert.JSON.encode((request).toJson());
     }
     if (projectId == null) {
       throw new core.ArgumentError("Parameter projectId is required.");
     }
     if (jobId == null) {
       throw new core.ArgumentError("Parameter jobId is required.");
     }
 
 
-    _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",
                                        body: _body,
                                        queryParams: _queryParams,
                                        uploadOptions: _uploadOptions,
                                        uploadMedia: _uploadMedia,
                                        downloadOptions: _downloadOptions);
     return _response.then((data) => new ReportWorkItemStatusResponse.fromJson(data));
   }
 
 }
 
 
 
-/** Not documented yet. */
 class ApproximateProgress {
-  /** Not documented yet. */
   core.double percentComplete;
 
-  /** Not documented yet. */
   Position position;
 
-  /** Not documented yet. */
   core.String remainingTime;
 
 
   ApproximateProgress();
 
   ApproximateProgress.fromJson(core.Map _json) {
     if (_json.containsKey("percentComplete")) {
       percentComplete = _json["percentComplete"];
     }
     if (_json.containsKey("position")) {
@@ skipping 13 matching lines @@
       _json["position"] = (position).toJson();
     }
     if (remainingTime != null) {
       _json["remainingTime"] = remainingTime;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class AutoscalingSettings {
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "AUTOSCALING_ALGORITHM_BASIC"
    * - "AUTOSCALING_ALGORITHM_NONE"
    * - "AUTOSCALING_ALGORITHM_UNKNOWN"
    */
   core.String algorithm;
 
-  /** Not documented yet. */
   core.int maxNumWorkers;
 
 
   AutoscalingSettings();
 
   AutoscalingSettings.fromJson(core.Map _json) {
     if (_json.containsKey("algorithm")) {
       algorithm = _json["algorithm"];
     }
     if (_json.containsKey("maxNumWorkers")) {
       maxNumWorkers = _json["maxNumWorkers"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (algorithm != null) {
       _json["algorithm"] = algorithm;
     }
     if (maxNumWorkers != null) {
       _json["maxNumWorkers"] = maxNumWorkers;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   ComputationTopology();
 
   ComputationTopology.fromJson(core.Map _json) {
     if (_json.containsKey("computationId")) {
       computationId = _json["computationId"];
     }
     if (_json.containsKey("inputs")) {
@@ skipping 19 matching lines @@
       _json["keyRanges"] = keyRanges.map((value) => (value).toJson()).toList();
     }
     if (outputs != null) {
       _json["outputs"] = outputs.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class DataDiskAssignment {
-  /** Not documented yet. */
   core.List<core.String> dataDisks;
 
-  /** Not documented yet. */
   core.String vmInstance;
 
 
   DataDiskAssignment();
 
   DataDiskAssignment.fromJson(core.Map _json) {
     if (_json.containsKey("dataDisks")) {
       dataDisks = _json["dataDisks"];
     }
     if (_json.containsKey("vmInstance")) {
       vmInstance = _json["vmInstance"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (dataDisks != null) {
       _json["dataDisks"] = dataDisks;
     }
     if (vmInstance != null) {
       _json["vmInstance"] = vmInstance;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   Disk();
 
   Disk.fromJson(core.Map _json) {
     if (_json.containsKey("diskType")) {
       diskType = _json["diskType"];
     }
     if (_json.containsKey("mountPoint")) {
@@ skipping 13 matching lines @@
       _json["mountPoint"] = mountPoint;
     }
     if (sizeGb != null) {
       _json["sizeGb"] = sizeGb;
     }
     return _json;
   }
 }
 
 
-/** 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.
    */
   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;
 
 
   Environment();
 
   Environment.fromJson(core.Map _json) {
     if (_json.containsKey("clusterManagerApiService")) {
       clusterManagerApiService = _json["clusterManagerApiService"];
     }
     if (_json.containsKey("dataset")) {
@@ skipping 43 matching lines @@
       _json["version"] = version;
     }
     if (workerPools != null) {
       _json["workerPools"] = workerPools.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class FlattenInstruction {
-  /** Not documented yet. */
   core.List<InstructionInput> inputs;
 
 
   FlattenInstruction();
 
   FlattenInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("inputs")) {
       inputs = _json["inputs"].map((value) => new InstructionInput.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (inputs != null) {
       _json["inputs"] = inputs.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class InstructionInput {
-  /** Not documented yet. */
   core.int outputNum;
 
-  /** Not documented yet. */
   core.int producerInstructionIndex;
 
 
   InstructionInput();
 
   InstructionInput.fromJson(core.Map _json) {
     if (_json.containsKey("outputNum")) {
       outputNum = _json["outputNum"];
     }
     if (_json.containsKey("producerInstructionIndex")) {
       producerInstructionIndex = _json["producerInstructionIndex"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (outputNum != null) {
       _json["outputNum"] = outputNum;
     }
     if (producerInstructionIndex != null) {
       _json["producerInstructionIndex"] = producerInstructionIndex;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   InstructionOutput();
 
   InstructionOutput.fromJson(core.Map _json) {
     if (_json.containsKey("codec")) {
       codec = _json["codec"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (codec != null) {
       _json["codec"] = codec;
     }
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class Job {
-  /** Not documented yet. */
   core.String createTime;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_STATE_CANCELLED"
    * - "JOB_STATE_DONE"
    * - "JOB_STATE_FAILED"
    * - "JOB_STATE_RUNNING"
    * - "JOB_STATE_STOPPED"
    * - "JOB_STATE_UNKNOWN"
    */
   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"
    * - "JOB_STATE_FAILED"
    * - "JOB_STATE_RUNNING"
    * - "JOB_STATE_STOPPED"
    * - "JOB_STATE_UNKNOWN"
    */
   core.String requestedState;
 
-  /** Not documented yet. */
   core.List<Step> steps;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_TYPE_BATCH"
    * - "JOB_TYPE_STREAMING"
    * - "JOB_TYPE_UNKNOWN"
    */
   core.String type;
 
 
   Job();
 
@@ skipping 66 matching lines @@
       _json["steps"] = steps.map((value) => (value).toJson()).toList();
     }
     if (type != null) {
       _json["type"] = type;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class JobExecutionInfo {
-  /** Not documented yet. */
   core.Map<core.String, JobExecutionStageInfo> stages;
 
 
   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;
 
 
   JobExecutionStageInfo();
 
   JobExecutionStageInfo.fromJson(core.Map _json) {
     if (_json.containsKey("stepName")) {
       stepName = _json["stepName"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (stepName != null) {
       _json["stepName"] = stepName;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class JobMessage {
-  /** Not documented yet. */
   core.String id;
 
   /**
-   * Not documented yet.
+   *
    * Possible string values are:
    * - "JOB_MESSAGE_DEBUG"
    * - "JOB_MESSAGE_DETAILED"
    * - "JOB_MESSAGE_ERROR"
    * - "JOB_MESSAGE_IMPORTANCE_UNKNOWN"
    * - "JOB_MESSAGE_WARNING"
    */
   core.String messageImportance;
 
-  /** Not documented yet. */
   core.String messageText;
 
-  /** Not documented yet. */
   core.String time;
 
 
   JobMessage();
 
   JobMessage.fromJson(core.Map _json) {
     if (_json.containsKey("id")) {
       id = _json["id"];
     }
     if (_json.containsKey("messageImportance")) {
@@ skipping 19 matching lines @@
       _json["messageText"] = messageText;
     }
     if (time != null) {
       _json["time"] = time;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class JobMetrics {
-  /** Not documented yet. */
   core.String metricTime;
 
-  /** Not documented yet. */
   core.List<MetricUpdate> metrics;
 
 
   JobMetrics();
 
   JobMetrics.fromJson(core.Map _json) {
     if (_json.containsKey("metricTime")) {
       metricTime = _json["metricTime"];
     }
     if (_json.containsKey("metrics")) {
       metrics = _json["metrics"].map((value) => new MetricUpdate.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (metricTime != null) {
       _json["metricTime"] = metricTime;
     }
     if (metrics != null) {
       _json["metrics"] = metrics.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
-class KeyRangeLocation {
-  /** Not documented yet. */
+class KeyRangeDataDiskAssignment {
   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;
 
 
+  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 {
+  core.String dataDisk;
+
+  core.String deliveryEndpoint;
+
+  core.String end;
+
+  core.String persistentDirectory;
+
+  core.String start;
+
+
   KeyRangeLocation();
 
   KeyRangeLocation.fromJson(core.Map _json) {
     if (_json.containsKey("dataDisk")) {
       dataDisk = _json["dataDisk"];
     }
     if (_json.containsKey("deliveryEndpoint")) {
       deliveryEndpoint = _json["deliveryEndpoint"];
     }
     if (_json.containsKey("end")) {
@@ skipping 22 matching lines @@
       _json["persistentDirectory"] = persistentDirectory;
     }
     if (start != null) {
       _json["start"] = start;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   LeaseWorkItemRequest();
 
   LeaseWorkItemRequest.fromJson(core.Map _json) {
     if (_json.containsKey("currentWorkerTime")) {
       currentWorkerTime = _json["currentWorkerTime"];
     }
     if (_json.containsKey("requestedLeaseDuration")) {
@@ skipping 25 matching lines @@
       _json["workerCapabilities"] = workerCapabilities;
     }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class LeaseWorkItemResponse {
-  /** Not documented yet. */
   core.List<WorkItem> workItems;
 
 
   LeaseWorkItemResponse();
 
   LeaseWorkItemResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workItems")) {
       workItems = _json["workItems"].map((value) => new WorkItem.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (workItems != null) {
       _json["workItems"] = workItems.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ListJobMessagesResponse {
-  /** Not documented yet. */
   core.List<JobMessage> jobMessages;
 
-  /** Not documented yet. */
   core.String nextPageToken;
 
 
   ListJobMessagesResponse();
 
   ListJobMessagesResponse.fromJson(core.Map _json) {
     if (_json.containsKey("jobMessages")) {
       jobMessages = _json["jobMessages"].map((value) => new JobMessage.fromJson(value)).toList();
     }
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (jobMessages != null) {
       _json["jobMessages"] = jobMessages.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ListJobsResponse {
-  /** Not documented yet. */
   core.List<Job> jobs;
 
-  /** Not documented yet. */
   core.String nextPageToken;
 
 
   ListJobsResponse();
 
   ListJobsResponse.fromJson(core.Map _json) {
     if (_json.containsKey("jobs")) {
       jobs = _json["jobs"].map((value) => new Job.fromJson(value)).toList();
     }
     if (_json.containsKey("nextPageToken")) {
       nextPageToken = _json["nextPageToken"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (jobs != null) {
       _json["jobs"] = jobs.map((value) => (value).toJson()).toList();
     }
     if (nextPageToken != null) {
       _json["nextPageToken"] = nextPageToken;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class MapTask {
-  /** Not documented yet. */
   core.List<ParallelInstruction> instructions;
 
-  /** Not documented yet. */
   core.String stageName;
 
-  /** Not documented yet. */
   core.String systemName;
 
 
   MapTask();
 
   MapTask.fromJson(core.Map _json) {
     if (_json.containsKey("instructions")) {
       instructions = _json["instructions"].map((value) => new ParallelInstruction.fromJson(value)).toList();
     }
     if (_json.containsKey("stageName")) {
@@ skipping 13 matching lines @@
       _json["stageName"] = stageName;
     }
     if (systemName != null) {
       _json["systemName"] = systemName;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   MetricStructuredName();
 
   MetricStructuredName.fromJson(core.Map _json) {
     if (_json.containsKey("context")) {
       context = _json["context"];
     }
     if (_json.containsKey("name")) {
@@ skipping 13 matching lines @@
       _json["name"] = name;
     }
     if (origin != null) {
       _json["origin"] = origin;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   MetricUpdate();
 
   MetricUpdate.fromJson(core.Map _json) {
     if (_json.containsKey("cumulative")) {
       cumulative = _json["cumulative"];
     }
     if (_json.containsKey("internal")) {
@@ skipping 49 matching lines @@
       _json["set"] = set;
     }
     if (updateTime != null) {
       _json["updateTime"] = updateTime;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   MultiOutputInfo();
 
   MultiOutputInfo.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;
   }
 }
 
 
-/** Not documented yet. */
 class Package {
-  /** Not documented yet. */
   core.String location;
 
-  /** Not documented yet. */
   core.String name;
 
 
   Package();
 
   Package.fromJson(core.Map _json) {
     if (_json.containsKey("location")) {
       location = _json["location"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (location != null) {
       _json["location"] = location;
     }
     if (name != null) {
       _json["name"] = name;
     }
     return _json;
   }
 }
 
 
-/** 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.
    */
   core.Map<core.String, core.Object> userFn;
 
 
   ParDoInstruction();
 
   ParDoInstruction.fromJson(core.Map _json) {
@@ skipping 29 matching lines @@
       _json["sideInputs"] = sideInputs.map((value) => (value).toJson()).toList();
     }
     if (userFn != null) {
       _json["userFn"] = userFn;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   ParallelInstruction();
 
   ParallelInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("flatten")) {
       flatten = new FlattenInstruction.fromJson(_json["flatten"]);
     }
     if (_json.containsKey("name")) {
@@ skipping 43 matching lines @@
       _json["systemName"] = systemName;
     }
     if (write != null) {
       _json["write"] = (write).toJson();
     }
     return _json;
   }
 }
 
 
-/** 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();
 
   PartialGroupByKeyInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("input")) {
       input = new InstructionInput.fromJson(_json["input"]);
     }
     if (_json.containsKey("inputElementCodec")) {
       inputElementCodec = _json["inputElementCodec"];
     }
+    if (_json.containsKey("valueCombiningFn")) {
+      valueCombiningFn = _json["valueCombiningFn"];
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     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;
 
 
   Position();
 
   Position.fromJson(core.Map _json) {
     if (_json.containsKey("byteOffset")) {
       byteOffset = _json["byteOffset"];
     }
     if (_json.containsKey("end")) {
@@ skipping 25 matching lines @@
       _json["recordIndex"] = recordIndex;
     }
     if (shufflePosition != null) {
       _json["shufflePosition"] = shufflePosition;
     }
     return _json;
   }
 }
 
 
-/** 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();
 
   PubsubLocation.fromJson(core.Map _json) {
     if (_json.containsKey("dropLateData")) {
       dropLateData = _json["dropLateData"];
     }
     if (_json.containsKey("idLabel")) {
       idLabel = _json["idLabel"];
     }
     if (_json.containsKey("subscription")) {
       subscription = _json["subscription"];
     }
     if (_json.containsKey("timestampLabel")) {
       timestampLabel = _json["timestampLabel"];
     }
     if (_json.containsKey("topic")) {
       topic = _json["topic"];
     }
+    if (_json.containsKey("trackingSubscription")) {
+      trackingSubscription = _json["trackingSubscription"];
+    }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (dropLateData != null) {
       _json["dropLateData"] = dropLateData;
     }
     if (idLabel != null) {
       _json["idLabel"] = idLabel;
     }
     if (subscription != null) {
       _json["subscription"] = subscription;
     }
     if (timestampLabel != null) {
       _json["timestampLabel"] = timestampLabel;
     }
     if (topic != null) {
       _json["topic"] = topic;
     }
+    if (trackingSubscription != null) {
+      _json["trackingSubscription"] = trackingSubscription;
+    }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ReadInstruction {
-  /** Not documented yet. */
   Source source;
 
 
   ReadInstruction();
 
   ReadInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ReportWorkItemStatusRequest {
-  /** Not documented yet. */
   core.String currentWorkerTime;
 
-  /** Not documented yet. */
   core.List<WorkItemStatus> workItemStatuses;
 
-  /** Not documented yet. */
   core.String workerId;
 
 
   ReportWorkItemStatusRequest();
 
   ReportWorkItemStatusRequest.fromJson(core.Map _json) {
     if (_json.containsKey("currentWorkerTime")) {
       currentWorkerTime = _json["currentWorkerTime"];
     }
     if (_json.containsKey("workItemStatuses")) {
@@ skipping 13 matching lines @@
       _json["workItemStatuses"] = workItemStatuses.map((value) => (value).toJson()).toList();
     }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ReportWorkItemStatusResponse {
-  /** Not documented yet. */
   core.List<WorkItemServiceState> workItemServiceStates;
 
 
   ReportWorkItemStatusResponse();
 
   ReportWorkItemStatusResponse.fromJson(core.Map _json) {
     if (_json.containsKey("workItemServiceStates")) {
       workItemServiceStates = _json["workItemServiceStates"].map((value) => new WorkItemServiceState.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (workItemServiceStates != null) {
       _json["workItemServiceStates"] = workItemServiceStates.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** 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.
    */
   core.Map<core.String, core.Object> userFn;
 
 
   SeqMapTask();
 
   SeqMapTask.fromJson(core.Map _json) {
@@ skipping 35 matching lines @@
       _json["systemName"] = systemName;
     }
     if (userFn != null) {
       _json["userFn"] = userFn;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SeqMapTaskOutputInfo {
-  /** Not documented yet. */
   Sink sink;
 
-  /** Not documented yet. */
   core.String tag;
 
 
   SeqMapTaskOutputInfo();
 
   SeqMapTaskOutputInfo.fromJson(core.Map _json) {
     if (_json.containsKey("sink")) {
       sink = new Sink.fromJson(_json["sink"]);
     }
     if (_json.containsKey("tag")) {
       tag = _json["tag"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     if (tag != null) {
       _json["tag"] = tag;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class ShellTask {
-  /** Not documented yet. */
   core.String command;
 
-  /** Not documented yet. */
   core.int exitCode;
 
 
   ShellTask();
 
   ShellTask.fromJson(core.Map _json) {
     if (_json.containsKey("command")) {
       command = _json["command"];
     }
     if (_json.containsKey("exitCode")) {
       exitCode = _json["exitCode"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (command != null) {
       _json["command"] = command;
     }
     if (exitCode != null) {
       _json["exitCode"] = exitCode;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   SideInputInfo();
 
   SideInputInfo.fromJson(core.Map _json) {
     if (_json.containsKey("kind")) {
       kind = _json["kind"];
     }
     if (_json.containsKey("sources")) {
@@ skipping 13 matching lines @@
       _json["sources"] = sources.map((value) => (value).toJson()).toList();
     }
     if (tag != null) {
       _json["tag"] = tag;
     }
     return _json;
   }
 }
 
 
-/** 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.
    */
   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.
    */
   core.Map<core.String, core.Object> spec;
 
 
   Sink();
 
   Sink.fromJson(core.Map _json) {
@@ skipping 11 matching lines @@
       _json["codec"] = codec;
     }
     if (spec != null) {
       _json["spec"] = spec;
     }
     return _json;
   }
 }
 
 
-/** 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.
    */
   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.
    */
   core.Map<core.String, core.Object> spec;
 
 
   Source();
 
   Source.fromJson(core.Map _json) {
@@ skipping 29 matching lines @@
       _json["metadata"] = (metadata).toJson();
     }
     if (spec != null) {
       _json["spec"] = spec;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceFork {
-  /** Not documented yet. */
   SourceSplitShard primary;
 
-  /** Not documented yet. */
+  DerivedSource primarySource;
+
   SourceSplitShard residual;
 
+  DerivedSource residualSource;
+
 
   SourceFork();
 
   SourceFork.fromJson(core.Map _json) {
     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() {
     var _json = new core.Map();
     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;
 
 
   SourceGetMetadataRequest();
 
   SourceGetMetadataRequest.fromJson(core.Map _json) {
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceGetMetadataResponse {
-  /** Not documented yet. */
   SourceMetadata metadata;
 
 
   SourceGetMetadataResponse();
 
   SourceGetMetadataResponse.fromJson(core.Map _json) {
     if (_json.containsKey("metadata")) {
       metadata = new SourceMetadata.fromJson(_json["metadata"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (metadata != null) {
       _json["metadata"] = (metadata).toJson();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceMetadata {
-  /** Not documented yet. */
   core.String estimatedSizeBytes;
 
-  /** Not documented yet. */
   core.bool infinite;
 
-  /** Not documented yet. */
   core.bool producesSortedKeys;
 
 
   SourceMetadata();
 
   SourceMetadata.fromJson(core.Map _json) {
     if (_json.containsKey("estimatedSizeBytes")) {
       estimatedSizeBytes = _json["estimatedSizeBytes"];
     }
     if (_json.containsKey("infinite")) {
@@ skipping 13 matching lines @@
       _json["infinite"] = infinite;
     }
     if (producesSortedKeys != null) {
       _json["producesSortedKeys"] = producesSortedKeys;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceOperationRequest {
-  /** Not documented yet. */
   SourceGetMetadataRequest getMetadata;
 
-  /** Not documented yet. */
   SourceSplitRequest split;
 
 
   SourceOperationRequest();
 
   SourceOperationRequest.fromJson(core.Map _json) {
     if (_json.containsKey("getMetadata")) {
       getMetadata = new SourceGetMetadataRequest.fromJson(_json["getMetadata"]);
     }
     if (_json.containsKey("split")) {
       split = new SourceSplitRequest.fromJson(_json["split"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (getMetadata != null) {
       _json["getMetadata"] = (getMetadata).toJson();
     }
     if (split != null) {
       _json["split"] = (split).toJson();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceOperationResponse {
-  /** Not documented yet. */
   SourceGetMetadataResponse getMetadata;
 
-  /** Not documented yet. */
   SourceSplitResponse split;
 
 
   SourceOperationResponse();
 
   SourceOperationResponse.fromJson(core.Map _json) {
     if (_json.containsKey("getMetadata")) {
       getMetadata = new SourceGetMetadataResponse.fromJson(_json["getMetadata"]);
     }
     if (_json.containsKey("split")) {
       split = new SourceSplitResponse.fromJson(_json["split"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (getMetadata != null) {
       _json["getMetadata"] = (getMetadata).toJson();
     }
     if (split != null) {
       _json["split"] = (split).toJson();
     }
     return _json;
   }
 }
 
 
-/** 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"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
+    if (desiredBundleSizeBytes != null) {
+      _json["desiredBundleSizeBytes"] = desiredBundleSizeBytes;
+    }
     if (desiredShardSizeBytes != null) {
       _json["desiredShardSizeBytes"] = desiredShardSizeBytes;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceSplitRequest {
-  /** Not documented yet. */
   SourceSplitOptions options;
 
-  /** Not documented yet. */
   Source source;
 
 
   SourceSplitRequest();
 
   SourceSplitRequest.fromJson(core.Map _json) {
     if (_json.containsKey("options")) {
       options = new SourceSplitOptions.fromJson(_json["options"]);
     }
     if (_json.containsKey("source")) {
       source = new Source.fromJson(_json["source"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (options != null) {
       _json["options"] = (options).toJson();
     }
     if (source != null) {
       _json["source"] = (source).toJson();
     }
     return _json;
   }
 }
 
 
-/** 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"
    * - "SOURCE_SPLIT_OUTCOME_USE_CURRENT"
    */
   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"];
     }
     if (_json.containsKey("shards")) {
       shards = _json["shards"].map((value) => new SourceSplitShard.fromJson(value)).toList();
     }
   }
 
   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;
     }
     if (shards != null) {
       _json["shards"] = shards.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class SourceSplitShard {
   /**
-   * Not documented yet.
+   *
    * 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;
 
-  /** Not documented yet. */
   Source source;
 
 
   SourceSplitShard();
 
   SourceSplitShard.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;
   }
 }
 
 
-/** 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;
 
 
   Status();
 
   Status.fromJson(core.Map _json) {
     if (_json.containsKey("code")) {
       code = _json["code"];
     }
     if (_json.containsKey("details")) {
@@ skipping 13 matching lines @@
       _json["details"] = details;
     }
     if (message != null) {
       _json["message"] = message;
     }
     return _json;
   }
 }
 
 
-/** 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.
    */
   core.Map<core.String, core.Object> properties;
 
 
   Step();
 
   Step.fromJson(core.Map _json) {
@@ skipping 17 matching lines @@
       _json["name"] = name;
     }
     if (properties != null) {
       _json["properties"] = properties;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class StreamLocation {
-  /** Not documented yet. */
   PubsubLocation pubsubLocation;
 
-  /** Not documented yet. */
+  StreamingSideInputLocation sideInputLocation;
+
   StreamingStageLocation streamingStageLocation;
 
 
   StreamLocation();
 
   StreamLocation.fromJson(core.Map _json) {
     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"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (pubsubLocation != null) {
       _json["pubsubLocation"] = (pubsubLocation).toJson();
     }
+    if (sideInputLocation != null) {
+      _json["sideInputLocation"] = (sideInputLocation).toJson();
+    }
     if (streamingStageLocation != null) {
       _json["streamingStageLocation"] = (streamingStageLocation).toJson();
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   StreamingSetupTask();
 
   StreamingSetupTask.fromJson(core.Map _json) {
     if (_json.containsKey("receiveWorkPort")) {
       receiveWorkPort = _json["receiveWorkPort"];
     }
     if (_json.containsKey("streamingComputationTopology")) {
@@ skipping 13 matching lines @@
       _json["streamingComputationTopology"] = (streamingComputationTopology).toJson();
     }
     if (workerHarnessPort != null) {
       _json["workerHarnessPort"] = workerHarnessPort;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   StreamingStageLocation();
 
   StreamingStageLocation.fromJson(core.Map _json) {
     if (_json.containsKey("streamId")) {
       streamId = _json["streamId"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (streamId != null) {
       _json["streamId"] = streamId;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   TaskRunnerSettings();
 
   TaskRunnerSettings.fromJson(core.Map _json) {
     if (_json.containsKey("alsologtostderr")) {
       alsologtostderr = _json["alsologtostderr"];
     }
     if (_json.containsKey("baseTaskDir")) {
@@ skipping 109 matching lines @@
       _json["vmId"] = vmId;
     }
     if (workflowFileName != null) {
       _json["workflowFileName"] = workflowFileName;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class TopologyConfig {
-  /** Not documented yet. */
   core.List<ComputationTopology> computations;
 
-  /** Not documented yet. */
   core.List<DataDiskAssignment> dataDiskAssignments;
 
 
   TopologyConfig();
 
   TopologyConfig.fromJson(core.Map _json) {
     if (_json.containsKey("computations")) {
       computations = _json["computations"].map((value) => new ComputationTopology.fromJson(value)).toList();
     }
     if (_json.containsKey("dataDiskAssignments")) {
       dataDiskAssignments = _json["dataDiskAssignments"].map((value) => new DataDiskAssignment.fromJson(value)).toList();
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (computations != null) {
       _json["computations"] = computations.map((value) => (value).toJson()).toList();
     }
     if (dataDiskAssignments != null) {
       _json["dataDiskAssignments"] = dataDiskAssignments.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   WorkItem();
 
   WorkItem.fromJson(core.Map _json) {
     if (_json.containsKey("configuration")) {
       configuration = _json["configuration"];
     }
     if (_json.containsKey("id")) {
       id = _json["id"];
     }
+    if (_json.containsKey("initialReportIndex")) {
+      initialReportIndex = _json["initialReportIndex"];
+    }
     if (_json.containsKey("jobId")) {
       jobId = _json["jobId"];
     }
     if (_json.containsKey("leaseExpireTime")) {
       leaseExpireTime = _json["leaseExpireTime"];
     }
     if (_json.containsKey("mapTask")) {
       mapTask = new MapTask.fromJson(_json["mapTask"]);
     }
     if (_json.containsKey("packages")) {
       packages = _json["packages"].map((value) => new Package.fromJson(value)).toList();
     }
     if (_json.containsKey("projectId")) {
       projectId = _json["projectId"];
     }
     if (_json.containsKey("reportStatusInterval")) {
       reportStatusInterval = _json["reportStatusInterval"];
     }
     if (_json.containsKey("seqMapTask")) {
       seqMapTask = new SeqMapTask.fromJson(_json["seqMapTask"]);
     }
     if (_json.containsKey("shellTask")) {
       shellTask = new ShellTask.fromJson(_json["shellTask"]);
     }
     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"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (configuration != null) {
       _json["configuration"] = configuration;
     }
     if (id != null) {
       _json["id"] = id;
     }
+    if (initialReportIndex != null) {
+      _json["initialReportIndex"] = initialReportIndex;
+    }
     if (jobId != null) {
       _json["jobId"] = jobId;
     }
     if (leaseExpireTime != null) {
       _json["leaseExpireTime"] = leaseExpireTime;
     }
     if (mapTask != null) {
       _json["mapTask"] = (mapTask).toJson();
     }
     if (packages != null) {
       _json["packages"] = packages.map((value) => (value).toJson()).toList();
     }
     if (projectId != null) {
       _json["projectId"] = projectId;
     }
     if (reportStatusInterval != null) {
       _json["reportStatusInterval"] = reportStatusInterval;
     }
     if (seqMapTask != null) {
       _json["seqMapTask"] = (seqMapTask).toJson();
     }
     if (shellTask != null) {
       _json["shellTask"] = (shellTask).toJson();
     }
     if (sourceOperationTask != null) {
       _json["sourceOperationTask"] = (sourceOperationTask).toJson();
     }
+    if (streamingComputationTask != null) {
+      _json["streamingComputationTask"] = (streamingComputationTask).toJson();
+    }
     if (streamingSetupTask != null) {
       _json["streamingSetupTask"] = (streamingSetupTask).toJson();
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   WorkItemServiceState();
 
   WorkItemServiceState.fromJson(core.Map _json) {
     if (_json.containsKey("harnessData")) {
       harnessData = _json["harnessData"];
     }
     if (_json.containsKey("leaseExpireTime")) {
       leaseExpireTime = _json["leaseExpireTime"];
     }
+    if (_json.containsKey("nextReportIndex")) {
+      nextReportIndex = _json["nextReportIndex"];
+    }
     if (_json.containsKey("reportStatusInterval")) {
       reportStatusInterval = _json["reportStatusInterval"];
     }
     if (_json.containsKey("suggestedStopPoint")) {
       suggestedStopPoint = new ApproximateProgress.fromJson(_json["suggestedStopPoint"]);
     }
     if (_json.containsKey("suggestedStopPosition")) {
       suggestedStopPosition = new Position.fromJson(_json["suggestedStopPosition"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (harnessData != null) {
       _json["harnessData"] = harnessData;
     }
     if (leaseExpireTime != null) {
       _json["leaseExpireTime"] = leaseExpireTime;
     }
+    if (nextReportIndex != null) {
+      _json["nextReportIndex"] = nextReportIndex;
+    }
     if (reportStatusInterval != null) {
       _json["reportStatusInterval"] = reportStatusInterval;
     }
     if (suggestedStopPoint != null) {
       _json["suggestedStopPoint"] = (suggestedStopPoint).toJson();
     }
     if (suggestedStopPosition != null) {
       _json["suggestedStopPosition"] = (suggestedStopPosition).toJson();
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   WorkItemStatus();
 
   WorkItemStatus.fromJson(core.Map _json) {
     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();
     }
     if (_json.containsKey("metricUpdates")) {
       metricUpdates = _json["metricUpdates"].map((value) => new MetricUpdate.fromJson(value)).toList();
     }
     if (_json.containsKey("progress")) {
       progress = new ApproximateProgress.fromJson(_json["progress"]);
     }
     if (_json.containsKey("reportIndex")) {
@@ skipping 14 matching lines @@
     if (_json.containsKey("workItemId")) {
       workItemId = _json["workItemId"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (completed != null) {
       _json["completed"] = completed;
     }
+    if (dynamicSourceSplit != null) {
+      _json["dynamicSourceSplit"] = (dynamicSourceSplit).toJson();
+    }
     if (errors != null) {
       _json["errors"] = errors.map((value) => (value).toJson()).toList();
     }
     if (metricUpdates != null) {
       _json["metricUpdates"] = metricUpdates.map((value) => (value).toJson()).toList();
     }
     if (progress != null) {
       _json["progress"] = (progress).toJson();
     }
     if (reportIndex != null) {
@@ skipping 12 matching lines @@
       _json["stopPosition"] = (stopPosition).toJson();
     }
     if (workItemId != null) {
       _json["workItemId"] = workItemId;
     }
     return _json;
   }
 }
 
 
-/** 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"
    * - "DEFAULT_PACKAGE_SET_PYTHON"
    * - "DEFAULT_PACKAGE_SET_UNKNOWN"
    */
   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"
    * - "TEARDOWN_ON_SUCCESS"
    * - "TEARDOWN_POLICY_UNKNOWN"
    */
   core.String teardownPolicy;
 
-  /** Not documented yet. */
   core.String zone;
 
 
   WorkerPool();
 
   WorkerPool.fromJson(core.Map _json) {
     if (_json.containsKey("autoscalingSettings")) {
       autoscalingSettings = new AutoscalingSettings.fromJson(_json["autoscalingSettings"]);
     }
     if (_json.containsKey("dataDisks")) {
@@ skipping 19 matching lines @@
     }
     if (_json.containsKey("numWorkers")) {
       numWorkers = _json["numWorkers"];
     }
     if (_json.containsKey("onHostMaintenance")) {
       onHostMaintenance = _json["onHostMaintenance"];
     }
     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"]);
     }
     if (_json.containsKey("teardownPolicy")) {
       teardownPolicy = _json["teardownPolicy"];
     }
     if (_json.containsKey("zone")) {
       zone = _json["zone"];
     }
   }
@@ skipping 26 matching lines @@
     }
     if (numWorkers != null) {
       _json["numWorkers"] = numWorkers;
     }
     if (onHostMaintenance != null) {
       _json["onHostMaintenance"] = onHostMaintenance;
     }
     if (packages != null) {
       _json["packages"] = packages.map((value) => (value).toJson()).toList();
     }
+    if (poolArgs != null) {
+      _json["poolArgs"] = poolArgs;
+    }
     if (taskrunnerSettings != null) {
       _json["taskrunnerSettings"] = (taskrunnerSettings).toJson();
     }
     if (teardownPolicy != null) {
       _json["teardownPolicy"] = teardownPolicy;
     }
     if (zone != null) {
       _json["zone"] = zone;
     }
     return _json;
   }
 }
 
 
-/** 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;
 
 
   WorkerSettings();
 
   WorkerSettings.fromJson(core.Map _json) {
     if (_json.containsKey("baseUrl")) {
       baseUrl = _json["baseUrl"];
     }
     if (_json.containsKey("reportingEnabled")) {
@@ skipping 31 matching lines @@
       _json["tempStoragePrefix"] = tempStoragePrefix;
     }
     if (workerId != null) {
       _json["workerId"] = workerId;
     }
     return _json;
   }
 }
 
 
-/** Not documented yet. */
 class WriteInstruction {
-  /** Not documented yet. */
   InstructionInput input;
 
-  /** Not documented yet. */
   Sink sink;
 
 
   WriteInstruction();
 
   WriteInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("input")) {
       input = new InstructionInput.fromJson(_json["input"]);
     }
     if (_json.containsKey("sink")) {
       sink = new Sink.fromJson(_json["sink"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }
-
-