Packages
google_api_dataflow
0.24.0
0.53.0
0.52.0
0.51.0
0.50.1
0.50.0
0.49.0
0.48.0
0.47.0
0.46.2
0.46.1
0.46.0
0.45.0
0.44.1
0.44.0
0.43.0
0.42.0
0.41.0
0.40.1
0.40.0
0.39.0
0.38.0
0.37.0
0.36.0
0.35.0
0.34.0
0.33.0
0.32.0
0.31.0
0.30.1
0.30.0
0.29.0
0.28.0
0.27.0
0.26.1
0.26.0
0.25.0
0.24.0
0.23.0
0.22.0
0.21.0
0.20.0
0.19.0
0.18.0
0.17.0
0.16.0
0.15.0
0.14.0
0.13.0
0.12.0
0.11.0
0.10.0
0.9.1
0.8.0
0.7.0
0.6.0
0.5.0
0.3.0
0.2.0
0.1.0
0.0.1
Dataflow API client library. Manages Google Cloud Dataflow projects on Google Cloud Platform.
Current section
Files
Jump to
Current section
Files
lib/google_api/dataflow/v1b3/model/map_task.ex
# Copyright 2019 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
# NOTE: This file is auto generated by the elixir code generator program.
# Do not edit this file manually.
defmodule GoogleApi.Dataflow.V1b3.Model.MapTask do
@moduledoc """
MapTask consists of an ordered set of instructions, each of which
describes one particular low-level operation for the worker to
perform in order to accomplish the MapTask's WorkItem.
Each instruction must appear in the list before any instructions which
depends on its output.
## Attributes
* `counterPrefix` (*type:* `String.t`, *default:* `nil`) - Counter prefix that can be used to prefix counters. Not currently used in
Dataflow.
* `instructions` (*type:* `list(GoogleApi.Dataflow.V1b3.Model.ParallelInstruction.t)`, *default:* `nil`) - The instructions in the MapTask.
* `stageName` (*type:* `String.t`, *default:* `nil`) - System-defined name of the stage containing this MapTask.
Unique across the workflow.
* `systemName` (*type:* `String.t`, *default:* `nil`) - System-defined name of this MapTask.
Unique across the workflow.
"""
use GoogleApi.Gax.ModelBase
@type t :: %__MODULE__{
:counterPrefix => String.t(),
:instructions => list(GoogleApi.Dataflow.V1b3.Model.ParallelInstruction.t()),
:stageName => String.t(),
:systemName => String.t()
}
field(:counterPrefix)
field(:instructions, as: GoogleApi.Dataflow.V1b3.Model.ParallelInstruction, type: :list)
field(:stageName)
field(:systemName)
end
defimpl Poison.Decoder, for: GoogleApi.Dataflow.V1b3.Model.MapTask do
def decode(value, options) do
GoogleApi.Dataflow.V1b3.Model.MapTask.decode(value, options)
end
end
defimpl Poison.Encoder, for: GoogleApi.Dataflow.V1b3.Model.MapTask do
def encode(value, options) do
GoogleApi.Gax.ModelBase.encode(value, options)
end
end