dataflow

package
v0.0.0-...-a8a6208 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 10, 2024 License: Apache-2.0 Imports: 2 Imported by: 2

Documentation

Overview

Package dataflow aliases all exported identifiers in package "cloud.google.com/go/dataflow/apiv1beta3/dataflowpb".

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb. Please read https://github.com/googleapis/google-cloud-go/blob/main/migration.md for more details.

Index

Constants

View Source 
const (
	AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC    = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_BASIC
	AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE     = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_NONE
	AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN  = src.AutoscalingAlgorithm_AUTOSCALING_ALGORITHM_UNKNOWN
	AutoscalingEvent_ACTUATION_FAILURE                  = src.AutoscalingEvent_ACTUATION_FAILURE
	AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED        = src.AutoscalingEvent_CURRENT_NUM_WORKERS_CHANGED
	AutoscalingEvent_NO_CHANGE                          = src.AutoscalingEvent_NO_CHANGE
	AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED         = src.AutoscalingEvent_TARGET_NUM_WORKERS_CHANGED
	AutoscalingEvent_TYPE_UNKNOWN                       = src.AutoscalingEvent_TYPE_UNKNOWN
	DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA          = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_JAVA
	DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE          = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_NONE
	DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON        = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_PYTHON
	DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN       = src.DefaultPackageSet_DEFAULT_PACKAGE_SET_UNKNOWN
	ExecutionState_EXECUTION_STATE_CANCELLED            = src.ExecutionState_EXECUTION_STATE_CANCELLED
	ExecutionState_EXECUTION_STATE_FAILED               = src.ExecutionState_EXECUTION_STATE_FAILED
	ExecutionState_EXECUTION_STATE_NOT_STARTED          = src.ExecutionState_EXECUTION_STATE_NOT_STARTED
	ExecutionState_EXECUTION_STATE_RUNNING              = src.ExecutionState_EXECUTION_STATE_RUNNING
	ExecutionState_EXECUTION_STATE_SUCCEEDED            = src.ExecutionState_EXECUTION_STATE_SUCCEEDED
	ExecutionState_EXECUTION_STATE_UNKNOWN              = src.ExecutionState_EXECUTION_STATE_UNKNOWN
	FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED    = src.FlexResourceSchedulingGoal_FLEXRS_COST_OPTIMIZED
	FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED   = src.FlexResourceSchedulingGoal_FLEXRS_SPEED_OPTIMIZED
	FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED       = src.FlexResourceSchedulingGoal_FLEXRS_UNSPECIFIED
	GetTemplateRequest_METADATA_ONLY                    = src.GetTemplateRequest_METADATA_ONLY
	GetTemplateResponse_FLEX                            = src.GetTemplateResponse_FLEX
	GetTemplateResponse_LEGACY                          = src.GetTemplateResponse_LEGACY
	GetTemplateResponse_UNKNOWN                         = src.GetTemplateResponse_UNKNOWN
	JobMessageImportance_JOB_MESSAGE_BASIC              = src.JobMessageImportance_JOB_MESSAGE_BASIC
	JobMessageImportance_JOB_MESSAGE_DEBUG              = src.JobMessageImportance_JOB_MESSAGE_DEBUG
	JobMessageImportance_JOB_MESSAGE_DETAILED           = src.JobMessageImportance_JOB_MESSAGE_DETAILED
	JobMessageImportance_JOB_MESSAGE_ERROR              = src.JobMessageImportance_JOB_MESSAGE_ERROR
	JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN = src.JobMessageImportance_JOB_MESSAGE_IMPORTANCE_UNKNOWN
	JobMessageImportance_JOB_MESSAGE_WARNING            = src.JobMessageImportance_JOB_MESSAGE_WARNING
	JobState_JOB_STATE_CANCELLED                        = src.JobState_JOB_STATE_CANCELLED
	JobState_JOB_STATE_CANCELLING                       = src.JobState_JOB_STATE_CANCELLING
	JobState_JOB_STATE_DONE                             = src.JobState_JOB_STATE_DONE
	JobState_JOB_STATE_DRAINED                          = src.JobState_JOB_STATE_DRAINED
	JobState_JOB_STATE_DRAINING                         = src.JobState_JOB_STATE_DRAINING
	JobState_JOB_STATE_FAILED                           = src.JobState_JOB_STATE_FAILED
	JobState_JOB_STATE_PENDING                          = src.JobState_JOB_STATE_PENDING
	JobState_JOB_STATE_QUEUED                           = src.JobState_JOB_STATE_QUEUED
	JobState_JOB_STATE_RESOURCE_CLEANING_UP             = src.JobState_JOB_STATE_RESOURCE_CLEANING_UP
	JobState_JOB_STATE_RUNNING                          = src.JobState_JOB_STATE_RUNNING
	JobState_JOB_STATE_STOPPED                          = src.JobState_JOB_STATE_STOPPED
	JobState_JOB_STATE_UNKNOWN                          = src.JobState_JOB_STATE_UNKNOWN
	JobState_JOB_STATE_UPDATED                          = src.JobState_JOB_STATE_UPDATED
	JobType_JOB_TYPE_BATCH                              = src.JobType_JOB_TYPE_BATCH
	JobType_JOB_TYPE_STREAMING                          = src.JobType_JOB_TYPE_STREAMING
	JobType_JOB_TYPE_UNKNOWN                            = src.JobType_JOB_TYPE_UNKNOWN
	JobView_JOB_VIEW_ALL                                = src.JobView_JOB_VIEW_ALL
	JobView_JOB_VIEW_DESCRIPTION                        = src.JobView_JOB_VIEW_DESCRIPTION
	JobView_JOB_VIEW_SUMMARY                            = src.JobView_JOB_VIEW_SUMMARY
	JobView_JOB_VIEW_UNKNOWN                            = src.JobView_JOB_VIEW_UNKNOWN
	KindType_CONSTANT_KIND                              = src.KindType_CONSTANT_KIND
	KindType_FLATTEN_KIND                               = src.KindType_FLATTEN_KIND
	KindType_GROUP_BY_KEY_KIND                          = src.KindType_GROUP_BY_KEY_KIND
	KindType_PAR_DO_KIND                                = src.KindType_PAR_DO_KIND
	KindType_READ_KIND                                  = src.KindType_READ_KIND
	KindType_SHUFFLE_KIND                               = src.KindType_SHUFFLE_KIND
	KindType_SINGLETON_KIND                             = src.KindType_SINGLETON_KIND
	KindType_UNKNOWN_KIND                               = src.KindType_UNKNOWN_KIND
	KindType_WRITE_KIND                                 = src.KindType_WRITE_KIND
	ListJobsRequest_ACTIVE                              = src.ListJobsRequest_ACTIVE
	ListJobsRequest_ALL                                 = src.ListJobsRequest_ALL
	ListJobsRequest_TERMINATED                          = src.ListJobsRequest_TERMINATED
	ListJobsRequest_UNKNOWN                             = src.ListJobsRequest_UNKNOWN
	ParameterType_DEFAULT                               = src.ParameterType_DEFAULT
	ParameterType_GCS_READ_BUCKET                       = src.ParameterType_GCS_READ_BUCKET
	ParameterType_GCS_READ_FILE                         = src.ParameterType_GCS_READ_FILE
	ParameterType_GCS_READ_FOLDER                       = src.ParameterType_GCS_READ_FOLDER
	ParameterType_GCS_WRITE_BUCKET                      = src.ParameterType_GCS_WRITE_BUCKET
	ParameterType_GCS_WRITE_FILE                        = src.ParameterType_GCS_WRITE_FILE
	ParameterType_GCS_WRITE_FOLDER                      = src.ParameterType_GCS_WRITE_FOLDER
	ParameterType_PUBSUB_SUBSCRIPTION                   = src.ParameterType_PUBSUB_SUBSCRIPTION
	ParameterType_PUBSUB_TOPIC                          = src.ParameterType_PUBSUB_TOPIC
	ParameterType_TEXT                                  = src.ParameterType_TEXT
	SDKInfo_JAVA                                        = src.SDKInfo_JAVA
	SDKInfo_PYTHON                                      = src.SDKInfo_PYTHON
	SDKInfo_UNKNOWN                                     = src.SDKInfo_UNKNOWN
	SdkVersion_DEPRECATED                               = src.SdkVersion_DEPRECATED
	SdkVersion_STALE                                    = src.SdkVersion_STALE
	SdkVersion_SUPPORTED                                = src.SdkVersion_SUPPORTED
	SdkVersion_UNKNOWN                                  = src.SdkVersion_UNKNOWN
	SdkVersion_UNSUPPORTED                              = src.SdkVersion_UNSUPPORTED
	ShuffleMode_SERVICE_BASED                           = src.ShuffleMode_SERVICE_BASED
	ShuffleMode_SHUFFLE_MODE_UNSPECIFIED                = src.ShuffleMode_SHUFFLE_MODE_UNSPECIFIED
	ShuffleMode_VM_BASED                                = src.ShuffleMode_VM_BASED
	SnapshotState_DELETED                               = src.SnapshotState_DELETED
	SnapshotState_FAILED                                = src.SnapshotState_FAILED
	SnapshotState_PENDING                               = src.SnapshotState_PENDING
	SnapshotState_READY                                 = src.SnapshotState_READY
	SnapshotState_RUNNING                               = src.SnapshotState_RUNNING
	SnapshotState_UNKNOWN_SNAPSHOT_STATE                = src.SnapshotState_UNKNOWN_SNAPSHOT_STATE
	TeardownPolicy_TEARDOWN_ALWAYS                      = src.TeardownPolicy_TEARDOWN_ALWAYS
	TeardownPolicy_TEARDOWN_NEVER                       = src.TeardownPolicy_TEARDOWN_NEVER
	TeardownPolicy_TEARDOWN_ON_SUCCESS                  = src.TeardownPolicy_TEARDOWN_ON_SUCCESS
	TeardownPolicy_TEARDOWN_POLICY_UNKNOWN              = src.TeardownPolicy_TEARDOWN_POLICY_UNKNOWN
	WorkerIPAddressConfiguration_WORKER_IP_PRIVATE      = src.WorkerIPAddressConfiguration_WORKER_IP_PRIVATE
	WorkerIPAddressConfiguration_WORKER_IP_PUBLIC       = src.WorkerIPAddressConfiguration_WORKER_IP_PUBLIC
	WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED  = src.WorkerIPAddressConfiguration_WORKER_IP_UNSPECIFIED
)

Deprecated: Please use consts in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

Variables

View Source 
var (
	AutoscalingAlgorithm_name                      = src.AutoscalingAlgorithm_name
	AutoscalingAlgorithm_value                     = src.AutoscalingAlgorithm_value
	AutoscalingEvent_AutoscalingEventType_name     = src.AutoscalingEvent_AutoscalingEventType_name
	AutoscalingEvent_AutoscalingEventType_value    = src.AutoscalingEvent_AutoscalingEventType_value
	DefaultPackageSet_name                         = src.DefaultPackageSet_name
	DefaultPackageSet_value                        = src.DefaultPackageSet_value
	ExecutionState_name                            = src.ExecutionState_name
	ExecutionState_value                           = src.ExecutionState_value
	File_google_dataflow_v1beta3_environment_proto = src.File_google_dataflow_v1beta3_environment_proto
	File_google_dataflow_v1beta3_jobs_proto        = src.File_google_dataflow_v1beta3_jobs_proto
	File_google_dataflow_v1beta3_messages_proto    = src.File_google_dataflow_v1beta3_messages_proto
	File_google_dataflow_v1beta3_metrics_proto     = src.File_google_dataflow_v1beta3_metrics_proto
	File_google_dataflow_v1beta3_snapshots_proto   = src.File_google_dataflow_v1beta3_snapshots_proto
	File_google_dataflow_v1beta3_streaming_proto   = src.File_google_dataflow_v1beta3_streaming_proto
	File_google_dataflow_v1beta3_templates_proto   = src.File_google_dataflow_v1beta3_templates_proto
	FlexResourceSchedulingGoal_name                = src.FlexResourceSchedulingGoal_name
	FlexResourceSchedulingGoal_value               = src.FlexResourceSchedulingGoal_value
	GetTemplateRequest_TemplateView_name           = src.GetTemplateRequest_TemplateView_name
	GetTemplateRequest_TemplateView_value          = src.GetTemplateRequest_TemplateView_value
	GetTemplateResponse_TemplateType_name          = src.GetTemplateResponse_TemplateType_name
	GetTemplateResponse_TemplateType_value         = src.GetTemplateResponse_TemplateType_value
	JobMessageImportance_name                      = src.JobMessageImportance_name
	JobMessageImportance_value                     = src.JobMessageImportance_value
	JobState_name                                  = src.JobState_name
	JobState_value                                 = src.JobState_value
	JobType_name                                   = src.JobType_name
	JobType_value                                  = src.JobType_value
	JobView_name                                   = src.JobView_name
	JobView_value                                  = src.JobView_value
	KindType_name                                  = src.KindType_name
	KindType_value                                 = src.KindType_value
	ListJobsRequest_Filter_name                    = src.ListJobsRequest_Filter_name
	ListJobsRequest_Filter_value                   = src.ListJobsRequest_Filter_value
	ParameterType_name                             = src.ParameterType_name
	ParameterType_value                            = src.ParameterType_value
	SDKInfo_Language_name                          = src.SDKInfo_Language_name
	SDKInfo_Language_value                         = src.SDKInfo_Language_value
	SdkVersion_SdkSupportStatus_name               = src.SdkVersion_SdkSupportStatus_name
	SdkVersion_SdkSupportStatus_value              = src.SdkVersion_SdkSupportStatus_value
	ShuffleMode_name                               = src.ShuffleMode_name
	ShuffleMode_value                              = src.ShuffleMode_value
	SnapshotState_name                             = src.SnapshotState_name
	SnapshotState_value                            = src.SnapshotState_value
	TeardownPolicy_name                            = src.TeardownPolicy_name
	TeardownPolicy_value                           = src.TeardownPolicy_value
	WorkerIPAddressConfiguration_name              = src.WorkerIPAddressConfiguration_name
	WorkerIPAddressConfiguration_value             = src.WorkerIPAddressConfiguration_value
)

Deprecated: Please use vars in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

Functions

func RegisterFlexTemplatesServiceServer deprecated 

func RegisterFlexTemplatesServiceServer(s *grpc.Server, srv FlexTemplatesServiceServer)

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func RegisterJobsV1Beta3Server deprecated 

func RegisterJobsV1Beta3Server(s *grpc.Server, srv JobsV1Beta3Server)

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func RegisterMessagesV1Beta3Server deprecated 

func RegisterMessagesV1Beta3Server(s *grpc.Server, srv MessagesV1Beta3Server)

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func RegisterMetricsV1Beta3Server deprecated 

func RegisterMetricsV1Beta3Server(s *grpc.Server, srv MetricsV1Beta3Server)

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func RegisterSnapshotsV1Beta3Server deprecated 

func RegisterSnapshotsV1Beta3Server(s *grpc.Server, srv SnapshotsV1Beta3Server)

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func RegisterTemplatesServiceServer deprecated 

func RegisterTemplatesServiceServer(s *grpc.Server, srv TemplatesServiceServer)

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

Types

type AutoscalingAlgorithm deprecated 

type AutoscalingAlgorithm = src.AutoscalingAlgorithm

Specifies the algorithm used to determine the number of worker processes to run at any given point in time, based on the amount of data left to process, the number of workers, and how quickly existing workers are processing data.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type AutoscalingEvent deprecated 

type AutoscalingEvent = src.AutoscalingEvent

A structured message reporting an autoscaling decision made by the Dataflow service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type AutoscalingEvent_AutoscalingEventType deprecated 

type AutoscalingEvent_AutoscalingEventType = src.AutoscalingEvent_AutoscalingEventType

Indicates the type of autoscaling event.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type AutoscalingSettings deprecated 

type AutoscalingSettings = src.AutoscalingSettings

Settings for WorkerPool autoscaling.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type BigQueryIODetails deprecated 

type BigQueryIODetails = src.BigQueryIODetails

Metadata for a BigQuery connector used by the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type BigTableIODetails deprecated 

type BigTableIODetails = src.BigTableIODetails

Metadata for a Cloud Bigtable connector used by the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type CheckActiveJobsRequest deprecated 

type CheckActiveJobsRequest = src.CheckActiveJobsRequest

Request to check is active jobs exists for a project

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type CheckActiveJobsResponse deprecated 

type CheckActiveJobsResponse = src.CheckActiveJobsResponse

Response for CheckActiveJobsRequest.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ComputationTopology deprecated 

type ComputationTopology = src.ComputationTopology

All configuration data for a particular Computation.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ContainerSpec deprecated 

type ContainerSpec = src.ContainerSpec

Container Spec.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type CreateJobFromTemplateRequest deprecated 

type CreateJobFromTemplateRequest = src.CreateJobFromTemplateRequest

A request to create a Cloud Dataflow job from a template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type CreateJobFromTemplateRequest_GcsPath 

type CreateJobFromTemplateRequest_GcsPath = src.CreateJobFromTemplateRequest_GcsPath

type CreateJobRequest deprecated 

type CreateJobRequest = src.CreateJobRequest

Request to create a Cloud Dataflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type CustomSourceLocation deprecated 

type CustomSourceLocation = src.CustomSourceLocation

Identifies the location of a custom souce.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DataDiskAssignment deprecated 

type DataDiskAssignment = src.DataDiskAssignment

Data disk assignment for a given VM instance.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DatastoreIODetails deprecated 

type DatastoreIODetails = src.DatastoreIODetails

Metadata for a Datastore connector used by the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DebugOptions deprecated 

type DebugOptions = src.DebugOptions

Describes any options that have an effect on the debugging of pipelines.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DefaultPackageSet deprecated 

type DefaultPackageSet = src.DefaultPackageSet

The default set of packages to be staged on a pool of workers.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DeleteSnapshotRequest deprecated 

type DeleteSnapshotRequest = src.DeleteSnapshotRequest

Request to delete a snapshot.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DeleteSnapshotResponse deprecated 

type DeleteSnapshotResponse = src.DeleteSnapshotResponse

Response from deleting a snapshot.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type Disk deprecated 

type Disk = src.Disk

Describes the data disk used by a workflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DisplayData deprecated 

type DisplayData = src.DisplayData

Data provided with a pipeline or transform to provide descriptive info.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type DisplayData_BoolValue 

type DisplayData_BoolValue = src.DisplayData_BoolValue

type DisplayData_DurationValue 

type DisplayData_DurationValue = src.DisplayData_DurationValue

type DisplayData_FloatValue 

type DisplayData_FloatValue = src.DisplayData_FloatValue

type DisplayData_Int64Value 

type DisplayData_Int64Value = src.DisplayData_Int64Value

type DisplayData_JavaClassValue 

type DisplayData_JavaClassValue = src.DisplayData_JavaClassValue

type DisplayData_StrValue 

type DisplayData_StrValue = src.DisplayData_StrValue

type DisplayData_TimestampValue 

type DisplayData_TimestampValue = src.DisplayData_TimestampValue

type DynamicTemplateLaunchParams deprecated 

type DynamicTemplateLaunchParams = src.DynamicTemplateLaunchParams

Params which should be passed when launching a dynamic template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type Environment deprecated 

type Environment = src.Environment

Describes the environment in which a Dataflow Job runs.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ExecutionStageState deprecated 

type ExecutionStageState = src.ExecutionStageState

A message describing the state of a particular execution stage.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ExecutionStageSummary deprecated 

type ExecutionStageSummary = src.ExecutionStageSummary

Description of the composing transforms, names/ids, and input/outputs of a stage of execution. Some composing transforms and sources may have been generated by the Dataflow service during execution planning.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ExecutionStageSummary_ComponentSource deprecated 

type ExecutionStageSummary_ComponentSource = src.ExecutionStageSummary_ComponentSource

Description of an interstitial value between transforms in an execution stage.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ExecutionStageSummary_ComponentTransform deprecated 

type ExecutionStageSummary_ComponentTransform = src.ExecutionStageSummary_ComponentTransform

Description of a transform executed as part of an execution stage.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ExecutionStageSummary_StageSource deprecated 

type ExecutionStageSummary_StageSource = src.ExecutionStageSummary_StageSource

Description of an input or output of an execution stage.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ExecutionState deprecated 

type ExecutionState = src.ExecutionState

The state of some component of job execution.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type FailedLocation deprecated 

type FailedLocation = src.FailedLocation

Indicates which [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) failed to respond to a request for data.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type FileIODetails deprecated 

type FileIODetails = src.FileIODetails

Metadata for a File connector used by the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type FlexResourceSchedulingGoal deprecated 

type FlexResourceSchedulingGoal = src.FlexResourceSchedulingGoal

Specifies the resource to optimize for in Flexible Resource Scheduling.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type FlexTemplateRuntimeEnvironment deprecated 

type FlexTemplateRuntimeEnvironment = src.FlexTemplateRuntimeEnvironment

The environment values to be set at runtime for flex template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type FlexTemplatesServiceClient deprecated 

type FlexTemplatesServiceClient = src.FlexTemplatesServiceClient

FlexTemplatesServiceClient is the client API for FlexTemplatesService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func NewFlexTemplatesServiceClient deprecated 

func NewFlexTemplatesServiceClient(cc grpc.ClientConnInterface) FlexTemplatesServiceClient

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type FlexTemplatesServiceServer deprecated 

type FlexTemplatesServiceServer = src.FlexTemplatesServiceServer

FlexTemplatesServiceServer is the server API for FlexTemplatesService service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetJobExecutionDetailsRequest deprecated 

type GetJobExecutionDetailsRequest = src.GetJobExecutionDetailsRequest

Request to get job execution details.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetJobMetricsRequest deprecated 

type GetJobMetricsRequest = src.GetJobMetricsRequest

Request to get job metrics.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetJobRequest deprecated 

type GetJobRequest = src.GetJobRequest

Request to get the state of a Cloud Dataflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetSnapshotRequest deprecated 

type GetSnapshotRequest = src.GetSnapshotRequest

Request to get information about a snapshot

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetStageExecutionDetailsRequest deprecated 

type GetStageExecutionDetailsRequest = src.GetStageExecutionDetailsRequest

Request to get information about a particular execution stage of a job. Currently only tracked for Batch jobs.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetTemplateRequest deprecated 

type GetTemplateRequest = src.GetTemplateRequest

A request to retrieve a Cloud Dataflow job template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetTemplateRequest_GcsPath 

type GetTemplateRequest_GcsPath = src.GetTemplateRequest_GcsPath

type GetTemplateRequest_TemplateView deprecated 

type GetTemplateRequest_TemplateView = src.GetTemplateRequest_TemplateView

The various views of a template that may be retrieved.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetTemplateResponse deprecated 

type GetTemplateResponse = src.GetTemplateResponse

The response to a GetTemplate request.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type GetTemplateResponse_TemplateType deprecated 

type GetTemplateResponse_TemplateType = src.GetTemplateResponse_TemplateType

Template Type.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type InvalidTemplateParameters deprecated 

type InvalidTemplateParameters = src.InvalidTemplateParameters

Used in the error_details field of a google.rpc.Status message, this indicates problems with the template parameter.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type InvalidTemplateParameters_ParameterViolation deprecated 

type InvalidTemplateParameters_ParameterViolation = src.InvalidTemplateParameters_ParameterViolation

A specific template-parameter violation.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type Job deprecated 

type Job = src.Job

Defines a job to be run by the Cloud Dataflow service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobExecutionDetails deprecated 

type JobExecutionDetails = src.JobExecutionDetails

Information about the execution of a job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobExecutionInfo deprecated 

type JobExecutionInfo = src.JobExecutionInfo

Additional information about how a Cloud Dataflow job will be executed that isn't contained in the submitted job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobExecutionStageInfo deprecated 

type JobExecutionStageInfo = src.JobExecutionStageInfo

Contains information about how a particular [google.dataflow.v1beta3.Step][google.dataflow.v1beta3.Step] will be executed.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobMessage deprecated 

type JobMessage = src.JobMessage

A particular message pertaining to a Dataflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobMessageImportance deprecated 

type JobMessageImportance = src.JobMessageImportance

Indicates the importance of the message.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobMetadata deprecated 

type JobMetadata = src.JobMetadata

Metadata available primarily for filtering jobs. Will be included in the ListJob response and Job SUMMARY view.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobMetrics deprecated 

type JobMetrics = src.JobMetrics

JobMetrics contains a collection of metrics describing the detailed progress of a Dataflow job. Metrics correspond to user-defined and system-defined metrics in the job. This resource captures only the most recent values of each metric; time-series data can be queried for them (under the same metric names) from Cloud Monitoring.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobState deprecated 

type JobState = src.JobState

Describes the overall state of a [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job].

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobType deprecated 

type JobType = src.JobType

Specifies the processing model used by a [google.dataflow.v1beta3.Job], which determines the way the Job is managed by the Cloud Dataflow service (how workers are scheduled, how inputs are sharded, etc).

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobView deprecated 

type JobView = src.JobView

Selector for how much information is returned in Job responses.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobsV1Beta3Client deprecated 

type JobsV1Beta3Client = src.JobsV1Beta3Client

JobsV1Beta3Client is the client API for JobsV1Beta3 service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func NewJobsV1Beta3Client deprecated 

func NewJobsV1Beta3Client(cc grpc.ClientConnInterface) JobsV1Beta3Client

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type JobsV1Beta3Server deprecated 

type JobsV1Beta3Server = src.JobsV1Beta3Server

JobsV1Beta3Server is the server API for JobsV1Beta3 service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type KeyRangeDataDiskAssignment deprecated 

type KeyRangeDataDiskAssignment = src.KeyRangeDataDiskAssignment

Data disk assignment information for a specific key-range of a sharded computation. Currently we only support UTF-8 character splits to simplify encoding into JSON.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type KeyRangeLocation deprecated 

type KeyRangeLocation = src.KeyRangeLocation

Location information for a specific key-range of a sharded computation. Currently we only support UTF-8 character splits to simplify encoding into JSON.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type KindType deprecated 

type KindType = src.KindType

Type of transform or stage operation.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type LaunchFlexTemplateParameter deprecated 

type LaunchFlexTemplateParameter = src.LaunchFlexTemplateParameter

Launch FlexTemplate Parameter.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type LaunchFlexTemplateParameter_ContainerSpec 

type LaunchFlexTemplateParameter_ContainerSpec = src.LaunchFlexTemplateParameter_ContainerSpec

type LaunchFlexTemplateParameter_ContainerSpecGcsPath 

type LaunchFlexTemplateParameter_ContainerSpecGcsPath = src.LaunchFlexTemplateParameter_ContainerSpecGcsPath

type LaunchFlexTemplateRequest deprecated 

type LaunchFlexTemplateRequest = src.LaunchFlexTemplateRequest

A request to launch a Cloud Dataflow job from a FlexTemplate.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type LaunchFlexTemplateResponse deprecated 

type LaunchFlexTemplateResponse = src.LaunchFlexTemplateResponse

Response to the request to launch a job from Flex Template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type LaunchTemplateParameters deprecated 

type LaunchTemplateParameters = src.LaunchTemplateParameters

Parameters to provide to the template being launched.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type LaunchTemplateRequest deprecated 

type LaunchTemplateRequest = src.LaunchTemplateRequest

A request to launch a template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type LaunchTemplateRequest_DynamicTemplate 

type LaunchTemplateRequest_DynamicTemplate = src.LaunchTemplateRequest_DynamicTemplate

type LaunchTemplateRequest_GcsPath 

type LaunchTemplateRequest_GcsPath = src.LaunchTemplateRequest_GcsPath

type LaunchTemplateResponse deprecated 

type LaunchTemplateResponse = src.LaunchTemplateResponse

Response to the request to launch a template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListJobMessagesRequest deprecated 

type ListJobMessagesRequest = src.ListJobMessagesRequest

Request to list job messages. Up to max_results messages will be returned in the time range specified starting with the oldest messages first. If no time range is specified the results with start with the oldest message.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListJobMessagesResponse deprecated 

type ListJobMessagesResponse = src.ListJobMessagesResponse

Response to a request to list job messages.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListJobsRequest deprecated 

type ListJobsRequest = src.ListJobsRequest

Request to list Cloud Dataflow jobs.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListJobsRequest_Filter deprecated 

type ListJobsRequest_Filter = src.ListJobsRequest_Filter

This field filters out and returns jobs in the specified job state. The order of data returned is determined by the filter used, and is subject to change.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListJobsResponse deprecated 

type ListJobsResponse = src.ListJobsResponse

Response to a request to list Cloud Dataflow jobs in a project. This might be a partial response, depending on the page size in the ListJobsRequest. However, if the project does not have any jobs, an instance of ListJobsResponse is not returned and the requests's response body is empty {}.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListSnapshotsRequest deprecated 

type ListSnapshotsRequest = src.ListSnapshotsRequest

Request to list snapshots.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ListSnapshotsResponse deprecated 

type ListSnapshotsResponse = src.ListSnapshotsResponse

List of snapshots.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MessagesV1Beta3Client deprecated 

type MessagesV1Beta3Client = src.MessagesV1Beta3Client

MessagesV1Beta3Client is the client API for MessagesV1Beta3 service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func NewMessagesV1Beta3Client deprecated 

func NewMessagesV1Beta3Client(cc grpc.ClientConnInterface) MessagesV1Beta3Client

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MessagesV1Beta3Server deprecated 

type MessagesV1Beta3Server = src.MessagesV1Beta3Server

MessagesV1Beta3Server is the server API for MessagesV1Beta3 service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MetricStructuredName deprecated 

type MetricStructuredName = src.MetricStructuredName

Identifies a metric, by describing the source which generated the metric.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MetricUpdate deprecated 

type MetricUpdate = src.MetricUpdate

Describes the state of a metric.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MetricsV1Beta3Client deprecated 

type MetricsV1Beta3Client = src.MetricsV1Beta3Client

MetricsV1Beta3Client is the client API for MetricsV1Beta3 service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func NewMetricsV1Beta3Client deprecated 

func NewMetricsV1Beta3Client(cc grpc.ClientConnInterface) MetricsV1Beta3Client

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MetricsV1Beta3Server deprecated 

type MetricsV1Beta3Server = src.MetricsV1Beta3Server

MetricsV1Beta3Server is the server API for MetricsV1Beta3 service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type MountedDataDisk deprecated 

type MountedDataDisk = src.MountedDataDisk

Describes mounted data disk.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type Package deprecated 

type Package = src.Package

The packages that must be installed in order for a worker to run the steps of the Cloud Dataflow job that will be assigned to its worker pool. This is the mechanism by which the Cloud Dataflow SDK causes code to be loaded onto the workers. For example, the Cloud Dataflow Java SDK might use this to install jars containing the user's code and all of the various dependencies (libraries, data files, etc.) required in order for that code to run.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ParameterMetadata deprecated 

type ParameterMetadata = src.ParameterMetadata

Metadata for a specific parameter.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ParameterType deprecated 

type ParameterType = src.ParameterType

ParameterType specifies what kind of input we need for this parameter.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type PipelineDescription deprecated 

type PipelineDescription = src.PipelineDescription

A descriptive representation of submitted pipeline as well as the executed form. This data is provided by the Dataflow service for ease of visualizing the pipeline and interpreting Dataflow provided metrics.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ProgressTimeseries deprecated 

type ProgressTimeseries = src.ProgressTimeseries

Information about the progress of some component of job execution.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ProgressTimeseries_Point deprecated 

type ProgressTimeseries_Point = src.ProgressTimeseries_Point

A point in the timeseries.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type PubSubIODetails deprecated 

type PubSubIODetails = src.PubSubIODetails

Metadata for a Pub/Sub connector used by the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type PubsubLocation deprecated 

type PubsubLocation = src.PubsubLocation

Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type PubsubSnapshotMetadata deprecated 

type PubsubSnapshotMetadata = src.PubsubSnapshotMetadata

Represents a Pubsub snapshot.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type RuntimeEnvironment deprecated 

type RuntimeEnvironment = src.RuntimeEnvironment

The environment values to set at runtime.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type RuntimeMetadata deprecated 

type RuntimeMetadata = src.RuntimeMetadata

RuntimeMetadata describing a runtime environment.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SDKInfo deprecated 

type SDKInfo = src.SDKInfo

SDK Information.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SDKInfo_Language deprecated 

type SDKInfo_Language = src.SDKInfo_Language

SDK Language.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SdkHarnessContainerImage deprecated 

type SdkHarnessContainerImage = src.SdkHarnessContainerImage

Defines a SDK harness container for executing Dataflow pipelines.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SdkVersion deprecated 

type SdkVersion = src.SdkVersion

The version of the SDK used to run the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SdkVersion_SdkSupportStatus deprecated 

type SdkVersion_SdkSupportStatus = src.SdkVersion_SdkSupportStatus

The support status of the SDK used to run the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type ShuffleMode deprecated 

type ShuffleMode = src.ShuffleMode

Specifies the shuffle mode used by a [google.dataflow.v1beta3.Job], which determines the approach data is shuffled during processing. More details in: https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-shuffle

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type Snapshot deprecated 

type Snapshot = src.Snapshot

Represents a snapshot of a job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SnapshotJobRequest deprecated 

type SnapshotJobRequest = src.SnapshotJobRequest

Request to create a snapshot of a job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SnapshotState deprecated 

type SnapshotState = src.SnapshotState

Snapshot state.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SnapshotsV1Beta3Client deprecated 

type SnapshotsV1Beta3Client = src.SnapshotsV1Beta3Client

SnapshotsV1Beta3Client is the client API for SnapshotsV1Beta3 service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func NewSnapshotsV1Beta3Client deprecated 

func NewSnapshotsV1Beta3Client(cc grpc.ClientConnInterface) SnapshotsV1Beta3Client

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SnapshotsV1Beta3Server deprecated 

type SnapshotsV1Beta3Server = src.SnapshotsV1Beta3Server

SnapshotsV1Beta3Server is the server API for SnapshotsV1Beta3 service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type SpannerIODetails deprecated 

type SpannerIODetails = src.SpannerIODetails

Metadata for a Spanner connector used by the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StageExecutionDetails deprecated 

type StageExecutionDetails = src.StageExecutionDetails

Information about the workers and work items within a stage.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StageSummary deprecated 

type StageSummary = src.StageSummary

Information about a particular execution stage of a job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StateFamilyConfig deprecated 

type StateFamilyConfig = src.StateFamilyConfig

State family configuration.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type Step deprecated 

type Step = src.Step

Defines a particular step within a Cloud Dataflow job. A job consists of multiple steps, each of which performs some specific operation as part of the overall job. Data is typically passed from one step to another as part of the job. Here's an example of a sequence of steps which together implement a Map-Reduce job: - Read a collection of data from some source, parsing the collection's elements. - Validate the elements. - Apply a user-defined function to map each element to some value and extract an element-specific key value. - Group elements with the same key into a single element with that key, transforming a multiply-keyed collection into a uniquely-keyed collection. - Write the elements out to some data sink. Note that the Cloud Dataflow service may be used to run many different types of jobs, not just Map-Reduce.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StreamLocation deprecated 

type StreamLocation = src.StreamLocation

Describes a stream of data, either as input to be processed or as output of a streaming Dataflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StreamLocation_CustomSourceLocation 

type StreamLocation_CustomSourceLocation = src.StreamLocation_CustomSourceLocation

type StreamLocation_PubsubLocation 

type StreamLocation_PubsubLocation = src.StreamLocation_PubsubLocation

type StreamLocation_SideInputLocation 

type StreamLocation_SideInputLocation = src.StreamLocation_SideInputLocation

type StreamLocation_StreamingStageLocation 

type StreamLocation_StreamingStageLocation = src.StreamLocation_StreamingStageLocation

type StreamingApplianceSnapshotConfig deprecated 

type StreamingApplianceSnapshotConfig = src.StreamingApplianceSnapshotConfig

Streaming appliance snapshot configuration.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StreamingComputationRanges deprecated 

type StreamingComputationRanges = src.StreamingComputationRanges

Describes full or partial data disk assignment information of the computation ranges.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StreamingSideInputLocation deprecated 

type StreamingSideInputLocation = src.StreamingSideInputLocation

Identifies the location of a streaming side input.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StreamingStageLocation deprecated 

type StreamingStageLocation = src.StreamingStageLocation

Identifies the location of a streaming computation stage, for stage-to-stage communication.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StructuredMessage deprecated 

type StructuredMessage = src.StructuredMessage

A rich message format, including a human readable string, a key for identifying the message, and structured data associated with the message for programmatic consumption.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type StructuredMessage_Parameter deprecated 

type StructuredMessage_Parameter = src.StructuredMessage_Parameter

Structured data associated with this message.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TaskRunnerSettings deprecated 

type TaskRunnerSettings = src.TaskRunnerSettings

Taskrunner configuration settings.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TeardownPolicy deprecated 

type TeardownPolicy = src.TeardownPolicy

Specifies what happens to a resource when a Cloud Dataflow [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job] has completed.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TemplateMetadata deprecated 

type TemplateMetadata = src.TemplateMetadata

Metadata describing a template.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TemplatesServiceClient deprecated 

type TemplatesServiceClient = src.TemplatesServiceClient

TemplatesServiceClient is the client API for TemplatesService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

func NewTemplatesServiceClient deprecated 

func NewTemplatesServiceClient(cc grpc.ClientConnInterface) TemplatesServiceClient

Deprecated: Please use funcs in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TemplatesServiceServer deprecated 

type TemplatesServiceServer = src.TemplatesServiceServer

TemplatesServiceServer is the server API for TemplatesService service.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TopologyConfig deprecated 

type TopologyConfig = src.TopologyConfig

Global topology of the streaming Dataflow job, including all computations and their sharded locations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type TransformSummary deprecated 

type TransformSummary = src.TransformSummary

Description of the type, names/ids, and input/outputs for a transform.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UnimplementedFlexTemplatesServiceServer deprecated 

type UnimplementedFlexTemplatesServiceServer = src.UnimplementedFlexTemplatesServiceServer

UnimplementedFlexTemplatesServiceServer can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UnimplementedJobsV1Beta3Server deprecated 

type UnimplementedJobsV1Beta3Server = src.UnimplementedJobsV1Beta3Server

UnimplementedJobsV1Beta3Server can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UnimplementedMessagesV1Beta3Server deprecated 

type UnimplementedMessagesV1Beta3Server = src.UnimplementedMessagesV1Beta3Server

UnimplementedMessagesV1Beta3Server can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UnimplementedMetricsV1Beta3Server deprecated 

type UnimplementedMetricsV1Beta3Server = src.UnimplementedMetricsV1Beta3Server

UnimplementedMetricsV1Beta3Server can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UnimplementedSnapshotsV1Beta3Server deprecated 

type UnimplementedSnapshotsV1Beta3Server = src.UnimplementedSnapshotsV1Beta3Server

UnimplementedSnapshotsV1Beta3Server can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UnimplementedTemplatesServiceServer deprecated 

type UnimplementedTemplatesServiceServer = src.UnimplementedTemplatesServiceServer

UnimplementedTemplatesServiceServer can be embedded to have forward compatible implementations.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type UpdateJobRequest deprecated 

type UpdateJobRequest = src.UpdateJobRequest

Request to update a Cloud Dataflow job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type WorkItemDetails deprecated 

type WorkItemDetails = src.WorkItemDetails

Information about an individual work item execution.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type WorkerDetails deprecated 

type WorkerDetails = src.WorkerDetails

Information about a worker

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type WorkerIPAddressConfiguration deprecated 

type WorkerIPAddressConfiguration = src.WorkerIPAddressConfiguration

Specifies how IP addresses should be allocated to the worker machines.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type WorkerPool deprecated 

type WorkerPool = src.WorkerPool

Describes one particular pool of Cloud Dataflow workers to be instantiated by the Cloud Dataflow service in order to perform the computations required by a job. Note that a workflow job may use multiple pools, in order to match the various computational requirements of the various stages of the job.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

type WorkerSettings deprecated 

type WorkerSettings = src.WorkerSettings

Provides data to pass through to the worker harness.

Deprecated: Please use types in: cloud.google.com/go/dataflow/apiv1beta3/dataflowpb

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.