| Index: generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| diff --git a/generated/googleapis_beta/lib/dataflow/v1b3.dart b/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| index c75c610c889756283870f1e507f4fa4540ee45a5..cb80a07271b2d0e1ee6b51297a7098aaf072c809 100644
|
| --- a/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| +++ b/generated/googleapis_beta/lib/dataflow/v1b3.dart
|
| @@ -1659,6 +1659,21 @@ class InstructionOutput {
|
| 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;
|
|
|
| @@ -1671,6 +1686,15 @@ class InstructionOutput {
|
| 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"];
|
| }
|
| @@ -1684,6 +1708,15 @@ class InstructionOutput {
|
| 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;
|
| }
|
| @@ -1790,6 +1823,14 @@ class 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
|
| @@ -1877,6 +1918,9 @@ class Job {
|
| if (_json.containsKey("id")) {
|
| id = _json["id"];
|
| }
|
| + if (_json.containsKey("labels")) {
|
| + labels = _json["labels"];
|
| + }
|
| if (_json.containsKey("name")) {
|
| name = _json["name"];
|
| }
|
| @@ -1929,6 +1973,9 @@ class Job {
|
| if (id != null) {
|
| _json["id"] = id;
|
| }
|
| + if (labels != null) {
|
| + _json["labels"] = labels;
|
| + }
|
| if (name != null) {
|
| _json["name"] = name;
|
| }
|
| @@ -2836,6 +2883,8 @@ class ParallelInstruction {
|
| 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. */
|
| @@ -2858,6 +2907,9 @@ class ParallelInstruction {
|
| 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();
|
| }
|
| @@ -2886,6 +2938,9 @@ class ParallelInstruction {
|
| if (name != null) {
|
| _json["name"] = name;
|
| }
|
| + if (originalName != null) {
|
| + _json["originalName"] = originalName;
|
| + }
|
| if (outputs != null) {
|
| _json["outputs"] = outputs.map((value) => (value).toJson()).toList();
|
| }
|
| @@ -2921,6 +2976,16 @@ class PartialGroupByKeyInstruction {
|
| * `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;
|
| /**
|
| @@ -2940,6 +3005,12 @@ class PartialGroupByKeyInstruction {
|
| 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();
|
| }
|
| @@ -2956,6 +3027,12 @@ class PartialGroupByKeyInstruction {
|
| 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();
|
| }
|
|
|