Documentation ¶
Index ¶
- Variables
- func RegisterTestStreamServiceServer(s *grpc.Server, srv TestStreamServiceServer)
- type AccumulationMode
- type AccumulationMode_Enum
- func (AccumulationMode_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x AccumulationMode_Enum) Enum() *AccumulationMode_Enum
- func (AccumulationMode_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x AccumulationMode_Enum) Number() protoreflect.EnumNumber
- func (x AccumulationMode_Enum) String() string
- func (AccumulationMode_Enum) Type() protoreflect.EnumType
- type Annotation
- type ApiServiceDescriptor
- func (*ApiServiceDescriptor) Descriptor() ([]byte, []int)deprecated
- func (x *ApiServiceDescriptor) GetAuthentication() *AuthenticationSpec
- func (x *ApiServiceDescriptor) GetUrl() string
- func (*ApiServiceDescriptor) ProtoMessage()
- func (x *ApiServiceDescriptor) ProtoReflect() protoreflect.Message
- func (x *ApiServiceDescriptor) Reset()
- func (x *ApiServiceDescriptor) String() string
- type ArrayType
- type ArrayTypeValue
- type ArtifactFilePayload
- func (*ArtifactFilePayload) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactFilePayload) GetPath() string
- func (x *ArtifactFilePayload) GetSha256() string
- func (*ArtifactFilePayload) ProtoMessage()
- func (x *ArtifactFilePayload) ProtoReflect() protoreflect.Message
- func (x *ArtifactFilePayload) Reset()
- func (x *ArtifactFilePayload) String() string
- type ArtifactInformation
- func (*ArtifactInformation) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactInformation) GetRolePayload() []byte
- func (x *ArtifactInformation) GetRoleUrn() string
- func (x *ArtifactInformation) GetTypePayload() []byte
- func (x *ArtifactInformation) GetTypeUrn() string
- func (*ArtifactInformation) ProtoMessage()
- func (x *ArtifactInformation) ProtoReflect() protoreflect.Message
- func (x *ArtifactInformation) Reset()
- func (x *ArtifactInformation) String() string
- type ArtifactStagingToRolePayload
- func (*ArtifactStagingToRolePayload) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactStagingToRolePayload) GetStagedName() string
- func (*ArtifactStagingToRolePayload) ProtoMessage()
- func (x *ArtifactStagingToRolePayload) ProtoReflect() protoreflect.Message
- func (x *ArtifactStagingToRolePayload) Reset()
- func (x *ArtifactStagingToRolePayload) String() string
- type ArtifactUrlPayload
- func (*ArtifactUrlPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ArtifactUrlPayload) GetSha256() string
- func (x *ArtifactUrlPayload) GetUrl() string
- func (*ArtifactUrlPayload) ProtoMessage()
- func (x *ArtifactUrlPayload) ProtoReflect() protoreflect.Message
- func (x *ArtifactUrlPayload) Reset()
- func (x *ArtifactUrlPayload) String() string
- type AtomicType
- type AtomicTypeValue
- func (*AtomicTypeValue) Descriptor() ([]byte, []int)deprecated
- func (x *AtomicTypeValue) GetBoolean() bool
- func (x *AtomicTypeValue) GetByte() int32
- func (x *AtomicTypeValue) GetBytes() []byte
- func (x *AtomicTypeValue) GetDouble() float64
- func (x *AtomicTypeValue) GetFloat() float32
- func (x *AtomicTypeValue) GetInt16() int32
- func (x *AtomicTypeValue) GetInt32() int32
- func (x *AtomicTypeValue) GetInt64() int64
- func (x *AtomicTypeValue) GetString_() string
- func (m *AtomicTypeValue) GetValue() isAtomicTypeValue_Value
- func (*AtomicTypeValue) ProtoMessage()
- func (x *AtomicTypeValue) ProtoReflect() protoreflect.Message
- func (x *AtomicTypeValue) Reset()
- func (x *AtomicTypeValue) String() string
- type AtomicTypeValue_Boolean
- type AtomicTypeValue_Byte
- type AtomicTypeValue_Bytes
- type AtomicTypeValue_Double
- type AtomicTypeValue_Float
- type AtomicTypeValue_Int16
- type AtomicTypeValue_Int32
- type AtomicTypeValue_Int64
- type AtomicTypeValue_String_
- type AuthenticationSpec
- func (*AuthenticationSpec) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticationSpec) GetPayload() []byte
- func (x *AuthenticationSpec) GetUrn() string
- func (*AuthenticationSpec) ProtoMessage()
- func (x *AuthenticationSpec) ProtoReflect() protoreflect.Message
- func (x *AuthenticationSpec) Reset()
- func (x *AuthenticationSpec) String() string
- type BagStateSpec
- type BeamConstants
- type BeamConstants_Constants
- func (BeamConstants_Constants) Descriptor() protoreflect.EnumDescriptor
- func (x BeamConstants_Constants) Enum() *BeamConstants_Constants
- func (BeamConstants_Constants) EnumDescriptor() ([]byte, []int)deprecated
- func (x BeamConstants_Constants) Number() protoreflect.EnumNumber
- func (x BeamConstants_Constants) String() string
- func (BeamConstants_Constants) Type() protoreflect.EnumType
- type ClosingBehavior
- type ClosingBehavior_Enum
- func (ClosingBehavior_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x ClosingBehavior_Enum) Enum() *ClosingBehavior_Enum
- func (ClosingBehavior_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClosingBehavior_Enum) Number() protoreflect.EnumNumber
- func (x ClosingBehavior_Enum) String() string
- func (ClosingBehavior_Enum) Type() protoreflect.EnumType
- type Coder
- type CombinePayload
- func (*CombinePayload) Descriptor() ([]byte, []int)deprecated
- func (x *CombinePayload) GetAccumulatorCoderId() string
- func (x *CombinePayload) GetCombineFn() *FunctionSpec
- func (*CombinePayload) ProtoMessage()
- func (x *CombinePayload) ProtoReflect() protoreflect.Message
- func (x *CombinePayload) Reset()
- func (x *CombinePayload) String() string
- type CombiningStateSpec
- func (*CombiningStateSpec) Descriptor() ([]byte, []int)deprecated
- func (x *CombiningStateSpec) GetAccumulatorCoderId() string
- func (x *CombiningStateSpec) GetCombineFn() *FunctionSpec
- func (*CombiningStateSpec) ProtoMessage()
- func (x *CombiningStateSpec) ProtoReflect() protoreflect.Message
- func (x *CombiningStateSpec) Reset()
- func (x *CombiningStateSpec) String() string
- type Components
- func (*Components) Descriptor() ([]byte, []int)deprecated
- func (x *Components) GetCoders() map[string]*Coder
- func (x *Components) GetEnvironments() map[string]*Environment
- func (x *Components) GetPcollections() map[string]*PCollection
- func (x *Components) GetTransforms() map[string]*PTransform
- func (x *Components) GetWindowingStrategies() map[string]*WindowingStrategy
- func (*Components) ProtoMessage()
- func (x *Components) ProtoReflect() protoreflect.Message
- func (x *Components) Reset()
- func (x *Components) String() string
- type DeferredArtifactPayload
- func (*DeferredArtifactPayload) Descriptor() ([]byte, []int)deprecated
- func (x *DeferredArtifactPayload) GetData() []byte
- func (x *DeferredArtifactPayload) GetKey() string
- func (*DeferredArtifactPayload) ProtoMessage()
- func (x *DeferredArtifactPayload) ProtoReflect() protoreflect.Message
- func (x *DeferredArtifactPayload) Reset()
- func (x *DeferredArtifactPayload) String() string
- type DisplayData
- type DockerPayload
- type EmbeddedFilePayload
- func (*EmbeddedFilePayload) Descriptor() ([]byte, []int)deprecated
- func (x *EmbeddedFilePayload) GetData() []byte
- func (*EmbeddedFilePayload) ProtoMessage()
- func (x *EmbeddedFilePayload) ProtoReflect() protoreflect.Message
- func (x *EmbeddedFilePayload) Reset()
- func (x *EmbeddedFilePayload) String() string
- type Environment
- func (*Environment) Descriptor() ([]byte, []int)deprecated
- func (x *Environment) GetCapabilities() []string
- func (x *Environment) GetDependencies() []*ArtifactInformation
- func (x *Environment) GetDisplayData() []*DisplayData
- func (x *Environment) GetPayload() []byte
- func (x *Environment) GetResourceHints() map[string][]byte
- func (x *Environment) GetUrn() string
- func (*Environment) ProtoMessage()
- func (x *Environment) ProtoReflect() protoreflect.Message
- func (x *Environment) Reset()
- func (x *Environment) String() string
- type EventsRequest
- type ExecutableStagePayload
- func (*ExecutableStagePayload) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStagePayload) GetComponents() *Components
- func (x *ExecutableStagePayload) GetEnvironment() *Environment
- func (x *ExecutableStagePayload) GetInput() string
- func (x *ExecutableStagePayload) GetOutputs() []string
- func (x *ExecutableStagePayload) GetSideInputs() []*ExecutableStagePayload_SideInputId
- func (x *ExecutableStagePayload) GetTimerFamilies() []*ExecutableStagePayload_TimerFamilyId
- func (x *ExecutableStagePayload) GetTimers() []*ExecutableStagePayload_TimerId
- func (x *ExecutableStagePayload) GetTransforms() []string
- func (x *ExecutableStagePayload) GetUserStates() []*ExecutableStagePayload_UserStateId
- func (x *ExecutableStagePayload) GetWireCoderSettings() []*ExecutableStagePayload_WireCoderSetting
- func (*ExecutableStagePayload) ProtoMessage()
- func (x *ExecutableStagePayload) ProtoReflect() protoreflect.Message
- func (x *ExecutableStagePayload) Reset()
- func (x *ExecutableStagePayload) String() string
- type ExecutableStagePayload_SideInputId
- func (*ExecutableStagePayload_SideInputId) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStagePayload_SideInputId) GetLocalName() string
- func (x *ExecutableStagePayload_SideInputId) GetTransformId() string
- func (*ExecutableStagePayload_SideInputId) ProtoMessage()
- func (x *ExecutableStagePayload_SideInputId) ProtoReflect() protoreflect.Message
- func (x *ExecutableStagePayload_SideInputId) Reset()
- func (x *ExecutableStagePayload_SideInputId) String() string
- type ExecutableStagePayload_TimerFamilyId
- func (*ExecutableStagePayload_TimerFamilyId) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStagePayload_TimerFamilyId) GetLocalName() string
- func (x *ExecutableStagePayload_TimerFamilyId) GetTransformId() string
- func (*ExecutableStagePayload_TimerFamilyId) ProtoMessage()
- func (x *ExecutableStagePayload_TimerFamilyId) ProtoReflect() protoreflect.Message
- func (x *ExecutableStagePayload_TimerFamilyId) Reset()
- func (x *ExecutableStagePayload_TimerFamilyId) String() string
- type ExecutableStagePayload_TimerId
- func (*ExecutableStagePayload_TimerId) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStagePayload_TimerId) GetLocalName() string
- func (x *ExecutableStagePayload_TimerId) GetTransformId() string
- func (*ExecutableStagePayload_TimerId) ProtoMessage()
- func (x *ExecutableStagePayload_TimerId) ProtoReflect() protoreflect.Message
- func (x *ExecutableStagePayload_TimerId) Reset()
- func (x *ExecutableStagePayload_TimerId) String() string
- type ExecutableStagePayload_UserStateId
- func (*ExecutableStagePayload_UserStateId) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStagePayload_UserStateId) GetLocalName() string
- func (x *ExecutableStagePayload_UserStateId) GetTransformId() string
- func (*ExecutableStagePayload_UserStateId) ProtoMessage()
- func (x *ExecutableStagePayload_UserStateId) ProtoReflect() protoreflect.Message
- func (x *ExecutableStagePayload_UserStateId) Reset()
- func (x *ExecutableStagePayload_UserStateId) String() string
- type ExecutableStagePayload_WireCoderSetting
- func (*ExecutableStagePayload_WireCoderSetting) Descriptor() ([]byte, []int)deprecated
- func (x *ExecutableStagePayload_WireCoderSetting) GetInputOrOutputId() string
- func (x *ExecutableStagePayload_WireCoderSetting) GetPayload() []byte
- func (m *ExecutableStagePayload_WireCoderSetting) GetTarget() isExecutableStagePayload_WireCoderSetting_Target
- func (x *ExecutableStagePayload_WireCoderSetting) GetTimer() *ExecutableStagePayload_TimerId
- func (x *ExecutableStagePayload_WireCoderSetting) GetUrn() string
- func (*ExecutableStagePayload_WireCoderSetting) ProtoMessage()
- func (x *ExecutableStagePayload_WireCoderSetting) ProtoReflect() protoreflect.Message
- func (x *ExecutableStagePayload_WireCoderSetting) Reset()
- func (x *ExecutableStagePayload_WireCoderSetting) String() string
- type ExecutableStagePayload_WireCoderSetting_InputOrOutputId
- type ExecutableStagePayload_WireCoderSetting_Timer
- type ExternalConfigurationPayload
- func (*ExternalConfigurationPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalConfigurationPayload) GetPayload() []byte
- func (x *ExternalConfigurationPayload) GetSchema() *Schema
- func (*ExternalConfigurationPayload) ProtoMessage()
- func (x *ExternalConfigurationPayload) ProtoReflect() protoreflect.Message
- func (x *ExternalConfigurationPayload) Reset()
- func (x *ExternalConfigurationPayload) String() string
- type ExternalPayload
- func (*ExternalPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalPayload) GetEndpoint() *ApiServiceDescriptor
- func (x *ExternalPayload) GetParams() map[string]string
- func (*ExternalPayload) ProtoMessage()
- func (x *ExternalPayload) ProtoReflect() protoreflect.Message
- func (x *ExternalPayload) Reset()
- func (x *ExternalPayload) String() string
- type Field
- func (*Field) Descriptor() ([]byte, []int)deprecated
- func (x *Field) GetDescription() string
- func (x *Field) GetEncodingPosition() int32
- func (x *Field) GetId() int32
- func (x *Field) GetName() string
- func (x *Field) GetOptions() []*Option
- func (x *Field) GetType() *FieldType
- func (*Field) ProtoMessage()
- func (x *Field) ProtoReflect() protoreflect.Message
- func (x *Field) Reset()
- func (x *Field) String() string
- type FieldType
- func (*FieldType) Descriptor() ([]byte, []int)deprecated
- func (x *FieldType) GetArrayType() *ArrayType
- func (x *FieldType) GetAtomicType() AtomicType
- func (x *FieldType) GetIterableType() *IterableType
- func (x *FieldType) GetLogicalType() *LogicalType
- func (x *FieldType) GetMapType() *MapType
- func (x *FieldType) GetNullable() bool
- func (x *FieldType) GetRowType() *RowType
- func (m *FieldType) GetTypeInfo() isFieldType_TypeInfo
- func (*FieldType) ProtoMessage()
- func (x *FieldType) ProtoReflect() protoreflect.Message
- func (x *FieldType) Reset()
- func (x *FieldType) String() string
- type FieldType_ArrayType
- type FieldType_AtomicType
- type FieldType_IterableType
- type FieldType_LogicalType
- type FieldType_MapType
- type FieldType_RowType
- type FieldValue
- func (*FieldValue) Descriptor() ([]byte, []int)deprecated
- func (x *FieldValue) GetArrayValue() *ArrayTypeValue
- func (x *FieldValue) GetAtomicValue() *AtomicTypeValue
- func (m *FieldValue) GetFieldValue() isFieldValue_FieldValue
- func (x *FieldValue) GetIterableValue() *IterableTypeValue
- func (x *FieldValue) GetLogicalTypeValue() *LogicalTypeValue
- func (x *FieldValue) GetMapValue() *MapTypeValue
- func (x *FieldValue) GetRowValue() *Row
- func (*FieldValue) ProtoMessage()
- func (x *FieldValue) ProtoReflect() protoreflect.Message
- func (x *FieldValue) Reset()
- func (x *FieldValue) String() string
- type FieldValue_ArrayValue
- type FieldValue_AtomicValue
- type FieldValue_IterableValue
- type FieldValue_LogicalTypeValue
- type FieldValue_MapValue
- type FieldValue_RowValue
- type FixedWindowsPayload
- func (*FixedWindowsPayload) Descriptor() ([]byte, []int)deprecated
- func (x *FixedWindowsPayload) GetOffset() *timestamp.Timestamp
- func (x *FixedWindowsPayload) GetSize() *duration.Duration
- func (*FixedWindowsPayload) ProtoMessage()
- func (x *FixedWindowsPayload) ProtoReflect() protoreflect.Message
- func (x *FixedWindowsPayload) Reset()
- func (x *FixedWindowsPayload) String() string
- type FixedWindowsPayload_Enum
- func (FixedWindowsPayload_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x FixedWindowsPayload_Enum) Enum() *FixedWindowsPayload_Enum
- func (FixedWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x FixedWindowsPayload_Enum) Number() protoreflect.EnumNumber
- func (x FixedWindowsPayload_Enum) String() string
- func (FixedWindowsPayload_Enum) Type() protoreflect.EnumType
- type FunctionSpec
- func (*FunctionSpec) Descriptor() ([]byte, []int)deprecated
- func (x *FunctionSpec) GetPayload() []byte
- func (x *FunctionSpec) GetUrn() string
- func (*FunctionSpec) ProtoMessage()
- func (x *FunctionSpec) ProtoReflect() protoreflect.Message
- func (x *FunctionSpec) Reset()
- func (x *FunctionSpec) String() string
- type GlobalWindowsPayload
- type GlobalWindowsPayload_Enum
- func (GlobalWindowsPayload_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x GlobalWindowsPayload_Enum) Enum() *GlobalWindowsPayload_Enum
- func (GlobalWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x GlobalWindowsPayload_Enum) Number() protoreflect.EnumNumber
- func (x GlobalWindowsPayload_Enum) String() string
- func (GlobalWindowsPayload_Enum) Type() protoreflect.EnumType
- type GroupIntoBatchesPayload
- func (*GroupIntoBatchesPayload) Descriptor() ([]byte, []int)deprecated
- func (x *GroupIntoBatchesPayload) GetBatchSize() int64
- func (x *GroupIntoBatchesPayload) GetMaxBufferingDurationMillis() int64
- func (*GroupIntoBatchesPayload) ProtoMessage()
- func (x *GroupIntoBatchesPayload) ProtoReflect() protoreflect.Message
- func (x *GroupIntoBatchesPayload) Reset()
- func (x *GroupIntoBatchesPayload) String() string
- type IsBounded
- type IsBounded_Enum
- func (IsBounded_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x IsBounded_Enum) Enum() *IsBounded_Enum
- func (IsBounded_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x IsBounded_Enum) Number() protoreflect.EnumNumber
- func (x IsBounded_Enum) String() string
- func (IsBounded_Enum) Type() protoreflect.EnumType
- type IterableType
- type IterableTypeValue
- func (*IterableTypeValue) Descriptor() ([]byte, []int)deprecated
- func (x *IterableTypeValue) GetElement() []*FieldValue
- func (*IterableTypeValue) ProtoMessage()
- func (x *IterableTypeValue) ProtoReflect() protoreflect.Message
- func (x *IterableTypeValue) Reset()
- func (x *IterableTypeValue) String() string
- type LabelledPayload
- func (*LabelledPayload) Descriptor() ([]byte, []int)deprecated
- func (x *LabelledPayload) GetBoolValue() bool
- func (x *LabelledPayload) GetDoubleValue() float64
- func (x *LabelledPayload) GetLabel() string
- func (x *LabelledPayload) GetStringValue() string
- func (m *LabelledPayload) GetValue() isLabelledPayload_Value
- func (*LabelledPayload) ProtoMessage()
- func (x *LabelledPayload) ProtoReflect() protoreflect.Message
- func (x *LabelledPayload) Reset()
- func (x *LabelledPayload) String() string
- type LabelledPayload_BoolValue
- type LabelledPayload_DoubleValue
- type LabelledPayload_StringValue
- type LogicalType
- func (*LogicalType) Descriptor() ([]byte, []int)deprecated
- func (x *LogicalType) GetArgument() *FieldValue
- func (x *LogicalType) GetArgumentType() *FieldType
- func (x *LogicalType) GetPayload() []byte
- func (x *LogicalType) GetRepresentation() *FieldType
- func (x *LogicalType) GetUrn() string
- func (*LogicalType) ProtoMessage()
- func (x *LogicalType) ProtoReflect() protoreflect.Message
- func (x *LogicalType) Reset()
- func (x *LogicalType) String() string
- type LogicalTypeValue
- type MapStateSpec
- func (*MapStateSpec) Descriptor() ([]byte, []int)deprecated
- func (x *MapStateSpec) GetKeyCoderId() string
- func (x *MapStateSpec) GetValueCoderId() string
- func (*MapStateSpec) ProtoMessage()
- func (x *MapStateSpec) ProtoReflect() protoreflect.Message
- func (x *MapStateSpec) Reset()
- func (x *MapStateSpec) String() string
- type MapType
- type MapTypeEntry
- func (*MapTypeEntry) Descriptor() ([]byte, []int)deprecated
- func (x *MapTypeEntry) GetKey() *FieldValue
- func (x *MapTypeEntry) GetValue() *FieldValue
- func (*MapTypeEntry) ProtoMessage()
- func (x *MapTypeEntry) ProtoReflect() protoreflect.Message
- func (x *MapTypeEntry) Reset()
- func (x *MapTypeEntry) String() string
- type MapTypeValue
- type MavenPayload
- func (*MavenPayload) Descriptor() ([]byte, []int)deprecated
- func (x *MavenPayload) GetArtifact() string
- func (x *MavenPayload) GetRepositoryUrl() string
- func (*MavenPayload) ProtoMessage()
- func (x *MavenPayload) ProtoReflect() protoreflect.Message
- func (x *MavenPayload) Reset()
- func (x *MavenPayload) String() string
- type MergeStatus
- type MergeStatus_Enum
- func (MergeStatus_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x MergeStatus_Enum) Enum() *MergeStatus_Enum
- func (MergeStatus_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x MergeStatus_Enum) Number() protoreflect.EnumNumber
- func (x MergeStatus_Enum) String() string
- func (MergeStatus_Enum) Type() protoreflect.EnumType
- type MessageWithComponents
- func (*MessageWithComponents) Descriptor() ([]byte, []int)deprecated
- func (x *MessageWithComponents) GetCoder() *Coder
- func (x *MessageWithComponents) GetCombinePayload() *CombinePayload
- func (x *MessageWithComponents) GetComponents() *Components
- func (x *MessageWithComponents) GetFunctionSpec() *FunctionSpec
- func (x *MessageWithComponents) GetParDoPayload() *ParDoPayload
- func (x *MessageWithComponents) GetPcollection() *PCollection
- func (x *MessageWithComponents) GetPtransform() *PTransform
- func (x *MessageWithComponents) GetReadPayload() *ReadPayload
- func (m *MessageWithComponents) GetRoot() isMessageWithComponents_Root
- func (x *MessageWithComponents) GetSideInput() *SideInput
- func (x *MessageWithComponents) GetWindowIntoPayload() *WindowIntoPayload
- func (x *MessageWithComponents) GetWindowingStrategy() *WindowingStrategy
- func (*MessageWithComponents) ProtoMessage()
- func (x *MessageWithComponents) ProtoReflect() protoreflect.Message
- func (x *MessageWithComponents) Reset()
- func (x *MessageWithComponents) String() string
- type MessageWithComponents_Coder
- type MessageWithComponents_CombinePayload
- type MessageWithComponents_FunctionSpec
- type MessageWithComponents_ParDoPayload
- type MessageWithComponents_Pcollection
- type MessageWithComponents_Ptransform
- type MessageWithComponents_ReadPayload
- type MessageWithComponents_SideInput
- type MessageWithComponents_WindowIntoPayload
- type MessageWithComponents_WindowingStrategy
- type MonitoringInfo
- func (*MonitoringInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MonitoringInfo) GetLabels() map[string]string
- func (x *MonitoringInfo) GetPayload() []byte
- func (x *MonitoringInfo) GetStartTime() *timestamp.Timestamp
- func (x *MonitoringInfo) GetType() string
- func (x *MonitoringInfo) GetUrn() string
- func (*MonitoringInfo) ProtoMessage()
- func (x *MonitoringInfo) ProtoReflect() protoreflect.Message
- func (x *MonitoringInfo) Reset()
- func (x *MonitoringInfo) String() string
- type MonitoringInfoLabelProps
- func (*MonitoringInfoLabelProps) Descriptor() ([]byte, []int)deprecated
- func (x *MonitoringInfoLabelProps) GetName() string
- func (*MonitoringInfoLabelProps) ProtoMessage()
- func (x *MonitoringInfoLabelProps) ProtoReflect() protoreflect.Message
- func (x *MonitoringInfoLabelProps) Reset()
- func (x *MonitoringInfoLabelProps) String() string
- type MonitoringInfoSpec
- func (*MonitoringInfoSpec) Descriptor() ([]byte, []int)deprecated
- func (x *MonitoringInfoSpec) GetAnnotations() []*Annotation
- func (x *MonitoringInfoSpec) GetRequiredLabels() []string
- func (x *MonitoringInfoSpec) GetType() string
- func (x *MonitoringInfoSpec) GetUrn() string
- func (*MonitoringInfoSpec) ProtoMessage()
- func (x *MonitoringInfoSpec) ProtoReflect() protoreflect.Message
- func (x *MonitoringInfoSpec) Reset()
- func (x *MonitoringInfoSpec) String() string
- type MonitoringInfoSpecs
- type MonitoringInfoSpecs_Enum
- func (MonitoringInfoSpecs_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x MonitoringInfoSpecs_Enum) Enum() *MonitoringInfoSpecs_Enum
- func (MonitoringInfoSpecs_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x MonitoringInfoSpecs_Enum) Number() protoreflect.EnumNumber
- func (x MonitoringInfoSpecs_Enum) String() string
- func (MonitoringInfoSpecs_Enum) Type() protoreflect.EnumType
- type MonitoringInfoTypeUrns
- type MonitoringInfoTypeUrns_Enum
- func (MonitoringInfoTypeUrns_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x MonitoringInfoTypeUrns_Enum) Enum() *MonitoringInfoTypeUrns_Enum
- func (MonitoringInfoTypeUrns_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x MonitoringInfoTypeUrns_Enum) Number() protoreflect.EnumNumber
- func (x MonitoringInfoTypeUrns_Enum) String() string
- func (MonitoringInfoTypeUrns_Enum) Type() protoreflect.EnumType
- type MonitoringInfo_MonitoringInfoLabels
- func (MonitoringInfo_MonitoringInfoLabels) Descriptor() protoreflect.EnumDescriptor
- func (x MonitoringInfo_MonitoringInfoLabels) Enum() *MonitoringInfo_MonitoringInfoLabels
- func (MonitoringInfo_MonitoringInfoLabels) EnumDescriptor() ([]byte, []int)deprecated
- func (x MonitoringInfo_MonitoringInfoLabels) Number() protoreflect.EnumNumber
- func (x MonitoringInfo_MonitoringInfoLabels) String() string
- func (MonitoringInfo_MonitoringInfoLabels) Type() protoreflect.EnumType
- type OnTimeBehavior
- type OnTimeBehavior_Enum
- func (OnTimeBehavior_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x OnTimeBehavior_Enum) Enum() *OnTimeBehavior_Enum
- func (OnTimeBehavior_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x OnTimeBehavior_Enum) Number() protoreflect.EnumNumber
- func (x OnTimeBehavior_Enum) String() string
- func (OnTimeBehavior_Enum) Type() protoreflect.EnumType
- type Option
- func (*Option) Descriptor() ([]byte, []int)deprecated
- func (x *Option) GetName() string
- func (x *Option) GetType() *FieldType
- func (x *Option) GetValue() *FieldValue
- func (*Option) ProtoMessage()
- func (x *Option) ProtoReflect() protoreflect.Message
- func (x *Option) Reset()
- func (x *Option) String() string
- type OrderedListStateSpec
- func (*OrderedListStateSpec) Descriptor() ([]byte, []int)deprecated
- func (x *OrderedListStateSpec) GetElementCoderId() string
- func (*OrderedListStateSpec) ProtoMessage()
- func (x *OrderedListStateSpec) ProtoReflect() protoreflect.Message
- func (x *OrderedListStateSpec) Reset()
- func (x *OrderedListStateSpec) String() string
- type OutputTime
- type OutputTime_Enum
- func (OutputTime_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x OutputTime_Enum) Enum() *OutputTime_Enum
- func (OutputTime_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x OutputTime_Enum) Number() protoreflect.EnumNumber
- func (x OutputTime_Enum) String() string
- func (OutputTime_Enum) Type() protoreflect.EnumType
- type PCollection
- func (*PCollection) Descriptor() ([]byte, []int)deprecated
- func (x *PCollection) GetCoderId() string
- func (x *PCollection) GetDisplayData() []*DisplayData
- func (x *PCollection) GetIsBounded() IsBounded_Enum
- func (x *PCollection) GetUniqueName() string
- func (x *PCollection) GetWindowingStrategyId() string
- func (*PCollection) ProtoMessage()
- func (x *PCollection) ProtoReflect() protoreflect.Message
- func (x *PCollection) Reset()
- func (x *PCollection) String() string
- type PTransform
- func (*PTransform) Descriptor() ([]byte, []int)deprecated
- func (x *PTransform) GetAnnotations() map[string][]byte
- func (x *PTransform) GetDisplayData() []*DisplayData
- func (x *PTransform) GetEnvironmentId() string
- func (x *PTransform) GetInputs() map[string]string
- func (x *PTransform) GetOutputs() map[string]string
- func (x *PTransform) GetSpec() *FunctionSpec
- func (x *PTransform) GetSubtransforms() []string
- func (x *PTransform) GetUniqueName() string
- func (*PTransform) ProtoMessage()
- func (x *PTransform) ProtoReflect() protoreflect.Message
- func (x *PTransform) Reset()
- func (x *PTransform) String() string
- type ParDoPayload
- func (*ParDoPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ParDoPayload) GetDoFn() *FunctionSpec
- func (x *ParDoPayload) GetRequestsFinalization() bool
- func (x *ParDoPayload) GetRequiresStableInput() bool
- func (x *ParDoPayload) GetRequiresTimeSortedInput() bool
- func (x *ParDoPayload) GetRestrictionCoderId() string
- func (x *ParDoPayload) GetSideInputs() map[string]*SideInput
- func (x *ParDoPayload) GetStateSpecs() map[string]*StateSpec
- func (x *ParDoPayload) GetTimerFamilySpecs() map[string]*TimerFamilySpec
- func (*ParDoPayload) ProtoMessage()
- func (x *ParDoPayload) ProtoReflect() protoreflect.Message
- func (x *ParDoPayload) Reset()
- func (x *ParDoPayload) String() string
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)deprecated
- func (x *Pipeline) GetComponents() *Components
- func (x *Pipeline) GetDisplayData() []*DisplayData
- func (x *Pipeline) GetRequirements() []string
- func (x *Pipeline) GetRootTransformIds() []string
- func (*Pipeline) ProtoMessage()
- func (x *Pipeline) ProtoReflect() protoreflect.Message
- func (x *Pipeline) Reset()
- func (x *Pipeline) String() string
- type ProcessPayload
- func (*ProcessPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessPayload) GetArch() string
- func (x *ProcessPayload) GetCommand() string
- func (x *ProcessPayload) GetEnv() map[string]string
- func (x *ProcessPayload) GetOs() string
- func (*ProcessPayload) ProtoMessage()
- func (x *ProcessPayload) ProtoReflect() protoreflect.Message
- func (x *ProcessPayload) Reset()
- func (x *ProcessPayload) String() string
- type PubSubReadPayload
- func (*PubSubReadPayload) Descriptor() ([]byte, []int)deprecated
- func (x *PubSubReadPayload) GetIdAttribute() string
- func (x *PubSubReadPayload) GetSubscription() string
- func (x *PubSubReadPayload) GetSubscriptionRuntimeOverridden() string
- func (x *PubSubReadPayload) GetTimestampAttribute() string
- func (x *PubSubReadPayload) GetTopic() string
- func (x *PubSubReadPayload) GetTopicRuntimeOverridden() string
- func (x *PubSubReadPayload) GetWithAttributes() bool
- func (*PubSubReadPayload) ProtoMessage()
- func (x *PubSubReadPayload) ProtoReflect() protoreflect.Message
- func (x *PubSubReadPayload) Reset()
- func (x *PubSubReadPayload) String() string
- type PubSubWritePayload
- func (*PubSubWritePayload) Descriptor() ([]byte, []int)deprecated
- func (x *PubSubWritePayload) GetIdAttribute() string
- func (x *PubSubWritePayload) GetTimestampAttribute() string
- func (x *PubSubWritePayload) GetTopic() string
- func (x *PubSubWritePayload) GetTopicRuntimeOverridden() string
- func (*PubSubWritePayload) ProtoMessage()
- func (x *PubSubWritePayload) ProtoReflect() protoreflect.Message
- func (x *PubSubWritePayload) Reset()
- func (x *PubSubWritePayload) String() string
- type PyPIPayload
- func (*PyPIPayload) Descriptor() ([]byte, []int)deprecated
- func (x *PyPIPayload) GetArtifactId() string
- func (x *PyPIPayload) GetVersion() string
- func (*PyPIPayload) ProtoMessage()
- func (x *PyPIPayload) ProtoReflect() protoreflect.Message
- func (x *PyPIPayload) Reset()
- func (x *PyPIPayload) String() string
- type ReadModifyWriteStateSpec
- func (*ReadModifyWriteStateSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ReadModifyWriteStateSpec) GetCoderId() string
- func (*ReadModifyWriteStateSpec) ProtoMessage()
- func (x *ReadModifyWriteStateSpec) ProtoReflect() protoreflect.Message
- func (x *ReadModifyWriteStateSpec) Reset()
- func (x *ReadModifyWriteStateSpec) String() string
- type ReadPayload
- func (*ReadPayload) Descriptor() ([]byte, []int)deprecated
- func (x *ReadPayload) GetIsBounded() IsBounded_Enum
- func (x *ReadPayload) GetSource() *FunctionSpec
- func (*ReadPayload) ProtoMessage()
- func (x *ReadPayload) ProtoReflect() protoreflect.Message
- func (x *ReadPayload) Reset()
- func (x *ReadPayload) String() string
- type Row
- type RowType
- type Schema
- func (*Schema) Descriptor() ([]byte, []int)deprecated
- func (x *Schema) GetEncodingPositionsSet() bool
- func (x *Schema) GetFields() []*Field
- func (x *Schema) GetId() string
- func (x *Schema) GetOptions() []*Option
- func (*Schema) ProtoMessage()
- func (x *Schema) ProtoReflect() protoreflect.Message
- func (x *Schema) Reset()
- func (x *Schema) String() string
- type SessionWindowsPayload
- func (*SessionWindowsPayload) Descriptor() ([]byte, []int)deprecated
- func (x *SessionWindowsPayload) GetGapSize() *duration.Duration
- func (*SessionWindowsPayload) ProtoMessage()
- func (x *SessionWindowsPayload) ProtoReflect() protoreflect.Message
- func (x *SessionWindowsPayload) Reset()
- func (x *SessionWindowsPayload) String() string
- type SessionWindowsPayload_Enum
- func (SessionWindowsPayload_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x SessionWindowsPayload_Enum) Enum() *SessionWindowsPayload_Enum
- func (SessionWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x SessionWindowsPayload_Enum) Number() protoreflect.EnumNumber
- func (x SessionWindowsPayload_Enum) String() string
- func (SessionWindowsPayload_Enum) Type() protoreflect.EnumType
- type SetStateSpec
- type SideInput
- func (*SideInput) Descriptor() ([]byte, []int)deprecated
- func (x *SideInput) GetAccessPattern() *FunctionSpec
- func (x *SideInput) GetViewFn() *FunctionSpec
- func (x *SideInput) GetWindowMappingFn() *FunctionSpec
- func (*SideInput) ProtoMessage()
- func (x *SideInput) ProtoReflect() protoreflect.Message
- func (x *SideInput) Reset()
- func (x *SideInput) String() string
- type SlidingWindowsPayload
- func (*SlidingWindowsPayload) Descriptor() ([]byte, []int)deprecated
- func (x *SlidingWindowsPayload) GetOffset() *timestamp.Timestamp
- func (x *SlidingWindowsPayload) GetPeriod() *duration.Duration
- func (x *SlidingWindowsPayload) GetSize() *duration.Duration
- func (*SlidingWindowsPayload) ProtoMessage()
- func (x *SlidingWindowsPayload) ProtoReflect() protoreflect.Message
- func (x *SlidingWindowsPayload) Reset()
- func (x *SlidingWindowsPayload) String() string
- type SlidingWindowsPayload_Enum
- func (SlidingWindowsPayload_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x SlidingWindowsPayload_Enum) Enum() *SlidingWindowsPayload_Enum
- func (SlidingWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x SlidingWindowsPayload_Enum) Number() protoreflect.EnumNumber
- func (x SlidingWindowsPayload_Enum) String() string
- func (SlidingWindowsPayload_Enum) Type() protoreflect.EnumType
- type StandardArtifacts
- type StandardArtifacts_Roles
- func (StandardArtifacts_Roles) Descriptor() protoreflect.EnumDescriptor
- func (x StandardArtifacts_Roles) Enum() *StandardArtifacts_Roles
- func (StandardArtifacts_Roles) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardArtifacts_Roles) Number() protoreflect.EnumNumber
- func (x StandardArtifacts_Roles) String() string
- func (StandardArtifacts_Roles) Type() protoreflect.EnumType
- type StandardArtifacts_Types
- func (StandardArtifacts_Types) Descriptor() protoreflect.EnumDescriptor
- func (x StandardArtifacts_Types) Enum() *StandardArtifacts_Types
- func (StandardArtifacts_Types) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardArtifacts_Types) Number() protoreflect.EnumNumber
- func (x StandardArtifacts_Types) String() string
- func (StandardArtifacts_Types) Type() protoreflect.EnumType
- type StandardCoders
- type StandardCoders_Enum
- func (StandardCoders_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x StandardCoders_Enum) Enum() *StandardCoders_Enum
- func (StandardCoders_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardCoders_Enum) Number() protoreflect.EnumNumber
- func (x StandardCoders_Enum) String() string
- func (StandardCoders_Enum) Type() protoreflect.EnumType
- type StandardDisplayData
- type StandardDisplayData_DisplayData
- func (StandardDisplayData_DisplayData) Descriptor() protoreflect.EnumDescriptor
- func (x StandardDisplayData_DisplayData) Enum() *StandardDisplayData_DisplayData
- func (StandardDisplayData_DisplayData) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardDisplayData_DisplayData) Number() protoreflect.EnumNumber
- func (x StandardDisplayData_DisplayData) String() string
- func (StandardDisplayData_DisplayData) Type() protoreflect.EnumType
- type StandardEnvironments
- type StandardEnvironments_Environments
- func (StandardEnvironments_Environments) Descriptor() protoreflect.EnumDescriptor
- func (x StandardEnvironments_Environments) Enum() *StandardEnvironments_Environments
- func (StandardEnvironments_Environments) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardEnvironments_Environments) Number() protoreflect.EnumNumber
- func (x StandardEnvironments_Environments) String() string
- func (StandardEnvironments_Environments) Type() protoreflect.EnumType
- type StandardPTransforms
- type StandardPTransforms_CombineComponents
- func (StandardPTransforms_CombineComponents) Descriptor() protoreflect.EnumDescriptor
- func (x StandardPTransforms_CombineComponents) Enum() *StandardPTransforms_CombineComponents
- func (StandardPTransforms_CombineComponents) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardPTransforms_CombineComponents) Number() protoreflect.EnumNumber
- func (x StandardPTransforms_CombineComponents) String() string
- func (StandardPTransforms_CombineComponents) Type() protoreflect.EnumType
- type StandardPTransforms_Composites
- func (StandardPTransforms_Composites) Descriptor() protoreflect.EnumDescriptor
- func (x StandardPTransforms_Composites) Enum() *StandardPTransforms_Composites
- func (StandardPTransforms_Composites) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardPTransforms_Composites) Number() protoreflect.EnumNumber
- func (x StandardPTransforms_Composites) String() string
- func (StandardPTransforms_Composites) Type() protoreflect.EnumType
- type StandardPTransforms_DeprecatedPrimitives
- func (StandardPTransforms_DeprecatedPrimitives) Descriptor() protoreflect.EnumDescriptor
- func (x StandardPTransforms_DeprecatedPrimitives) Enum() *StandardPTransforms_DeprecatedPrimitives
- func (StandardPTransforms_DeprecatedPrimitives) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardPTransforms_DeprecatedPrimitives) Number() protoreflect.EnumNumber
- func (x StandardPTransforms_DeprecatedPrimitives) String() string
- func (StandardPTransforms_DeprecatedPrimitives) Type() protoreflect.EnumType
- type StandardPTransforms_GroupIntoBatchesComponents
- func (StandardPTransforms_GroupIntoBatchesComponents) Descriptor() protoreflect.EnumDescriptor
- func (x StandardPTransforms_GroupIntoBatchesComponents) Enum() *StandardPTransforms_GroupIntoBatchesComponents
- func (StandardPTransforms_GroupIntoBatchesComponents) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardPTransforms_GroupIntoBatchesComponents) Number() protoreflect.EnumNumber
- func (x StandardPTransforms_GroupIntoBatchesComponents) String() string
- func (StandardPTransforms_GroupIntoBatchesComponents) Type() protoreflect.EnumType
- type StandardPTransforms_Primitives
- func (StandardPTransforms_Primitives) Descriptor() protoreflect.EnumDescriptor
- func (x StandardPTransforms_Primitives) Enum() *StandardPTransforms_Primitives
- func (StandardPTransforms_Primitives) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardPTransforms_Primitives) Number() protoreflect.EnumNumber
- func (x StandardPTransforms_Primitives) String() string
- func (StandardPTransforms_Primitives) Type() protoreflect.EnumType
- type StandardPTransforms_SplittableParDoComponents
- func (StandardPTransforms_SplittableParDoComponents) Descriptor() protoreflect.EnumDescriptor
- func (x StandardPTransforms_SplittableParDoComponents) Enum() *StandardPTransforms_SplittableParDoComponents
- func (StandardPTransforms_SplittableParDoComponents) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardPTransforms_SplittableParDoComponents) Number() protoreflect.EnumNumber
- func (x StandardPTransforms_SplittableParDoComponents) String() string
- func (StandardPTransforms_SplittableParDoComponents) Type() protoreflect.EnumType
- type StandardProtocols
- type StandardProtocols_Enum
- func (StandardProtocols_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x StandardProtocols_Enum) Enum() *StandardProtocols_Enum
- func (StandardProtocols_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardProtocols_Enum) Number() protoreflect.EnumNumber
- func (x StandardProtocols_Enum) String() string
- func (StandardProtocols_Enum) Type() protoreflect.EnumType
- type StandardRequirements
- type StandardRequirements_Enum
- func (StandardRequirements_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x StandardRequirements_Enum) Enum() *StandardRequirements_Enum
- func (StandardRequirements_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardRequirements_Enum) Number() protoreflect.EnumNumber
- func (x StandardRequirements_Enum) String() string
- func (StandardRequirements_Enum) Type() protoreflect.EnumType
- type StandardResourceHints
- type StandardResourceHints_Enum
- func (StandardResourceHints_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x StandardResourceHints_Enum) Enum() *StandardResourceHints_Enum
- func (StandardResourceHints_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardResourceHints_Enum) Number() protoreflect.EnumNumber
- func (x StandardResourceHints_Enum) String() string
- func (StandardResourceHints_Enum) Type() protoreflect.EnumType
- type StandardRunnerProtocols
- type StandardRunnerProtocols_Enum
- func (StandardRunnerProtocols_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x StandardRunnerProtocols_Enum) Enum() *StandardRunnerProtocols_Enum
- func (StandardRunnerProtocols_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardRunnerProtocols_Enum) Number() protoreflect.EnumNumber
- func (x StandardRunnerProtocols_Enum) String() string
- func (StandardRunnerProtocols_Enum) Type() protoreflect.EnumType
- type StandardSideInputTypes
- type StandardSideInputTypes_Enum
- func (StandardSideInputTypes_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x StandardSideInputTypes_Enum) Enum() *StandardSideInputTypes_Enum
- func (StandardSideInputTypes_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x StandardSideInputTypes_Enum) Number() protoreflect.EnumNumber
- func (x StandardSideInputTypes_Enum) String() string
- func (StandardSideInputTypes_Enum) Type() protoreflect.EnumType
- type StateSpec
- func (*StateSpec) Descriptor() ([]byte, []int)deprecated
- func (x *StateSpec) GetBagSpec() *BagStateSpec
- func (x *StateSpec) GetCombiningSpec() *CombiningStateSpec
- func (x *StateSpec) GetMapSpec() *MapStateSpec
- func (x *StateSpec) GetOrderedListSpec() *OrderedListStateSpec
- func (x *StateSpec) GetReadModifyWriteSpec() *ReadModifyWriteStateSpec
- func (x *StateSpec) GetSetSpec() *SetStateSpec
- func (m *StateSpec) GetSpec() isStateSpec_Spec
- func (*StateSpec) ProtoMessage()
- func (x *StateSpec) ProtoReflect() protoreflect.Message
- func (x *StateSpec) Reset()
- func (x *StateSpec) String() string
- type StateSpec_BagSpec
- type StateSpec_CombiningSpec
- type StateSpec_MapSpec
- type StateSpec_OrderedListSpec
- type StateSpec_ReadModifyWriteSpec
- type StateSpec_SetSpec
- type TestStreamPayload
- func (*TestStreamPayload) Descriptor() ([]byte, []int)deprecated
- func (x *TestStreamPayload) GetCoderId() string
- func (x *TestStreamPayload) GetEndpoint() *ApiServiceDescriptor
- func (x *TestStreamPayload) GetEvents() []*TestStreamPayload_Event
- func (*TestStreamPayload) ProtoMessage()
- func (x *TestStreamPayload) ProtoReflect() protoreflect.Message
- func (x *TestStreamPayload) Reset()
- func (x *TestStreamPayload) String() string
- type TestStreamPayload_Event
- func (*TestStreamPayload_Event) Descriptor() ([]byte, []int)deprecated
- func (x *TestStreamPayload_Event) GetElementEvent() *TestStreamPayload_Event_AddElements
- func (m *TestStreamPayload_Event) GetEvent() isTestStreamPayload_Event_Event
- func (x *TestStreamPayload_Event) GetProcessingTimeEvent() *TestStreamPayload_Event_AdvanceProcessingTime
- func (x *TestStreamPayload_Event) GetWatermarkEvent() *TestStreamPayload_Event_AdvanceWatermark
- func (*TestStreamPayload_Event) ProtoMessage()
- func (x *TestStreamPayload_Event) ProtoReflect() protoreflect.Message
- func (x *TestStreamPayload_Event) Reset()
- func (x *TestStreamPayload_Event) String() string
- type TestStreamPayload_Event_AddElements
- func (*TestStreamPayload_Event_AddElements) Descriptor() ([]byte, []int)deprecated
- func (x *TestStreamPayload_Event_AddElements) GetElements() []*TestStreamPayload_TimestampedElement
- func (x *TestStreamPayload_Event_AddElements) GetTag() string
- func (*TestStreamPayload_Event_AddElements) ProtoMessage()
- func (x *TestStreamPayload_Event_AddElements) ProtoReflect() protoreflect.Message
- func (x *TestStreamPayload_Event_AddElements) Reset()
- func (x *TestStreamPayload_Event_AddElements) String() string
- type TestStreamPayload_Event_AdvanceProcessingTime
- func (*TestStreamPayload_Event_AdvanceProcessingTime) Descriptor() ([]byte, []int)deprecated
- func (x *TestStreamPayload_Event_AdvanceProcessingTime) GetAdvanceDuration() int64
- func (*TestStreamPayload_Event_AdvanceProcessingTime) ProtoMessage()
- func (x *TestStreamPayload_Event_AdvanceProcessingTime) ProtoReflect() protoreflect.Message
- func (x *TestStreamPayload_Event_AdvanceProcessingTime) Reset()
- func (x *TestStreamPayload_Event_AdvanceProcessingTime) String() string
- type TestStreamPayload_Event_AdvanceWatermark
- func (*TestStreamPayload_Event_AdvanceWatermark) Descriptor() ([]byte, []int)deprecated
- func (x *TestStreamPayload_Event_AdvanceWatermark) GetNewWatermark() int64
- func (x *TestStreamPayload_Event_AdvanceWatermark) GetTag() string
- func (*TestStreamPayload_Event_AdvanceWatermark) ProtoMessage()
- func (x *TestStreamPayload_Event_AdvanceWatermark) ProtoReflect() protoreflect.Message
- func (x *TestStreamPayload_Event_AdvanceWatermark) Reset()
- func (x *TestStreamPayload_Event_AdvanceWatermark) String() string
- type TestStreamPayload_Event_ElementEvent
- type TestStreamPayload_Event_ProcessingTimeEvent
- type TestStreamPayload_Event_WatermarkEvent
- type TestStreamPayload_TimestampedElement
- func (*TestStreamPayload_TimestampedElement) Descriptor() ([]byte, []int)deprecated
- func (x *TestStreamPayload_TimestampedElement) GetEncodedElement() []byte
- func (x *TestStreamPayload_TimestampedElement) GetTimestamp() int64
- func (*TestStreamPayload_TimestampedElement) ProtoMessage()
- func (x *TestStreamPayload_TimestampedElement) ProtoReflect() protoreflect.Message
- func (x *TestStreamPayload_TimestampedElement) Reset()
- func (x *TestStreamPayload_TimestampedElement) String() string
- type TestStreamServiceClient
- type TestStreamServiceServer
- type TestStreamService_EventsClient
- type TestStreamService_EventsServer
- type TimeDomain
- type TimeDomain_Enum
- func (TimeDomain_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x TimeDomain_Enum) Enum() *TimeDomain_Enum
- func (TimeDomain_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x TimeDomain_Enum) Number() protoreflect.EnumNumber
- func (x TimeDomain_Enum) String() string
- func (TimeDomain_Enum) Type() protoreflect.EnumType
- type TimerFamilySpec
- func (*TimerFamilySpec) Descriptor() ([]byte, []int)deprecated
- func (x *TimerFamilySpec) GetTimeDomain() TimeDomain_Enum
- func (x *TimerFamilySpec) GetTimerFamilyCoderId() string
- func (*TimerFamilySpec) ProtoMessage()
- func (x *TimerFamilySpec) ProtoReflect() protoreflect.Message
- func (x *TimerFamilySpec) Reset()
- func (x *TimerFamilySpec) String() string
- type TimestampTransform
- func (*TimestampTransform) Descriptor() ([]byte, []int)deprecated
- func (x *TimestampTransform) GetAlignTo() *TimestampTransform_AlignTo
- func (x *TimestampTransform) GetDelay() *TimestampTransform_Delay
- func (m *TimestampTransform) GetTimestampTransform() isTimestampTransform_TimestampTransform
- func (*TimestampTransform) ProtoMessage()
- func (x *TimestampTransform) ProtoReflect() protoreflect.Message
- func (x *TimestampTransform) Reset()
- func (x *TimestampTransform) String() string
- type TimestampTransform_AlignTo
- func (*TimestampTransform_AlignTo) Descriptor() ([]byte, []int)deprecated
- func (x *TimestampTransform_AlignTo) GetOffset() int64
- func (x *TimestampTransform_AlignTo) GetPeriod() int64
- func (*TimestampTransform_AlignTo) ProtoMessage()
- func (x *TimestampTransform_AlignTo) ProtoReflect() protoreflect.Message
- func (x *TimestampTransform_AlignTo) Reset()
- func (x *TimestampTransform_AlignTo) String() string
- type TimestampTransform_AlignTo_
- type TimestampTransform_Delay
- func (*TimestampTransform_Delay) Descriptor() ([]byte, []int)deprecated
- func (x *TimestampTransform_Delay) GetDelayMillis() int64
- func (*TimestampTransform_Delay) ProtoMessage()
- func (x *TimestampTransform_Delay) ProtoReflect() protoreflect.Message
- func (x *TimestampTransform_Delay) Reset()
- func (x *TimestampTransform_Delay) String() string
- type TimestampTransform_Delay_
- type Trigger
- func (*Trigger) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger) GetAfterAll() *Trigger_AfterAll
- func (x *Trigger) GetAfterAny() *Trigger_AfterAny
- func (x *Trigger) GetAfterEach() *Trigger_AfterEach
- func (x *Trigger) GetAfterEndOfWindow() *Trigger_AfterEndOfWindow
- func (x *Trigger) GetAfterProcessingTime() *Trigger_AfterProcessingTime
- func (x *Trigger) GetAfterSynchronizedProcessingTime() *Trigger_AfterSynchronizedProcessingTime
- func (x *Trigger) GetAlways() *Trigger_Always
- func (x *Trigger) GetDefault() *Trigger_Default
- func (x *Trigger) GetElementCount() *Trigger_ElementCount
- func (x *Trigger) GetNever() *Trigger_Never
- func (x *Trigger) GetOrFinally() *Trigger_OrFinally
- func (x *Trigger) GetRepeat() *Trigger_Repeat
- func (m *Trigger) GetTrigger() isTrigger_Trigger
- func (*Trigger) ProtoMessage()
- func (x *Trigger) ProtoReflect() protoreflect.Message
- func (x *Trigger) Reset()
- func (x *Trigger) String() string
- type Trigger_AfterAll
- type Trigger_AfterAll_
- type Trigger_AfterAny
- type Trigger_AfterAny_
- type Trigger_AfterEach
- func (*Trigger_AfterEach) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger_AfterEach) GetSubtriggers() []*Trigger
- func (*Trigger_AfterEach) ProtoMessage()
- func (x *Trigger_AfterEach) ProtoReflect() protoreflect.Message
- func (x *Trigger_AfterEach) Reset()
- func (x *Trigger_AfterEach) String() string
- type Trigger_AfterEach_
- type Trigger_AfterEndOfWindow
- func (*Trigger_AfterEndOfWindow) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger_AfterEndOfWindow) GetEarlyFirings() *Trigger
- func (x *Trigger_AfterEndOfWindow) GetLateFirings() *Trigger
- func (*Trigger_AfterEndOfWindow) ProtoMessage()
- func (x *Trigger_AfterEndOfWindow) ProtoReflect() protoreflect.Message
- func (x *Trigger_AfterEndOfWindow) Reset()
- func (x *Trigger_AfterEndOfWindow) String() string
- type Trigger_AfterEndOfWindow_
- type Trigger_AfterProcessingTime
- func (*Trigger_AfterProcessingTime) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger_AfterProcessingTime) GetTimestampTransforms() []*TimestampTransform
- func (*Trigger_AfterProcessingTime) ProtoMessage()
- func (x *Trigger_AfterProcessingTime) ProtoReflect() protoreflect.Message
- func (x *Trigger_AfterProcessingTime) Reset()
- func (x *Trigger_AfterProcessingTime) String() string
- type Trigger_AfterProcessingTime_
- type Trigger_AfterSynchronizedProcessingTime
- func (*Trigger_AfterSynchronizedProcessingTime) Descriptor() ([]byte, []int)deprecated
- func (*Trigger_AfterSynchronizedProcessingTime) ProtoMessage()
- func (x *Trigger_AfterSynchronizedProcessingTime) ProtoReflect() protoreflect.Message
- func (x *Trigger_AfterSynchronizedProcessingTime) Reset()
- func (x *Trigger_AfterSynchronizedProcessingTime) String() string
- type Trigger_AfterSynchronizedProcessingTime_
- type Trigger_Always
- type Trigger_Always_
- type Trigger_Default
- type Trigger_Default_
- type Trigger_ElementCount
- func (*Trigger_ElementCount) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger_ElementCount) GetElementCount() int32
- func (*Trigger_ElementCount) ProtoMessage()
- func (x *Trigger_ElementCount) ProtoReflect() protoreflect.Message
- func (x *Trigger_ElementCount) Reset()
- func (x *Trigger_ElementCount) String() string
- type Trigger_ElementCount_
- type Trigger_Never
- type Trigger_Never_
- type Trigger_OrFinally
- func (*Trigger_OrFinally) Descriptor() ([]byte, []int)deprecated
- func (x *Trigger_OrFinally) GetFinally() *Trigger
- func (x *Trigger_OrFinally) GetMain() *Trigger
- func (*Trigger_OrFinally) ProtoMessage()
- func (x *Trigger_OrFinally) ProtoReflect() protoreflect.Message
- func (x *Trigger_OrFinally) Reset()
- func (x *Trigger_OrFinally) String() string
- type Trigger_OrFinally_
- type Trigger_Repeat
- type Trigger_Repeat_
- type UnimplementedTestStreamServiceServer
- type WindowIntoPayload
- func (*WindowIntoPayload) Descriptor() ([]byte, []int)deprecated
- func (x *WindowIntoPayload) GetWindowFn() *FunctionSpec
- func (*WindowIntoPayload) ProtoMessage()
- func (x *WindowIntoPayload) ProtoReflect() protoreflect.Message
- func (x *WindowIntoPayload) Reset()
- func (x *WindowIntoPayload) String() string
- type WindowingStrategy
- func (*WindowingStrategy) Descriptor() ([]byte, []int)deprecated
- func (x *WindowingStrategy) GetAccumulationMode() AccumulationMode_Enum
- func (x *WindowingStrategy) GetAllowedLateness() int64
- func (x *WindowingStrategy) GetAssignsToOneWindow() bool
- func (x *WindowingStrategy) GetClosingBehavior() ClosingBehavior_Enum
- func (x *WindowingStrategy) GetEnvironmentId() string
- func (x *WindowingStrategy) GetMergeStatus() MergeStatus_Enum
- func (x *WindowingStrategy) GetOnTimeBehavior() OnTimeBehavior_Enum
- func (x *WindowingStrategy) GetOutputTime() OutputTime_Enum
- func (x *WindowingStrategy) GetTrigger() *Trigger
- func (x *WindowingStrategy) GetWindowCoderId() string
- func (x *WindowingStrategy) GetWindowFn() *FunctionSpec
- func (*WindowingStrategy) ProtoMessage()
- func (x *WindowingStrategy) ProtoReflect() protoreflect.Message
- func (x *WindowingStrategy) Reset()
- func (x *WindowingStrategy) String() string
- type WriteFilesPayload
- func (*WriteFilesPayload) Descriptor() ([]byte, []int)deprecated
- func (x *WriteFilesPayload) GetFormatFunction() *FunctionSpec
- func (x *WriteFilesPayload) GetRunnerDeterminedSharding() bool
- func (x *WriteFilesPayload) GetSideInputs() map[string]*SideInput
- func (x *WriteFilesPayload) GetSink() *FunctionSpec
- func (x *WriteFilesPayload) GetWindowedWrites() bool
- func (*WriteFilesPayload) ProtoMessage()
- func (x *WriteFilesPayload) ProtoReflect() protoreflect.Message
- func (x *WriteFilesPayload) Reset()
- func (x *WriteFilesPayload) String() string
Constants ¶
This section is empty.
Variables ¶
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.
var ( StandardPTransforms_Primitives_name = map[int32]string{ 0: "PAR_DO", 1: "FLATTEN", 2: "GROUP_BY_KEY", 3: "IMPULSE", 4: "ASSIGN_WINDOWS", 5: "TEST_STREAM", 6: "MAP_WINDOWS", 7: "MERGE_WINDOWS", 8: "TO_STRING", } StandardPTransforms_Primitives_value = map[string]int32{ "PAR_DO": 0, "FLATTEN": 1, "GROUP_BY_KEY": 2, "IMPULSE": 3, "ASSIGN_WINDOWS": 4, "TEST_STREAM": 5, "MAP_WINDOWS": 6, "MERGE_WINDOWS": 7, "TO_STRING": 8, } )
Enum value maps for StandardPTransforms_Primitives.
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.
var ( StandardPTransforms_Composites_name = map[int32]string{ 0: "COMBINE_PER_KEY", 1: "COMBINE_GLOBALLY", 2: "RESHUFFLE", 3: "WRITE_FILES", 4: "PUBSUB_READ", 5: "PUBSUB_WRITE", 6: "GROUP_INTO_BATCHES_WITH_SHARDED_KEY", } StandardPTransforms_Composites_value = map[string]int32{ "COMBINE_PER_KEY": 0, "COMBINE_GLOBALLY": 1, "RESHUFFLE": 2, "WRITE_FILES": 3, "PUBSUB_READ": 4, "PUBSUB_WRITE": 5, "GROUP_INTO_BATCHES_WITH_SHARDED_KEY": 6, } )
Enum value maps for StandardPTransforms_Composites.
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.
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.
var ( StandardPTransforms_GroupIntoBatchesComponents_name = map[int32]string{ 0: "GROUP_INTO_BATCHES", } StandardPTransforms_GroupIntoBatchesComponents_value = map[string]int32{ "GROUP_INTO_BATCHES": 0, } )
Enum value maps for StandardPTransforms_GroupIntoBatchesComponents.
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.
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.
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", 15: "SHARDED_KEY", } StandardCoders_Enum_value = map[string]int32{ "BYTES": 0, "STRING_UTF8": 10, "KV": 1, "BOOL": 12, "VARINT": 2, "DOUBLE": 11, "ITERABLE": 3, "TIMER": 4, "INTERVAL_WINDOW": 5, "LENGTH_PREFIX": 6, "GLOBAL_WINDOW": 7, "WINDOWED_VALUE": 8, "PARAM_WINDOWED_VALUE": 14, "STATE_BACKED_ITERABLE": 9, "ROW": 13, "SHARDED_KEY": 15, } )
Enum value maps for StandardCoders_Enum.
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.
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.
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.
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.
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.
var ( TimeDomain_Enum_name = map[int32]string{ 0: "UNSPECIFIED", 1: "EVENT_TIME", 2: "PROCESSING_TIME", } TimeDomain_Enum_value = map[string]int32{ "UNSPECIFIED": 0, "EVENT_TIME": 1, "PROCESSING_TIME": 2, } )
Enum value maps for TimeDomain_Enum.
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.
var ( StandardArtifacts_Roles_name = map[int32]string{ 0: "STAGING_TO", 1: "PIP_REQUIREMENTS_FILE", } StandardArtifacts_Roles_value = map[string]int32{ "STAGING_TO": 0, "PIP_REQUIREMENTS_FILE": 1, } )
Enum value maps for StandardArtifacts_Roles.
var ( StandardEnvironments_Environments_name = map[int32]string{ 0: "DOCKER", 1: "PROCESS", 2: "EXTERNAL", 3: "DEFAULT", } StandardEnvironments_Environments_value = map[string]int32{ "DOCKER": 0, "PROCESS": 1, "EXTERNAL": 2, "DEFAULT": 3, } )
Enum value maps for StandardEnvironments_Environments.
var ( StandardProtocols_Enum_name = map[int32]string{ 0: "LEGACY_PROGRESS_REPORTING", 1: "PROGRESS_REPORTING", 2: "WORKER_STATUS", 3: "MULTI_CORE_BUNDLE_PROCESSING", 4: "HARNESS_MONITORING_INFOS", } StandardProtocols_Enum_value = map[string]int32{ "LEGACY_PROGRESS_REPORTING": 0, "PROGRESS_REPORTING": 1, "WORKER_STATUS": 2, "MULTI_CORE_BUNDLE_PROCESSING": 3, "HARNESS_MONITORING_INFOS": 4, } )
Enum value maps for StandardProtocols_Enum.
var ( StandardRunnerProtocols_Enum_name = map[int32]string{ 0: "MONITORING_INFO_SHORT_IDS", } StandardRunnerProtocols_Enum_value = map[string]int32{ "MONITORING_INFO_SHORT_IDS": 0, } )
Enum value maps for StandardRunnerProtocols_Enum.
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.
var ( StandardDisplayData_DisplayData_name = map[int32]string{ 0: "LABELLED", } StandardDisplayData_DisplayData_value = map[string]int32{ "LABELLED": 0, } )
Enum value maps for StandardDisplayData_DisplayData.
var ( StandardResourceHints_Enum_name = map[int32]string{ 0: "ACCELERATOR", 1: "MIN_RAM_BYTES", } StandardResourceHints_Enum_value = map[string]int32{ "ACCELERATOR": 0, "MIN_RAM_BYTES": 1, } )
Enum value maps for StandardResourceHints_Enum.
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.
var ( MonitoringInfoSpecs_Enum_name = map[int32]string{ 0: "USER_SUM_INT64", 1: "USER_SUM_DOUBLE", 2: "USER_DISTRIBUTION_INT64", 3: "USER_DISTRIBUTION_DOUBLE", 4: "USER_LATEST_INT64", 5: "USER_LATEST_DOUBLE", 6: "USER_TOP_N_INT64", 7: "USER_TOP_N_DOUBLE", 8: "USER_BOTTOM_N_INT64", 9: "USER_BOTTOM_N_DOUBLE", 10: "ELEMENT_COUNT", 11: "SAMPLED_BYTE_SIZE", 12: "START_BUNDLE_MSECS", 13: "PROCESS_BUNDLE_MSECS", 14: "FINISH_BUNDLE_MSECS", 15: "TOTAL_MSECS", 16: "WORK_REMAINING", 17: "WORK_COMPLETED", 18: "DATA_CHANNEL_READ_INDEX", 19: "API_REQUEST_COUNT", 20: "API_REQUEST_LATENCIES", } MonitoringInfoSpecs_Enum_value = map[string]int32{ "USER_SUM_INT64": 0, "USER_SUM_DOUBLE": 1, "USER_DISTRIBUTION_INT64": 2, "USER_DISTRIBUTION_DOUBLE": 3, "USER_LATEST_INT64": 4, "USER_LATEST_DOUBLE": 5, "USER_TOP_N_INT64": 6, "USER_TOP_N_DOUBLE": 7, "USER_BOTTOM_N_INT64": 8, "USER_BOTTOM_N_DOUBLE": 9, "ELEMENT_COUNT": 10, "SAMPLED_BYTE_SIZE": 11, "START_BUNDLE_MSECS": 12, "PROCESS_BUNDLE_MSECS": 13, "FINISH_BUNDLE_MSECS": 14, "TOTAL_MSECS": 15, "WORK_REMAINING": 16, "WORK_COMPLETED": 17, "DATA_CHANNEL_READ_INDEX": 18, "API_REQUEST_COUNT": 19, "API_REQUEST_LATENCIES": 20, } )
Enum value maps for MonitoringInfoSpecs_Enum.
var ( MonitoringInfo_MonitoringInfoLabels_name = map[int32]string{ 0: "TRANSFORM", 1: "PCOLLECTION", 2: "WINDOWING_STRATEGY", 3: "CODER", 4: "ENVIRONMENT", 5: "NAMESPACE", 6: "NAME", 7: "SERVICE", 8: "METHOD", 9: "RESOURCE", 10: "STATUS", 11: "BIGQUERY_PROJECT_ID", 12: "BIGQUERY_DATASET", 13: "BIGQUERY_TABLE", 14: "BIGQUERY_VIEW", 15: "BIGQUERY_QUERY_NAME", } MonitoringInfo_MonitoringInfoLabels_value = map[string]int32{ "TRANSFORM": 0, "PCOLLECTION": 1, "WINDOWING_STRATEGY": 2, "CODER": 3, "ENVIRONMENT": 4, "NAMESPACE": 5, "NAME": 6, "SERVICE": 7, "METHOD": 8, "RESOURCE": 9, "STATUS": 10, "BIGQUERY_PROJECT_ID": 11, "BIGQUERY_DATASET": 12, "BIGQUERY_TABLE": 13, "BIGQUERY_VIEW": 14, "BIGQUERY_QUERY_NAME": 15, } )
Enum value maps for MonitoringInfo_MonitoringInfoLabels.
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.
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.
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.
var ( GlobalWindowsPayload_Enum_name = map[int32]string{ 0: "PROPERTIES", } GlobalWindowsPayload_Enum_value = map[string]int32{ "PROPERTIES": 0, } )
Enum value maps for GlobalWindowsPayload_Enum.
var ( FixedWindowsPayload_Enum_name = map[int32]string{ 0: "PROPERTIES", } FixedWindowsPayload_Enum_value = map[string]int32{ "PROPERTIES": 0, } )
Enum value maps for FixedWindowsPayload_Enum.
var ( SlidingWindowsPayload_Enum_name = map[int32]string{ 0: "PROPERTIES", } SlidingWindowsPayload_Enum_value = map[string]int32{ "PROPERTIES": 0, } )
Enum value maps for SlidingWindowsPayload_Enum.
var ( SessionWindowsPayload_Enum_name = map[int32]string{ 0: "PROPERTIES", } SessionWindowsPayload_Enum_value = map[string]int32{ "PROPERTIES": 0, } )
Enum value maps for SessionWindowsPayload_Enum.
var File_beam_runner_api_proto protoreflect.FileDescriptor
var File_endpoints_proto protoreflect.FileDescriptor
var File_external_transforms_proto protoreflect.FileDescriptor
var File_metrics_proto protoreflect.FileDescriptor
var File_schema_proto protoreflect.FileDescriptor
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) GetElementType ¶
func (*ArrayType) ProtoMessage ¶
func (*ArrayType) ProtoMessage()
func (*ArrayType) ProtoReflect ¶
func (x *ArrayType) ProtoReflect() protoreflect.Message
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"` // (Optional) The hex-encoded sha256 checksum of the artifact if available. Sha256 string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"` // contains filtered or unexported fields }
func (*ArtifactUrlPayload) Descriptor
deprecated
func (*ArtifactUrlPayload) Descriptor() ([]byte, []int)
Deprecated: Use ArtifactUrlPayload.ProtoReflect.Descriptor instead.
func (*ArtifactUrlPayload) GetSha256 ¶
func (x *ArtifactUrlPayload) GetSha256() string
func (*ArtifactUrlPayload) GetUrl ¶
func (x *ArtifactUrlPayload) GetUrl() string
func (*ArtifactUrlPayload) ProtoMessage ¶
func (*ArtifactUrlPayload) ProtoMessage()
func (*ArtifactUrlPayload) ProtoReflect ¶
func (x *ArtifactUrlPayload) ProtoReflect() protoreflect.Message
func (*ArtifactUrlPayload) Reset ¶
func (x *ArtifactUrlPayload) Reset()
func (*ArtifactUrlPayload) String ¶
func (x *ArtifactUrlPayload) String() string
type AtomicType ¶
type AtomicType int32
const ( AtomicType_UNSPECIFIED AtomicType = 0 AtomicType_BYTE AtomicType = 1 AtomicType_INT16 AtomicType = 2 AtomicType_INT32 AtomicType = 3 AtomicType_INT64 AtomicType = 4 AtomicType_FLOAT AtomicType = 5 AtomicType_DOUBLE AtomicType = 6 AtomicType_STRING AtomicType = 7 AtomicType_BOOLEAN AtomicType = 8 AtomicType_BYTES AtomicType = 9 )
func (AtomicType) Descriptor ¶
func (AtomicType) Descriptor() protoreflect.EnumDescriptor
func (AtomicType) Enum ¶
func (x AtomicType) Enum() *AtomicType
func (AtomicType) EnumDescriptor
deprecated
func (AtomicType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AtomicType.Descriptor instead.
func (AtomicType) Number ¶
func (x AtomicType) Number() protoreflect.EnumNumber
func (AtomicType) String ¶
func (x AtomicType) String() string
func (AtomicType) Type ¶
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) GetComponentCoderIds ¶
func (*Coder) GetSpec ¶
func (x *Coder) GetSpec() *FunctionSpec
func (*Coder) ProtoMessage ¶
func (*Coder) ProtoMessage()
func (*Coder) ProtoReflect ¶
func (x *Coder) ProtoReflect() protoreflect.Message
type CombinePayload ¶
type CombinePayload struct { // (Required) The FunctionSpec of the CombineFn. CombineFn *FunctionSpec `protobuf:"bytes,1,opt,name=combine_fn,json=combineFn,proto3" json:"combine_fn,omitempty"` // (Required) A reference to the Coder to use for accumulators of the CombineFn AccumulatorCoderId string `protobuf:"bytes,2,opt,name=accumulator_coder_id,json=accumulatorCoderId,proto3" json:"accumulator_coder_id,omitempty"` // contains filtered or unexported fields }
The payload for the special-but-not-primitive Combine transform.
func (*CombinePayload) Descriptor
deprecated
func (*CombinePayload) Descriptor() ([]byte, []int)
Deprecated: Use CombinePayload.ProtoReflect.Descriptor instead.
func (*CombinePayload) GetAccumulatorCoderId ¶
func (x *CombinePayload) GetAccumulatorCoderId() string
func (*CombinePayload) GetCombineFn ¶
func (x *CombinePayload) GetCombineFn() *FunctionSpec
func (*CombinePayload) ProtoMessage ¶
func (*CombinePayload) ProtoMessage()
func (*CombinePayload) ProtoReflect ¶
func (x *CombinePayload) ProtoReflect() protoreflect.Message
func (*CombinePayload) Reset ¶
func (x *CombinePayload) Reset()
func (*CombinePayload) String ¶
func (x *CombinePayload) String() string
type CombiningStateSpec ¶
type CombiningStateSpec struct { AccumulatorCoderId string `protobuf:"bytes,1,opt,name=accumulator_coder_id,json=accumulatorCoderId,proto3" json:"accumulator_coder_id,omitempty"` CombineFn *FunctionSpec `protobuf:"bytes,2,opt,name=combine_fn,json=combineFn,proto3" json:"combine_fn,omitempty"` // contains filtered or unexported fields }
func (*CombiningStateSpec) Descriptor
deprecated
func (*CombiningStateSpec) Descriptor() ([]byte, []int)
Deprecated: Use CombiningStateSpec.ProtoReflect.Descriptor instead.
func (*CombiningStateSpec) GetAccumulatorCoderId ¶
func (x *CombiningStateSpec) GetAccumulatorCoderId() string
func (*CombiningStateSpec) GetCombineFn ¶
func (x *CombiningStateSpec) GetCombineFn() *FunctionSpec
func (*CombiningStateSpec) ProtoMessage ¶
func (*CombiningStateSpec) ProtoMessage()
func (*CombiningStateSpec) ProtoReflect ¶
func (x *CombiningStateSpec) ProtoReflect() protoreflect.Message
func (*CombiningStateSpec) Reset ¶
func (x *CombiningStateSpec) Reset()
func (*CombiningStateSpec) String ¶
func (x *CombiningStateSpec) String() string
type Components ¶
type Components struct { // (Required) A map from pipeline-scoped id to PTransform. // // Keys of the transforms map may be used by runners to identify pipeline // steps. Hence it's recommended to use strings that are not too long that // match regex '[A-Za-z0-9-_]+'. Transforms map[string]*PTransform `` /* 161-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to PCollection. Pcollections map[string]*PCollection `` /* 165-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to WindowingStrategy. WindowingStrategies map[string]*WindowingStrategy `` /* 206-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to Coder. Coders map[string]*Coder `` /* 153-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to Environment. Environments map[string]*Environment `` /* 165-byte string literal not displayed */ // contains filtered or unexported fields }
A set of mappings from id to message. This is included as an optional field on any proto message that may contain references needing resolution.
func (*Components) Descriptor
deprecated
func (*Components) Descriptor() ([]byte, []int)
Deprecated: Use Components.ProtoReflect.Descriptor instead.
func (*Components) GetCoders ¶
func (x *Components) GetCoders() map[string]*Coder
func (*Components) GetEnvironments ¶
func (x *Components) GetEnvironments() map[string]*Environment
func (*Components) GetPcollections ¶
func (x *Components) GetPcollections() map[string]*PCollection
func (*Components) GetTransforms ¶
func (x *Components) GetTransforms() map[string]*PTransform
func (*Components) GetWindowingStrategies ¶
func (x *Components) GetWindowingStrategies() map[string]*WindowingStrategy
func (*Components) ProtoMessage ¶
func (*Components) ProtoMessage()
func (*Components) ProtoReflect ¶
func (x *Components) ProtoReflect() protoreflect.Message
func (*Components) Reset ¶
func (x *Components) Reset()
func (*Components) String ¶
func (x *Components) String() string
type DeferredArtifactPayload ¶
type DeferredArtifactPayload struct { // A unique string identifier assigned by the creator of this payload. The creator may use this key to confirm // whether they can parse the data. Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Data for deferred artifacts. Interpretation of bytes is delegated to the creator of this payload. Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*DeferredArtifactPayload) Descriptor
deprecated
func (*DeferredArtifactPayload) Descriptor() ([]byte, []int)
Deprecated: Use DeferredArtifactPayload.ProtoReflect.Descriptor instead.
func (*DeferredArtifactPayload) GetData ¶
func (x *DeferredArtifactPayload) GetData() []byte
func (*DeferredArtifactPayload) GetKey ¶
func (x *DeferredArtifactPayload) GetKey() string
func (*DeferredArtifactPayload) ProtoMessage ¶
func (*DeferredArtifactPayload) ProtoMessage()
func (*DeferredArtifactPayload) ProtoReflect ¶
func (x *DeferredArtifactPayload) ProtoReflect() protoreflect.Message
func (*DeferredArtifactPayload) Reset ¶
func (x *DeferredArtifactPayload) Reset()
func (*DeferredArtifactPayload) String ¶
func (x *DeferredArtifactPayload) String() string
type DisplayData ¶
type DisplayData struct { // A key used to describe the type of display data. See StandardDisplayData // for the set of well known urns describing how the payload is meant to be // interpreted. Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"` // (Optional) The data specifying any parameters to the URN. If // the URN does not require any arguments, this may be omitted. Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
Static display data associated with a pipeline component. Display data is useful for pipeline runners IOs and diagnostic dashboards to display details about annotated components.
func (*DisplayData) Descriptor
deprecated
func (*DisplayData) Descriptor() ([]byte, []int)
Deprecated: Use DisplayData.ProtoReflect.Descriptor instead.
func (*DisplayData) GetPayload ¶
func (x *DisplayData) GetPayload() []byte
func (*DisplayData) GetUrn ¶
func (x *DisplayData) GetUrn() string
func (*DisplayData) ProtoMessage ¶
func (*DisplayData) ProtoMessage()
func (*DisplayData) ProtoReflect ¶
func (x *DisplayData) ProtoReflect() protoreflect.Message
func (*DisplayData) Reset ¶
func (x *DisplayData) Reset()
func (*DisplayData) String ¶
func (x *DisplayData) String() string
type DockerPayload ¶
type DockerPayload struct { ContainerImage string `protobuf:"bytes,1,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"` // implicitly linux_amd64. // contains filtered or unexported fields }
The payload of a Docker image
func (*DockerPayload) Descriptor
deprecated
func (*DockerPayload) Descriptor() ([]byte, []int)
Deprecated: Use DockerPayload.ProtoReflect.Descriptor instead.
func (*DockerPayload) GetContainerImage ¶
func (x *DockerPayload) GetContainerImage() string
func (*DockerPayload) ProtoMessage ¶
func (*DockerPayload) ProtoMessage()
func (*DockerPayload) ProtoReflect ¶
func (x *DockerPayload) ProtoReflect() protoreflect.Message
func (*DockerPayload) Reset ¶
func (x *DockerPayload) Reset()
func (*DockerPayload) String ¶
func (x *DockerPayload) String() string
type EmbeddedFilePayload ¶
type EmbeddedFilePayload struct { // raw data bytes for an embedded artifact Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*EmbeddedFilePayload) Descriptor
deprecated
func (*EmbeddedFilePayload) Descriptor() ([]byte, []int)
Deprecated: Use EmbeddedFilePayload.ProtoReflect.Descriptor instead.
func (*EmbeddedFilePayload) GetData ¶
func (x *EmbeddedFilePayload) GetData() []byte
func (*EmbeddedFilePayload) ProtoMessage ¶
func (*EmbeddedFilePayload) ProtoMessage()
func (*EmbeddedFilePayload) ProtoReflect ¶
func (x *EmbeddedFilePayload) ProtoReflect() protoreflect.Message
func (*EmbeddedFilePayload) Reset ¶
func (x *EmbeddedFilePayload) Reset()
func (*EmbeddedFilePayload) String ¶
func (x *EmbeddedFilePayload) String() string
type Environment ¶
type Environment struct { // (Required) The URN of the payload Urn string `protobuf:"bytes,2,opt,name=urn,proto3" json:"urn,omitempty"` // (Optional) The data specifying any parameters to the URN. If // the URN does not require any arguments, this may be omitted. Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` // (Optional) Static display data for the environment. If there is none, // it may be omitted. DisplayData []*DisplayData `protobuf:"bytes,4,rep,name=display_data,json=displayData,proto3" json:"display_data,omitempty"` // (Optional) A set of capabilities this environment supports. This is // typically a list of common URNs designating coders, transforms, etc. that // this environment understands (and a runner MAY use) despite not // appearing in the pipeline proto. This may also be used to indicate // support of optional protocols not tied to a concrete component. Capabilities []string `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"` // (Optional) artifact dependency information used for executing UDFs in this environment. Dependencies []*ArtifactInformation `protobuf:"bytes,6,rep,name=dependencies,proto3" json:"dependencies,omitempty"` // (Optional) A mapping of resource URNs to requested values. The encoding // of the values is specified by the URN. Resource hints are advisory; // a runner is free to ignore resource hints that it does not understand. ResourceHints map[string][]byte `` /* 188-byte string literal not displayed */ // contains filtered or unexported fields }
An environment for executing UDFs. By default, an SDK container URL, but can also be a process forked by a command, or an externally managed process.
func (*Environment) Descriptor
deprecated
func (*Environment) Descriptor() ([]byte, []int)
Deprecated: Use Environment.ProtoReflect.Descriptor instead.
func (*Environment) GetCapabilities ¶
func (x *Environment) GetCapabilities() []string
func (*Environment) GetDependencies ¶
func (x *Environment) GetDependencies() []*ArtifactInformation
func (*Environment) GetDisplayData ¶
func (x *Environment) GetDisplayData() []*DisplayData
func (*Environment) GetPayload ¶
func (x *Environment) GetPayload() []byte
func (*Environment) GetResourceHints ¶
func (x *Environment) GetResourceHints() map[string][]byte
func (*Environment) GetUrn ¶
func (x *Environment) GetUrn() string
func (*Environment) ProtoMessage ¶
func (*Environment) ProtoMessage()
func (*Environment) ProtoReflect ¶
func (x *Environment) ProtoReflect() protoreflect.Message
func (*Environment) Reset ¶
func (x *Environment) Reset()
func (*Environment) String ¶
func (x *Environment) String() string
type EventsRequest ¶
type EventsRequest struct { // The set of PCollections to read from. These are the PTransform outputs // local names. These are a subset of the TestStream's outputs. This allows // Interactive Beam to cache many PCollections from a pipeline then replay a // subset of them. OutputIds []string `protobuf:"bytes,1,rep,name=output_ids,json=outputIds,proto3" json:"output_ids,omitempty"` // contains filtered or unexported fields }
func (*EventsRequest) Descriptor
deprecated
func (*EventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use EventsRequest.ProtoReflect.Descriptor instead.
func (*EventsRequest) GetOutputIds ¶
func (x *EventsRequest) GetOutputIds() []string
func (*EventsRequest) ProtoMessage ¶
func (*EventsRequest) ProtoMessage()
func (*EventsRequest) ProtoReflect ¶
func (x *EventsRequest) ProtoReflect() protoreflect.Message
func (*EventsRequest) Reset ¶
func (x *EventsRequest) Reset()
func (*EventsRequest) String ¶
func (x *EventsRequest) String() string
type ExecutableStagePayload ¶
type ExecutableStagePayload struct { // (Required) Environment in which this stage executes. // // We use an environment rather than environment id // because ExecutableStages use environments directly. This may change in the future. Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` // The wire coder settings of this executable stage WireCoderSettings []*ExecutableStagePayload_WireCoderSetting `protobuf:"bytes,9,rep,name=wire_coder_settings,json=wireCoderSettings,proto3" json:"wire_coder_settings,omitempty"` // (Required) Input PCollection id. This must be present as a value in the inputs of any // PTransform the ExecutableStagePayload is the payload of. Input string `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"` // The side inputs required for this executable stage. Each side input of each PTransform within // this ExecutableStagePayload must be represented within this field. SideInputs []*ExecutableStagePayload_SideInputId `protobuf:"bytes,3,rep,name=side_inputs,json=sideInputs,proto3" json:"side_inputs,omitempty"` // PTransform ids contained within this executable stage. This must contain at least one // PTransform id. Transforms []string `protobuf:"bytes,4,rep,name=transforms,proto3" json:"transforms,omitempty"` // Output PCollection ids. This must be equal to the values of the outputs of any // PTransform the ExecutableStagePayload is the payload of. Outputs []string `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"` // (Required) The components for the Executable Stage. This must contain all of the Transforms // in transforms, and the closure of all of the components they recognize. Components *Components `protobuf:"bytes,6,opt,name=components,proto3" json:"components,omitempty"` // The user states required for this executable stage. Each user state of each PTransform within // this ExecutableStagePayload must be represented within this field. UserStates []*ExecutableStagePayload_UserStateId `protobuf:"bytes,7,rep,name=user_states,json=userStates,proto3" json:"user_states,omitempty"` // The timers required for this executable stage. Each timer of each PTransform within // this ExecutableStagePayload must be represented within this field. Timers []*ExecutableStagePayload_TimerId `protobuf:"bytes,8,rep,name=timers,proto3" json:"timers,omitempty"` // The timerfamilies required for this executable stage. Each timer familyof each PTransform within // this ExecutableStagePayload must be represented within this field. TimerFamilies []*ExecutableStagePayload_TimerFamilyId `protobuf:"bytes,10,rep,name=timerFamilies,proto3" json:"timerFamilies,omitempty"` // contains filtered or unexported fields }
The payload for an executable stage. This will eventually be passed to an SDK in the form of a ProcessBundleDescriptor.
func (*ExecutableStagePayload) Descriptor
deprecated
func (*ExecutableStagePayload) Descriptor() ([]byte, []int)
Deprecated: Use ExecutableStagePayload.ProtoReflect.Descriptor instead.
func (*ExecutableStagePayload) GetComponents ¶
func (x *ExecutableStagePayload) GetComponents() *Components
func (*ExecutableStagePayload) GetEnvironment ¶
func (x *ExecutableStagePayload) GetEnvironment() *Environment
func (*ExecutableStagePayload) GetInput ¶
func (x *ExecutableStagePayload) GetInput() string
func (*ExecutableStagePayload) GetOutputs ¶
func (x *ExecutableStagePayload) GetOutputs() []string
func (*ExecutableStagePayload) GetSideInputs ¶
func (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. // If this Field is part of a Schema where encoding_positions_set is True then encoding_position must be // defined, otherwise this field is ignored. EncodingPosition int32 `protobuf:"varint,5,opt,name=encoding_position,json=encodingPosition,proto3" json:"encoding_position,omitempty"` Options []*Option `protobuf:"bytes,6,rep,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*Field) Descriptor
deprecated
func (*Field) GetDescription ¶
func (*Field) GetEncodingPosition ¶
func (*Field) GetOptions ¶
func (*Field) ProtoMessage ¶
func (*Field) ProtoMessage()
func (*Field) ProtoReflect ¶
func (x *Field) ProtoReflect() protoreflect.Message
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) GetArrayType ¶
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 (*FieldType) GetNullable ¶
func (*FieldType) GetRowType ¶
func (*FieldType) GetTypeInfo ¶
func (m *FieldType) GetTypeInfo() isFieldType_TypeInfo
func (*FieldType) ProtoMessage ¶
func (*FieldType) ProtoMessage()
func (*FieldType) ProtoReflect ¶
func (x *FieldType) ProtoReflect() protoreflect.Message
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:
- This can be a specification of the function over PCollections that a PTransform computes.
- 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:
- 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).
- 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 GroupIntoBatchesPayload ¶
type GroupIntoBatchesPayload struct { // (Required) Max size of a batch. BatchSize int64 `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"` // (Optional) Max duration a batch is allowed to be cached in states. MaxBufferingDurationMillis int64 `` /* 144-byte string literal not displayed */ // contains filtered or unexported fields }
Payload for GroupIntoBatches composite transform.
func (*GroupIntoBatchesPayload) Descriptor
deprecated
func (*GroupIntoBatchesPayload) Descriptor() ([]byte, []int)
Deprecated: Use GroupIntoBatchesPayload.ProtoReflect.Descriptor instead.
func (*GroupIntoBatchesPayload) GetBatchSize ¶
func (x *GroupIntoBatchesPayload) GetBatchSize() int64
func (*GroupIntoBatchesPayload) GetMaxBufferingDurationMillis ¶
func (x *GroupIntoBatchesPayload) GetMaxBufferingDurationMillis() int64
func (*GroupIntoBatchesPayload) ProtoMessage ¶
func (*GroupIntoBatchesPayload) ProtoMessage()
func (*GroupIntoBatchesPayload) ProtoReflect ¶
func (x *GroupIntoBatchesPayload) ProtoReflect() protoreflect.Message
func (*GroupIntoBatchesPayload) Reset ¶
func (x *GroupIntoBatchesPayload) Reset()
func (*GroupIntoBatchesPayload) String ¶
func (x *GroupIntoBatchesPayload) String() string
type IsBounded ¶
type IsBounded struct {
// contains filtered or unexported fields
}
func (*IsBounded) Descriptor
deprecated
func (*IsBounded) ProtoMessage ¶
func (*IsBounded) ProtoMessage()
func (*IsBounded) ProtoReflect ¶
func (x *IsBounded) ProtoReflect() protoreflect.Message
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 LabelledPayload ¶
type LabelledPayload struct { // (Required) A human readable label for the value. Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"` // (Required) A value which will be displayed to the user. // // Types that are assignable to Value: // *LabelledPayload_StringValue // *LabelledPayload_BoolValue // *LabelledPayload_DoubleValue Value isLabelledPayload_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*LabelledPayload) Descriptor
deprecated
func (*LabelledPayload) Descriptor() ([]byte, []int)
Deprecated: Use LabelledPayload.ProtoReflect.Descriptor instead.
func (*LabelledPayload) GetBoolValue ¶
func (x *LabelledPayload) GetBoolValue() bool
func (*LabelledPayload) GetDoubleValue ¶
func (x *LabelledPayload) GetDoubleValue() float64
func (*LabelledPayload) GetLabel ¶
func (x *LabelledPayload) GetLabel() string
func (*LabelledPayload) GetStringValue ¶
func (x *LabelledPayload) GetStringValue() string
func (*LabelledPayload) GetValue ¶
func (m *LabelledPayload) GetValue() isLabelledPayload_Value
func (*LabelledPayload) ProtoMessage ¶
func (*LabelledPayload) ProtoMessage()
func (*LabelledPayload) ProtoReflect ¶
func (x *LabelledPayload) ProtoReflect() protoreflect.Message
func (*LabelledPayload) Reset ¶
func (x *LabelledPayload) Reset()
func (*LabelledPayload) String ¶
func (x *LabelledPayload) String() string
type LabelledPayload_BoolValue ¶
type LabelledPayload_BoolValue struct {
BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
type LabelledPayload_DoubleValue ¶
type LabelledPayload_DoubleValue struct {
DoubleValue float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue,proto3,oneof"`
}
type LabelledPayload_StringValue ¶
type LabelledPayload_StringValue struct {
StringValue string `protobuf:"bytes,2,opt,name=string_value,json=stringValue,proto3,oneof"`
}
type LogicalType ¶
type LogicalType struct { Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"` Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` Representation *FieldType `protobuf:"bytes,3,opt,name=representation,proto3" json:"representation,omitempty"` ArgumentType *FieldType `protobuf:"bytes,4,opt,name=argument_type,json=argumentType,proto3" json:"argument_type,omitempty"` Argument *FieldValue `protobuf:"bytes,5,opt,name=argument,proto3" json:"argument,omitempty"` // contains filtered or unexported fields }
func (*LogicalType) Descriptor
deprecated
func (*LogicalType) Descriptor() ([]byte, []int)
Deprecated: Use LogicalType.ProtoReflect.Descriptor instead.
func (*LogicalType) GetArgument ¶
func (x *LogicalType) GetArgument() *FieldValue
func (*LogicalType) GetArgumentType ¶
func (x *LogicalType) GetArgumentType() *FieldType
func (*LogicalType) GetPayload ¶
func (x *LogicalType) GetPayload() []byte
func (*LogicalType) GetRepresentation ¶
func (x *LogicalType) GetRepresentation() *FieldType
func (*LogicalType) GetUrn ¶
func (x *LogicalType) GetUrn() string
func (*LogicalType) ProtoMessage ¶
func (*LogicalType) ProtoMessage()
func (*LogicalType) ProtoReflect ¶
func (x *LogicalType) ProtoReflect() protoreflect.Message
func (*LogicalType) Reset ¶
func (x *LogicalType) Reset()
func (*LogicalType) String ¶
func (x *LogicalType) String() string
type LogicalTypeValue ¶
type LogicalTypeValue struct { Value *FieldValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*LogicalTypeValue) Descriptor
deprecated
func (*LogicalTypeValue) Descriptor() ([]byte, []int)
Deprecated: Use LogicalTypeValue.ProtoReflect.Descriptor instead.
func (*LogicalTypeValue) GetValue ¶
func (x *LogicalTypeValue) GetValue() *FieldValue
func (*LogicalTypeValue) ProtoMessage ¶
func (*LogicalTypeValue) ProtoMessage()
func (*LogicalTypeValue) ProtoReflect ¶
func (x *LogicalTypeValue) ProtoReflect() protoreflect.Message
func (*LogicalTypeValue) Reset ¶
func (x *LogicalTypeValue) Reset()
func (*LogicalTypeValue) String ¶
func (x *LogicalTypeValue) String() string
type MapStateSpec ¶
type MapStateSpec struct { KeyCoderId string `protobuf:"bytes,1,opt,name=key_coder_id,json=keyCoderId,proto3" json:"key_coder_id,omitempty"` ValueCoderId string `protobuf:"bytes,2,opt,name=value_coder_id,json=valueCoderId,proto3" json:"value_coder_id,omitempty"` // contains filtered or unexported fields }
func (*MapStateSpec) Descriptor
deprecated
func (*MapStateSpec) Descriptor() ([]byte, []int)
Deprecated: Use MapStateSpec.ProtoReflect.Descriptor instead.
func (*MapStateSpec) GetKeyCoderId ¶
func (x *MapStateSpec) GetKeyCoderId() string
func (*MapStateSpec) GetValueCoderId ¶
func (x *MapStateSpec) GetValueCoderId() string
func (*MapStateSpec) ProtoMessage ¶
func (*MapStateSpec) ProtoMessage()
func (*MapStateSpec) ProtoReflect ¶
func (x *MapStateSpec) ProtoReflect() protoreflect.Message
func (*MapStateSpec) Reset ¶
func (x *MapStateSpec) Reset()
func (*MapStateSpec) String ¶
func (x *MapStateSpec) String() string
type MapType ¶
type MapType struct { KeyType *FieldType `protobuf:"bytes,1,opt,name=key_type,json=keyType,proto3" json:"key_type,omitempty"` ValueType *FieldType `protobuf:"bytes,2,opt,name=value_type,json=valueType,proto3" json:"value_type,omitempty"` // contains filtered or unexported fields }
func (*MapType) Descriptor
deprecated
func (*MapType) GetKeyType ¶
func (*MapType) GetValueType ¶
func (*MapType) ProtoMessage ¶
func (*MapType) ProtoMessage()
func (*MapType) ProtoReflect ¶
func (x *MapType) ProtoReflect() protoreflect.Message
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.