pipeline_v1

package
Version: v2.34.0-RC1 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	BeamConstants_Constants_name = map[int32]string{
		0: "MIN_TIMESTAMP_MILLIS",
		1: "MAX_TIMESTAMP_MILLIS",
		2: "GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS",
	}
	BeamConstants_Constants_value = map[string]int32{
		"MIN_TIMESTAMP_MILLIS":               0,
		"MAX_TIMESTAMP_MILLIS":               1,
		"GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS": 2,
	}
)

Enum value maps for BeamConstants_Constants.

View Source
var (
	StandardPTransforms_Primitives_name = map[int32]string{
		0: "PAR_DO",
		1: "FLATTEN",
		2: "GROUP_BY_KEY",
		3: "IMPULSE",
		4: "ASSIGN_WINDOWS",
		5: "TEST_STREAM",
		6: "MAP_WINDOWS",
		7: "MERGE_WINDOWS",
		8: "TO_STRING",
	}
	StandardPTransforms_Primitives_value = map[string]int32{
		"PAR_DO":         0,
		"FLATTEN":        1,
		"GROUP_BY_KEY":   2,
		"IMPULSE":        3,
		"ASSIGN_WINDOWS": 4,
		"TEST_STREAM":    5,
		"MAP_WINDOWS":    6,
		"MERGE_WINDOWS":  7,
		"TO_STRING":      8,
	}
)

Enum value maps for StandardPTransforms_Primitives.

View Source
var (
	StandardPTransforms_DeprecatedPrimitives_name = map[int32]string{
		0: "READ",
		1: "CREATE_VIEW",
	}
	StandardPTransforms_DeprecatedPrimitives_value = map[string]int32{
		"READ":        0,
		"CREATE_VIEW": 1,
	}
)

Enum value maps for StandardPTransforms_DeprecatedPrimitives.

View Source
var (
	StandardPTransforms_Composites_name = map[int32]string{
		0: "COMBINE_PER_KEY",
		1: "COMBINE_GLOBALLY",
		2: "RESHUFFLE",
		3: "WRITE_FILES",
		4: "PUBSUB_READ",
		5: "PUBSUB_WRITE",
		6: "GROUP_INTO_BATCHES_WITH_SHARDED_KEY",
	}
	StandardPTransforms_Composites_value = map[string]int32{
		"COMBINE_PER_KEY":                     0,
		"COMBINE_GLOBALLY":                    1,
		"RESHUFFLE":                           2,
		"WRITE_FILES":                         3,
		"PUBSUB_READ":                         4,
		"PUBSUB_WRITE":                        5,
		"GROUP_INTO_BATCHES_WITH_SHARDED_KEY": 6,
	}
)

Enum value maps for StandardPTransforms_Composites.

View Source
var (
	StandardPTransforms_CombineComponents_name = map[int32]string{
		0: "COMBINE_PER_KEY_PRECOMBINE",
		1: "COMBINE_PER_KEY_MERGE_ACCUMULATORS",
		2: "COMBINE_PER_KEY_EXTRACT_OUTPUTS",
		3: "COMBINE_GROUPED_VALUES",
		4: "COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS",
	}
	StandardPTransforms_CombineComponents_value = map[string]int32{
		"COMBINE_PER_KEY_PRECOMBINE":              0,
		"COMBINE_PER_KEY_MERGE_ACCUMULATORS":      1,
		"COMBINE_PER_KEY_EXTRACT_OUTPUTS":         2,
		"COMBINE_GROUPED_VALUES":                  3,
		"COMBINE_PER_KEY_CONVERT_TO_ACCUMULATORS": 4,
	}
)

Enum value maps for StandardPTransforms_CombineComponents.

View Source
var (
	StandardPTransforms_SplittableParDoComponents_name = map[int32]string{
		0: "PAIR_WITH_RESTRICTION",
		1: "SPLIT_AND_SIZE_RESTRICTIONS",
		2: "PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS",
		3: "TRUNCATE_SIZED_RESTRICTION",
	}
	StandardPTransforms_SplittableParDoComponents_value = map[string]int32{
		"PAIR_WITH_RESTRICTION":                   0,
		"SPLIT_AND_SIZE_RESTRICTIONS":             1,
		"PROCESS_SIZED_ELEMENTS_AND_RESTRICTIONS": 2,
		"TRUNCATE_SIZED_RESTRICTION":              3,
	}
)

Enum value maps for StandardPTransforms_SplittableParDoComponents.

View Source
var (
	StandardPTransforms_GroupIntoBatchesComponents_name = map[int32]string{
		0: "GROUP_INTO_BATCHES",
	}
	StandardPTransforms_GroupIntoBatchesComponents_value = map[string]int32{
		"GROUP_INTO_BATCHES": 0,
	}
)

Enum value maps for StandardPTransforms_GroupIntoBatchesComponents.

View Source
var (
	StandardSideInputTypes_Enum_name = map[int32]string{
		0: "ITERABLE",
		1: "MULTIMAP",
	}
	StandardSideInputTypes_Enum_value = map[string]int32{
		"ITERABLE": 0,
		"MULTIMAP": 1,
	}
)

Enum value maps for StandardSideInputTypes_Enum.

View Source
var (
	IsBounded_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "UNBOUNDED",
		2: "BOUNDED",
	}
	IsBounded_Enum_value = map[string]int32{
		"UNSPECIFIED": 0,
		"UNBOUNDED":   1,
		"BOUNDED":     2,
	}
)

Enum value maps for IsBounded_Enum.

View Source
var (
	StandardCoders_Enum_name = map[int32]string{
		0:  "BYTES",
		10: "STRING_UTF8",
		1:  "KV",
		12: "BOOL",
		2:  "VARINT",
		11: "DOUBLE",
		3:  "ITERABLE",
		4:  "TIMER",
		5:  "INTERVAL_WINDOW",
		6:  "LENGTH_PREFIX",
		7:  "GLOBAL_WINDOW",
		8:  "WINDOWED_VALUE",
		14: "PARAM_WINDOWED_VALUE",
		9:  "STATE_BACKED_ITERABLE",
		16: "CUSTOM_WINDOW",
		13: "ROW",
		15: "SHARDED_KEY",
	}
	StandardCoders_Enum_value = map[string]int32{
		"BYTES":                 0,
		"STRING_UTF8":           10,
		"KV":                    1,
		"BOOL":                  12,
		"VARINT":                2,
		"DOUBLE":                11,
		"ITERABLE":              3,
		"TIMER":                 4,
		"INTERVAL_WINDOW":       5,
		"LENGTH_PREFIX":         6,
		"GLOBAL_WINDOW":         7,
		"WINDOWED_VALUE":        8,
		"PARAM_WINDOWED_VALUE":  14,
		"STATE_BACKED_ITERABLE": 9,
		"CUSTOM_WINDOW":         16,
		"ROW":                   13,
		"SHARDED_KEY":           15,
	}
)

Enum value maps for StandardCoders_Enum.

View Source
var (
	MergeStatus_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "NON_MERGING",
		2: "NEEDS_MERGE",
		3: "ALREADY_MERGED",
	}
	MergeStatus_Enum_value = map[string]int32{
		"UNSPECIFIED":    0,
		"NON_MERGING":    1,
		"NEEDS_MERGE":    2,
		"ALREADY_MERGED": 3,
	}
)

Enum value maps for MergeStatus_Enum.

View Source
var (
	AccumulationMode_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "DISCARDING",
		2: "ACCUMULATING",
		3: "RETRACTING",
	}
	AccumulationMode_Enum_value = map[string]int32{
		"UNSPECIFIED":  0,
		"DISCARDING":   1,
		"ACCUMULATING": 2,
		"RETRACTING":   3,
	}
)

Enum value maps for AccumulationMode_Enum.

View Source
var (
	ClosingBehavior_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "EMIT_ALWAYS",
		2: "EMIT_IF_NONEMPTY",
	}
	ClosingBehavior_Enum_value = map[string]int32{
		"UNSPECIFIED":      0,
		"EMIT_ALWAYS":      1,
		"EMIT_IF_NONEMPTY": 2,
	}
)

Enum value maps for ClosingBehavior_Enum.

View Source
var (
	OnTimeBehavior_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "FIRE_ALWAYS",
		2: "FIRE_IF_NONEMPTY",
	}
	OnTimeBehavior_Enum_value = map[string]int32{
		"UNSPECIFIED":      0,
		"FIRE_ALWAYS":      1,
		"FIRE_IF_NONEMPTY": 2,
	}
)

Enum value maps for OnTimeBehavior_Enum.

View Source
var (
	OutputTime_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "END_OF_WINDOW",
		2: "LATEST_IN_PANE",
		3: "EARLIEST_IN_PANE",
	}
	OutputTime_Enum_value = map[string]int32{
		"UNSPECIFIED":      0,
		"END_OF_WINDOW":    1,
		"LATEST_IN_PANE":   2,
		"EARLIEST_IN_PANE": 3,
	}
)

Enum value maps for OutputTime_Enum.

View Source
var (
	TimeDomain_Enum_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "EVENT_TIME",
		2: "PROCESSING_TIME",
	}
	TimeDomain_Enum_value = map[string]int32{
		"UNSPECIFIED":     0,
		"EVENT_TIME":      1,
		"PROCESSING_TIME": 2,
	}
)

Enum value maps for TimeDomain_Enum.

View Source
var (
	StandardArtifacts_Types_name = map[int32]string{
		0: "FILE",
		1: "URL",
		2: "EMBEDDED",
		3: "PYPI",
		4: "MAVEN",
		5: "DEFERRED",
	}
	StandardArtifacts_Types_value = map[string]int32{
		"FILE":     0,
		"URL":      1,
		"EMBEDDED": 2,
		"PYPI":     3,
		"MAVEN":    4,
		"DEFERRED": 5,
	}
)

Enum value maps for StandardArtifacts_Types.

View Source
var (
	StandardArtifacts_Roles_name = map[int32]string{
		0: "STAGING_TO",
		1: "PIP_REQUIREMENTS_FILE",
	}
	StandardArtifacts_Roles_value = map[string]int32{
		"STAGING_TO":            0,
		"PIP_REQUIREMENTS_FILE": 1,
	}
)

Enum value maps for StandardArtifacts_Roles.

View Source
var (
	StandardEnvironments_Environments_name = map[int32]string{
		0: "DOCKER",
		1: "PROCESS",
		2: "EXTERNAL",
		3: "DEFAULT",
	}
	StandardEnvironments_Environments_value = map[string]int32{
		"DOCKER":   0,
		"PROCESS":  1,
		"EXTERNAL": 2,
		"DEFAULT":  3,
	}
)

Enum value maps for StandardEnvironments_Environments.

View Source
var (
	StandardProtocols_Enum_name = map[int32]string{
		0: "LEGACY_PROGRESS_REPORTING",
		1: "PROGRESS_REPORTING",
		2: "WORKER_STATUS",
		3: "MULTI_CORE_BUNDLE_PROCESSING",
		4: "HARNESS_MONITORING_INFOS",
	}
	StandardProtocols_Enum_value = map[string]int32{
		"LEGACY_PROGRESS_REPORTING":    0,
		"PROGRESS_REPORTING":           1,
		"WORKER_STATUS":                2,
		"MULTI_CORE_BUNDLE_PROCESSING": 3,
		"HARNESS_MONITORING_INFOS":     4,
	}
)

Enum value maps for StandardProtocols_Enum.

View Source
var (
	StandardRunnerProtocols_Enum_name = map[int32]string{
		0: "MONITORING_INFO_SHORT_IDS",
	}
	StandardRunnerProtocols_Enum_value = map[string]int32{
		"MONITORING_INFO_SHORT_IDS": 0,
	}
)

Enum value maps for StandardRunnerProtocols_Enum.

View Source
var (
	StandardRequirements_Enum_name = map[int32]string{
		0: "REQUIRES_STATEFUL_PROCESSING",
		1: "REQUIRES_BUNDLE_FINALIZATION",
		2: "REQUIRES_STABLE_INPUT",
		3: "REQUIRES_TIME_SORTED_INPUT",
		4: "REQUIRES_SPLITTABLE_DOFN",
	}
	StandardRequirements_Enum_value = map[string]int32{
		"REQUIRES_STATEFUL_PROCESSING": 0,
		"REQUIRES_BUNDLE_FINALIZATION": 1,
		"REQUIRES_STABLE_INPUT":        2,
		"REQUIRES_TIME_SORTED_INPUT":   3,
		"REQUIRES_SPLITTABLE_DOFN":     4,
	}
)

Enum value maps for StandardRequirements_Enum.

View Source
var (
	StandardDisplayData_DisplayData_name = map[int32]string{
		0: "LABELLED",
	}
	StandardDisplayData_DisplayData_value = map[string]int32{
		"LABELLED": 0,
	}
)

Enum value maps for StandardDisplayData_DisplayData.

View Source
var (
	StandardResourceHints_Enum_name = map[int32]string{
		0: "ACCELERATOR",
		1: "MIN_RAM_BYTES",
	}
	StandardResourceHints_Enum_value = map[string]int32{
		"ACCELERATOR":   0,
		"MIN_RAM_BYTES": 1,
	}
)

Enum value maps for StandardResourceHints_Enum.

View Source
var (
	// An extension to be used for specifying the standard URN of various
	// pipeline entities, e.g. transforms, functions, coders etc.
	// Code should refer to the URNs of those entities by extracting
	// it from the (beam_urn) extension, rather than by hard-coding
	// the URN.
	//
	// The recommended pattern for declaring it is (exemplified by coders):
	//
	// message StandardCoders {
	//   enum Enum {
	//     BYTES = 0 [(beam_urn) = "beam:coder:bytes:v1"];
	//     ...
	//   }
	// }
	//
	// If there are multiple categories of entities of this type, use the
	// following pattern (exemplified by PTransforms):
	//
	// message StandardPTransforms {
	//   enum Primitives {
	//     ...
	//   }
	//   enum Composites {
	//     ...
	//   }
	// }
	//
	// optional string beam_urn = 185324356;
	E_BeamUrn = &file_beam_runner_api_proto_extTypes[0]
	// A value to store other constants
	//
	// optional string beam_constant = 185324357;
	E_BeamConstant = &file_beam_runner_api_proto_extTypes[1]
)

Extension fields to descriptorpb.EnumValueOptions.

View Source
var (
	MonitoringInfoSpecs_Enum_name = map[int32]string{
		0:  "USER_SUM_INT64",
		1:  "USER_SUM_DOUBLE",
		2:  "USER_DISTRIBUTION_INT64",
		3:  "USER_DISTRIBUTION_DOUBLE",
		4:  "USER_LATEST_INT64",
		5:  "USER_LATEST_DOUBLE",
		6:  "USER_TOP_N_INT64",
		7:  "USER_TOP_N_DOUBLE",
		8:  "USER_BOTTOM_N_INT64",
		9:  "USER_BOTTOM_N_DOUBLE",
		10: "ELEMENT_COUNT",
		11: "SAMPLED_BYTE_SIZE",
		12: "START_BUNDLE_MSECS",
		13: "PROCESS_BUNDLE_MSECS",
		14: "FINISH_BUNDLE_MSECS",
		15: "TOTAL_MSECS",
		16: "WORK_REMAINING",
		17: "WORK_COMPLETED",
		18: "DATA_CHANNEL_READ_INDEX",
		19: "API_REQUEST_COUNT",
		20: "API_REQUEST_LATENCIES",
	}
	MonitoringInfoSpecs_Enum_value = map[string]int32{
		"USER_SUM_INT64":           0,
		"USER_SUM_DOUBLE":          1,
		"USER_DISTRIBUTION_INT64":  2,
		"USER_DISTRIBUTION_DOUBLE": 3,
		"USER_LATEST_INT64":        4,
		"USER_LATEST_DOUBLE":       5,
		"USER_TOP_N_INT64":         6,
		"USER_TOP_N_DOUBLE":        7,
		"USER_BOTTOM_N_INT64":      8,
		"USER_BOTTOM_N_DOUBLE":     9,
		"ELEMENT_COUNT":            10,
		"SAMPLED_BYTE_SIZE":        11,
		"START_BUNDLE_MSECS":       12,
		"PROCESS_BUNDLE_MSECS":     13,
		"FINISH_BUNDLE_MSECS":      14,
		"TOTAL_MSECS":              15,
		"WORK_REMAINING":           16,
		"WORK_COMPLETED":           17,
		"DATA_CHANNEL_READ_INDEX":  18,
		"API_REQUEST_COUNT":        19,
		"API_REQUEST_LATENCIES":    20,
	}
)

Enum value maps for MonitoringInfoSpecs_Enum.

View Source
var (
	MonitoringInfo_MonitoringInfoLabels_name = map[int32]string{
		0:  "TRANSFORM",
		1:  "PCOLLECTION",
		2:  "WINDOWING_STRATEGY",
		3:  "CODER",
		4:  "ENVIRONMENT",
		5:  "NAMESPACE",
		6:  "NAME",
		7:  "SERVICE",
		8:  "METHOD",
		9:  "RESOURCE",
		10: "STATUS",
		11: "BIGQUERY_PROJECT_ID",
		12: "BIGQUERY_DATASET",
		13: "BIGQUERY_TABLE",
		14: "BIGQUERY_VIEW",
		15: "BIGQUERY_QUERY_NAME",
		16: "GCS_BUCKET",
		17: "GCS_PROJECT_ID",
	}
	MonitoringInfo_MonitoringInfoLabels_value = map[string]int32{
		"TRANSFORM":           0,
		"PCOLLECTION":         1,
		"WINDOWING_STRATEGY":  2,
		"CODER":               3,
		"ENVIRONMENT":         4,
		"NAMESPACE":           5,
		"NAME":                6,
		"SERVICE":             7,
		"METHOD":              8,
		"RESOURCE":            9,
		"STATUS":              10,
		"BIGQUERY_PROJECT_ID": 11,
		"BIGQUERY_DATASET":    12,
		"BIGQUERY_TABLE":      13,
		"BIGQUERY_VIEW":       14,
		"BIGQUERY_QUERY_NAME": 15,
		"GCS_BUCKET":          16,
		"GCS_PROJECT_ID":      17,
	}
)

Enum value maps for MonitoringInfo_MonitoringInfoLabels.

View Source
var (
	MonitoringInfoTypeUrns_Enum_name = map[int32]string{
		0:  "SUM_INT64_TYPE",
		1:  "SUM_DOUBLE_TYPE",
		2:  "DISTRIBUTION_INT64_TYPE",
		3:  "DISTRIBUTION_DOUBLE_TYPE",
		4:  "LATEST_INT64_TYPE",
		5:  "LATEST_DOUBLE_TYPE",
		6:  "TOP_N_INT64_TYPE",
		7:  "TOP_N_DOUBLE_TYPE",
		8:  "BOTTOM_N_INT64_TYPE",
		9:  "BOTTOM_N_DOUBLE_TYPE",
		10: "PROGRESS_TYPE",
	}
	MonitoringInfoTypeUrns_Enum_value = map[string]int32{
		"SUM_INT64_TYPE":           0,
		"SUM_DOUBLE_TYPE":          1,
		"DISTRIBUTION_INT64_TYPE":  2,
		"DISTRIBUTION_DOUBLE_TYPE": 3,
		"LATEST_INT64_TYPE":        4,
		"LATEST_DOUBLE_TYPE":       5,
		"TOP_N_INT64_TYPE":         6,
		"TOP_N_DOUBLE_TYPE":        7,
		"BOTTOM_N_INT64_TYPE":      8,
		"BOTTOM_N_DOUBLE_TYPE":     9,
		"PROGRESS_TYPE":            10,
	}
)

Enum value maps for MonitoringInfoTypeUrns_Enum.

View Source
var (
	// optional org.apache.beam.model.pipeline.v1.MonitoringInfoLabelProps label_props = 127337796;
	E_LabelProps = &file_metrics_proto_extTypes[0] // From: commit 0x7970544.
	// Enum extension to store the MonitoringInfoSpecs.
	//
	// optional org.apache.beam.model.pipeline.v1.MonitoringInfoSpec monitoring_info_spec = 207174266;
	E_MonitoringInfoSpec = &file_metrics_proto_extTypes[1]
)

Extension fields to descriptorpb.EnumValueOptions.

View Source
var (
	AtomicType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "BYTE",
		2: "INT16",
		3: "INT32",
		4: "INT64",
		5: "FLOAT",
		6: "DOUBLE",
		7: "STRING",
		8: "BOOLEAN",
		9: "BYTES",
	}
	AtomicType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"BYTE":        1,
		"INT16":       2,
		"INT32":       3,
		"INT64":       4,
		"FLOAT":       5,
		"DOUBLE":      6,
		"STRING":      7,
		"BOOLEAN":     8,
		"BYTES":       9,
	}
)

Enum value maps for AtomicType.

View Source
var (
	GlobalWindowsPayload_Enum_name = map[int32]string{
		0: "PROPERTIES",
	}
	GlobalWindowsPayload_Enum_value = map[string]int32{
		"PROPERTIES": 0,
	}
)

Enum value maps for GlobalWindowsPayload_Enum.

View Source
var (
	FixedWindowsPayload_Enum_name = map[int32]string{
		0: "PROPERTIES",
	}
	FixedWindowsPayload_Enum_value = map[string]int32{
		"PROPERTIES": 0,
	}
)

Enum value maps for FixedWindowsPayload_Enum.

View Source
var (
	SlidingWindowsPayload_Enum_name = map[int32]string{
		0: "PROPERTIES",
	}
	SlidingWindowsPayload_Enum_value = map[string]int32{
		"PROPERTIES": 0,
	}
)

Enum value maps for SlidingWindowsPayload_Enum.

View Source
var (
	SessionWindowsPayload_Enum_name = map[int32]string{
		0: "PROPERTIES",
	}
	SessionWindowsPayload_Enum_value = map[string]int32{
		"PROPERTIES": 0,
	}
)

Enum value maps for SessionWindowsPayload_Enum.

View Source
var File_beam_runner_api_proto protoreflect.FileDescriptor
View Source
var File_endpoints_proto protoreflect.FileDescriptor
View Source
var File_external_transforms_proto protoreflect.FileDescriptor
View Source
var File_metrics_proto protoreflect.FileDescriptor
View Source
var File_schema_proto protoreflect.FileDescriptor
View Source
var File_standard_window_fns_proto protoreflect.FileDescriptor
View Source
var TestStreamService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "org.apache.beam.model.pipeline.v1.TestStreamService",
	HandlerType: (*TestStreamServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Events",
			Handler:       _TestStreamService_Events_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "beam_runner_api.proto",
}

TestStreamService_ServiceDesc is the grpc.ServiceDesc for TestStreamService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTestStreamServiceServer

func RegisterTestStreamServiceServer(s grpc.ServiceRegistrar, srv TestStreamServiceServer)

Types

type AccumulationMode

type AccumulationMode struct {
	// contains filtered or unexported fields
}

Whether or not subsequent outputs of aggregations should be entire replacement values or just the aggregation of inputs received since the prior output.

func (*AccumulationMode) Descriptor deprecated

func (*AccumulationMode) Descriptor() ([]byte, []int)

Deprecated: Use AccumulationMode.ProtoReflect.Descriptor instead.

func (*AccumulationMode) ProtoMessage

func (*AccumulationMode) ProtoMessage()

func (*AccumulationMode) ProtoReflect

func (x *AccumulationMode) ProtoReflect() protoreflect.Message

func (*AccumulationMode) Reset

func (x *AccumulationMode) Reset()

func (*AccumulationMode) String

func (x *AccumulationMode) String() string

type AccumulationMode_Enum

type AccumulationMode_Enum int32
const (
	AccumulationMode_UNSPECIFIED AccumulationMode_Enum = 0
	// The aggregation is discarded when it is output
	AccumulationMode_DISCARDING AccumulationMode_Enum = 1
	// The aggregation is accumulated across outputs
	AccumulationMode_ACCUMULATING AccumulationMode_Enum = 2
	// The aggregation emits retractions when it is output
	AccumulationMode_RETRACTING AccumulationMode_Enum = 3
)

func (AccumulationMode_Enum) Descriptor

func (AccumulationMode_Enum) Enum

func (AccumulationMode_Enum) EnumDescriptor deprecated

func (AccumulationMode_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use AccumulationMode_Enum.Descriptor instead.

func (AccumulationMode_Enum) Number

func (AccumulationMode_Enum) String

func (x AccumulationMode_Enum) String() string

func (AccumulationMode_Enum) Type

type Annotation

type Annotation struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

The key name and value string of MonitoringInfo annotations.

func (*Annotation) Descriptor deprecated

func (*Annotation) Descriptor() ([]byte, []int)

Deprecated: Use Annotation.ProtoReflect.Descriptor instead.

func (*Annotation) GetKey

func (x *Annotation) GetKey() string

func (*Annotation) GetValue

func (x *Annotation) GetValue() string

func (*Annotation) ProtoMessage

func (*Annotation) ProtoMessage()

func (*Annotation) ProtoReflect

func (x *Annotation) ProtoReflect() protoreflect.Message

func (*Annotation) Reset

func (x *Annotation) Reset()

func (*Annotation) String

func (x *Annotation) String() string

type ApiServiceDescriptor

type ApiServiceDescriptor struct {

	// (Required) The URL to connect to.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// (Optional) The method for authentication. If unspecified, access to the
	// url is already being performed in a trusted context (e.g. localhost,
	// private network).
	Authentication *AuthenticationSpec `protobuf:"bytes,2,opt,name=authentication,proto3" json:"authentication,omitempty"`
	// contains filtered or unexported fields
}

A description of how to connect to a Beam API endpoint.

func (*ApiServiceDescriptor) Descriptor deprecated

func (*ApiServiceDescriptor) Descriptor() ([]byte, []int)

Deprecated: Use ApiServiceDescriptor.ProtoReflect.Descriptor instead.

func (*ApiServiceDescriptor) GetAuthentication

func (x *ApiServiceDescriptor) GetAuthentication() *AuthenticationSpec

func (*ApiServiceDescriptor) GetUrl

func (x *ApiServiceDescriptor) GetUrl() string

func (*ApiServiceDescriptor) ProtoMessage

func (*ApiServiceDescriptor) ProtoMessage()

func (*ApiServiceDescriptor) ProtoReflect

func (x *ApiServiceDescriptor) ProtoReflect() protoreflect.Message

func (*ApiServiceDescriptor) Reset

func (x *ApiServiceDescriptor) Reset()

func (*ApiServiceDescriptor) String

func (x *ApiServiceDescriptor) String() string

type ArrayType

type ArrayType struct {
	ElementType *FieldType `protobuf:"bytes,1,opt,name=element_type,json=elementType,proto3" json:"element_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ArrayType) Descriptor deprecated

func (*ArrayType) Descriptor() ([]byte, []int)

Deprecated: Use ArrayType.ProtoReflect.Descriptor instead.

func (*ArrayType) GetElementType

func (x *ArrayType) GetElementType() *FieldType

func (*ArrayType) ProtoMessage

func (*ArrayType) ProtoMessage()

func (*ArrayType) ProtoReflect

func (x *ArrayType) ProtoReflect() protoreflect.Message

func (*ArrayType) Reset

func (x *ArrayType) Reset()

func (*ArrayType) String

func (x *ArrayType) String() string

type ArrayTypeValue

type ArrayTypeValue struct {
	Element []*FieldValue `protobuf:"bytes,1,rep,name=element,proto3" json:"element,omitempty"`
	// contains filtered or unexported fields
}

func (*ArrayTypeValue) Descriptor deprecated

func (*ArrayTypeValue) Descriptor() ([]byte, []int)

Deprecated: Use ArrayTypeValue.ProtoReflect.Descriptor instead.

func (*ArrayTypeValue) GetElement

func (x *ArrayTypeValue) GetElement() []*FieldValue

func (*ArrayTypeValue) ProtoMessage

func (*ArrayTypeValue) ProtoMessage()

func (*ArrayTypeValue) ProtoReflect

func (x *ArrayTypeValue) ProtoReflect() protoreflect.Message

func (*ArrayTypeValue) Reset

func (x *ArrayTypeValue) Reset()

func (*ArrayTypeValue) String

func (x *ArrayTypeValue) String() string

type ArtifactFilePayload

type ArtifactFilePayload struct {

	// a string for an artifact file path e.g. "/tmp/foo.jar"
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// The hex-encoded sha256 checksum of the artifact.
	Sha256 string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactFilePayload) Descriptor deprecated

func (*ArtifactFilePayload) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactFilePayload.ProtoReflect.Descriptor instead.

func (*ArtifactFilePayload) GetPath

func (x *ArtifactFilePayload) GetPath() string

func (*ArtifactFilePayload) GetSha256

func (x *ArtifactFilePayload) GetSha256() string

func (*ArtifactFilePayload) ProtoMessage

func (*ArtifactFilePayload) ProtoMessage()

func (*ArtifactFilePayload) ProtoReflect

func (x *ArtifactFilePayload) ProtoReflect() protoreflect.Message

func (*ArtifactFilePayload) Reset

func (x *ArtifactFilePayload) Reset()

func (*ArtifactFilePayload) String

func (x *ArtifactFilePayload) String() string

type ArtifactInformation

type ArtifactInformation struct {

	// A URN that describes the type of artifact
	TypeUrn     string `protobuf:"bytes,1,opt,name=type_urn,json=typeUrn,proto3" json:"type_urn,omitempty"`
	TypePayload []byte `protobuf:"bytes,2,opt,name=type_payload,json=typePayload,proto3" json:"type_payload,omitempty"`
	// A URN that describes the role of artifact
	RoleUrn     string `protobuf:"bytes,3,opt,name=role_urn,json=roleUrn,proto3" json:"role_urn,omitempty"`
	RolePayload []byte `protobuf:"bytes,4,opt,name=role_payload,json=rolePayload,proto3" json:"role_payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactInformation) Descriptor deprecated

func (*ArtifactInformation) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactInformation.ProtoReflect.Descriptor instead.

func (*ArtifactInformation) GetRolePayload

func (x *ArtifactInformation) GetRolePayload() []byte

func (*ArtifactInformation) GetRoleUrn

func (x *ArtifactInformation) GetRoleUrn() string

func (*ArtifactInformation) GetTypePayload

func (x *ArtifactInformation) GetTypePayload() []byte

func (*ArtifactInformation) GetTypeUrn

func (x *ArtifactInformation) GetTypeUrn() string

func (*ArtifactInformation) ProtoMessage

func (*ArtifactInformation) ProtoMessage()

func (*ArtifactInformation) ProtoReflect

func (x *ArtifactInformation) ProtoReflect() protoreflect.Message

func (*ArtifactInformation) Reset

func (x *ArtifactInformation) Reset()

func (*ArtifactInformation) String

func (x *ArtifactInformation) String() string

type ArtifactStagingToRolePayload

type ArtifactStagingToRolePayload struct {

	// A generated staged name (relative path under staging directory).
	StagedName string `protobuf:"bytes,1,opt,name=staged_name,json=stagedName,proto3" json:"staged_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactStagingToRolePayload) Descriptor deprecated

func (*ArtifactStagingToRolePayload) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactStagingToRolePayload.ProtoReflect.Descriptor instead.

func (*ArtifactStagingToRolePayload) GetStagedName

func (x *ArtifactStagingToRolePayload) GetStagedName() string

func (*ArtifactStagingToRolePayload) ProtoMessage

func (*ArtifactStagingToRolePayload) ProtoMessage()

func (*ArtifactStagingToRolePayload) ProtoReflect

func (*ArtifactStagingToRolePayload) Reset

func (x *ArtifactStagingToRolePayload) Reset()

func (*ArtifactStagingToRolePayload) String

type ArtifactUrlPayload

type ArtifactUrlPayload struct {

	// a string for an artifact URL e.g. "https://.../foo.jar" or "gs://tmp/foo.jar"
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// (Optional) The hex-encoded sha256 checksum of the artifact if available.
	Sha256 string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

func (*ArtifactUrlPayload) Descriptor deprecated

func (*ArtifactUrlPayload) Descriptor() ([]byte, []int)

Deprecated: Use ArtifactUrlPayload.ProtoReflect.Descriptor instead.

func (*ArtifactUrlPayload) GetSha256

func (x *ArtifactUrlPayload) GetSha256() string

func (*ArtifactUrlPayload) GetUrl

func (x *ArtifactUrlPayload) GetUrl() string

func (*ArtifactUrlPayload) ProtoMessage

func (*ArtifactUrlPayload) ProtoMessage()

func (*ArtifactUrlPayload) ProtoReflect

func (x *ArtifactUrlPayload) ProtoReflect() protoreflect.Message

func (*ArtifactUrlPayload) Reset

func (x *ArtifactUrlPayload) Reset()

func (*ArtifactUrlPayload) String

func (x *ArtifactUrlPayload) String() string

type AtomicType

type AtomicType int32
const (
	AtomicType_UNSPECIFIED AtomicType = 0
	AtomicType_BYTE        AtomicType = 1
	AtomicType_INT16       AtomicType = 2
	AtomicType_INT32       AtomicType = 3
	AtomicType_INT64       AtomicType = 4
	AtomicType_FLOAT       AtomicType = 5
	AtomicType_DOUBLE      AtomicType = 6
	AtomicType_STRING      AtomicType = 7
	AtomicType_BOOLEAN     AtomicType = 8
	AtomicType_BYTES       AtomicType = 9
)

func (AtomicType) Descriptor

func (AtomicType) Descriptor() protoreflect.EnumDescriptor

func (AtomicType) Enum

func (x AtomicType) Enum() *AtomicType

func (AtomicType) EnumDescriptor deprecated

func (AtomicType) EnumDescriptor() ([]byte, []int)

Deprecated: Use AtomicType.Descriptor instead.

func (AtomicType) Number

func (x AtomicType) Number() protoreflect.EnumNumber

func (AtomicType) String

func (x AtomicType) String() string

func (AtomicType) Type

type AtomicTypeValue

type AtomicTypeValue struct {

	// Types that are assignable to Value:
	//	*AtomicTypeValue_Byte
	//	*AtomicTypeValue_Int16
	//	*AtomicTypeValue_Int32
	//	*AtomicTypeValue_Int64
	//	*AtomicTypeValue_Float
	//	*AtomicTypeValue_Double
	//	*AtomicTypeValue_String_
	//	*AtomicTypeValue_Boolean
	//	*AtomicTypeValue_Bytes
	Value isAtomicTypeValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*AtomicTypeValue) Descriptor deprecated

func (*AtomicTypeValue) Descriptor() ([]byte, []int)

Deprecated: Use AtomicTypeValue.ProtoReflect.Descriptor instead.

func (*AtomicTypeValue) GetBoolean

func (x *AtomicTypeValue) GetBoolean() bool

func (*AtomicTypeValue) GetByte

func (x *AtomicTypeValue) GetByte() int32

func (*AtomicTypeValue) GetBytes

func (x *AtomicTypeValue) GetBytes() []byte

func (*AtomicTypeValue) GetDouble

func (x *AtomicTypeValue) GetDouble() float64

func (*AtomicTypeValue) GetFloat

func (x *AtomicTypeValue) GetFloat() float32

func (*AtomicTypeValue) GetInt16

func (x *AtomicTypeValue) GetInt16() int32

func (*AtomicTypeValue) GetInt32

func (x *AtomicTypeValue) GetInt32() int32

func (*AtomicTypeValue) GetInt64

func (x *AtomicTypeValue) GetInt64() int64

func (*AtomicTypeValue) GetString_

func (x *AtomicTypeValue) GetString_() string

func (*AtomicTypeValue) GetValue

func (m *AtomicTypeValue) GetValue() isAtomicTypeValue_Value

func (*AtomicTypeValue) ProtoMessage

func (*AtomicTypeValue) ProtoMessage()

func (*AtomicTypeValue) ProtoReflect

func (x *AtomicTypeValue) ProtoReflect() protoreflect.Message

func (*AtomicTypeValue) Reset

func (x *AtomicTypeValue) Reset()

func (*AtomicTypeValue) String

func (x *AtomicTypeValue) String() string

type AtomicTypeValue_Boolean

type AtomicTypeValue_Boolean struct {
	Boolean bool `protobuf:"varint,8,opt,name=boolean,proto3,oneof"`
}

type AtomicTypeValue_Byte

type AtomicTypeValue_Byte struct {
	Byte int32 `protobuf:"varint,1,opt,name=byte,proto3,oneof"`
}

type AtomicTypeValue_Bytes

type AtomicTypeValue_Bytes struct {
	Bytes []byte `protobuf:"bytes,9,opt,name=bytes,proto3,oneof"`
}

type AtomicTypeValue_Double

type AtomicTypeValue_Double struct {
	Double float64 `protobuf:"fixed64,6,opt,name=double,proto3,oneof"`
}

type AtomicTypeValue_Float

type AtomicTypeValue_Float struct {
	Float float32 `protobuf:"fixed32,5,opt,name=float,proto3,oneof"`
}

type AtomicTypeValue_Int16

type AtomicTypeValue_Int16 struct {
	Int16 int32 `protobuf:"varint,2,opt,name=int16,proto3,oneof"`
}

type AtomicTypeValue_Int32

type AtomicTypeValue_Int32 struct {
	Int32 int32 `protobuf:"varint,3,opt,name=int32,proto3,oneof"`
}

type AtomicTypeValue_Int64

type AtomicTypeValue_Int64 struct {
	Int64 int64 `protobuf:"varint,4,opt,name=int64,proto3,oneof"`
}

type AtomicTypeValue_String_

type AtomicTypeValue_String_ struct {
	String_ string `protobuf:"bytes,7,opt,name=string,proto3,oneof"`
}

type AuthenticationSpec

type AuthenticationSpec struct {

	// (Required) A URN that describes the accompanying payload.
	// For any URN that is not recognized (by whomever is inspecting
	// it) the parameter payload should be treated as opaque and
	// passed as-is.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthenticationSpec) Descriptor deprecated

func (*AuthenticationSpec) Descriptor() ([]byte, []int)

Deprecated: Use AuthenticationSpec.ProtoReflect.Descriptor instead.

func (*AuthenticationSpec) GetPayload

func (x *AuthenticationSpec) GetPayload() []byte

func (*AuthenticationSpec) GetUrn

func (x *AuthenticationSpec) GetUrn() string

func (*AuthenticationSpec) ProtoMessage

func (*AuthenticationSpec) ProtoMessage()

func (*AuthenticationSpec) ProtoReflect

func (x *AuthenticationSpec) ProtoReflect() protoreflect.Message

func (*AuthenticationSpec) Reset

func (x *AuthenticationSpec) Reset()

func (*AuthenticationSpec) String

func (x *AuthenticationSpec) String() string

type BagStateSpec

type BagStateSpec struct {
	ElementCoderId string `protobuf:"bytes,1,opt,name=element_coder_id,json=elementCoderId,proto3" json:"element_coder_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BagStateSpec) Descriptor deprecated

func (*BagStateSpec) Descriptor() ([]byte, []int)

Deprecated: Use BagStateSpec.ProtoReflect.Descriptor instead.

func (*BagStateSpec) GetElementCoderId

func (x *BagStateSpec) GetElementCoderId() string

func (*BagStateSpec) ProtoMessage

func (*BagStateSpec) ProtoMessage()

func (*BagStateSpec) ProtoReflect

func (x *BagStateSpec) ProtoReflect() protoreflect.Message

func (*BagStateSpec) Reset

func (x *BagStateSpec) Reset()

func (*BagStateSpec) String

func (x *BagStateSpec) String() string

type BeamConstants

type BeamConstants struct {
	// contains filtered or unexported fields
}

func (*BeamConstants) Descriptor deprecated

func (*BeamConstants) Descriptor() ([]byte, []int)

Deprecated: Use BeamConstants.ProtoReflect.Descriptor instead.

func (*BeamConstants) ProtoMessage

func (*BeamConstants) ProtoMessage()

func (*BeamConstants) ProtoReflect

func (x *BeamConstants) ProtoReflect() protoreflect.Message

func (*BeamConstants) Reset

func (x *BeamConstants) Reset()

func (*BeamConstants) String

func (x *BeamConstants) String() string

type BeamConstants_Constants

type BeamConstants_Constants int32
const (
	// All timestamps of elements or window boundaries must be within
	// the interval [MIN_TIMESTAMP_MILLIS, MAX_TIMESTAMP_MILLIS].
	// The smallest representable timestamp of an element or a window boundary.
	BeamConstants_MIN_TIMESTAMP_MILLIS BeamConstants_Constants = 0
	// The largest representable timestamp of an element or a window boundary.
	BeamConstants_MAX_TIMESTAMP_MILLIS BeamConstants_Constants = 1
	// The maximum timestamp for the global window.
	// Triggers use max timestamp to set timers' timestamp. Timers fire when
	// the watermark passes their timestamps. So, the timestamp needs to be
	// smaller than the MAX_TIMESTAMP_MILLIS.
	// One standard day is subtracted from MAX_TIMESTAMP_MILLIS to make sure
	// the max timestamp is smaller than MAX_TIMESTAMP_MILLIS even after rounding up
	// to seconds or minutes.
	BeamConstants_GLOBAL_WINDOW_MAX_TIMESTAMP_MILLIS BeamConstants_Constants = 2
)

func (BeamConstants_Constants) Descriptor

func (BeamConstants_Constants) Enum

func (BeamConstants_Constants) EnumDescriptor deprecated

func (BeamConstants_Constants) EnumDescriptor() ([]byte, []int)

Deprecated: Use BeamConstants_Constants.Descriptor instead.

func (BeamConstants_Constants) Number

func (BeamConstants_Constants) String

func (x BeamConstants_Constants) String() string

func (BeamConstants_Constants) Type

type ClosingBehavior

type ClosingBehavior struct {
	// contains filtered or unexported fields
}

Controls whether or not an aggregating transform should output data when a window expires.

func (*ClosingBehavior) Descriptor deprecated

func (*ClosingBehavior) Descriptor() ([]byte, []int)

Deprecated: Use ClosingBehavior.ProtoReflect.Descriptor instead.

func (*ClosingBehavior) ProtoMessage

func (*ClosingBehavior) ProtoMessage()

func (*ClosingBehavior) ProtoReflect

func (x *ClosingBehavior) ProtoReflect() protoreflect.Message

func (*ClosingBehavior) Reset

func (x *ClosingBehavior) Reset()

func (*ClosingBehavior) String

func (x *ClosingBehavior) String() string

type ClosingBehavior_Enum

type ClosingBehavior_Enum int32
const (
	ClosingBehavior_UNSPECIFIED ClosingBehavior_Enum = 0
	// Emit output when a window expires, whether or not there has been
	// any new data since the last output.
	ClosingBehavior_EMIT_ALWAYS ClosingBehavior_Enum = 1
	// Only emit output when new data has arrives since the last output
	ClosingBehavior_EMIT_IF_NONEMPTY ClosingBehavior_Enum = 2
)

func (ClosingBehavior_Enum) Descriptor

func (ClosingBehavior_Enum) Enum

func (ClosingBehavior_Enum) EnumDescriptor deprecated

func (ClosingBehavior_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClosingBehavior_Enum.Descriptor instead.

func (ClosingBehavior_Enum) Number

func (ClosingBehavior_Enum) String

func (x ClosingBehavior_Enum) String() string

func (ClosingBehavior_Enum) Type

type Coder

type Coder struct {

	// (Required) A specification for the coder, as a URN plus parameters. This
	// may be a cross-language agreed-upon format, or it may be a "custom coder"
	// that can only be used by a particular SDK. It does not include component
	// coders, as it is beneficial for these to be comprehensible to a runner
	// regardless of whether the binary format is agreed-upon.
	Spec *FunctionSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// (Optional) If this coder is parametric, such as ListCoder(VarIntCoder),
	// this is a list of the components. In order for encodings to be identical,
	// the FunctionSpec and all components must be identical, recursively.
	ComponentCoderIds []string `protobuf:"bytes,2,rep,name=component_coder_ids,json=componentCoderIds,proto3" json:"component_coder_ids,omitempty"`
	// contains filtered or unexported fields
}

A coder, the binary format for serialization and deserialization of data in a pipeline.

func (*Coder) Descriptor deprecated

func (*Coder) Descriptor() ([]byte, []int)

Deprecated: Use Coder.ProtoReflect.Descriptor instead.

func (*Coder) GetComponentCoderIds

func (x *Coder) GetComponentCoderIds() []string

func (*Coder) GetSpec

func (x *Coder) GetSpec() *FunctionSpec

func (*Coder) ProtoMessage

func (*Coder) ProtoMessage()

func (*Coder) ProtoReflect

func (x *Coder) ProtoReflect() protoreflect.Message

func (*Coder) Reset

func (x *Coder) Reset()

func (*Coder) String

func (x *Coder) String() string

type CombinePayload

type CombinePayload struct {

	// (Required) The FunctionSpec of the CombineFn.
	CombineFn *FunctionSpec `protobuf:"bytes,1,opt,name=combine_fn,json=combineFn,proto3" json:"combine_fn,omitempty"`
	// (Required) A reference to the Coder to use for accumulators of the CombineFn
	AccumulatorCoderId string `protobuf:"bytes,2,opt,name=accumulator_coder_id,json=accumulatorCoderId,proto3" json:"accumulator_coder_id,omitempty"`
	// contains filtered or unexported fields
}

The payload for the special-but-not-primitive Combine transform.

func (*CombinePayload) Descriptor deprecated

func (*CombinePayload) Descriptor() ([]byte, []int)

Deprecated: Use CombinePayload.ProtoReflect.Descriptor instead.

func (*CombinePayload) GetAccumulatorCoderId

func (x *CombinePayload) GetAccumulatorCoderId() string

func (*CombinePayload) GetCombineFn

func (x *CombinePayload) GetCombineFn() *FunctionSpec

func (*CombinePayload) ProtoMessage

func (*CombinePayload) ProtoMessage()

func (*CombinePayload) ProtoReflect

func (x *CombinePayload) ProtoReflect() protoreflect.Message

func (*CombinePayload) Reset

func (x *CombinePayload) Reset()

func (*CombinePayload) String

func (x *CombinePayload) String() string

type CombiningStateSpec

type CombiningStateSpec struct {
	AccumulatorCoderId string        `protobuf:"bytes,1,opt,name=accumulator_coder_id,json=accumulatorCoderId,proto3" json:"accumulator_coder_id,omitempty"`
	CombineFn          *FunctionSpec `protobuf:"bytes,2,opt,name=combine_fn,json=combineFn,proto3" json:"combine_fn,omitempty"`
	// contains filtered or unexported fields
}

func (*CombiningStateSpec) Descriptor deprecated

func (*CombiningStateSpec) Descriptor() ([]byte, []int)

Deprecated: Use CombiningStateSpec.ProtoReflect.Descriptor instead.

func (*CombiningStateSpec) GetAccumulatorCoderId

func (x *CombiningStateSpec) GetAccumulatorCoderId() string

func (*CombiningStateSpec) GetCombineFn

func (x *CombiningStateSpec) GetCombineFn() *FunctionSpec

func (*CombiningStateSpec) ProtoMessage

func (*CombiningStateSpec) ProtoMessage()

func (*CombiningStateSpec) ProtoReflect

func (x *CombiningStateSpec) ProtoReflect() protoreflect.Message

func (*CombiningStateSpec) Reset

func (x *CombiningStateSpec) Reset()

func (*CombiningStateSpec) String

func (x *CombiningStateSpec) String() string

type Components

type Components struct {

	// (Required) A map from pipeline-scoped id to PTransform.
	//
	// Keys of the transforms map may be used by runners to identify pipeline
	// steps. Hence it's recommended to use strings that are not too long that
	// match regex '[A-Za-z0-9-_]+'.
	Transforms map[string]*PTransform `` /* 161-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to PCollection.
	Pcollections map[string]*PCollection `` /* 165-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to WindowingStrategy.
	WindowingStrategies map[string]*WindowingStrategy `` /* 206-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to Coder.
	Coders map[string]*Coder `` /* 153-byte string literal not displayed */
	// (Required) A map from pipeline-scoped id to Environment.
	Environments map[string]*Environment `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

A set of mappings from id to message. This is included as an optional field on any proto message that may contain references needing resolution.

func (*Components) Descriptor deprecated

func (*Components) Descriptor() ([]byte, []int)

Deprecated: Use Components.ProtoReflect.Descriptor instead.

func (*Components) GetCoders

func (x *Components) GetCoders() map[string]*Coder

func (*Components) GetEnvironments

func (x *Components) GetEnvironments() map[string]*Environment

func (*Components) GetPcollections

func (x *Components) GetPcollections() map[string]*PCollection

func (*Components) GetTransforms

func (x *Components) GetTransforms() map[string]*PTransform

func (*Components) GetWindowingStrategies

func (x *Components) GetWindowingStrategies() map[string]*WindowingStrategy

func (*Components) ProtoMessage

func (*Components) ProtoMessage()

func (*Components) ProtoReflect

func (x *Components) ProtoReflect() protoreflect.Message

func (*Components) Reset

func (x *Components) Reset()

func (*Components) String

func (x *Components) String() string

type DeferredArtifactPayload

type DeferredArtifactPayload struct {

	// A unique string identifier assigned by the creator of this payload. The creator may use this key to confirm
	// whether they can parse the data.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Data for deferred artifacts. Interpretation of bytes is delegated to the creator of this payload.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DeferredArtifactPayload) Descriptor deprecated

func (*DeferredArtifactPayload) Descriptor() ([]byte, []int)

Deprecated: Use DeferredArtifactPayload.ProtoReflect.Descriptor instead.

func (*DeferredArtifactPayload) GetData

func (x *DeferredArtifactPayload) GetData() []byte

func (*DeferredArtifactPayload) GetKey

func (x *DeferredArtifactPayload) GetKey() string

func (*DeferredArtifactPayload) ProtoMessage

func (*DeferredArtifactPayload) ProtoMessage()

func (*DeferredArtifactPayload) ProtoReflect

func (x *DeferredArtifactPayload) ProtoReflect() protoreflect.Message

func (*DeferredArtifactPayload) Reset

func (x *DeferredArtifactPayload) Reset()

func (*DeferredArtifactPayload) String

func (x *DeferredArtifactPayload) String() string

type DisplayData

type DisplayData struct {

	// A key used to describe the type of display data. See StandardDisplayData
	// for the set of well known urns describing how the payload is meant to be
	// interpreted.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

Static display data associated with a pipeline component. Display data is useful for pipeline runners IOs and diagnostic dashboards to display details about annotated components.

func (*DisplayData) Descriptor deprecated

func (*DisplayData) Descriptor() ([]byte, []int)

Deprecated: Use DisplayData.ProtoReflect.Descriptor instead.

func (*DisplayData) GetPayload

func (x *DisplayData) GetPayload() []byte

func (*DisplayData) GetUrn

func (x *DisplayData) GetUrn() string

func (*DisplayData) ProtoMessage

func (*DisplayData) ProtoMessage()

func (*DisplayData) ProtoReflect

func (x *DisplayData) ProtoReflect() protoreflect.Message

func (*DisplayData) Reset

func (x *DisplayData) Reset()

func (*DisplayData) String

func (x *DisplayData) String() string

type DockerPayload

type DockerPayload struct {
	ContainerImage string `protobuf:"bytes,1,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"` // implicitly linux_amd64.
	// contains filtered or unexported fields
}

The payload of a Docker image

func (*DockerPayload) Descriptor deprecated

func (*DockerPayload) Descriptor() ([]byte, []int)

Deprecated: Use DockerPayload.ProtoReflect.Descriptor instead.

func (*DockerPayload) GetContainerImage

func (x *DockerPayload) GetContainerImage() string

func (*DockerPayload) ProtoMessage

func (*DockerPayload) ProtoMessage()

func (*DockerPayload) ProtoReflect

func (x *DockerPayload) ProtoReflect() protoreflect.Message

func (*DockerPayload) Reset

func (x *DockerPayload) Reset()

func (*DockerPayload) String

func (x *DockerPayload) String() string

type EmbeddedFilePayload

type EmbeddedFilePayload struct {

	// raw data bytes for an embedded artifact
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*EmbeddedFilePayload) Descriptor deprecated

func (*EmbeddedFilePayload) Descriptor() ([]byte, []int)

Deprecated: Use EmbeddedFilePayload.ProtoReflect.Descriptor instead.

func (*EmbeddedFilePayload) GetData

func (x *EmbeddedFilePayload) GetData() []byte

func (*EmbeddedFilePayload) ProtoMessage

func (*EmbeddedFilePayload) ProtoMessage()

func (*EmbeddedFilePayload) ProtoReflect

func (x *EmbeddedFilePayload) ProtoReflect() protoreflect.Message

func (*EmbeddedFilePayload) Reset

func (x *EmbeddedFilePayload) Reset()

func (*EmbeddedFilePayload) String

func (x *EmbeddedFilePayload) String() string

type Environment

type Environment struct {

	// (Required) The URN of the payload
	Urn string `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// (Optional) Static display data for the environment. If there is none,
	// it may be omitted.
	DisplayData []*DisplayData `protobuf:"bytes,4,rep,name=display_data,json=displayData,proto3" json:"display_data,omitempty"`
	// (Optional) A set of capabilities this environment supports. This is
	// typically a list of common URNs designating coders, transforms, etc. that
	// this environment understands (and a runner MAY use) despite not
	// appearing in the pipeline proto. This may also be used to indicate
	// support of optional protocols not tied to a concrete component.
	Capabilities []string `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// (Optional) artifact dependency information used for executing UDFs in this environment.
	Dependencies []*ArtifactInformation `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// (Optional) A mapping of resource URNs to requested values.  The encoding
	// of the values is specified by the URN.  Resource hints are advisory;
	// a runner is free to ignore resource hints that it does not understand.
	ResourceHints map[string][]byte `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

An environment for executing UDFs. By default, an SDK container URL, but can also be a process forked by a command, or an externally managed process.

func (*Environment) Descriptor deprecated

func (*Environment) Descriptor() ([]byte, []int)

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetCapabilities

func (x *Environment) GetCapabilities() []string

func (*Environment) GetDependencies

func (x *Environment) GetDependencies() []*ArtifactInformation

func (*Environment) GetDisplayData

func (x *Environment) GetDisplayData() []*DisplayData

func (*Environment) GetPayload

func (x *Environment) GetPayload() []byte

func (*Environment) GetResourceHints

func (x *Environment) GetResourceHints() map[string][]byte

func (*Environment) GetUrn

func (x *Environment) GetUrn() string

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect

func (x *Environment) ProtoReflect() protoreflect.Message

func (*Environment) Reset

func (x *Environment) Reset()

func (*Environment) String

func (x *Environment) String() string

type EventsRequest

type EventsRequest struct {

	// The set of PCollections to read from. These are the PTransform outputs
	// local names. These are a subset of the TestStream's outputs. This allows
	// Interactive Beam to cache many PCollections from a pipeline then replay a
	// subset of them.
	OutputIds []string `protobuf:"bytes,1,rep,name=output_ids,json=outputIds,proto3" json:"output_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*EventsRequest) Descriptor deprecated

func (*EventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.

func (*EventsRequest) GetOutputIds

func (x *EventsRequest) GetOutputIds() []string

func (*EventsRequest) ProtoMessage

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) ProtoReflect

func (x *EventsRequest) ProtoReflect() protoreflect.Message

func (*EventsRequest) Reset

func (x *EventsRequest) Reset()

func (*EventsRequest) String

func (x *EventsRequest) String() string

type ExecutableStagePayload

type ExecutableStagePayload struct {

	// (Required) Environment in which this stage executes.
	//
	// We use an environment rather than environment id
	// because ExecutableStages use environments directly. This may change in the future.
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// The wire coder settings of this executable stage
	WireCoderSettings []*ExecutableStagePayload_WireCoderSetting `protobuf:"bytes,9,rep,name=wire_coder_settings,json=wireCoderSettings,proto3" json:"wire_coder_settings,omitempty"`
	// (Required) Input PCollection id. This must be present as a value in the inputs of any
	// PTransform the ExecutableStagePayload is the payload of.
	Input string `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// The side inputs required for this executable stage. Each side input of each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	SideInputs []*ExecutableStagePayload_SideInputId `protobuf:"bytes,3,rep,name=side_inputs,json=sideInputs,proto3" json:"side_inputs,omitempty"`
	// PTransform ids contained within this executable stage. This must contain at least one
	// PTransform id.
	Transforms []string `protobuf:"bytes,4,rep,name=transforms,proto3" json:"transforms,omitempty"`
	// Output PCollection ids. This must be equal to the values of the outputs of any
	// PTransform the ExecutableStagePayload is the payload of.
	Outputs []string `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// (Required) The components for the Executable Stage. This must contain all of the Transforms
	// in transforms, and the closure of all of the components they recognize.
	Components *Components `protobuf:"bytes,6,opt,name=components,proto3" json:"components,omitempty"`
	// The user states required for this executable stage. Each user state of each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	UserStates []*ExecutableStagePayload_UserStateId `protobuf:"bytes,7,rep,name=user_states,json=userStates,proto3" json:"user_states,omitempty"`
	// The timers required for this executable stage. Each timer of each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	Timers []*ExecutableStagePayload_TimerId `protobuf:"bytes,8,rep,name=timers,proto3" json:"timers,omitempty"`
	// The timerfamilies required for this executable stage. Each timer familyof each PTransform within
	// this ExecutableStagePayload must be represented within this field.
	TimerFamilies []*ExecutableStagePayload_TimerFamilyId `protobuf:"bytes,10,rep,name=timerFamilies,proto3" json:"timerFamilies,omitempty"`
	// contains filtered or unexported fields
}

The payload for an executable stage. This will eventually be passed to an SDK in the form of a ProcessBundleDescriptor.

func (*ExecutableStagePayload) Descriptor deprecated

func (*ExecutableStagePayload) Descriptor() ([]byte, []int)

Deprecated: Use ExecutableStagePayload.ProtoReflect.Descriptor instead.

func (*ExecutableStagePayload) GetComponents

func (x *ExecutableStagePayload) GetComponents() *Components

func (*ExecutableStagePayload) GetEnvironment

func (x *ExecutableStagePayload) GetEnvironment() *Environment

func (*ExecutableStagePayload) GetInput

func (x *ExecutableStagePayload) GetInput() string

func (*ExecutableStagePayload) GetOutputs

func (x *ExecutableStagePayload) GetOutputs() []string

func (*ExecutableStagePayload) GetSideInputs

func (*ExecutableStagePayload) GetTimerFamilies

func (*ExecutableStagePayload) GetTimers

func (*ExecutableStagePayload) GetTransforms

func (x *ExecutableStagePayload) GetTransforms() []string

func (*ExecutableStagePayload) GetUserStates

func (*ExecutableStagePayload) GetWireCoderSettings

func (*ExecutableStagePayload) ProtoMessage

func (*ExecutableStagePayload) ProtoMessage()

func (*ExecutableStagePayload) ProtoReflect

func (x *ExecutableStagePayload) ProtoReflect() protoreflect.Message

func (*ExecutableStagePayload) Reset

func (x *ExecutableStagePayload) Reset()

func (*ExecutableStagePayload) String

func (x *ExecutableStagePayload) String() string

type ExecutableStagePayload_SideInputId

type ExecutableStagePayload_SideInputId struct {

	// (Required) The id of the PTransform that references this side input.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this side input from the PTransform that references it.
	LocalName string `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	// contains filtered or unexported fields
}

A reference to a side input. Side inputs are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_SideInputId) Descriptor deprecated

func (*ExecutableStagePayload_SideInputId) Descriptor() ([]byte, []int)

Deprecated: Use ExecutableStagePayload_SideInputId.ProtoReflect.Descriptor instead.

func (*ExecutableStagePayload_SideInputId) GetLocalName

func (x *ExecutableStagePayload_SideInputId) GetLocalName() string

func (*ExecutableStagePayload_SideInputId) GetTransformId

func (x *ExecutableStagePayload_SideInputId) GetTransformId() string

func (*ExecutableStagePayload_SideInputId) ProtoMessage

func (*ExecutableStagePayload_SideInputId) ProtoMessage()

func (*ExecutableStagePayload_SideInputId) ProtoReflect

func (*ExecutableStagePayload_SideInputId) Reset

func (*ExecutableStagePayload_SideInputId) String

type ExecutableStagePayload_TimerFamilyId

type ExecutableStagePayload_TimerFamilyId struct {

	// (Required) The id of the PTransform that references this timer family.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this timer family for the PTransform that references it.
	LocalName string `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	// contains filtered or unexported fields
}

A reference to a timer. Timers are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_TimerFamilyId) Descriptor deprecated

func (*ExecutableStagePayload_TimerFamilyId) Descriptor() ([]byte, []int)

Deprecated: Use ExecutableStagePayload_TimerFamilyId.ProtoReflect.Descriptor instead.

func (*ExecutableStagePayload_TimerFamilyId) GetLocalName

func (x *ExecutableStagePayload_TimerFamilyId) GetLocalName() string

func (*ExecutableStagePayload_TimerFamilyId) GetTransformId

func (x *ExecutableStagePayload_TimerFamilyId) GetTransformId() string

func (*ExecutableStagePayload_TimerFamilyId) ProtoMessage

func (*ExecutableStagePayload_TimerFamilyId) ProtoMessage()

func (*ExecutableStagePayload_TimerFamilyId) ProtoReflect

func (*ExecutableStagePayload_TimerFamilyId) Reset

func (*ExecutableStagePayload_TimerFamilyId) String

type ExecutableStagePayload_TimerId

type ExecutableStagePayload_TimerId struct {

	// (Required) The id of the PTransform that references this timer.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this timer for the PTransform that references it.
	LocalName string `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	// contains filtered or unexported fields
}

A reference to a timer. Timers are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_TimerId) Descriptor deprecated

func (*ExecutableStagePayload_TimerId) Descriptor() ([]byte, []int)

Deprecated: Use ExecutableStagePayload_TimerId.ProtoReflect.Descriptor instead.

func (*ExecutableStagePayload_TimerId) GetLocalName

func (x *ExecutableStagePayload_TimerId) GetLocalName() string

func (*ExecutableStagePayload_TimerId) GetTransformId

func (x *ExecutableStagePayload_TimerId) GetTransformId() string

func (*ExecutableStagePayload_TimerId) ProtoMessage

func (*ExecutableStagePayload_TimerId) ProtoMessage()

func (*ExecutableStagePayload_TimerId) ProtoReflect

func (*ExecutableStagePayload_TimerId) Reset

func (x *ExecutableStagePayload_TimerId) Reset()

func (*ExecutableStagePayload_TimerId) String

type ExecutableStagePayload_UserStateId

type ExecutableStagePayload_UserStateId struct {

	// (Required) The id of the PTransform that references this user state.
	TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId,proto3" json:"transform_id,omitempty"`
	// (Required) The local name of this user state for the PTransform that references it.
	LocalName string `protobuf:"bytes,2,opt,name=local_name,json=localName,proto3" json:"local_name,omitempty"`
	// contains filtered or unexported fields
}

A reference to user state. User states are uniquely identified by PTransform id and local name.

func (*ExecutableStagePayload_UserStateId) Descriptor deprecated

func (*ExecutableStagePayload_UserStateId) Descriptor() ([]byte, []int)

Deprecated: Use ExecutableStagePayload_UserStateId.ProtoReflect.Descriptor instead.

func (*ExecutableStagePayload_UserStateId) GetLocalName

func (x *ExecutableStagePayload_UserStateId) GetLocalName() string

func (*ExecutableStagePayload_UserStateId) GetTransformId

func (x *ExecutableStagePayload_UserStateId) GetTransformId() string

func (*ExecutableStagePayload_UserStateId) ProtoMessage

func (*ExecutableStagePayload_UserStateId) ProtoMessage()

func (*ExecutableStagePayload_UserStateId) ProtoReflect

func (*ExecutableStagePayload_UserStateId) Reset

func (*ExecutableStagePayload_UserStateId) String

type ExecutableStagePayload_WireCoderSetting

type ExecutableStagePayload_WireCoderSetting struct {

	// (Required) The URN of the wire coder.
	// Note that only windowed value coder or parameterized windowed value coder are supported.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN is beam:coder:windowed_value:v1, this may be omitted. If the URN is
	// beam:coder:param_windowed_value:v1, the payload is an encoded windowed
	// value using the beam:coder:windowed_value:v1 coder parameterized by
	// a beam:coder:bytes:v1 element coder and the window coder that this
	// param_windowed_value coder uses.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// (Required) The target(PCollection or Timer) this setting applies to.
	//
	// Types that are assignable to Target:
	//	*ExecutableStagePayload_WireCoderSetting_InputOrOutputId
	//	*ExecutableStagePayload_WireCoderSetting_Timer
	Target isExecutableStagePayload_WireCoderSetting_Target `protobuf_oneof:"target"`
	// contains filtered or unexported fields
}

Settings that decide the coder type of wire coder.

func (*ExecutableStagePayload_WireCoderSetting) Descriptor deprecated

func (*ExecutableStagePayload_WireCoderSetting) Descriptor() ([]byte, []int)

Deprecated: Use ExecutableStagePayload_WireCoderSetting.ProtoReflect.Descriptor instead.

func (*ExecutableStagePayload_WireCoderSetting) GetInputOrOutputId

func (x *ExecutableStagePayload_WireCoderSetting) GetInputOrOutputId() string

func (*ExecutableStagePayload_WireCoderSetting) GetPayload

func (*ExecutableStagePayload_WireCoderSetting) GetTarget

func (m *ExecutableStagePayload_WireCoderSetting) GetTarget() isExecutableStagePayload_WireCoderSetting_Target

func (*ExecutableStagePayload_WireCoderSetting) GetTimer

func (*ExecutableStagePayload_WireCoderSetting) GetUrn

func (*ExecutableStagePayload_WireCoderSetting) ProtoMessage

func (*ExecutableStagePayload_WireCoderSetting) ProtoReflect

func (*ExecutableStagePayload_WireCoderSetting) Reset

func (*ExecutableStagePayload_WireCoderSetting) String

type ExecutableStagePayload_WireCoderSetting_InputOrOutputId

type ExecutableStagePayload_WireCoderSetting_InputOrOutputId struct {
	// The input or output PCollection id this setting applies to.
	InputOrOutputId string `protobuf:"bytes,3,opt,name=input_or_output_id,json=inputOrOutputId,proto3,oneof"`
}

type ExecutableStagePayload_WireCoderSetting_Timer

type ExecutableStagePayload_WireCoderSetting_Timer struct {
	// The timer id this setting applies to.
	Timer *ExecutableStagePayload_TimerId `protobuf:"bytes,4,opt,name=timer,proto3,oneof"`
}

type ExternalConfigurationPayload

type ExternalConfigurationPayload struct {

	// A schema for use in beam:coder:row:v1
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// A payload which can be decoded using beam:coder:row:v1 and the given
	// schema.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

A configuration payload for an external transform. Used as the payload of ExternalTransform as part of an ExpansionRequest.

func (*ExternalConfigurationPayload) Descriptor deprecated

func (*ExternalConfigurationPayload) Descriptor() ([]byte, []int)

Deprecated: Use ExternalConfigurationPayload.ProtoReflect.Descriptor instead.

func (*ExternalConfigurationPayload) GetPayload

func (x *ExternalConfigurationPayload) GetPayload() []byte

func (*ExternalConfigurationPayload) GetSchema

func (x *ExternalConfigurationPayload) GetSchema() *Schema

func (*ExternalConfigurationPayload) ProtoMessage

func (*ExternalConfigurationPayload) ProtoMessage()

func (*ExternalConfigurationPayload) ProtoReflect

func (*ExternalConfigurationPayload) Reset

func (x *ExternalConfigurationPayload) Reset()

func (*ExternalConfigurationPayload) String

type ExternalPayload

type ExternalPayload struct {
	Endpoint *ApiServiceDescriptor `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Params   map[string]string     `` // Arbitrary extra parameters to pass
	/* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExternalPayload) Descriptor deprecated

func (*ExternalPayload) Descriptor() ([]byte, []int)

Deprecated: Use ExternalPayload.ProtoReflect.Descriptor instead.

func (*ExternalPayload) GetEndpoint

func (x *ExternalPayload) GetEndpoint() *ApiServiceDescriptor

func (*ExternalPayload) GetParams

func (x *ExternalPayload) GetParams() map[string]string

func (*ExternalPayload) ProtoMessage

func (*ExternalPayload) ProtoMessage()

func (*ExternalPayload) ProtoReflect

func (x *ExternalPayload) ProtoReflect() protoreflect.Message

func (*ExternalPayload) Reset

func (x *ExternalPayload) Reset()

func (*ExternalPayload) String

func (x *ExternalPayload) String() string

type Field

type Field struct {

	// REQUIRED. Name of this field within the schema.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// OPTIONAL. Human readable description of this field, such as the query that generated it.
	Description string     `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type        *FieldType `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Id          int32      `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	// OPTIONAL. The position of this field's data when encoded, e.g. with beam:coder:row:v1.
	// Either no fields in a given row are have encoding position populated,
	// or all of them are. Used to support backwards compatibility with schema
	// changes.
	// If no fields have encoding position populated the order of encoding is the same as the order in the Schema.
	// If this Field is part of a Schema where encoding_positions_set is True then encoding_position must be
	// defined, otherwise this field is ignored.
	EncodingPosition int32     `protobuf:"varint,5,opt,name=encoding_position,json=encodingPosition,proto3" json:"encoding_position,omitempty"`
	Options          []*Option `protobuf:"bytes,6,rep,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Field) Descriptor deprecated

func (*Field) Descriptor() ([]byte, []int)

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetDescription

func (x *Field) GetDescription() string

func (*Field) GetEncodingPosition

func (x *Field) GetEncodingPosition() int32

func (*Field) GetId

func (x *Field) GetId() int32

func (*Field) GetName

func (x *Field) GetName() string

func (*Field) GetOptions

func (x *Field) GetOptions() []*Option

func (*Field) GetType

func (x *Field) GetType() *FieldType

func (*Field) ProtoMessage

func (*Field) ProtoMessage()

func (*Field) ProtoReflect

func (x *Field) ProtoReflect() protoreflect.Message

func (*Field) Reset

func (x *Field) Reset()

func (*Field) String

func (x *Field) String() string

type FieldType

type FieldType struct {
	Nullable bool `protobuf:"varint,1,opt,name=nullable,proto3" json:"nullable,omitempty"`
	// Types that are assignable to TypeInfo:
	//	*FieldType_AtomicType
	//	*FieldType_ArrayType
	//	*FieldType_IterableType
	//	*FieldType_MapType
	//	*FieldType_RowType
	//	*FieldType_LogicalType
	TypeInfo isFieldType_TypeInfo `protobuf_oneof:"type_info"`
	// contains filtered or unexported fields
}

func (*FieldType) Descriptor deprecated

func (*FieldType) Descriptor() ([]byte, []int)

Deprecated: Use FieldType.ProtoReflect.Descriptor instead.

func (*FieldType) GetArrayType

func (x *FieldType) GetArrayType() *ArrayType

func (*FieldType) GetAtomicType

func (x *FieldType) GetAtomicType() AtomicType

func (*FieldType) GetIterableType

func (x *FieldType) GetIterableType() *IterableType

func (*FieldType) GetLogicalType

func (x *FieldType) GetLogicalType() *LogicalType

func (*FieldType) GetMapType

func (x *FieldType) GetMapType() *MapType

func (*FieldType) GetNullable

func (x *FieldType) GetNullable() bool

func (*FieldType) GetRowType

func (x *FieldType) GetRowType() *RowType

func (*FieldType) GetTypeInfo

func (m *FieldType) GetTypeInfo() isFieldType_TypeInfo

func (*FieldType) ProtoMessage

func (*FieldType) ProtoMessage()

func (*FieldType) ProtoReflect

func (x *FieldType) ProtoReflect() protoreflect.Message

func (*FieldType) Reset

func (x *FieldType) Reset()

func (*FieldType) String

func (x *FieldType) String() string

type FieldType_ArrayType

type FieldType_ArrayType struct {
	ArrayType *ArrayType `protobuf:"bytes,3,opt,name=array_type,json=arrayType,proto3,oneof"`
}

type FieldType_AtomicType

type FieldType_AtomicType struct {
	AtomicType AtomicType `protobuf:"varint,2,opt,name=atomic_type,json=atomicType,proto3,enum=org.apache.beam.model.pipeline.v1.AtomicType,oneof"`
}

type FieldType_IterableType

type FieldType_IterableType struct {
	IterableType *IterableType `protobuf:"bytes,4,opt,name=iterable_type,json=iterableType,proto3,oneof"`
}

type FieldType_LogicalType

type FieldType_LogicalType struct {
	LogicalType *LogicalType `protobuf:"bytes,7,opt,name=logical_type,json=logicalType,proto3,oneof"`
}

type FieldType_MapType

type FieldType_MapType struct {
	MapType *MapType `protobuf:"bytes,5,opt,name=map_type,json=mapType,proto3,oneof"`
}

type FieldType_RowType

type FieldType_RowType struct {
	RowType *RowType `protobuf:"bytes,6,opt,name=row_type,json=rowType,proto3,oneof"`
}

type FieldValue

type FieldValue struct {

	// Types that are assignable to FieldValue:
	//	*FieldValue_AtomicValue
	//	*FieldValue_ArrayValue
	//	*FieldValue_IterableValue
	//	*FieldValue_MapValue
	//	*FieldValue_RowValue
	//	*FieldValue_LogicalTypeValue
	FieldValue isFieldValue_FieldValue `protobuf_oneof:"field_value"`
	// contains filtered or unexported fields
}

func (*FieldValue) Descriptor deprecated

func (*FieldValue) Descriptor() ([]byte, []int)

Deprecated: Use FieldValue.ProtoReflect.Descriptor instead.

func (*FieldValue) GetArrayValue

func (x *FieldValue) GetArrayValue() *ArrayTypeValue

func (*FieldValue) GetAtomicValue

func (x *FieldValue) GetAtomicValue() *AtomicTypeValue

func (*FieldValue) GetFieldValue

func (m *FieldValue) GetFieldValue() isFieldValue_FieldValue

func (*FieldValue) GetIterableValue

func (x *FieldValue) GetIterableValue() *IterableTypeValue

func (*FieldValue) GetLogicalTypeValue

func (x *FieldValue) GetLogicalTypeValue() *LogicalTypeValue

func (*FieldValue) GetMapValue

func (x *FieldValue) GetMapValue() *MapTypeValue

func (*FieldValue) GetRowValue

func (x *FieldValue) GetRowValue() *Row

func (*FieldValue) ProtoMessage

func (*FieldValue) ProtoMessage()

func (*FieldValue) ProtoReflect

func (x *FieldValue) ProtoReflect() protoreflect.Message

func (*FieldValue) Reset

func (x *FieldValue) Reset()

func (*FieldValue) String

func (x *FieldValue) String() string

type FieldValue_ArrayValue

type FieldValue_ArrayValue struct {
	ArrayValue *ArrayTypeValue `protobuf:"bytes,2,opt,name=array_value,json=arrayValue,proto3,oneof"`
}

type FieldValue_AtomicValue

type FieldValue_AtomicValue struct {
	AtomicValue *AtomicTypeValue `protobuf:"bytes,1,opt,name=atomic_value,json=atomicValue,proto3,oneof"`
}

type FieldValue_IterableValue

type FieldValue_IterableValue struct {
	IterableValue *IterableTypeValue `protobuf:"bytes,3,opt,name=iterable_value,json=iterableValue,proto3,oneof"`
}

type FieldValue_LogicalTypeValue

type FieldValue_LogicalTypeValue struct {
	LogicalTypeValue *LogicalTypeValue `protobuf:"bytes,6,opt,name=logical_type_value,json=logicalTypeValue,proto3,oneof"`
}

type FieldValue_MapValue

type FieldValue_MapValue struct {
	MapValue *MapTypeValue `protobuf:"bytes,4,opt,name=map_value,json=mapValue,proto3,oneof"`
}

type FieldValue_RowValue

type FieldValue_RowValue struct {
	RowValue *Row `protobuf:"bytes,5,opt,name=row_value,json=rowValue,proto3,oneof"`
}

type FixedWindowsPayload

type FixedWindowsPayload struct {

	// (Required) Represents the size of the window.
	Size *durationpb.Duration `protobuf:"bytes,1,opt,name=size,proto3" json:"size,omitempty"`
	// (Required) Represents the timestamp of when the first window begins.
	// Window N will start at offset + N * size.
	Offset *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

A fixed time window represents a consistent duration size, non overlapping time interval in the data stream.

See https://beam.apache.org/documentation/programming-guide/#fixed-time-windows for additional details.

func (*FixedWindowsPayload) Descriptor deprecated

func (*FixedWindowsPayload) Descriptor() ([]byte, []int)

Deprecated: Use FixedWindowsPayload.ProtoReflect.Descriptor instead.

func (*FixedWindowsPayload) GetOffset

func (x *FixedWindowsPayload) GetOffset() *timestamppb.Timestamp

func (*FixedWindowsPayload) GetSize

func (x *FixedWindowsPayload) GetSize() *durationpb.Duration

func (*FixedWindowsPayload) ProtoMessage

func (*FixedWindowsPayload) ProtoMessage()

func (*FixedWindowsPayload) ProtoReflect

func (x *FixedWindowsPayload) ProtoReflect() protoreflect.Message

func (*FixedWindowsPayload) Reset

func (x *FixedWindowsPayload) Reset()

func (*FixedWindowsPayload) String

func (x *FixedWindowsPayload) String() string

type FixedWindowsPayload_Enum

type FixedWindowsPayload_Enum int32
const (
	FixedWindowsPayload_PROPERTIES FixedWindowsPayload_Enum = 0
)

func (FixedWindowsPayload_Enum) Descriptor

func (FixedWindowsPayload_Enum) Enum

func (FixedWindowsPayload_Enum) EnumDescriptor deprecated

func (FixedWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use FixedWindowsPayload_Enum.Descriptor instead.

func (FixedWindowsPayload_Enum) Number

func (FixedWindowsPayload_Enum) String

func (x FixedWindowsPayload_Enum) String() string

func (FixedWindowsPayload_Enum) Type

type FunctionSpec

type FunctionSpec struct {

	// (Required) A URN that describes the accompanying payload.
	// For any URN that is not recognized (by whomever is inspecting
	// it) the parameter payload should be treated as opaque and
	// passed as-is.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

A URN along with a parameter object whose schema is determined by the URN.

This structure is reused in two distinct, but compatible, ways:

1. This can be a specification of the function over PCollections

that a PTransform computes.

2. This can be a specification of a user-defined function, possibly

SDK-specific. (external to this message must be adequate context
to indicate the environment in which the UDF can be understood).

Though not explicit in this proto, there are two possibilities for the relationship of a runner to this specification that one should bear in mind:

1. The runner understands the URN. For example, it might be

a well-known URN like "beam:transform:Top" or
"beam:window_fn:FixedWindows" with
an agreed-upon payload (e.g. a number or duration,
respectively).

2. The runner does not understand the URN. It might be an

SDK specific URN such as "beam:dofn:javasdk:1.0"
that indicates to the SDK what the payload is,
such as a serialized Java DoFn from a particular
version of the Beam Java SDK. The payload will often
then be an opaque message such as bytes in a
language-specific serialization format.

func (*FunctionSpec) Descriptor deprecated

func (*FunctionSpec) Descriptor() ([]byte, []int)

Deprecated: Use FunctionSpec.ProtoReflect.Descriptor instead.

func (*FunctionSpec) GetPayload

func (x *FunctionSpec) GetPayload() []byte

func (*FunctionSpec) GetUrn

func (x *FunctionSpec) GetUrn() string

func (*FunctionSpec) ProtoMessage

func (*FunctionSpec) ProtoMessage()

func (*FunctionSpec) ProtoReflect

func (x *FunctionSpec) ProtoReflect() protoreflect.Message

func (*FunctionSpec) Reset

func (x *FunctionSpec) Reset()

func (*FunctionSpec) String

func (x *FunctionSpec) String() string

type GlobalWindowsPayload

type GlobalWindowsPayload struct {
	// contains filtered or unexported fields
}

By default, all data in a PCollection is assigned to the single global window. See BeamConstants for the time span this window encompasses.

See https://beam.apache.org/documentation/programming-guide/#single-global-window for additional details.

func (*GlobalWindowsPayload) Descriptor deprecated

func (*GlobalWindowsPayload) Descriptor() ([]byte, []int)

Deprecated: Use GlobalWindowsPayload.ProtoReflect.Descriptor instead.

func (*GlobalWindowsPayload) ProtoMessage

func (*GlobalWindowsPayload) ProtoMessage()

func (*GlobalWindowsPayload) ProtoReflect

func (x *GlobalWindowsPayload) ProtoReflect() protoreflect.Message

func (*GlobalWindowsPayload) Reset

func (x *GlobalWindowsPayload) Reset()

func (*GlobalWindowsPayload) String

func (x *GlobalWindowsPayload) String() string

type GlobalWindowsPayload_Enum

type GlobalWindowsPayload_Enum int32
const (
	GlobalWindowsPayload_PROPERTIES GlobalWindowsPayload_Enum = 0
)

func (GlobalWindowsPayload_Enum) Descriptor

func (GlobalWindowsPayload_Enum) Enum

func (GlobalWindowsPayload_Enum) EnumDescriptor deprecated

func (GlobalWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use GlobalWindowsPayload_Enum.Descriptor instead.

func (GlobalWindowsPayload_Enum) Number

func (GlobalWindowsPayload_Enum) String

func (x GlobalWindowsPayload_Enum) String() string

func (GlobalWindowsPayload_Enum) Type

type GroupIntoBatchesPayload

type GroupIntoBatchesPayload struct {

	// Max size of a batch.
	BatchSize int64 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Max byte size of a batch in element.
	BatchSizeBytes int64 `protobuf:"varint,3,opt,name=batch_size_bytes,json=batchSizeBytes,proto3" json:"batch_size_bytes,omitempty"`
	// (Optional) Max duration a batch is allowed to be cached in states.
	MaxBufferingDurationMillis int64 `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

Payload for GroupIntoBatches composite transform.

func (*GroupIntoBatchesPayload) Descriptor deprecated

func (*GroupIntoBatchesPayload) Descriptor() ([]byte, []int)

Deprecated: Use GroupIntoBatchesPayload.ProtoReflect.Descriptor instead.

func (*GroupIntoBatchesPayload) GetBatchSize

func (x *GroupIntoBatchesPayload) GetBatchSize() int64

func (*GroupIntoBatchesPayload) GetBatchSizeBytes

func (x *GroupIntoBatchesPayload) GetBatchSizeBytes() int64

func (*GroupIntoBatchesPayload) GetMaxBufferingDurationMillis

func (x *GroupIntoBatchesPayload) GetMaxBufferingDurationMillis() int64

func (*GroupIntoBatchesPayload) ProtoMessage

func (*GroupIntoBatchesPayload) ProtoMessage()

func (*GroupIntoBatchesPayload) ProtoReflect

func (x *GroupIntoBatchesPayload) ProtoReflect() protoreflect.Message

func (*GroupIntoBatchesPayload) Reset

func (x *GroupIntoBatchesPayload) Reset()

func (*GroupIntoBatchesPayload) String

func (x *GroupIntoBatchesPayload) String() string

type IsBounded

type IsBounded struct {
	// contains filtered or unexported fields
}

func (*IsBounded) Descriptor deprecated

func (*IsBounded) Descriptor() ([]byte, []int)

Deprecated: Use IsBounded.ProtoReflect.Descriptor instead.

func (*IsBounded) ProtoMessage

func (*IsBounded) ProtoMessage()

func (*IsBounded) ProtoReflect

func (x *IsBounded) ProtoReflect() protoreflect.Message

func (*IsBounded) Reset

func (x *IsBounded) Reset()

func (*IsBounded) String

func (x *IsBounded) String() string

type IsBounded_Enum

type IsBounded_Enum int32
const (
	IsBounded_UNSPECIFIED IsBounded_Enum = 0
	IsBounded_UNBOUNDED   IsBounded_Enum = 1
	IsBounded_BOUNDED     IsBounded_Enum = 2
)

func (IsBounded_Enum) Descriptor

func (IsBounded_Enum) Enum

func (x IsBounded_Enum) Enum() *IsBounded_Enum

func (IsBounded_Enum) EnumDescriptor deprecated

func (IsBounded_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use IsBounded_Enum.Descriptor instead.

func (IsBounded_Enum) Number

func (IsBounded_Enum) String

func (x IsBounded_Enum) String() string

func (IsBounded_Enum) Type

type IterableType

type IterableType struct {
	ElementType *FieldType `protobuf:"bytes,1,opt,name=element_type,json=elementType,proto3" json:"element_type,omitempty"`
	// contains filtered or unexported fields
}

func (*IterableType) Descriptor deprecated

func (*IterableType) Descriptor() ([]byte, []int)

Deprecated: Use IterableType.ProtoReflect.Descriptor instead.

func (*IterableType) GetElementType

func (x *IterableType) GetElementType() *FieldType

func (*IterableType) ProtoMessage

func (*IterableType) ProtoMessage()

func (*IterableType) ProtoReflect

func (x *IterableType) ProtoReflect() protoreflect.Message

func (*IterableType) Reset

func (x *IterableType) Reset()

func (*IterableType) String

func (x *IterableType) String() string

type IterableTypeValue

type IterableTypeValue struct {
	Element []*FieldValue `protobuf:"bytes,1,rep,name=element,proto3" json:"element,omitempty"`
	// contains filtered or unexported fields
}

func (*IterableTypeValue) Descriptor deprecated

func (*IterableTypeValue) Descriptor() ([]byte, []int)

Deprecated: Use IterableTypeValue.ProtoReflect.Descriptor instead.

func (*IterableTypeValue) GetElement

func (x *IterableTypeValue) GetElement() []*FieldValue

func (*IterableTypeValue) ProtoMessage

func (*IterableTypeValue) ProtoMessage()

func (*IterableTypeValue) ProtoReflect

func (x *IterableTypeValue) ProtoReflect() protoreflect.Message

func (*IterableTypeValue) Reset

func (x *IterableTypeValue) Reset()

func (*IterableTypeValue) String

func (x *IterableTypeValue) String() string

type LabelledPayload

type LabelledPayload struct {

	// (Required) A human readable label for the value.
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	// (Required) A value which will be displayed to the user.
	//
	// Types that are assignable to Value:
	//	*LabelledPayload_StringValue
	//	*LabelledPayload_BoolValue
	//	*LabelledPayload_DoubleValue
	Value isLabelledPayload_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*LabelledPayload) Descriptor deprecated

func (*LabelledPayload) Descriptor() ([]byte, []int)

Deprecated: Use LabelledPayload.ProtoReflect.Descriptor instead.

func (*LabelledPayload) GetBoolValue

func (x *LabelledPayload) GetBoolValue() bool

func (*LabelledPayload) GetDoubleValue

func (x *LabelledPayload) GetDoubleValue() float64

func (*LabelledPayload) GetLabel

func (x *LabelledPayload) GetLabel() string

func (*LabelledPayload) GetStringValue

func (x *LabelledPayload) GetStringValue() string

func (*LabelledPayload) GetValue

func (m *LabelledPayload) GetValue() isLabelledPayload_Value

func (*LabelledPayload) ProtoMessage

func (*LabelledPayload) ProtoMessage()

func (*LabelledPayload) ProtoReflect

func (x *LabelledPayload) ProtoReflect() protoreflect.Message

func (*LabelledPayload) Reset

func (x *LabelledPayload) Reset()

func (*LabelledPayload) String

func (x *LabelledPayload) String() string

type LabelledPayload_BoolValue

type LabelledPayload_BoolValue struct {
	BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof"`
}

type LabelledPayload_DoubleValue

type LabelledPayload_DoubleValue struct {
	DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}

type LabelledPayload_StringValue

type LabelledPayload_StringValue struct {
	StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type LogicalType

type LogicalType struct {
	Urn            string      `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	Payload        []byte      `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Representation *FieldType  `protobuf:"bytes,3,opt,name=representation,proto3" json:"representation,omitempty"`
	ArgumentType   *FieldType  `protobuf:"bytes,4,opt,name=argument_type,json=argumentType,proto3" json:"argument_type,omitempty"`
	Argument       *FieldValue `protobuf:"bytes,5,opt,name=argument,proto3" json:"argument,omitempty"`
	// contains filtered or unexported fields
}

func (*LogicalType) Descriptor deprecated

func (*LogicalType) Descriptor() ([]byte, []int)

Deprecated: Use LogicalType.ProtoReflect.Descriptor instead.

func (*LogicalType) GetArgument

func (x *LogicalType) GetArgument() *FieldValue

func (*LogicalType) GetArgumentType

func (x *LogicalType) GetArgumentType() *FieldType

func (*LogicalType) GetPayload

func (x *LogicalType) GetPayload() []byte

func (*LogicalType) GetRepresentation

func (x *LogicalType) GetRepresentation() *FieldType

func (*LogicalType) GetUrn

func (x *LogicalType) GetUrn() string

func (*LogicalType) ProtoMessage

func (*LogicalType) ProtoMessage()

func (*LogicalType) ProtoReflect

func (x *LogicalType) ProtoReflect() protoreflect.Message

func (*LogicalType) Reset

func (x *LogicalType) Reset()

func (*LogicalType) String

func (x *LogicalType) String() string

type LogicalTypeValue

type LogicalTypeValue struct {
	Value *FieldValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LogicalTypeValue) Descriptor deprecated

func (*LogicalTypeValue) Descriptor() ([]byte, []int)

Deprecated: Use LogicalTypeValue.ProtoReflect.Descriptor instead.

func (*LogicalTypeValue) GetValue

func (x *LogicalTypeValue) GetValue() *FieldValue

func (*LogicalTypeValue) ProtoMessage

func (*LogicalTypeValue) ProtoMessage()

func (*LogicalTypeValue) ProtoReflect

func (x *LogicalTypeValue) ProtoReflect() protoreflect.Message

func (*LogicalTypeValue) Reset

func (x *LogicalTypeValue) Reset()

func (*LogicalTypeValue) String

func (x *LogicalTypeValue) String() string

type MapStateSpec

type MapStateSpec struct {
	KeyCoderId   string `protobuf:"bytes,1,opt,name=key_coder_id,json=keyCoderId,proto3" json:"key_coder_id,omitempty"`
	ValueCoderId string `protobuf:"bytes,2,opt,name=value_coder_id,json=valueCoderId,proto3" json:"value_coder_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MapStateSpec) Descriptor deprecated

func (*MapStateSpec) Descriptor() ([]byte, []int)

Deprecated: Use MapStateSpec.ProtoReflect.Descriptor instead.

func (*MapStateSpec) GetKeyCoderId

func (x *MapStateSpec) GetKeyCoderId() string

func (*MapStateSpec) GetValueCoderId

func (x *MapStateSpec) GetValueCoderId() string

func (*MapStateSpec) ProtoMessage

func (*MapStateSpec) ProtoMessage()

func (*MapStateSpec) ProtoReflect

func (x *MapStateSpec) ProtoReflect() protoreflect.Message

func (*MapStateSpec) Reset

func (x *MapStateSpec) Reset()

func (*MapStateSpec) String

func (x *MapStateSpec) String() string

type MapType

type MapType struct {
	KeyType   *FieldType `protobuf:"bytes,1,opt,name=key_type,json=keyType,proto3" json:"key_type,omitempty"`
	ValueType *FieldType `protobuf:"bytes,2,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"`
	// contains filtered or unexported fields
}

func (*MapType) Descriptor deprecated

func (*MapType) Descriptor() ([]byte, []int)

Deprecated: Use MapType.ProtoReflect.Descriptor instead.

func (*MapType) GetKeyType

func (x *MapType) GetKeyType() *FieldType

func (*MapType) GetValueType

func (x *MapType) GetValueType() *FieldType

func (*MapType) ProtoMessage

func (*MapType) ProtoMessage()

func (*MapType) ProtoReflect

func (x *MapType) ProtoReflect() protoreflect.Message

func (*MapType) Reset

func (x *MapType) Reset()

func (*MapType) String

func (x *MapType) String() string

type MapTypeEntry

type MapTypeEntry struct {
	Key   *FieldValue `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *FieldValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MapTypeEntry) Descriptor deprecated

func (*MapTypeEntry) Descriptor() ([]byte, []int)

Deprecated: Use MapTypeEntry.ProtoReflect.Descriptor instead.

func (*MapTypeEntry) GetKey

func (x *MapTypeEntry) GetKey() *FieldValue

func (*MapTypeEntry) GetValue

func (x *MapTypeEntry) GetValue() *FieldValue

func (*MapTypeEntry) ProtoMessage

func (*MapTypeEntry) ProtoMessage()

func (*MapTypeEntry) ProtoReflect

func (x *MapTypeEntry) ProtoReflect() protoreflect.Message

func (*MapTypeEntry) Reset

func (x *MapTypeEntry) Reset()

func (*MapTypeEntry) String

func (x *MapTypeEntry) String() string

type MapTypeValue

type MapTypeValue struct {
	Entries []*MapTypeEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*MapTypeValue) Descriptor deprecated

func (*MapTypeValue) Descriptor() ([]byte, []int)

Deprecated: Use MapTypeValue.ProtoReflect.Descriptor instead.

func (*MapTypeValue) GetEntries

func (x *MapTypeValue) GetEntries() []*MapTypeEntry

func (*MapTypeValue) ProtoMessage

func (*MapTypeValue) ProtoMessage()

func (*MapTypeValue) ProtoReflect

func (x *MapTypeValue) ProtoReflect() protoreflect.Message

func (*MapTypeValue) Reset

func (x *MapTypeValue) Reset()

func (*MapTypeValue) String

func (x *MapTypeValue) String() string

type MavenPayload

type MavenPayload struct {

	// A string specifying Maven artifact.
	// The standard format is "groupId:artifactId:version[:packaging[:classifier]]"
	Artifact string `protobuf:"bytes,1,opt,name=artifact,proto3" json:"artifact,omitempty"`
	// (Optional) Repository URL. If not specified, Maven central is used by default.
	RepositoryUrl string `protobuf:"bytes,2,opt,name=repository_url,json=repositoryUrl,proto3" json:"repository_url,omitempty"`
	// contains filtered or unexported fields
}

func (*MavenPayload) Descriptor deprecated

func (*MavenPayload) Descriptor() ([]byte, []int)

Deprecated: Use MavenPayload.ProtoReflect.Descriptor instead.

func (*MavenPayload) GetArtifact

func (x *MavenPayload) GetArtifact() string

func (*MavenPayload) GetRepositoryUrl

func (x *MavenPayload) GetRepositoryUrl() string

func (*MavenPayload) ProtoMessage

func (*MavenPayload) ProtoMessage()

func (*MavenPayload) ProtoReflect

func (x *MavenPayload) ProtoReflect() protoreflect.Message

func (*MavenPayload) Reset

func (x *MavenPayload) Reset()

func (*MavenPayload) String

func (x *MavenPayload) String() string

type MergeStatus

type MergeStatus struct {
	// contains filtered or unexported fields
}

Whether or not a PCollection's WindowFn is non-merging, merging, or merging-but-already-merged, in which case a subsequent GroupByKey is almost always going to do something the user does not want

func (*MergeStatus) Descriptor deprecated

func (*MergeStatus) Descriptor() ([]byte, []int)

Deprecated: Use MergeStatus.ProtoReflect.Descriptor instead.

func (*MergeStatus) ProtoMessage

func (*MergeStatus) ProtoMessage()

func (*MergeStatus) ProtoReflect

func (x *MergeStatus) ProtoReflect() protoreflect.Message

func (*MergeStatus) Reset

func (x *MergeStatus) Reset()

func (*MergeStatus) String

func (x *MergeStatus) String() string

type MergeStatus_Enum

type MergeStatus_Enum int32
const (
	MergeStatus_UNSPECIFIED MergeStatus_Enum = 0
	// The WindowFn does not require merging.
	// Examples: global window, FixedWindows, SlidingWindows
	MergeStatus_NON_MERGING MergeStatus_Enum = 1
	// The WindowFn is merging and the PCollection has not had merging
	// performed.
	// Example: Sessions prior to a GroupByKey
	MergeStatus_NEEDS_MERGE MergeStatus_Enum = 2
	// The WindowFn is merging and the PCollection has had merging occur
	// already.
	// Example: Sessions after a GroupByKey
	MergeStatus_ALREADY_MERGED MergeStatus_Enum = 3
)

func (MergeStatus_Enum) Descriptor

func (MergeStatus_Enum) Enum

func (MergeStatus_Enum) EnumDescriptor deprecated

func (MergeStatus_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use MergeStatus_Enum.Descriptor instead.

func (MergeStatus_Enum) Number

func (MergeStatus_Enum) String

func (x MergeStatus_Enum) String() string

func (MergeStatus_Enum) Type

type MessageWithComponents

type MessageWithComponents struct {

	// (Optional) The by-reference components of the root message,
	// enabling a standalone message.
	//
	// If this is absent, it is expected that there are no
	// references.
	Components *Components `protobuf:"bytes,1,opt,name=components,proto3" json:"components,omitempty"`
	// (Required) The root message that may contain pointers
	// that should be resolved by looking inside components.
	//
	// Types that are assignable to Root:
	//	*MessageWithComponents_Coder
	//	*MessageWithComponents_CombinePayload
	//	*MessageWithComponents_FunctionSpec
	//	*MessageWithComponents_ParDoPayload
	//	*MessageWithComponents_Ptransform
	//	*MessageWithComponents_Pcollection
	//	*MessageWithComponents_ReadPayload
	//	*MessageWithComponents_SideInput
	//	*MessageWithComponents_WindowIntoPayload
	//	*MessageWithComponents_WindowingStrategy
	Root isMessageWithComponents_Root `protobuf_oneof:"root"`
	// contains filtered or unexported fields
}

A disjoint union of all the things that may contain references that require Components to resolve.

func (*MessageWithComponents) Descriptor deprecated

func (*MessageWithComponents) Descriptor() ([]byte, []int)

Deprecated: Use MessageWithComponents.ProtoReflect.Descriptor instead.

func (*MessageWithComponents) GetCoder

func (x *MessageWithComponents) GetCoder() *Coder

func (*MessageWithComponents) GetCombinePayload

func (x *MessageWithComponents) GetCombinePayload() *CombinePayload

func (*MessageWithComponents) GetComponents

func (x *MessageWithComponents) GetComponents() *Components

func (*MessageWithComponents) GetFunctionSpec

func (x *MessageWithComponents) GetFunctionSpec() *FunctionSpec

func (*MessageWithComponents) GetParDoPayload

func (x *MessageWithComponents) GetParDoPayload() *ParDoPayload

func (*MessageWithComponents) GetPcollection

func (x *MessageWithComponents) GetPcollection() *PCollection

func (*MessageWithComponents) GetPtransform

func (x *MessageWithComponents) GetPtransform() *PTransform

func (*MessageWithComponents) GetReadPayload

func (x *MessageWithComponents) GetReadPayload() *ReadPayload

func (*MessageWithComponents) GetRoot

func (m *MessageWithComponents) GetRoot() isMessageWithComponents_Root