Api-roll 39: 2016-07-18

generated/googleapis_beta/lib/dataflow/v1b3.dart

 // This is a generated file (see the discoveryapis_generator project).
 
 library googleapis_beta.dataflow.v1b3;
 
 import 'dart:core' as core;
 import 'dart:async' as async;
 import 'dart:convert' as convert;
 
 import 'package:_discoveryapis_commons/_discoveryapis_commons.dart' as commons;
 import 'package:http/http.dart' as http;
@@ skipping 1641 matching lines @@
 class InstructionOutput {
   /**
    * The codec to use to encode data being written via this output.
    *
    * 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;
   /** The user-provided name of this output. */
   core.String name;
+  /**
+   * For system-generated byte and mean byte metrics, certain instructions
+   * should only report the key size.
+   */
+  core.bool onlyCountKeyBytes;
+  /**
+   * For system-generated byte and mean byte metrics, certain instructions
+   * should only report the value size.
+   */
+  core.bool onlyCountValueBytes;
+  /**
+   * System-defined name for this output in the original workflow graph. Outputs
+   * that do not contribute to an original instruction do not set this.
+   */
+  core.String originalName;
   /** System-defined name of this output. Unique across the workflow. */
   core.String systemName;
 
   InstructionOutput();
 
   InstructionOutput.fromJson(core.Map _json) {
     if (_json.containsKey("codec")) {
       codec = _json["codec"];
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
+    if (_json.containsKey("onlyCountKeyBytes")) {
+      onlyCountKeyBytes = _json["onlyCountKeyBytes"];
+    }
+    if (_json.containsKey("onlyCountValueBytes")) {
+      onlyCountValueBytes = _json["onlyCountValueBytes"];
+    }
+    if (_json.containsKey("originalName")) {
+      originalName = _json["originalName"];
+    }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (codec != null) {
       _json["codec"] = codec;
     }
     if (name != null) {
       _json["name"] = name;
     }
+    if (onlyCountKeyBytes != null) {
+      _json["onlyCountKeyBytes"] = onlyCountKeyBytes;
+    }
+    if (onlyCountValueBytes != null) {
+      _json["onlyCountValueBytes"] = onlyCountValueBytes;
+    }
+    if (originalName != null) {
+      _json["originalName"] = originalName;
+    }
     if (systemName != null) {
       _json["systemName"] = systemName;
     }
     return _json;
   }
 }
 
 /** A metric value representing a list of integers. */
 class IntegerList {
   /** Elements of the list. */
@@ skipping 86 matching lines @@
   /** Environment for the job. */
   Environment environment;
   /** Information about how the Dataflow service will actually run the job. */
   JobExecutionInfo executionInfo;
   /**
    * The unique ID of this job. This field is set by the Dataflow service when
    * the Job is created, and is immutable for the life of the Job.
    */
   core.String id;
   /**
+   * User-defined labels for this job. The labels map can contain no more than
+   * 64 entries. Entries of the labels map are UTF8 strings that comply with the
+   * following restrictions: * Keys must conform to regexp: \p{Ll}\p{Lo}{0,62} *
+   * Values must conform to regexp: [\p{Ll}\p{Lo}\p{N}_-]{0,63} * Both keys and
+   * values are additionally constrained to be <= 128 bytes in size.
+   */
+  core.Map<core.String, core.String> labels;
+  /**
    * The user-specified Dataflow job name. Only one Job with a given name may
    * exist in a project at any given time. If a caller attempts to create a Job
    * with the same name as an already-existing Job, the attempt will return the
    * existing Job. The name must match the regular expression
    * [a-z]([-a-z0-9]{0,38}[a-z0-9])?
    */
   core.String name;
   /** The project which owns the job. */
   core.String projectId;
   /**
@@ skipping 67 matching lines @@
     }
     if (_json.containsKey("environment")) {
       environment = new Environment.fromJson(_json["environment"]);
     }
     if (_json.containsKey("executionInfo")) {
       executionInfo = new JobExecutionInfo.fromJson(_json["executionInfo"]);
     }
     if (_json.containsKey("id")) {
       id = _json["id"];
     }
+    if (_json.containsKey("labels")) {
+      labels = _json["labels"];
+    }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
     if (_json.containsKey("projectId")) {
       projectId = _json["projectId"];
     }
     if (_json.containsKey("replaceJobId")) {
       replaceJobId = _json["replaceJobId"];
     }
     if (_json.containsKey("replacedByJobId")) {
@@ skipping 32 matching lines @@
     }
     if (environment != null) {
       _json["environment"] = (environment).toJson();
     }
     if (executionInfo != null) {
       _json["executionInfo"] = (executionInfo).toJson();
     }
     if (id != null) {
       _json["id"] = id;
     }
+    if (labels != null) {
+      _json["labels"] = labels;
+    }
     if (name != null) {
       _json["name"] = name;
     }
     if (projectId != null) {
       _json["projectId"] = projectId;
     }
     if (replaceJobId != null) {
       _json["replaceJobId"] = replaceJobId;
     }
     if (replacedByJobId != null) {
@@ skipping 887 matching lines @@
     return _json;
   }
 }
 
 /** Describes a particular operation comprising a MapTask. */
 class ParallelInstruction {
   /** Additional information for Flatten instructions. */
   FlattenInstruction flatten;
   /** User-provided name of this operation. */
   core.String name;
+  /** System-defined name for the operation in the original workflow graph. */
+  core.String originalName;
   /** Describes the outputs of the instruction. */
   core.List<InstructionOutput> outputs;
   /** Additional information for ParDo instructions. */
   ParDoInstruction parDo;
   /** Additional information for PartialGroupByKey instructions. */
   PartialGroupByKeyInstruction partialGroupByKey;
   /** Additional information for Read instructions. */
   ReadInstruction read;
   /** System-defined name of this operation. Unique across the workflow. */
   core.String systemName;
   /** Additional information for Write instructions. */
   WriteInstruction write;
 
   ParallelInstruction();
 
   ParallelInstruction.fromJson(core.Map _json) {
     if (_json.containsKey("flatten")) {
       flatten = new FlattenInstruction.fromJson(_json["flatten"]);
     }
     if (_json.containsKey("name")) {
       name = _json["name"];
     }
+    if (_json.containsKey("originalName")) {
+      originalName = _json["originalName"];
+    }
     if (_json.containsKey("outputs")) {
       outputs = _json["outputs"].map((value) => new InstructionOutput.fromJson(value)).toList();
     }
     if (_json.containsKey("parDo")) {
       parDo = new ParDoInstruction.fromJson(_json["parDo"]);
     }
     if (_json.containsKey("partialGroupByKey")) {
       partialGroupByKey = new PartialGroupByKeyInstruction.fromJson(_json["partialGroupByKey"]);
     }
     if (_json.containsKey("read")) {
       read = new ReadInstruction.fromJson(_json["read"]);
     }
     if (_json.containsKey("systemName")) {
       systemName = _json["systemName"];
     }
     if (_json.containsKey("write")) {
       write = new WriteInstruction.fromJson(_json["write"]);
     }
   }
 
   core.Map toJson() {
     var _json = new core.Map();
     if (flatten != null) {
       _json["flatten"] = (flatten).toJson();
     }
     if (name != null) {
       _json["name"] = name;
     }
+    if (originalName != null) {
+      _json["originalName"] = originalName;
+    }
     if (outputs != null) {
       _json["outputs"] = outputs.map((value) => (value).toJson()).toList();
     }
     if (parDo != null) {
       _json["parDo"] = (parDo).toJson();
     }
     if (partialGroupByKey != null) {
       _json["partialGroupByKey"] = (partialGroupByKey).toJson();
     }
     if (read != null) {
@@ skipping 15 matching lines @@
 class PartialGroupByKeyInstruction {
   /** Describes the input to the partial group-by-key instruction. */
   InstructionInput input;
   /**
    * The codec to use for interpreting an element in the input PTable.
    *
    * 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;
+  /**
+   * If this instruction includes a combining function this is the name of the
+   * intermediate store between the GBK and the CombineValues.
+   */
+  core.String originalCombineValuesInputStoreName;
+  /**
+   * If this instruction includes a combining function, this is the name of the
+   * CombineValues instruction lifted into this instruction.
+   */
+  core.String originalCombineValuesStepName;
   /** Zero or more side inputs. */
   core.List<SideInputInfo> sideInputs;
   /**
    * The value combining function to invoke.
    *
    * 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("originalCombineValuesInputStoreName")) {
+      originalCombineValuesInputStoreName = _json["originalCombineValuesInputStoreName"];
+    }
+    if (_json.containsKey("originalCombineValuesStepName")) {
+      originalCombineValuesStepName = _json["originalCombineValuesStepName"];
+    }
     if (_json.containsKey("sideInputs")) {
       sideInputs = _json["sideInputs"].map((value) => new SideInputInfo.fromJson(value)).toList();
     }
     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 (originalCombineValuesInputStoreName != null) {
+      _json["originalCombineValuesInputStoreName"] = originalCombineValuesInputStoreName;
+    }
+    if (originalCombineValuesStepName != null) {
+      _json["originalCombineValuesStepName"] = originalCombineValuesStepName;
+    }
     if (sideInputs != null) {
       _json["sideInputs"] = sideInputs.map((value) => (value).toJson()).toList();
     }
     if (valueCombiningFn != null) {
       _json["valueCombiningFn"] = valueCombiningFn;
     }
     return _json;
   }
 }
 
@@ skipping 2792 matching lines @@
     var _json = new core.Map();
     if (input != null) {
       _json["input"] = (input).toJson();
     }
     if (sink != null) {
       _json["sink"] = (sink).toJson();
     }
     return _json;
   }
 }