Api-Roll 53: 2017-08-21

generated/googleapis/lib/bigquery/v2.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis.bigquery.v2;
 
 import 'dart:core' as core;
 import 'dart:collection' as collection;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
@@ skipping 1989 matching lines @@
       _json["message"] = message;
     }
     if (reason != null) {
       _json["reason"] = reason;
     }
     return _json;
   }
 }
 
 class ExplainQueryStage {
+  /** Milliseconds the average shard spent on CPU-bound tasks. */
+  core.String computeMsAvg;
+  /** Milliseconds the slowest shard spent on CPU-bound tasks. */
+  core.String computeMsMax;
   /** Relative amount of time the average shard spent on CPU-bound tasks. */
   core.double computeRatioAvg;
   /** Relative amount of time the slowest shard spent on CPU-bound tasks. */
   core.double computeRatioMax;
   /** Unique ID for stage within plan. */
   core.String id;
   /** Human-readable name for stage. */
   core.String name;
+  /** Milliseconds the average shard spent reading input. */
+  core.String readMsAvg;
+  /** Milliseconds the slowest shard spent reading input. */
+  core.String readMsMax;
   /** Relative amount of time the average shard spent reading input. */
   core.double readRatioAvg;
   /** Relative amount of time the slowest shard spent reading input. */
   core.double readRatioMax;
   /** Number of records read into the stage. */
   core.String recordsRead;
   /** Number of records written by the stage. */
   core.String recordsWritten;
+  /** Total number of bytes written to shuffle. */
+  core.String shuffleOutputBytes;
+  /** Total number of bytes written to shuffle and spilled to disk. */
+  core.String shuffleOutputBytesSpilled;
   /** Current status for the stage. */
   core.String status;
   /**
    * List of operations within the stage in dependency order (approximately
    * chronological).
    */
   core.List<ExplainQueryStep> steps;
+  /** Milliseconds the average shard spent waiting to be scheduled. */
+  core.String waitMsAvg;
+  /** Milliseconds the slowest shard spent waiting to be scheduled. */
+  core.String waitMsMax;
   /**
    * Relative amount of time the average shard spent waiting to be scheduled.
    */
   core.double waitRatioAvg;
   /**
    * Relative amount of time the slowest shard spent waiting to be scheduled.
    */
   core.double waitRatioMax;
+  /** Milliseconds the average shard spent on writing output. */
+  core.String writeMsAvg;
+  /** Milliseconds the slowest shard spent on writing output. */
+  core.String writeMsMax;
   /** Relative amount of time the average shard spent on writing output. */
   core.double writeRatioAvg;
   /** Relative amount of time the slowest shard spent on writing output. */
   core.double writeRatioMax;
 
   ExplainQueryStage();
 
   ExplainQueryStage.fromJson(core.Map _json) {
+    if (_json.containsKey("computeMsAvg")) {
+      computeMsAvg = _json["computeMsAvg"];
+    }
+    if (_json.containsKey("computeMsMax")) {
+      computeMsMax = _json["computeMsMax"];
+    }
     if (_json.containsKey("computeRatioAvg")) {
       computeRatioAvg = _json["computeRatioAvg"];
     }
     if (_json.containsKey("computeRatioMax")) {
       computeRatioMax = _json["computeRatioMax"];
     }
     if (_json.containsKey("id")) {
       id = _json["id"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
+    if (_json.containsKey("readMsAvg")) {
+      readMsAvg = _json["readMsAvg"];
+    }
+    if (_json.containsKey("readMsMax")) {
+      readMsMax = _json["readMsMax"];
+    }
     if (_json.containsKey("readRatioAvg")) {
       readRatioAvg = _json["readRatioAvg"];
     }
     if (_json.containsKey("readRatioMax")) {
       readRatioMax = _json["readRatioMax"];
     }
     if (_json.containsKey("recordsRead")) {
       recordsRead = _json["recordsRead"];
     }
     if (_json.containsKey("recordsWritten")) {
       recordsWritten = _json["recordsWritten"];
     }
+    if (_json.containsKey("shuffleOutputBytes")) {
+      shuffleOutputBytes = _json["shuffleOutputBytes"];
+    }
+    if (_json.containsKey("shuffleOutputBytesSpilled")) {
+      shuffleOutputBytesSpilled = _json["shuffleOutputBytesSpilled"];
+    }
     if (_json.containsKey("status")) {
       status = _json["status"];
     }
     if (_json.containsKey("steps")) {
       steps = _json["steps"].map((value) => new ExplainQueryStep.fromJson(value)).toList();
     }
+    if (_json.containsKey("waitMsAvg")) {
+      waitMsAvg = _json["waitMsAvg"];
+    }
+    if (_json.containsKey("waitMsMax")) {
+      waitMsMax = _json["waitMsMax"];
+    }
     if (_json.containsKey("waitRatioAvg")) {
       waitRatioAvg = _json["waitRatioAvg"];
     }
     if (_json.containsKey("waitRatioMax")) {
       waitRatioMax = _json["waitRatioMax"];
     }
+    if (_json.containsKey("writeMsAvg")) {
+      writeMsAvg = _json["writeMsAvg"];
+    }
+    if (_json.containsKey("writeMsMax")) {
+      writeMsMax = _json["writeMsMax"];
+    }
     if (_json.containsKey("writeRatioAvg")) {
       writeRatioAvg = _json["writeRatioAvg"];
     }
     if (_json.containsKey("writeRatioMax")) {
       writeRatioMax = _json["writeRatioMax"];
     }
   }
 
   core.Map<core.String, core.Object> toJson() {
     final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
+    if (computeMsAvg != null) {
+      _json["computeMsAvg"] = computeMsAvg;
+    }
+    if (computeMsMax != null) {
+      _json["computeMsMax"] = computeMsMax;
+    }
     if (computeRatioAvg != null) {
       _json["computeRatioAvg"] = computeRatioAvg;
     }
     if (computeRatioMax != null) {
       _json["computeRatioMax"] = computeRatioMax;
     }
     if (id != null) {
       _json["id"] = id;
     }
     if (name != null) {
       _json["name"] = name;
     }
+    if (readMsAvg != null) {
+      _json["readMsAvg"] = readMsAvg;
+    }
+    if (readMsMax != null) {
+      _json["readMsMax"] = readMsMax;
+    }
     if (readRatioAvg != null) {
       _json["readRatioAvg"] = readRatioAvg;
     }
     if (readRatioMax != null) {
       _json["readRatioMax"] = readRatioMax;
     }
     if (recordsRead != null) {
       _json["recordsRead"] = recordsRead;
     }
     if (recordsWritten != null) {
       _json["recordsWritten"] = recordsWritten;
     }
+    if (shuffleOutputBytes != null) {
+      _json["shuffleOutputBytes"] = shuffleOutputBytes;
+    }
+    if (shuffleOutputBytesSpilled != null) {
+      _json["shuffleOutputBytesSpilled"] = shuffleOutputBytesSpilled;
+    }
     if (status != null) {
       _json["status"] = status;
     }
     if (steps != null) {
       _json["steps"] = steps.map((value) => (value).toJson()).toList();
     }
+    if (waitMsAvg != null) {
+      _json["waitMsAvg"] = waitMsAvg;
+    }
+    if (waitMsMax != null) {
+      _json["waitMsMax"] = waitMsMax;
+    }
     if (waitRatioAvg != null) {
       _json["waitRatioAvg"] = waitRatioAvg;
     }
     if (waitRatioMax != null) {
       _json["waitRatioMax"] = waitRatioMax;
     }
+    if (writeMsAvg != null) {
+      _json["writeMsAvg"] = writeMsAvg;
+    }
+    if (writeMsMax != null) {
+      _json["writeMsMax"] = writeMsMax;
+    }
     if (writeRatioAvg != null) {
       _json["writeRatioAvg"] = writeRatioAvg;
     }
     if (writeRatioMax != null) {
       _json["writeRatioMax"] = writeRatioMax;
     }
     return _json;
   }
 }
 
@@ skipping 78 matching lines @@
    * Bigtable, specify "BIGTABLE".
    */
   core.String sourceFormat;
   /**
    * [Required] The fully-qualified URIs that point to your data in Google
    * Cloud. For Google Cloud Storage URIs: Each URI can contain one '*' wildcard
    * character and it must come after the 'bucket' name. Size limits related to
    * load jobs apply to external data sources. For Google Cloud Bigtable URIs:
    * Exactly one URI can be specified and it has be a fully specified and valid
    * HTTPS URL for a Google Cloud Bigtable table. For Google Cloud Datastore
-   * backups, exactly one URI can be specified, and it must end with
-   * '.backup_info'. Also, the '*' wildcard character is not allowed.
+   * backups, exactly one URI can be specified. Also, the '*' wildcard character
+   * is not allowed.
    */
   core.List<core.String> sourceUris;
 
   ExternalDataConfiguration();
 
   ExternalDataConfiguration.fromJson(core.Map _json) {
     if (_json.containsKey("autodetect")) {
       autodetect = _json["autodetect"];
     }
     if (_json.containsKey("bigtableOptions")) {
@@ skipping 616 matching lines @@
   /**
    * [Deprecated] The inline schema. For CSV schemas, specify as
    * "Field1:Type1[,Field2:Type2]*". For example, "foo:STRING, bar:INTEGER,
    * baz:FLOAT".
    */
   core.String schemaInline;
   /** [Deprecated] The format of the schemaInline property. */
   core.String schemaInlineFormat;
   /**
    * [Experimental] Allows the schema of the desitination table to be updated as
-   * a side effect of the load job. Schema update options are supported in two
-   * cases: when writeDisposition is WRITE_APPEND; when writeDisposition is
+   * a side effect of the load job if a schema is autodetected or supplied in
+   * the job configuration. Schema update options are supported in two cases:
+   * when writeDisposition is WRITE_APPEND; when writeDisposition is
    * WRITE_TRUNCATE and the destination table is a partition of a table,
    * specified by partition decorators. For normal tables, WRITE_TRUNCATE will
    * always overwrite the schema. One or more of the following values are
    * specified: ALLOW_FIELD_ADDITION: allow adding a nullable field to the
    * schema. ALLOW_FIELD_RELAXATION: allow relaxing a required field in the
    * original schema to nullable.
    */
   core.List<core.String> schemaUpdateOptions;
   /**
    * [Optional] The number of rows at the top of a CSV file that BigQuery will
    * skip when loading the data. The default value is 0. This property is useful
    * if you have header rows in the file that should be skipped.
    */
   core.int skipLeadingRows;
   /**
    * [Optional] The format of the data files. For CSV files, specify "CSV". For
    * datastore backups, specify "DATASTORE_BACKUP". For newline-delimited JSON,
    * specify "NEWLINE_DELIMITED_JSON". For Avro, specify "AVRO". The default
    * value is CSV.
    */
   core.String sourceFormat;
   /**
    * [Required] The fully-qualified URIs that point to your data in Google
    * Cloud. For Google Cloud Storage URIs: Each URI can contain one '*' wildcard
    * character and it must come after the 'bucket' name. Size limits related to
    * load jobs apply to external data sources. For Google Cloud Bigtable URIs:
    * Exactly one URI can be specified and it has be a fully specified and valid
    * HTTPS URL for a Google Cloud Bigtable table. For Google Cloud Datastore
-   * backups: Exactly one URI can be specified, and it must end with
-   * '.backup_info'. Also, the '*' wildcard character is not allowed.
+   * backups: Exactly one URI can be specified. Also, the '*' wildcard character
+   * is not allowed.
    */
   core.List<core.String> sourceUris;
   /**
+   * [Experimental] If specified, configures time-based partitioning for the
+   * destination table.
+   */
+  TimePartitioning timePartitioning;
+  /**
    * [Optional] Specifies the action that occurs if the destination table
    * already exists. The following values are supported: WRITE_TRUNCATE: If the
    * table already exists, BigQuery overwrites the table data. WRITE_APPEND: If
    * the table already exists, BigQuery appends the data to the table.
    * WRITE_EMPTY: If the table already exists and contains data, a 'duplicate'
    * error is returned in the job result. The default value is WRITE_APPEND.
    * Each action is atomic and only occurs if BigQuery is able to complete the
    * job successfully. Creation, truncation and append actions occur as one
    * atomic update upon job completion.
    */
@@ skipping 52 matching lines @@
     }
     if (_json.containsKey("skipLeadingRows")) {
       skipLeadingRows = _json["skipLeadingRows"];
     }
     if (_json.containsKey("sourceFormat")) {
       sourceFormat = _json["sourceFormat"];
     }
     if (_json.containsKey("sourceUris")) {
       sourceUris = _json["sourceUris"];
     }
+    if (_json.containsKey("timePartitioning")) {
+      timePartitioning = new TimePartitioning.fromJson(_json["timePartitioning"]);
+    }
     if (_json.containsKey("writeDisposition")) {
       writeDisposition = _json["writeDisposition"];
     }
   }
 
   core.Map<core.String, core.Object> toJson() {
     final core.Map<core.String, core.Object> _json = new core.Map<core.String, core.Object>();
     if (allowJaggedRows != null) {
       _json["allowJaggedRows"] = allowJaggedRows;
     }
@@ skipping 44 matching lines @@
     }
     if (skipLeadingRows != null) {
       _json["skipLeadingRows"] = skipLeadingRows;
     }
     if (sourceFormat != null) {
       _json["sourceFormat"] = sourceFormat;
     }
     if (sourceUris != null) {
       _json["sourceUris"] = sourceUris;
     }
+    if (timePartitioning != null) {
+      _json["timePartitioning"] = (timePartitioning).toJson();
+    }
     if (writeDisposition != null) {
       _json["writeDisposition"] = writeDisposition;
     }
     return _json;
   }
 }
 
 class JobConfigurationQuery {
   /**
    * [Optional] If true and query uses legacy SQL dialect, allows the query to
@@ skipping 76 matching lines @@
    */
   core.List<core.String> schemaUpdateOptions;
   /**
    * [Optional] If querying an external data source outside of BigQuery,
    * describes the data format, location and other properties of the data
    * source. By defining these properties, the data source can then be queried
    * as if it were a standard BigQuery table.
    */
   core.Map<core.String, ExternalDataConfiguration> tableDefinitions;
   /**
+   * [Experimental] If specified, configures time-based partitioning for the
+   * destination table.
+   */
+  TimePartitioning timePartitioning;
+  /**
    * Specifies whether to use BigQuery's legacy SQL dialect for this query. The
    * default value is true. If set to false, the query will use BigQuery's
    * standard SQL: https://cloud.google.com/bigquery/sql-reference/ When
    * useLegacySql is set to false, the value of flattenResults is ignored; query
    * will be run as if flattenResults is false.
    */
   core.bool useLegacySql;
   /**
    * [Optional] Whether to look for the result in the query cache. The query
    * cache is a best-effort cache that will be flushed whenever tables in the
@@ skipping 56 matching lines @@
     }
     if (_json.containsKey("queryParameters")) {
       queryParameters = _json["queryParameters"].map((value) => new QueryParameter.fromJson(value)).toList();
     }
     if (_json.containsKey("schemaUpdateOptions")) {
       schemaUpdateOptions = _json["schemaUpdateOptions"];
     }
     if (_json.containsKey("tableDefinitions")) {
       tableDefinitions = commons.mapMap<core.Map<core.String, core.Object>, ExternalDataConfiguration>(_json["tableDefinitions"], (core.Map<core.String, core.Object> item) => new ExternalDataConfiguration.fromJson(item));
     }
+    if (_json.containsKey("timePartitioning")) {
+      timePartitioning = new TimePartitioning.fromJson(_json["timePartitioning"]);
+    }
     if (_json.containsKey("useLegacySql")) {
       useLegacySql = _json["useLegacySql"];
     }
     if (_json.containsKey("useQueryCache")) {
       useQueryCache = _json["useQueryCache"];
     }
     if (_json.containsKey("userDefinedFunctionResources")) {
       userDefinedFunctionResources = _json["userDefinedFunctionResources"].map((value) => new UserDefinedFunctionResource.fromJson(value)).toList();
     }
     if (_json.containsKey("writeDisposition")) {
@@ skipping 38 matching lines @@
     }
     if (queryParameters != null) {
       _json["queryParameters"] = queryParameters.map((value) => (value).toJson()).toList();
     }
     if (schemaUpdateOptions != null) {
       _json["schemaUpdateOptions"] = schemaUpdateOptions;
     }
     if (tableDefinitions != null) {
       _json["tableDefinitions"] = commons.mapMap<ExternalDataConfiguration, core.Map<core.String, core.Object>>(tableDefinitions, (ExternalDataConfiguration item) => (item).toJson());
     }
+    if (timePartitioning != null) {
+      _json["timePartitioning"] = (timePartitioning).toJson();
+    }
     if (useLegacySql != null) {
       _json["useLegacySql"] = useLegacySql;
     }
     if (useQueryCache != null) {
       _json["useQueryCache"] = useQueryCache;
     }
     if (userDefinedFunctionResources != null) {
       _json["userDefinedFunctionResources"] = userDefinedFunctionResources.map((value) => (value).toJson()).toList();
     }
     if (writeDisposition != null) {
@@ skipping 2099 matching lines @@
     }
     if (useLegacySql != null) {
       _json["useLegacySql"] = useLegacySql;
     }
     if (userDefinedFunctionResources != null) {
       _json["userDefinedFunctionResources"] = userDefinedFunctionResources.map((value) => (value).toJson()).toList();
     }
     return _json;
   }
 }