google_api_dataflow

v0.7.0

google_api_dataflow v0.7.0 GoogleApi.Dataflow.V1b3.Model.WorkItem View Source

WorkItem represents basic information about a WorkItem to be executed in the cloud.

Attributes

  • configuration (String.t): Work item-specific configuration as an opaque blob. Defaults to: null.
  • id (String.t): Identifies this WorkItem. Defaults to: null.
  • initialReportIndex (String.t): The initial index to use when reporting the status of the WorkItem. Defaults to: null.
  • jobId (String.t): Identifies the workflow job this WorkItem belongs to. Defaults to: null.
  • leaseExpireTime (DateTime.t): Time when the lease on this Work will expire. Defaults to: null.
  • mapTask (MapTask): Additional information for MapTask WorkItems. Defaults to: null.
  • packages ([Package]): Any required packages that need to be fetched in order to execute this WorkItem. Defaults to: null.
  • projectId (String.t): Identifies the cloud project this WorkItem belongs to. Defaults to: null.
  • reportStatusInterval (String.t): Recommended reporting interval. Defaults to: null.
  • seqMapTask (SeqMapTask): Additional information for SeqMapTask WorkItems. Defaults to: null.
  • shellTask (ShellTask): Additional information for ShellTask WorkItems. Defaults to: null.
  • sourceOperationTask (SourceOperationRequest): Additional information for source operation WorkItems. Defaults to: null.
  • streamingComputationTask (StreamingComputationTask): Additional information for StreamingComputationTask WorkItems. Defaults to: null.
  • streamingConfigTask (StreamingConfigTask): Additional information for StreamingConfigTask WorkItems. Defaults to: null.
  • streamingSetupTask (StreamingSetupTask): Additional information for StreamingSetupTask WorkItems. Defaults to: null.

Link to this section Summary

Types

t()

Functions

decode(value, options)

Unwrap a decoded JSON object into its complex fields.

Link to this section Types

Link to this type

t() View Source 
t() :: %GoogleApi.Dataflow.V1b3.Model.WorkItem{
  configuration: any(),
  id: any(),
  initialReportIndex: any(),
  jobId: any(),
  leaseExpireTime: DateTime.t(),
  mapTask: GoogleApi.Dataflow.V1b3.Model.MapTask.t(),
  packages: [GoogleApi.Dataflow.V1b3.Model.Package.t()],
  projectId: any(),
  reportStatusInterval: any(),
  seqMapTask: GoogleApi.Dataflow.V1b3.Model.SeqMapTask.t(),
  shellTask: GoogleApi.Dataflow.V1b3.Model.ShellTask.t(),
  sourceOperationTask: GoogleApi.Dataflow.V1b3.Model.SourceOperationRequest.t(),
  streamingComputationTask:
    GoogleApi.Dataflow.V1b3.Model.StreamingComputationTask.t(),
  streamingConfigTask: GoogleApi.Dataflow.V1b3.Model.StreamingConfigTask.t(),
  streamingSetupTask: GoogleApi.Dataflow.V1b3.Model.StreamingSetupTask.t()
}

Link to this section Functions

Link to this function

decode(value, options) View Source 
decode(struct(), keyword()) :: struct()

Unwrap a decoded JSON object into its complex fields.