pipeline_v1

package
v2.26.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2020 License: Apache-2.0 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",
	}
	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,
	}
)

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",
	}
	StandardPTransforms_Composites_value = map[string]int32{
		"COMBINE_PER_KEY":  0,
		"COMBINE_GLOBALLY": 1,
		"RESHUFFLE":        2,
		"WRITE_FILES":      3,
		"PUBSUB_READ":      4,
		"PUBSUB_WRITE":     5,
	}
)

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 (
	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",
		13: "ROW",
	}
	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,
		"ROW":                   13,
	}
)

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",
		3: "SYNCHRONIZED_PROCESSING_TIME",
	}
	TimeDomain_Enum_value = map[string]int32{
		"UNSPECIFIED":                  0,
		"EVENT_TIME":                   1,
		"PROCESSING_TIME":              2,
		"SYNCHRONIZED_PROCESSING_TIME": 3,
	}
)

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",
	}
	StandardArtifacts_Roles_value = map[string]int32{
		"STAGING_TO": 0,
	}
)

Enum value maps for StandardArtifacts_Roles.

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

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",
	}
	StandardProtocols_Enum_value = map[string]int32{
		"LEGACY_PROGRESS_REPORTING":    0,
		"PROGRESS_REPORTING":           1,
		"WORKER_STATUS":                2,
		"MULTI_CORE_BUNDLE_PROCESSING": 3,
	}
)

Enum value maps for StandardProtocols_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_STRING",
	}
	StandardDisplayData_DisplayData_value = map[string]int32{
		"LABELLED_STRING": 0,
	}
)

Enum value maps for StandardDisplayData_DisplayData.

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 descriptor.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",
	}
	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,
	}
)

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",
	}
	MonitoringInfo_MonitoringInfoLabels_value = map[string]int32{
		"TRANSFORM":          0,
		"PCOLLECTION":        1,
		"WINDOWING_STRATEGY": 2,
		"CODER":              3,
		"ENVIRONMENT":        4,
		"NAMESPACE":          5,
		"NAME":               6,
	}
)

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 descriptor.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

Functions

func RegisterTestStreamServiceServer 

func RegisterTestStreamServiceServer(s *grpc.Server, 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) Descriptor() protoreflect.EnumDescriptor

func (AccumulationMode_Enum) Enum 

func (x AccumulationMode_Enum) Enum() *AccumulationMode_Enum

func (AccumulationMode_Enum) EnumDescriptor deprecated 

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

Deprecated: Use AccumulationMode_Enum.Descriptor instead.

func (AccumulationMode_Enum) Number 

func (x AccumulationMode_Enum) Number() protoreflect.EnumNumber

func (AccumulationMode_Enum) String 

func (x AccumulationMode_Enum) String() string

func (AccumulationMode_Enum) Type 

func (AccumulationMode_Enum) Type() protoreflect.EnumType

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 (x *ArtifactStagingToRolePayload) ProtoReflect() protoreflect.Message

func (*ArtifactStagingToRolePayload) Reset 

func (x *ArtifactStagingToRolePayload) Reset()

func (*ArtifactStagingToRolePayload) String 

func (x *ArtifactStagingToRolePayload) String() 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"`
	// contains filtered or unexported fields
}

func (*ArtifactUrlPayload) Descriptor deprecated 

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

Deprecated: Use ArtifactUrlPayload.ProtoReflect.Descriptor instead.

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 

func (AtomicType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (BeamConstants_Constants) Enum 

func (x BeamConstants_Constants) Enum() *BeamConstants_Constants

func (BeamConstants_Constants) EnumDescriptor deprecated 

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

Deprecated: Use BeamConstants_Constants.Descriptor instead.

func (BeamConstants_Constants) Number 

func (x BeamConstants_Constants) Number() protoreflect.EnumNumber

func (BeamConstants_Constants) String 

func (x BeamConstants_Constants) String() string

func (BeamConstants_Constants) Type 

func (BeamConstants_Constants) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (ClosingBehavior_Enum) Enum 

func (x ClosingBehavior_Enum) Enum() *ClosingBehavior_Enum

func (ClosingBehavior_Enum) EnumDescriptor deprecated 

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

Deprecated: Use ClosingBehavior_Enum.Descriptor instead.

func (ClosingBehavior_Enum) Number 

func (x ClosingBehavior_Enum) Number() protoreflect.EnumNumber

func (ClosingBehavior_Enum) String 

func (x ClosingBehavior_Enum) String() string

func (ClosingBehavior_Enum) Type 

func (ClosingBehavior_Enum) Type() protoreflect.EnumType

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.
	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"`
	// 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) 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 (x *ExecutableStagePayload) GetSideInputs() []*ExecutableStagePayload_SideInputId

func (*ExecutableStagePayload) GetTimerFamilies 

func (x *ExecutableStagePayload) GetTimerFamilies() []*ExecutableStagePayload_TimerFamilyId

func (*ExecutableStagePayload) GetTimers 

func (x *ExecutableStagePayload) GetTimers() []*ExecutableStagePayload_TimerId

func (*ExecutableStagePayload) GetTransforms 

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

func (*ExecutableStagePayload) GetUserStates 

func (x *ExecutableStagePayload) GetUserStates() []*ExecutableStagePayload_UserStateId

func (*ExecutableStagePayload) GetWireCoderSettings 

func (x *ExecutableStagePayload) GetWireCoderSettings() []*ExecutableStagePayload_WireCoderSetting

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 (x *ExecutableStagePayload_SideInputId) ProtoReflect() protoreflect.Message

func (*ExecutableStagePayload_SideInputId) Reset 

func (x *ExecutableStagePayload_SideInputId) Reset()

func (*ExecutableStagePayload_SideInputId) String 

func (x *ExecutableStagePayload_SideInputId) String() 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 (x *ExecutableStagePayload_TimerFamilyId) ProtoReflect() protoreflect.Message

func (*ExecutableStagePayload_TimerFamilyId) Reset 

func (x *ExecutableStagePayload_TimerFamilyId) Reset()

func (*ExecutableStagePayload_TimerFamilyId) String 

func (x *ExecutableStagePayload_TimerFamilyId) String() 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 (x *ExecutableStagePayload_TimerId) ProtoReflect() protoreflect.Message

func (*ExecutableStagePayload_TimerId) Reset 

func (x *ExecutableStagePayload_TimerId) Reset()

func (*ExecutableStagePayload_TimerId) String 

func (x *ExecutableStagePayload_TimerId) String() 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 (x *ExecutableStagePayload_UserStateId) ProtoReflect() protoreflect.Message

func (*ExecutableStagePayload_UserStateId) Reset 

func (x *ExecutableStagePayload_UserStateId) Reset()

func (*ExecutableStagePayload_UserStateId) String 

func (x *ExecutableStagePayload_UserStateId) String() 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 (x *ExecutableStagePayload_WireCoderSetting) GetPayload() []byte

func (*ExecutableStagePayload_WireCoderSetting) GetTarget 

func (m *ExecutableStagePayload_WireCoderSetting) GetTarget() isExecutableStagePayload_WireCoderSetting_Target

func (*ExecutableStagePayload_WireCoderSetting) GetTimer 

func (x *ExecutableStagePayload_WireCoderSetting) GetTimer() *ExecutableStagePayload_TimerId

func (*ExecutableStagePayload_WireCoderSetting) GetUrn 

func (x *ExecutableStagePayload_WireCoderSetting) GetUrn() string

func (*ExecutableStagePayload_WireCoderSetting) ProtoMessage 

func (*ExecutableStagePayload_WireCoderSetting) ProtoMessage()

func (*ExecutableStagePayload_WireCoderSetting) ProtoReflect 

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

func (*ExecutableStagePayload_WireCoderSetting) Reset 

func (x *ExecutableStagePayload_WireCoderSetting) Reset()

func (*ExecutableStagePayload_WireCoderSetting) String 

func (x *ExecutableStagePayload_WireCoderSetting) String() 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 (x *ExternalConfigurationPayload) ProtoReflect() protoreflect.Message

func (*ExternalConfigurationPayload) Reset 

func (x *ExternalConfigurationPayload) Reset()

func (*ExternalConfigurationPayload) String 

func (x *ExternalConfigurationPayload) String() 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.
	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 *duration.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 *timestamp.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() *timestamp.Timestamp

func (*FixedWindowsPayload) GetSize 

func (x *FixedWindowsPayload) GetSize() *duration.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) Descriptor() protoreflect.EnumDescriptor

func (FixedWindowsPayload_Enum) Enum 

func (x FixedWindowsPayload_Enum) Enum() *FixedWindowsPayload_Enum

func (FixedWindowsPayload_Enum) EnumDescriptor deprecated 

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

Deprecated: Use FixedWindowsPayload_Enum.Descriptor instead.

func (FixedWindowsPayload_Enum) Number 

func (x FixedWindowsPayload_Enum) Number() protoreflect.EnumNumber

func (FixedWindowsPayload_Enum) String 

func (x FixedWindowsPayload_Enum) String() string

func (FixedWindowsPayload_Enum) Type 

func (FixedWindowsPayload_Enum) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (GlobalWindowsPayload_Enum) Enum 

func (x GlobalWindowsPayload_Enum) Enum() *GlobalWindowsPayload_Enum

func (GlobalWindowsPayload_Enum) EnumDescriptor deprecated 

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

Deprecated: Use GlobalWindowsPayload_Enum.Descriptor instead.

func (GlobalWindowsPayload_Enum) Number 

func (x GlobalWindowsPayload_Enum) Number() protoreflect.EnumNumber

func (GlobalWindowsPayload_Enum) String 

func (x GlobalWindowsPayload_Enum) String() string

func (GlobalWindowsPayload_Enum) Type 

func (GlobalWindowsPayload_Enum) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 (x IsBounded_Enum) Number() protoreflect.EnumNumber

func (IsBounded_Enum) String 

func (x IsBounded_Enum) String() string

func (IsBounded_Enum) Type 

func (IsBounded_Enum) Type() protoreflect.EnumType

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 LabelledStringPayload 

type LabelledStringPayload 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. The urn describes
	// how the value can be interpreted and/or categorized.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LabelledStringPayload) Descriptor deprecated 

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

Deprecated: Use LabelledStringPayload.ProtoReflect.Descriptor instead.

func (*LabelledStringPayload) GetLabel 

func (x *LabelledStringPayload) GetLabel() string

func (*LabelledStringPayload) GetValue 

func (x *LabelledStringPayload) GetValue() string

func (*LabelledStringPayload) ProtoMessage 

func (*LabelledStringPayload) ProtoMessage()

func (*LabelledStringPayload) ProtoReflect 

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

func (*LabelledStringPayload) Reset 

func (x *LabelledStringPayload) Reset()

func (*LabelledStringPayload) String 

func (x *LabelledStringPayload) String() string

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) Descriptor() protoreflect.EnumDescriptor

func (MergeStatus_Enum) Enum 

func (x MergeStatus_Enum) Enum() *MergeStatus_Enum

func (MergeStatus_Enum) EnumDescriptor deprecated 

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

Deprecated: Use MergeStatus_Enum.Descriptor instead.

func (MergeStatus_Enum) Number 

func (x MergeStatus_Enum) Number() protoreflect.EnumNumber

func (MergeStatus_Enum) String 

func (x MergeStatus_Enum) String() string

func (MergeStatus_Enum) Type 

func (MergeStatus_Enum) Type() protoreflect.EnumType

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

func (*MessageWithComponents) GetSideInput 

func (x *MessageWithComponents) GetSideInput() *SideInput

func (*MessageWithComponents) GetWindowIntoPayload 

func (x *MessageWithComponents) GetWindowIntoPayload() *WindowIntoPayload

func (*MessageWithComponents) GetWindowingStrategy 

func (x *MessageWithComponents) GetWindowingStrategy() *WindowingStrategy

func (*MessageWithComponents) ProtoMessage 

func (*MessageWithComponents) ProtoMessage()

func (*MessageWithComponents) ProtoReflect 

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

func (*MessageWithComponents) Reset 

func (x *MessageWithComponents) Reset()

func (*MessageWithComponents) String 

func (x *MessageWithComponents) String() string

type MessageWithComponents_Coder 

type MessageWithComponents_Coder struct {
	Coder *Coder `protobuf:"bytes,2,opt,name=coder,proto3,oneof"`
}

type MessageWithComponents_CombinePayload 

type MessageWithComponents_CombinePayload struct {
	CombinePayload *CombinePayload `protobuf:"bytes,3,opt,name=combine_payload,json=combinePayload,proto3,oneof"`
}

type MessageWithComponents_FunctionSpec 

type MessageWithComponents_FunctionSpec struct {
	FunctionSpec *FunctionSpec `protobuf:"bytes,4,opt,name=function_spec,json=functionSpec,proto3,oneof"`
}

type MessageWithComponents_ParDoPayload 

type MessageWithComponents_ParDoPayload struct {
	ParDoPayload *ParDoPayload `protobuf:"bytes,6,opt,name=par_do_payload,json=parDoPayload,proto3,oneof"`
}

type MessageWithComponents_Pcollection 

type MessageWithComponents_Pcollection struct {
	Pcollection *PCollection `protobuf:"bytes,8,opt,name=pcollection,proto3,oneof"`
}

type MessageWithComponents_Ptransform 

type MessageWithComponents_Ptransform struct {
	Ptransform *PTransform `protobuf:"bytes,7,opt,name=ptransform,proto3,oneof"`
}

type MessageWithComponents_ReadPayload 

type MessageWithComponents_ReadPayload struct {
	ReadPayload *ReadPayload `protobuf:"bytes,9,opt,name=read_payload,json=readPayload,proto3,oneof"`
}

type MessageWithComponents_SideInput 

type MessageWithComponents_SideInput struct {
	SideInput *SideInput `protobuf:"bytes,11,opt,name=side_input,json=sideInput,proto3,oneof"`
}

type MessageWithComponents_WindowIntoPayload 

type MessageWithComponents_WindowIntoPayload struct {
	WindowIntoPayload *WindowIntoPayload `protobuf:"bytes,12,opt,name=window_into_payload,json=windowIntoPayload,proto3,oneof"`
}

type MessageWithComponents_WindowingStrategy