Documentation ¶
Index ¶
- Variables
- type AccumulationMode
- func (*AccumulationMode) Descriptor() ([]byte, []int)
- func (*AccumulationMode) ProtoMessage()
- func (m *AccumulationMode) Reset()
- func (m *AccumulationMode) String() string
- func (m *AccumulationMode) XXX_DiscardUnknown()
- func (m *AccumulationMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *AccumulationMode) XXX_Merge(src proto.Message)
- func (m *AccumulationMode) XXX_Size() int
- func (m *AccumulationMode) XXX_Unmarshal(b []byte) error
- type AccumulationMode_Enum
- type ApiServiceDescriptor
- func (*ApiServiceDescriptor) Descriptor() ([]byte, []int)
- func (m *ApiServiceDescriptor) GetAuthentication() isApiServiceDescriptor_Authentication
- func (m *ApiServiceDescriptor) GetOauth2ClientCredentialsGrant() *OAuth2ClientCredentialsGrant
- func (m *ApiServiceDescriptor) GetUrl() string
- func (*ApiServiceDescriptor) ProtoMessage()
- func (m *ApiServiceDescriptor) Reset()
- func (m *ApiServiceDescriptor) String() string
- func (m *ApiServiceDescriptor) XXX_DiscardUnknown()
- func (m *ApiServiceDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ApiServiceDescriptor) XXX_Merge(src proto.Message)
- func (*ApiServiceDescriptor) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ApiServiceDescriptor) XXX_Size() int
- func (m *ApiServiceDescriptor) XXX_Unmarshal(b []byte) error
- type ApiServiceDescriptor_Oauth2ClientCredentialsGrant
- type BagStateSpec
- func (*BagStateSpec) Descriptor() ([]byte, []int)
- func (m *BagStateSpec) GetElementCoderId() string
- func (*BagStateSpec) ProtoMessage()
- func (m *BagStateSpec) Reset()
- func (m *BagStateSpec) String() string
- func (m *BagStateSpec) XXX_DiscardUnknown()
- func (m *BagStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BagStateSpec) XXX_Merge(src proto.Message)
- func (m *BagStateSpec) XXX_Size() int
- func (m *BagStateSpec) XXX_Unmarshal(b []byte) error
- type ClosingBehavior
- func (*ClosingBehavior) Descriptor() ([]byte, []int)
- func (*ClosingBehavior) ProtoMessage()
- func (m *ClosingBehavior) Reset()
- func (m *ClosingBehavior) String() string
- func (m *ClosingBehavior) XXX_DiscardUnknown()
- func (m *ClosingBehavior) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClosingBehavior) XXX_Merge(src proto.Message)
- func (m *ClosingBehavior) XXX_Size() int
- func (m *ClosingBehavior) XXX_Unmarshal(b []byte) error
- type ClosingBehavior_Enum
- type Coder
- func (*Coder) Descriptor() ([]byte, []int)
- func (m *Coder) GetComponentCoderIds() []string
- func (m *Coder) GetSpec() *SdkFunctionSpec
- func (*Coder) ProtoMessage()
- func (m *Coder) Reset()
- func (m *Coder) String() string
- func (m *Coder) XXX_DiscardUnknown()
- func (m *Coder) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Coder) XXX_Merge(src proto.Message)
- func (m *Coder) XXX_Size() int
- func (m *Coder) XXX_Unmarshal(b []byte) error
- type CombinePayload
- func (*CombinePayload) Descriptor() ([]byte, []int)
- func (m *CombinePayload) GetAccumulatorCoderId() string
- func (m *CombinePayload) GetCombineFn() *SdkFunctionSpec
- func (*CombinePayload) ProtoMessage()
- func (m *CombinePayload) Reset()
- func (m *CombinePayload) String() string
- func (m *CombinePayload) XXX_DiscardUnknown()
- func (m *CombinePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CombinePayload) XXX_Merge(src proto.Message)
- func (m *CombinePayload) XXX_Size() int
- func (m *CombinePayload) XXX_Unmarshal(b []byte) error
- type CombiningStateSpec
- func (*CombiningStateSpec) Descriptor() ([]byte, []int)
- func (m *CombiningStateSpec) GetAccumulatorCoderId() string
- func (m *CombiningStateSpec) GetCombineFn() *SdkFunctionSpec
- func (*CombiningStateSpec) ProtoMessage()
- func (m *CombiningStateSpec) Reset()
- func (m *CombiningStateSpec) String() string
- func (m *CombiningStateSpec) XXX_DiscardUnknown()
- func (m *CombiningStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CombiningStateSpec) XXX_Merge(src proto.Message)
- func (m *CombiningStateSpec) XXX_Size() int
- func (m *CombiningStateSpec) XXX_Unmarshal(b []byte) error
- type Components
- func (*Components) Descriptor() ([]byte, []int)
- func (m *Components) GetCoders() map[string]*Coder
- func (m *Components) GetEnvironments() map[string]*Environment
- func (m *Components) GetPcollections() map[string]*PCollection
- func (m *Components) GetTransforms() map[string]*PTransform
- func (m *Components) GetWindowingStrategies() map[string]*WindowingStrategy
- func (*Components) ProtoMessage()
- func (m *Components) Reset()
- func (m *Components) String() string
- func (m *Components) XXX_DiscardUnknown()
- func (m *Components) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Components) XXX_Merge(src proto.Message)
- func (m *Components) XXX_Size() int
- func (m *Components) XXX_Unmarshal(b []byte) error
- type DisplayData
- func (*DisplayData) Descriptor() ([]byte, []int)
- func (m *DisplayData) GetItems() []*DisplayData_Item
- func (*DisplayData) ProtoMessage()
- func (m *DisplayData) Reset()
- func (m *DisplayData) String() string
- func (m *DisplayData) XXX_DiscardUnknown()
- func (m *DisplayData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DisplayData) XXX_Merge(src proto.Message)
- func (m *DisplayData) XXX_Size() int
- func (m *DisplayData) XXX_Unmarshal(b []byte) error
- type DisplayData_Identifier
- func (*DisplayData_Identifier) Descriptor() ([]byte, []int)
- func (m *DisplayData_Identifier) GetKey() string
- func (m *DisplayData_Identifier) GetTransformId() string
- func (m *DisplayData_Identifier) GetTransformUrn() string
- func (*DisplayData_Identifier) ProtoMessage()
- func (m *DisplayData_Identifier) Reset()
- func (m *DisplayData_Identifier) String() string
- func (m *DisplayData_Identifier) XXX_DiscardUnknown()
- func (m *DisplayData_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DisplayData_Identifier) XXX_Merge(src proto.Message)
- func (m *DisplayData_Identifier) XXX_Size() int
- func (m *DisplayData_Identifier) XXX_Unmarshal(b []byte) error
- type DisplayData_Item
- func (*DisplayData_Item) Descriptor() ([]byte, []int)
- func (m *DisplayData_Item) GetId() *DisplayData_Identifier
- func (m *DisplayData_Item) GetLabel() string
- func (m *DisplayData_Item) GetLinkUrl() string
- func (m *DisplayData_Item) GetShortValue() *any.Any
- func (m *DisplayData_Item) GetType() DisplayData_Type_Enum
- func (m *DisplayData_Item) GetValue() *any.Any
- func (*DisplayData_Item) ProtoMessage()
- func (m *DisplayData_Item) Reset()
- func (m *DisplayData_Item) String() string
- func (m *DisplayData_Item) XXX_DiscardUnknown()
- func (m *DisplayData_Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DisplayData_Item) XXX_Merge(src proto.Message)
- func (m *DisplayData_Item) XXX_Size() int
- func (m *DisplayData_Item) XXX_Unmarshal(b []byte) error
- type DisplayData_Type
- func (*DisplayData_Type) Descriptor() ([]byte, []int)
- func (*DisplayData_Type) ProtoMessage()
- func (m *DisplayData_Type) Reset()
- func (m *DisplayData_Type) String() string
- func (m *DisplayData_Type) XXX_DiscardUnknown()
- func (m *DisplayData_Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DisplayData_Type) XXX_Merge(src proto.Message)
- func (m *DisplayData_Type) XXX_Size() int
- func (m *DisplayData_Type) XXX_Unmarshal(b []byte) error
- type DisplayData_Type_Enum
- type Environment
- func (*Environment) Descriptor() ([]byte, []int)
- func (m *Environment) GetUrl() string
- func (*Environment) ProtoMessage()
- func (m *Environment) Reset()
- func (m *Environment) String() string
- func (m *Environment) XXX_DiscardUnknown()
- func (m *Environment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Environment) XXX_Merge(src proto.Message)
- func (m *Environment) XXX_Size() int
- func (m *Environment) XXX_Unmarshal(b []byte) error
- type ExecutableStagePayload
- func (*ExecutableStagePayload) Descriptor() ([]byte, []int)
- func (m *ExecutableStagePayload) GetComponents() *Components
- func (m *ExecutableStagePayload) GetEnvironment() *Environment
- func (m *ExecutableStagePayload) GetInput() string
- func (m *ExecutableStagePayload) GetOutputs() []string
- func (m *ExecutableStagePayload) GetSideInputs() []*ExecutableStagePayload_SideInputId
- func (m *ExecutableStagePayload) GetTransforms() []string
- func (*ExecutableStagePayload) ProtoMessage()
- func (m *ExecutableStagePayload) Reset()
- func (m *ExecutableStagePayload) String() string
- func (m *ExecutableStagePayload) XXX_DiscardUnknown()
- func (m *ExecutableStagePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExecutableStagePayload) XXX_Merge(src proto.Message)
- func (m *ExecutableStagePayload) XXX_Size() int
- func (m *ExecutableStagePayload) XXX_Unmarshal(b []byte) error
- type ExecutableStagePayload_SideInputId
- func (*ExecutableStagePayload_SideInputId) Descriptor() ([]byte, []int)
- func (m *ExecutableStagePayload_SideInputId) GetLocalName() string
- func (m *ExecutableStagePayload_SideInputId) GetTransformId() string
- func (*ExecutableStagePayload_SideInputId) ProtoMessage()
- func (m *ExecutableStagePayload_SideInputId) Reset()
- func (m *ExecutableStagePayload_SideInputId) String() string
- func (m *ExecutableStagePayload_SideInputId) XXX_DiscardUnknown()
- func (m *ExecutableStagePayload_SideInputId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ExecutableStagePayload_SideInputId) XXX_Merge(src proto.Message)
- func (m *ExecutableStagePayload_SideInputId) XXX_Size() int
- func (m *ExecutableStagePayload_SideInputId) XXX_Unmarshal(b []byte) error
- type FixedWindowsPayload
- func (*FixedWindowsPayload) Descriptor() ([]byte, []int)
- func (m *FixedWindowsPayload) GetOffset() *timestamp.Timestamp
- func (m *FixedWindowsPayload) GetSize() *duration.Duration
- func (*FixedWindowsPayload) ProtoMessage()
- func (m *FixedWindowsPayload) Reset()
- func (m *FixedWindowsPayload) String() string
- func (m *FixedWindowsPayload) XXX_DiscardUnknown()
- func (m *FixedWindowsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FixedWindowsPayload) XXX_Merge(src proto.Message)
- func (m *FixedWindowsPayload) XXX_Size() int
- func (m *FixedWindowsPayload) XXX_Unmarshal(b []byte) error
- type FixedWindowsPayload_Enum
- type FunctionSpec
- func (*FunctionSpec) Descriptor() ([]byte, []int)
- func (m *FunctionSpec) GetPayload() []byte
- func (m *FunctionSpec) GetUrn() string
- func (*FunctionSpec) ProtoMessage()
- func (m *FunctionSpec) Reset()
- func (m *FunctionSpec) String() string
- func (m *FunctionSpec) XXX_DiscardUnknown()
- func (m *FunctionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FunctionSpec) XXX_Merge(src proto.Message)
- func (m *FunctionSpec) XXX_Size() int
- func (m *FunctionSpec) XXX_Unmarshal(b []byte) error
- type GlobalWindowsPayload
- func (*GlobalWindowsPayload) Descriptor() ([]byte, []int)
- func (*GlobalWindowsPayload) ProtoMessage()
- func (m *GlobalWindowsPayload) Reset()
- func (m *GlobalWindowsPayload) String() string
- func (m *GlobalWindowsPayload) XXX_DiscardUnknown()
- func (m *GlobalWindowsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GlobalWindowsPayload) XXX_Merge(src proto.Message)
- func (m *GlobalWindowsPayload) XXX_Size() int
- func (m *GlobalWindowsPayload) XXX_Unmarshal(b []byte) error
- type GlobalWindowsPayload_Enum
- type IsBounded
- func (*IsBounded) Descriptor() ([]byte, []int)
- func (*IsBounded) ProtoMessage()
- func (m *IsBounded) Reset()
- func (m *IsBounded) String() string
- func (m *IsBounded) XXX_DiscardUnknown()
- func (m *IsBounded) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *IsBounded) XXX_Merge(src proto.Message)
- func (m *IsBounded) XXX_Size() int
- func (m *IsBounded) XXX_Unmarshal(b []byte) error
- type IsBounded_Enum
- type MapStateSpec
- func (*MapStateSpec) Descriptor() ([]byte, []int)
- func (m *MapStateSpec) GetKeyCoderId() string
- func (m *MapStateSpec) GetValueCoderId() string
- func (*MapStateSpec) ProtoMessage()
- func (m *MapStateSpec) Reset()
- func (m *MapStateSpec) String() string
- func (m *MapStateSpec) XXX_DiscardUnknown()
- func (m *MapStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MapStateSpec) XXX_Merge(src proto.Message)
- func (m *MapStateSpec) XXX_Size() int
- func (m *MapStateSpec) XXX_Unmarshal(b []byte) error
- type MergeStatus
- func (*MergeStatus) Descriptor() ([]byte, []int)
- func (*MergeStatus) ProtoMessage()
- func (m *MergeStatus) Reset()
- func (m *MergeStatus) String() string
- func (m *MergeStatus) XXX_DiscardUnknown()
- func (m *MergeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MergeStatus) XXX_Merge(src proto.Message)
- func (m *MergeStatus) XXX_Size() int
- func (m *MergeStatus) XXX_Unmarshal(b []byte) error
- type MergeStatus_Enum
- type MessageWithComponents
- func (*MessageWithComponents) Descriptor() ([]byte, []int)
- func (m *MessageWithComponents) GetCoder() *Coder
- func (m *MessageWithComponents) GetCombinePayload() *CombinePayload
- func (m *MessageWithComponents) GetComponents() *Components
- func (m *MessageWithComponents) GetFunctionSpec() *FunctionSpec
- func (m *MessageWithComponents) GetParDoPayload() *ParDoPayload
- func (m *MessageWithComponents) GetPcollection() *PCollection
- func (m *MessageWithComponents) GetPtransform() *PTransform
- func (m *MessageWithComponents) GetReadPayload() *ReadPayload
- func (m *MessageWithComponents) GetRoot() isMessageWithComponents_Root
- func (m *MessageWithComponents) GetSdkFunctionSpec() *SdkFunctionSpec
- func (m *MessageWithComponents) GetSideInput() *SideInput
- func (m *MessageWithComponents) GetWindowIntoPayload() *WindowIntoPayload
- func (m *MessageWithComponents) GetWindowingStrategy() *WindowingStrategy
- func (*MessageWithComponents) ProtoMessage()
- func (m *MessageWithComponents) Reset()
- func (m *MessageWithComponents) String() string
- func (m *MessageWithComponents) XXX_DiscardUnknown()
- func (m *MessageWithComponents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *MessageWithComponents) XXX_Merge(src proto.Message)
- func (*MessageWithComponents) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *MessageWithComponents) XXX_Size() int
- func (m *MessageWithComponents) XXX_Unmarshal(b []byte) error
- type MessageWithComponents_Coder
- type MessageWithComponents_CombinePayload
- type MessageWithComponents_FunctionSpec
- type MessageWithComponents_ParDoPayload
- type MessageWithComponents_Pcollection
- type MessageWithComponents_Ptransform
- type MessageWithComponents_ReadPayload
- type MessageWithComponents_SdkFunctionSpec
- type MessageWithComponents_SideInput
- type MessageWithComponents_WindowIntoPayload
- type MessageWithComponents_WindowingStrategy
- type OAuth2ClientCredentialsGrant
- func (*OAuth2ClientCredentialsGrant) Descriptor() ([]byte, []int)
- func (m *OAuth2ClientCredentialsGrant) GetUrl() string
- func (*OAuth2ClientCredentialsGrant) ProtoMessage()
- func (m *OAuth2ClientCredentialsGrant) Reset()
- func (m *OAuth2ClientCredentialsGrant) String() string
- func (m *OAuth2ClientCredentialsGrant) XXX_DiscardUnknown()
- func (m *OAuth2ClientCredentialsGrant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *OAuth2ClientCredentialsGrant) XXX_Merge(src proto.Message)
- func (m *OAuth2ClientCredentialsGrant) XXX_Size() int
- func (m *OAuth2ClientCredentialsGrant) XXX_Unmarshal(b []byte) error
- type OnTimeBehavior
- func (*OnTimeBehavior) Descriptor() ([]byte, []int)
- func (*OnTimeBehavior) ProtoMessage()
- func (m *OnTimeBehavior) Reset()
- func (m *OnTimeBehavior) String() string
- func (m *OnTimeBehavior) XXX_DiscardUnknown()
- func (m *OnTimeBehavior) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *OnTimeBehavior) XXX_Merge(src proto.Message)
- func (m *OnTimeBehavior) XXX_Size() int
- func (m *OnTimeBehavior) XXX_Unmarshal(b []byte) error
- type OnTimeBehavior_Enum
- type OutputTime
- func (*OutputTime) Descriptor() ([]byte, []int)
- func (*OutputTime) ProtoMessage()
- func (m *OutputTime) Reset()
- func (m *OutputTime) String() string
- func (m *OutputTime) XXX_DiscardUnknown()
- func (m *OutputTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *OutputTime) XXX_Merge(src proto.Message)
- func (m *OutputTime) XXX_Size() int
- func (m *OutputTime) XXX_Unmarshal(b []byte) error
- type OutputTime_Enum
- type PCollection
- func (*PCollection) Descriptor() ([]byte, []int)
- func (m *PCollection) GetCoderId() string
- func (m *PCollection) GetDisplayData() *DisplayData
- func (m *PCollection) GetIsBounded() IsBounded_Enum
- func (m *PCollection) GetUniqueName() string
- func (m *PCollection) GetWindowingStrategyId() string
- func (*PCollection) ProtoMessage()
- func (m *PCollection) Reset()
- func (m *PCollection) String() string
- func (m *PCollection) XXX_DiscardUnknown()
- func (m *PCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PCollection) XXX_Merge(src proto.Message)
- func (m *PCollection) XXX_Size() int
- func (m *PCollection) XXX_Unmarshal(b []byte) error
- type PTransform
- func (*PTransform) Descriptor() ([]byte, []int)
- func (m *PTransform) GetDisplayData() *DisplayData
- func (m *PTransform) GetInputs() map[string]string
- func (m *PTransform) GetOutputs() map[string]string
- func (m *PTransform) GetSpec() *FunctionSpec
- func (m *PTransform) GetSubtransforms() []string
- func (m *PTransform) GetUniqueName() string
- func (*PTransform) ProtoMessage()
- func (m *PTransform) Reset()
- func (m *PTransform) String() string
- func (m *PTransform) XXX_DiscardUnknown()
- func (m *PTransform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PTransform) XXX_Merge(src proto.Message)
- func (m *PTransform) XXX_Size() int
- func (m *PTransform) XXX_Unmarshal(b []byte) error
- type ParDoPayload
- func (*ParDoPayload) Descriptor() ([]byte, []int)
- func (m *ParDoPayload) GetDoFn() *SdkFunctionSpec
- func (m *ParDoPayload) GetParameters() []*Parameter
- func (m *ParDoPayload) GetRestrictionCoderId() string
- func (m *ParDoPayload) GetSideInputs() map[string]*SideInput
- func (m *ParDoPayload) GetSplittable() bool
- func (m *ParDoPayload) GetStateSpecs() map[string]*StateSpec
- func (m *ParDoPayload) GetTimerSpecs() map[string]*TimerSpec
- func (*ParDoPayload) ProtoMessage()
- func (m *ParDoPayload) Reset()
- func (m *ParDoPayload) String() string
- func (m *ParDoPayload) XXX_DiscardUnknown()
- func (m *ParDoPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ParDoPayload) XXX_Merge(src proto.Message)
- func (m *ParDoPayload) XXX_Size() int
- func (m *ParDoPayload) XXX_Unmarshal(b []byte) error
- type Parameter
- func (*Parameter) Descriptor() ([]byte, []int)
- func (m *Parameter) GetType() Parameter_Type_Enum
- func (*Parameter) ProtoMessage()
- func (m *Parameter) Reset()
- func (m *Parameter) String() string
- func (m *Parameter) XXX_DiscardUnknown()
- func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Parameter) XXX_Merge(src proto.Message)
- func (m *Parameter) XXX_Size() int
- func (m *Parameter) XXX_Unmarshal(b []byte) error
- type Parameter_Type
- func (*Parameter_Type) Descriptor() ([]byte, []int)
- func (*Parameter_Type) ProtoMessage()
- func (m *Parameter_Type) Reset()
- func (m *Parameter_Type) String() string
- func (m *Parameter_Type) XXX_DiscardUnknown()
- func (m *Parameter_Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Parameter_Type) XXX_Merge(src proto.Message)
- func (m *Parameter_Type) XXX_Size() int
- func (m *Parameter_Type) XXX_Unmarshal(b []byte) error
- type Parameter_Type_Enum
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)
- func (m *Pipeline) GetComponents() *Components
- func (m *Pipeline) GetDisplayData() *DisplayData
- func (m *Pipeline) GetRootTransformIds() []string
- func (*Pipeline) ProtoMessage()
- func (m *Pipeline) Reset()
- func (m *Pipeline) String() string
- func (m *Pipeline) XXX_DiscardUnknown()
- func (m *Pipeline) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Pipeline) XXX_Merge(src proto.Message)
- func (m *Pipeline) XXX_Size() int
- func (m *Pipeline) XXX_Unmarshal(b []byte) error
- type ReadPayload
- func (*ReadPayload) Descriptor() ([]byte, []int)
- func (m *ReadPayload) GetIsBounded() IsBounded_Enum
- func (m *ReadPayload) GetSource() *SdkFunctionSpec
- func (*ReadPayload) ProtoMessage()
- func (m *ReadPayload) Reset()
- func (m *ReadPayload) String() string
- func (m *ReadPayload) XXX_DiscardUnknown()
- func (m *ReadPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ReadPayload) XXX_Merge(src proto.Message)
- func (m *ReadPayload) XXX_Size() int
- func (m *ReadPayload) XXX_Unmarshal(b []byte) error
- type SdkFunctionSpec
- func (*SdkFunctionSpec) Descriptor() ([]byte, []int)
- func (m *SdkFunctionSpec) GetEnvironmentId() string
- func (m *SdkFunctionSpec) GetSpec() *FunctionSpec
- func (*SdkFunctionSpec) ProtoMessage()
- func (m *SdkFunctionSpec) Reset()
- func (m *SdkFunctionSpec) String() string
- func (m *SdkFunctionSpec) XXX_DiscardUnknown()
- func (m *SdkFunctionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SdkFunctionSpec) XXX_Merge(src proto.Message)
- func (m *SdkFunctionSpec) XXX_Size() int
- func (m *SdkFunctionSpec) XXX_Unmarshal(b []byte) error
- type SessionsPayload
- func (*SessionsPayload) Descriptor() ([]byte, []int)
- func (m *SessionsPayload) GetGapSize() *duration.Duration
- func (*SessionsPayload) ProtoMessage()
- func (m *SessionsPayload) Reset()
- func (m *SessionsPayload) String() string
- func (m *SessionsPayload) XXX_DiscardUnknown()
- func (m *SessionsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SessionsPayload) XXX_Merge(src proto.Message)
- func (m *SessionsPayload) XXX_Size() int
- func (m *SessionsPayload) XXX_Unmarshal(b []byte) error
- type SessionsPayload_Enum
- type SetStateSpec
- func (*SetStateSpec) Descriptor() ([]byte, []int)
- func (m *SetStateSpec) GetElementCoderId() string
- func (*SetStateSpec) ProtoMessage()
- func (m *SetStateSpec) Reset()
- func (m *SetStateSpec) String() string
- func (m *SetStateSpec) XXX_DiscardUnknown()
- func (m *SetStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SetStateSpec) XXX_Merge(src proto.Message)
- func (m *SetStateSpec) XXX_Size() int
- func (m *SetStateSpec) XXX_Unmarshal(b []byte) error
- type SideInput
- func (*SideInput) Descriptor() ([]byte, []int)
- func (m *SideInput) GetAccessPattern() *FunctionSpec
- func (m *SideInput) GetViewFn() *SdkFunctionSpec
- func (m *SideInput) GetWindowMappingFn() *SdkFunctionSpec
- func (*SideInput) ProtoMessage()
- func (m *SideInput) Reset()
- func (m *SideInput) String() string
- func (m *SideInput) XXX_DiscardUnknown()
- func (m *SideInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SideInput) XXX_Merge(src proto.Message)
- func (m *SideInput) XXX_Size() int
- func (m *SideInput) XXX_Unmarshal(b []byte) error
- type SlidingWindowsPayload
- func (*SlidingWindowsPayload) Descriptor() ([]byte, []int)
- func (m *SlidingWindowsPayload) GetOffset() *timestamp.Timestamp
- func (m *SlidingWindowsPayload) GetPeriod() *duration.Duration
- func (m *SlidingWindowsPayload) GetSize() *duration.Duration
- func (*SlidingWindowsPayload) ProtoMessage()
- func (m *SlidingWindowsPayload) Reset()
- func (m *SlidingWindowsPayload) String() string
- func (m *SlidingWindowsPayload) XXX_DiscardUnknown()
- func (m *SlidingWindowsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SlidingWindowsPayload) XXX_Merge(src proto.Message)
- func (m *SlidingWindowsPayload) XXX_Size() int
- func (m *SlidingWindowsPayload) XXX_Unmarshal(b []byte) error
- type SlidingWindowsPayload_Enum
- type StandardCoders
- func (*StandardCoders) Descriptor() ([]byte, []int)
- func (*StandardCoders) ProtoMessage()
- func (m *StandardCoders) Reset()
- func (m *StandardCoders) String() string
- func (m *StandardCoders) XXX_DiscardUnknown()
- func (m *StandardCoders) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StandardCoders) XXX_Merge(src proto.Message)
- func (m *StandardCoders) XXX_Size() int
- func (m *StandardCoders) XXX_Unmarshal(b []byte) error
- type StandardCoders_Enum
- type StandardPTransforms
- func (*StandardPTransforms) Descriptor() ([]byte, []int)
- func (*StandardPTransforms) ProtoMessage()
- func (m *StandardPTransforms) Reset()
- func (m *StandardPTransforms) String() string
- func (m *StandardPTransforms) XXX_DiscardUnknown()
- func (m *StandardPTransforms) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StandardPTransforms) XXX_Merge(src proto.Message)
- func (m *StandardPTransforms) XXX_Size() int
- func (m *StandardPTransforms) XXX_Unmarshal(b []byte) error
- type StandardPTransforms_CombineComponents
- type StandardPTransforms_Composites
- type StandardPTransforms_DeprecatedPrimitives
- type StandardPTransforms_Primitives
- type StandardPTransforms_SplittableParDoComponents
- type StandardSideInputTypes
- func (*StandardSideInputTypes) Descriptor() ([]byte, []int)
- func (*StandardSideInputTypes) ProtoMessage()
- func (m *StandardSideInputTypes) Reset()
- func (m *StandardSideInputTypes) String() string
- func (m *StandardSideInputTypes) XXX_DiscardUnknown()
- func (m *StandardSideInputTypes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StandardSideInputTypes) XXX_Merge(src proto.Message)
- func (m *StandardSideInputTypes) XXX_Size() int
- func (m *StandardSideInputTypes) XXX_Unmarshal(b []byte) error
- type StandardSideInputTypes_Enum
- type StateSpec
- func (*StateSpec) Descriptor() ([]byte, []int)
- func (m *StateSpec) GetBagSpec() *BagStateSpec
- func (m *StateSpec) GetCombiningSpec() *CombiningStateSpec
- func (m *StateSpec) GetMapSpec() *MapStateSpec
- func (m *StateSpec) GetSetSpec() *SetStateSpec
- func (m *StateSpec) GetSpec() isStateSpec_Spec
- func (m *StateSpec) GetValueSpec() *ValueStateSpec
- func (*StateSpec) ProtoMessage()
- func (m *StateSpec) Reset()
- func (m *StateSpec) String() string
- func (m *StateSpec) XXX_DiscardUnknown()
- func (m *StateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StateSpec) XXX_Merge(src proto.Message)
- func (*StateSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *StateSpec) XXX_Size() int
- func (m *StateSpec) XXX_Unmarshal(b []byte) error
- type StateSpec_BagSpec
- type StateSpec_CombiningSpec
- type StateSpec_MapSpec
- type StateSpec_SetSpec
- type StateSpec_ValueSpec
- type TestStreamPayload
- func (*TestStreamPayload) Descriptor() ([]byte, []int)
- func (m *TestStreamPayload) GetCoderId() string
- func (m *TestStreamPayload) GetEvents() []*TestStreamPayload_Event
- func (*TestStreamPayload) ProtoMessage()
- func (m *TestStreamPayload) Reset()
- func (m *TestStreamPayload) String() string
- func (m *TestStreamPayload) XXX_DiscardUnknown()
- func (m *TestStreamPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TestStreamPayload) XXX_Merge(src proto.Message)
- func (m *TestStreamPayload) XXX_Size() int
- func (m *TestStreamPayload) XXX_Unmarshal(b []byte) error
- type TestStreamPayload_Event
- func (*TestStreamPayload_Event) Descriptor() ([]byte, []int)
- func (m *TestStreamPayload_Event) GetElementEvent() *TestStreamPayload_Event_AddElements
- func (m *TestStreamPayload_Event) GetEvent() isTestStreamPayload_Event_Event
- func (m *TestStreamPayload_Event) GetProcessingTimeEvent() *TestStreamPayload_Event_AdvanceProcessingTime
- func (m *TestStreamPayload_Event) GetWatermarkEvent() *TestStreamPayload_Event_AdvanceWatermark
- func (*TestStreamPayload_Event) ProtoMessage()
- func (m *TestStreamPayload_Event) Reset()
- func (m *TestStreamPayload_Event) String() string
- func (m *TestStreamPayload_Event) XXX_DiscardUnknown()
- func (m *TestStreamPayload_Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TestStreamPayload_Event) XXX_Merge(src proto.Message)
- func (*TestStreamPayload_Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *TestStreamPayload_Event) XXX_Size() int
- func (m *TestStreamPayload_Event) XXX_Unmarshal(b []byte) error
- type TestStreamPayload_Event_AddElements
- func (*TestStreamPayload_Event_AddElements) Descriptor() ([]byte, []int)
- func (m *TestStreamPayload_Event_AddElements) GetElements() []*TestStreamPayload_TimestampedElement
- func (*TestStreamPayload_Event_AddElements) ProtoMessage()
- func (m *TestStreamPayload_Event_AddElements) Reset()
- func (m *TestStreamPayload_Event_AddElements) String() string
- func (m *TestStreamPayload_Event_AddElements) XXX_DiscardUnknown()
- func (m *TestStreamPayload_Event_AddElements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TestStreamPayload_Event_AddElements) XXX_Merge(src proto.Message)
- func (m *TestStreamPayload_Event_AddElements) XXX_Size() int
- func (m *TestStreamPayload_Event_AddElements) XXX_Unmarshal(b []byte) error
- type TestStreamPayload_Event_AdvanceProcessingTime
- func (*TestStreamPayload_Event_AdvanceProcessingTime) Descriptor() ([]byte, []int)
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) GetAdvanceDuration() int64
- func (*TestStreamPayload_Event_AdvanceProcessingTime) ProtoMessage()
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) Reset()
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) String() string
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_DiscardUnknown()
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Merge(src proto.Message)
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Size() int
- func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Unmarshal(b []byte) error
- type TestStreamPayload_Event_AdvanceWatermark
- func (*TestStreamPayload_Event_AdvanceWatermark) Descriptor() ([]byte, []int)
- func (m *TestStreamPayload_Event_AdvanceWatermark) GetNewWatermark() int64
- func (*TestStreamPayload_Event_AdvanceWatermark) ProtoMessage()
- func (m *TestStreamPayload_Event_AdvanceWatermark) Reset()
- func (m *TestStreamPayload_Event_AdvanceWatermark) String() string
- func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_DiscardUnknown()
- func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TestStreamPayload_Event_AdvanceWatermark) XXX_Merge(src proto.Message)
- func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_Size() int
- func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_Unmarshal(b []byte) error
- type TestStreamPayload_Event_ElementEvent
- type TestStreamPayload_Event_ProcessingTimeEvent
- type TestStreamPayload_Event_WatermarkEvent
- type TestStreamPayload_TimestampedElement
- func (*TestStreamPayload_TimestampedElement) Descriptor() ([]byte, []int)
- func (m *TestStreamPayload_TimestampedElement) GetEncodedElement() []byte
- func (m *TestStreamPayload_TimestampedElement) GetTimestamp() int64
- func (*TestStreamPayload_TimestampedElement) ProtoMessage()
- func (m *TestStreamPayload_TimestampedElement) Reset()
- func (m *TestStreamPayload_TimestampedElement) String() string
- func (m *TestStreamPayload_TimestampedElement) XXX_DiscardUnknown()
- func (m *TestStreamPayload_TimestampedElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TestStreamPayload_TimestampedElement) XXX_Merge(src proto.Message)
- func (m *TestStreamPayload_TimestampedElement) XXX_Size() int
- func (m *TestStreamPayload_TimestampedElement) XXX_Unmarshal(b []byte) error
- type TimeDomain
- func (*TimeDomain) Descriptor() ([]byte, []int)
- func (*TimeDomain) ProtoMessage()
- func (m *TimeDomain) Reset()
- func (m *TimeDomain) String() string
- func (m *TimeDomain) XXX_DiscardUnknown()
- func (m *TimeDomain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimeDomain) XXX_Merge(src proto.Message)
- func (m *TimeDomain) XXX_Size() int
- func (m *TimeDomain) XXX_Unmarshal(b []byte) error
- type TimeDomain_Enum
- type TimerSpec
- func (*TimerSpec) Descriptor() ([]byte, []int)
- func (m *TimerSpec) GetTimeDomain() TimeDomain_Enum
- func (*TimerSpec) ProtoMessage()
- func (m *TimerSpec) Reset()
- func (m *TimerSpec) String() string
- func (m *TimerSpec) XXX_DiscardUnknown()
- func (m *TimerSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimerSpec) XXX_Merge(src proto.Message)
- func (m *TimerSpec) XXX_Size() int
- func (m *TimerSpec) XXX_Unmarshal(b []byte) error
- type TimestampTransform
- func (*TimestampTransform) Descriptor() ([]byte, []int)
- func (m *TimestampTransform) GetAlignTo() *TimestampTransform_AlignTo
- func (m *TimestampTransform) GetDelay() *TimestampTransform_Delay
- func (m *TimestampTransform) GetTimestampTransform() isTimestampTransform_TimestampTransform
- func (*TimestampTransform) ProtoMessage()
- func (m *TimestampTransform) Reset()
- func (m *TimestampTransform) String() string
- func (m *TimestampTransform) XXX_DiscardUnknown()
- func (m *TimestampTransform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimestampTransform) XXX_Merge(src proto.Message)
- func (*TimestampTransform) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *TimestampTransform) XXX_Size() int
- func (m *TimestampTransform) XXX_Unmarshal(b []byte) error
- type TimestampTransform_AlignTo
- func (*TimestampTransform_AlignTo) Descriptor() ([]byte, []int)
- func (m *TimestampTransform_AlignTo) GetOffset() int64
- func (m *TimestampTransform_AlignTo) GetPeriod() int64
- func (*TimestampTransform_AlignTo) ProtoMessage()
- func (m *TimestampTransform_AlignTo) Reset()
- func (m *TimestampTransform_AlignTo) String() string
- func (m *TimestampTransform_AlignTo) XXX_DiscardUnknown()
- func (m *TimestampTransform_AlignTo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimestampTransform_AlignTo) XXX_Merge(src proto.Message)
- func (m *TimestampTransform_AlignTo) XXX_Size() int
- func (m *TimestampTransform_AlignTo) XXX_Unmarshal(b []byte) error
- type TimestampTransform_AlignTo_
- type TimestampTransform_Delay
- func (*TimestampTransform_Delay) Descriptor() ([]byte, []int)
- func (m *TimestampTransform_Delay) GetDelayMillis() int64
- func (*TimestampTransform_Delay) ProtoMessage()
- func (m *TimestampTransform_Delay) Reset()
- func (m *TimestampTransform_Delay) String() string
- func (m *TimestampTransform_Delay) XXX_DiscardUnknown()
- func (m *TimestampTransform_Delay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *TimestampTransform_Delay) XXX_Merge(src proto.Message)
- func (m *TimestampTransform_Delay) XXX_Size() int
- func (m *TimestampTransform_Delay) XXX_Unmarshal(b []byte) error
- type TimestampTransform_Delay_
- type Trigger
- func (*Trigger) Descriptor() ([]byte, []int)
- func (m *Trigger) GetAfterAll() *Trigger_AfterAll
- func (m *Trigger) GetAfterAny() *Trigger_AfterAny
- func (m *Trigger) GetAfterEach() *Trigger_AfterEach
- func (m *Trigger) GetAfterEndOfWindow() *Trigger_AfterEndOfWindow
- func (m *Trigger) GetAfterProcessingTime() *Trigger_AfterProcessingTime
- func (m *Trigger) GetAfterSynchronizedProcessingTime() *Trigger_AfterSynchronizedProcessingTime
- func (m *Trigger) GetAlways() *Trigger_Always
- func (m *Trigger) GetDefault() *Trigger_Default
- func (m *Trigger) GetElementCount() *Trigger_ElementCount
- func (m *Trigger) GetNever() *Trigger_Never
- func (m *Trigger) GetOrFinally() *Trigger_OrFinally
- func (m *Trigger) GetRepeat() *Trigger_Repeat
- func (m *Trigger) GetTrigger() isTrigger_Trigger
- func (*Trigger) ProtoMessage()
- func (m *Trigger) Reset()
- func (m *Trigger) String() string
- func (m *Trigger) XXX_DiscardUnknown()
- func (m *Trigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger) XXX_Merge(src proto.Message)
- func (*Trigger) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Trigger) XXX_Size() int
- func (m *Trigger) XXX_Unmarshal(b []byte) error
- type Trigger_AfterAll
- func (*Trigger_AfterAll) Descriptor() ([]byte, []int)
- func (m *Trigger_AfterAll) GetSubtriggers() []*Trigger
- func (*Trigger_AfterAll) ProtoMessage()
- func (m *Trigger_AfterAll) Reset()
- func (m *Trigger_AfterAll) String() string
- func (m *Trigger_AfterAll) XXX_DiscardUnknown()
- func (m *Trigger_AfterAll) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_AfterAll) XXX_Merge(src proto.Message)
- func (m *Trigger_AfterAll) XXX_Size() int
- func (m *Trigger_AfterAll) XXX_Unmarshal(b []byte) error
- type Trigger_AfterAll_
- type Trigger_AfterAny
- func (*Trigger_AfterAny) Descriptor() ([]byte, []int)
- func (m *Trigger_AfterAny) GetSubtriggers() []*Trigger
- func (*Trigger_AfterAny) ProtoMessage()
- func (m *Trigger_AfterAny) Reset()
- func (m *Trigger_AfterAny) String() string
- func (m *Trigger_AfterAny) XXX_DiscardUnknown()
- func (m *Trigger_AfterAny) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_AfterAny) XXX_Merge(src proto.Message)
- func (m *Trigger_AfterAny) XXX_Size() int
- func (m *Trigger_AfterAny) XXX_Unmarshal(b []byte) error
- type Trigger_AfterAny_
- type Trigger_AfterEach
- func (*Trigger_AfterEach) Descriptor() ([]byte, []int)
- func (m *Trigger_AfterEach) GetSubtriggers() []*Trigger
- func (*Trigger_AfterEach) ProtoMessage()
- func (m *Trigger_AfterEach) Reset()
- func (m *Trigger_AfterEach) String() string
- func (m *Trigger_AfterEach) XXX_DiscardUnknown()
- func (m *Trigger_AfterEach) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_AfterEach) XXX_Merge(src proto.Message)
- func (m *Trigger_AfterEach) XXX_Size() int
- func (m *Trigger_AfterEach) XXX_Unmarshal(b []byte) error
- type Trigger_AfterEach_
- type Trigger_AfterEndOfWindow
- func (*Trigger_AfterEndOfWindow) Descriptor() ([]byte, []int)
- func (m *Trigger_AfterEndOfWindow) GetEarlyFirings() *Trigger
- func (m *Trigger_AfterEndOfWindow) GetLateFirings() *Trigger
- func (*Trigger_AfterEndOfWindow) ProtoMessage()
- func (m *Trigger_AfterEndOfWindow) Reset()
- func (m *Trigger_AfterEndOfWindow) String() string
- func (m *Trigger_AfterEndOfWindow) XXX_DiscardUnknown()
- func (m *Trigger_AfterEndOfWindow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_AfterEndOfWindow) XXX_Merge(src proto.Message)
- func (m *Trigger_AfterEndOfWindow) XXX_Size() int
- func (m *Trigger_AfterEndOfWindow) XXX_Unmarshal(b []byte) error
- type Trigger_AfterEndOfWindow_
- type Trigger_AfterProcessingTime
- func (*Trigger_AfterProcessingTime) Descriptor() ([]byte, []int)
- func (m *Trigger_AfterProcessingTime) GetTimestampTransforms() []*TimestampTransform
- func (*Trigger_AfterProcessingTime) ProtoMessage()
- func (m *Trigger_AfterProcessingTime) Reset()
- func (m *Trigger_AfterProcessingTime) String() string
- func (m *Trigger_AfterProcessingTime) XXX_DiscardUnknown()
- func (m *Trigger_AfterProcessingTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_AfterProcessingTime) XXX_Merge(src proto.Message)
- func (m *Trigger_AfterProcessingTime) XXX_Size() int
- func (m *Trigger_AfterProcessingTime) XXX_Unmarshal(b []byte) error
- type Trigger_AfterProcessingTime_
- type Trigger_AfterSynchronizedProcessingTime
- func (*Trigger_AfterSynchronizedProcessingTime) Descriptor() ([]byte, []int)
- func (*Trigger_AfterSynchronizedProcessingTime) ProtoMessage()
- func (m *Trigger_AfterSynchronizedProcessingTime) Reset()
- func (m *Trigger_AfterSynchronizedProcessingTime) String() string
- func (m *Trigger_AfterSynchronizedProcessingTime) XXX_DiscardUnknown()
- func (m *Trigger_AfterSynchronizedProcessingTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_AfterSynchronizedProcessingTime) XXX_Merge(src proto.Message)
- func (m *Trigger_AfterSynchronizedProcessingTime) XXX_Size() int
- func (m *Trigger_AfterSynchronizedProcessingTime) XXX_Unmarshal(b []byte) error
- type Trigger_AfterSynchronizedProcessingTime_
- type Trigger_Always
- func (*Trigger_Always) Descriptor() ([]byte, []int)
- func (*Trigger_Always) ProtoMessage()
- func (m *Trigger_Always) Reset()
- func (m *Trigger_Always) String() string
- func (m *Trigger_Always) XXX_DiscardUnknown()
- func (m *Trigger_Always) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_Always) XXX_Merge(src proto.Message)
- func (m *Trigger_Always) XXX_Size() int
- func (m *Trigger_Always) XXX_Unmarshal(b []byte) error
- type Trigger_Always_
- type Trigger_Default
- func (*Trigger_Default) Descriptor() ([]byte, []int)
- func (*Trigger_Default) ProtoMessage()
- func (m *Trigger_Default) Reset()
- func (m *Trigger_Default) String() string
- func (m *Trigger_Default) XXX_DiscardUnknown()
- func (m *Trigger_Default) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_Default) XXX_Merge(src proto.Message)
- func (m *Trigger_Default) XXX_Size() int
- func (m *Trigger_Default) XXX_Unmarshal(b []byte) error
- type Trigger_Default_
- type Trigger_ElementCount
- func (*Trigger_ElementCount) Descriptor() ([]byte, []int)
- func (m *Trigger_ElementCount) GetElementCount() int32
- func (*Trigger_ElementCount) ProtoMessage()
- func (m *Trigger_ElementCount) Reset()
- func (m *Trigger_ElementCount) String() string
- func (m *Trigger_ElementCount) XXX_DiscardUnknown()
- func (m *Trigger_ElementCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_ElementCount) XXX_Merge(src proto.Message)
- func (m *Trigger_ElementCount) XXX_Size() int
- func (m *Trigger_ElementCount) XXX_Unmarshal(b []byte) error
- type Trigger_ElementCount_
- type Trigger_Never
- func (*Trigger_Never) Descriptor() ([]byte, []int)
- func (*Trigger_Never) ProtoMessage()
- func (m *Trigger_Never) Reset()
- func (m *Trigger_Never) String() string
- func (m *Trigger_Never) XXX_DiscardUnknown()
- func (m *Trigger_Never) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_Never) XXX_Merge(src proto.Message)
- func (m *Trigger_Never) XXX_Size() int
- func (m *Trigger_Never) XXX_Unmarshal(b []byte) error
- type Trigger_Never_
- type Trigger_OrFinally
- func (*Trigger_OrFinally) Descriptor() ([]byte, []int)
- func (m *Trigger_OrFinally) GetFinally() *Trigger
- func (m *Trigger_OrFinally) GetMain() *Trigger
- func (*Trigger_OrFinally) ProtoMessage()
- func (m *Trigger_OrFinally) Reset()
- func (m *Trigger_OrFinally) String() string
- func (m *Trigger_OrFinally) XXX_DiscardUnknown()
- func (m *Trigger_OrFinally) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_OrFinally) XXX_Merge(src proto.Message)
- func (m *Trigger_OrFinally) XXX_Size() int
- func (m *Trigger_OrFinally) XXX_Unmarshal(b []byte) error
- type Trigger_OrFinally_
- type Trigger_Repeat
- func (*Trigger_Repeat) Descriptor() ([]byte, []int)
- func (m *Trigger_Repeat) GetSubtrigger() *Trigger
- func (*Trigger_Repeat) ProtoMessage()
- func (m *Trigger_Repeat) Reset()
- func (m *Trigger_Repeat) String() string
- func (m *Trigger_Repeat) XXX_DiscardUnknown()
- func (m *Trigger_Repeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Trigger_Repeat) XXX_Merge(src proto.Message)
- func (m *Trigger_Repeat) XXX_Size() int
- func (m *Trigger_Repeat) XXX_Unmarshal(b []byte) error
- type Trigger_Repeat_
- type ValueStateSpec
- func (*ValueStateSpec) Descriptor() ([]byte, []int)
- func (m *ValueStateSpec) GetCoderId() string
- func (*ValueStateSpec) ProtoMessage()
- func (m *ValueStateSpec) Reset()
- func (m *ValueStateSpec) String() string
- func (m *ValueStateSpec) XXX_DiscardUnknown()
- func (m *ValueStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ValueStateSpec) XXX_Merge(src proto.Message)
- func (m *ValueStateSpec) XXX_Size() int
- func (m *ValueStateSpec) XXX_Unmarshal(b []byte) error
- type WindowIntoPayload
- func (*WindowIntoPayload) Descriptor() ([]byte, []int)
- func (m *WindowIntoPayload) GetWindowFn() *SdkFunctionSpec
- func (*WindowIntoPayload) ProtoMessage()
- func (m *WindowIntoPayload) Reset()
- func (m *WindowIntoPayload) String() string
- func (m *WindowIntoPayload) XXX_DiscardUnknown()
- func (m *WindowIntoPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WindowIntoPayload) XXX_Merge(src proto.Message)
- func (m *WindowIntoPayload) XXX_Size() int
- func (m *WindowIntoPayload) XXX_Unmarshal(b []byte) error
- type WindowingStrategy
- func (*WindowingStrategy) Descriptor() ([]byte, []int)
- func (m *WindowingStrategy) GetAccumulationMode() AccumulationMode_Enum
- func (m *WindowingStrategy) GetAllowedLateness() int64
- func (m *WindowingStrategy) GetAssignsToOneWindow() bool
- func (m *WindowingStrategy) GetClosingBehavior() ClosingBehavior_Enum
- func (m *WindowingStrategy) GetMergeStatus() MergeStatus_Enum
- func (m *WindowingStrategy) GetOnTimeBehavior() OnTimeBehavior_Enum
- func (m *WindowingStrategy) GetOutputTime() OutputTime_Enum
- func (m *WindowingStrategy) GetTrigger() *Trigger
- func (m *WindowingStrategy) GetWindowCoderId() string
- func (m *WindowingStrategy) GetWindowFn() *SdkFunctionSpec
- func (*WindowingStrategy) ProtoMessage()
- func (m *WindowingStrategy) Reset()
- func (m *WindowingStrategy) String() string
- func (m *WindowingStrategy) XXX_DiscardUnknown()
- func (m *WindowingStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WindowingStrategy) XXX_Merge(src proto.Message)
- func (m *WindowingStrategy) XXX_Size() int
- func (m *WindowingStrategy) XXX_Unmarshal(b []byte) error
- type WriteFilesPayload
- func (*WriteFilesPayload) Descriptor() ([]byte, []int)
- func (m *WriteFilesPayload) GetFormatFunction() *SdkFunctionSpec
- func (m *WriteFilesPayload) GetRunnerDeterminedSharding() bool
- func (m *WriteFilesPayload) GetSideInputs() map[string]*SideInput
- func (m *WriteFilesPayload) GetSink() *SdkFunctionSpec
- func (m *WriteFilesPayload) GetWindowedWrites() bool
- func (*WriteFilesPayload) ProtoMessage()
- func (m *WriteFilesPayload) Reset()
- func (m *WriteFilesPayload) String() string
- func (m *WriteFilesPayload) XXX_DiscardUnknown()
- func (m *WriteFilesPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *WriteFilesPayload) XXX_Merge(src proto.Message)
- func (m *WriteFilesPayload) XXX_Size() int
- func (m *WriteFilesPayload) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var AccumulationMode_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "DISCARDING",
2: "ACCUMULATING",
}
var AccumulationMode_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"DISCARDING": 1,
"ACCUMULATING": 2,
}
var ClosingBehavior_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "EMIT_ALWAYS",
2: "EMIT_IF_NONEMPTY",
}
var ClosingBehavior_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"EMIT_ALWAYS": 1,
"EMIT_IF_NONEMPTY": 2,
}
var DisplayData_Type_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "STRING",
2: "INTEGER",
3: "FLOAT",
4: "BOOLEAN",
5: "TIMESTAMP",
6: "DURATION",
7: "JAVA_CLASS",
}
var DisplayData_Type_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"STRING": 1,
"INTEGER": 2,
"FLOAT": 3,
"BOOLEAN": 4,
"TIMESTAMP": 5,
"DURATION": 6,
"JAVA_CLASS": 7,
}
var E_BeamUrn = &proto.ExtensionDesc{ ExtendedType: (*descriptor.EnumValueOptions)(nil), ExtensionType: (*string)(nil), Field: 185324356, Name: "org.apache.beam.model.pipeline.v1.beam_urn", Tag: "bytes,185324356,opt,name=beam_urn,json=beamUrn", Filename: "beam_runner_api.proto", }
var FixedWindowsPayload_Enum_name = map[int32]string{
0: "PROPERTIES",
}
var FixedWindowsPayload_Enum_value = map[string]int32{
"PROPERTIES": 0,
}
var GlobalWindowsPayload_Enum_name = map[int32]string{
0: "PROPERTIES",
}
var GlobalWindowsPayload_Enum_value = map[string]int32{
"PROPERTIES": 0,
}
var IsBounded_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "UNBOUNDED",
2: "BOUNDED",
}
var IsBounded_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"UNBOUNDED": 1,
"BOUNDED": 2,
}
var MergeStatus_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "NON_MERGING",
2: "NEEDS_MERGE",
3: "ALREADY_MERGED",
}
var MergeStatus_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"NON_MERGING": 1,
"NEEDS_MERGE": 2,
"ALREADY_MERGED": 3,
}
var OnTimeBehavior_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "FIRE_ALWAYS",
2: "FIRE_IF_NONEMPTY",
}
var OnTimeBehavior_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"FIRE_ALWAYS": 1,
"FIRE_IF_NONEMPTY": 2,
}
var OutputTime_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "END_OF_WINDOW",
2: "LATEST_IN_PANE",
3: "EARLIEST_IN_PANE",
}
var OutputTime_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"END_OF_WINDOW": 1,
"LATEST_IN_PANE": 2,
"EARLIEST_IN_PANE": 3,
}
var Parameter_Type_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "WINDOW",
2: "PIPELINE_OPTIONS",
3: "RESTRICTION_TRACKER",
}
var Parameter_Type_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"WINDOW": 1,
"PIPELINE_OPTIONS": 2,
"RESTRICTION_TRACKER": 3,
}
var SessionsPayload_Enum_name = map[int32]string{
0: "PROPERTIES",
}
var SessionsPayload_Enum_value = map[string]int32{
"PROPERTIES": 0,
}
var SlidingWindowsPayload_Enum_name = map[int32]string{
0: "PROPERTIES",
}
var SlidingWindowsPayload_Enum_value = map[string]int32{
"PROPERTIES": 0,
}
var StandardCoders_Enum_name = map[int32]string{
0: "BYTES",
1: "KV",
2: "VARINT",
3: "ITERABLE",
4: "TIMESTAMP",
5: "INTERVAL_WINDOW",
6: "LENGTH_PREFIX",
7: "GLOBAL_WINDOW",
8: "WINDOWED_VALUE",
}
var StandardCoders_Enum_value = map[string]int32{
"BYTES": 0,
"KV": 1,
"VARINT": 2,
"ITERABLE": 3,
"TIMESTAMP": 4,
"INTERVAL_WINDOW": 5,
"LENGTH_PREFIX": 6,
"GLOBAL_WINDOW": 7,
"WINDOWED_VALUE": 8,
}
var StandardPTransforms_CombineComponents_name = map[int32]string{
0: "COMBINE_PGBKCV",
1: "COMBINE_MERGE_ACCUMULATORS",
2: "COMBINE_EXTRACT_OUTPUTS",
3: "COMBINE_PER_KEY_PRECOMBINE",
4: "COMBINE_PER_KEY_MERGE_ACCUMULATORS",
5: "COMBINE_PER_KEY_EXTRACT_OUTPUTS",
}
var StandardPTransforms_CombineComponents_value = map[string]int32{
"COMBINE_PGBKCV": 0,
"COMBINE_MERGE_ACCUMULATORS": 1,
"COMBINE_EXTRACT_OUTPUTS": 2,
"COMBINE_PER_KEY_PRECOMBINE": 3,
"COMBINE_PER_KEY_MERGE_ACCUMULATORS": 4,
"COMBINE_PER_KEY_EXTRACT_OUTPUTS": 5,
}
var StandardPTransforms_Composites_name = map[int32]string{
0: "COMBINE_PER_KEY",
1: "COMBINE_GLOBALLY",
2: "COMBINE_GROUPED_VALUES",
3: "RESHUFFLE",
4: "WRITE_FILES",
}
var StandardPTransforms_Composites_value = map[string]int32{
"COMBINE_PER_KEY": 0,
"COMBINE_GLOBALLY": 1,
"COMBINE_GROUPED_VALUES": 2,
"RESHUFFLE": 3,
"WRITE_FILES": 4,
}
var StandardPTransforms_DeprecatedPrimitives_name = map[int32]string{
0: "READ",
1: "CREATE_VIEW",
}
var StandardPTransforms_DeprecatedPrimitives_value = map[string]int32{
"READ": 0,
"CREATE_VIEW": 1,
}
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",
}
var 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,
}
var StandardPTransforms_SplittableParDoComponents_name = map[int32]string{
0: "PAIR_WITH_RESTRICTION",
1: "SPLIT_RESTRICTION",
2: "PROCESS_KEYED_ELEMENTS",
}
var StandardPTransforms_SplittableParDoComponents_value = map[string]int32{
"PAIR_WITH_RESTRICTION": 0,
"SPLIT_RESTRICTION": 1,
"PROCESS_KEYED_ELEMENTS": 2,
}
var StandardSideInputTypes_Enum_name = map[int32]string{
0: "ITERABLE",
1: "MULTIMAP",
}
var StandardSideInputTypes_Enum_value = map[string]int32{
"ITERABLE": 0,
"MULTIMAP": 1,
}
var TimeDomain_Enum_name = map[int32]string{
0: "UNSPECIFIED",
1: "EVENT_TIME",
2: "PROCESSING_TIME",
3: "SYNCHRONIZED_PROCESSING_TIME",
}
var TimeDomain_Enum_value = map[string]int32{
"UNSPECIFIED": 0,
"EVENT_TIME": 1,
"PROCESSING_TIME": 2,
"SYNCHRONIZED_PROCESSING_TIME": 3,
}
Functions ¶
This section is empty.
Types ¶
type AccumulationMode ¶
type AccumulationMode struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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 ¶
func (*AccumulationMode) Descriptor() ([]byte, []int)
func (*AccumulationMode) ProtoMessage ¶
func (*AccumulationMode) ProtoMessage()
func (*AccumulationMode) Reset ¶
func (m *AccumulationMode) Reset()
func (*AccumulationMode) String ¶
func (m *AccumulationMode) String() string
func (*AccumulationMode) XXX_DiscardUnknown ¶
func (m *AccumulationMode) XXX_DiscardUnknown()
func (*AccumulationMode) XXX_Marshal ¶
func (m *AccumulationMode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AccumulationMode) XXX_Merge ¶
func (dst *AccumulationMode) XXX_Merge(src proto.Message)
func (*AccumulationMode) XXX_Size ¶
func (m *AccumulationMode) XXX_Size() int
func (*AccumulationMode) XXX_Unmarshal ¶
func (m *AccumulationMode) XXX_Unmarshal(b []byte) error
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 )
func (AccumulationMode_Enum) EnumDescriptor ¶
func (AccumulationMode_Enum) EnumDescriptor() ([]byte, []int)
func (AccumulationMode_Enum) String ¶
func (x AccumulationMode_Enum) String() string
type ApiServiceDescriptor ¶
type ApiServiceDescriptor struct { // (Required) The URL to connect to. Url string `protobuf:"bytes,2,opt,name=url" 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). // // Types that are valid to be assigned to Authentication: // *ApiServiceDescriptor_Oauth2ClientCredentialsGrant Authentication isApiServiceDescriptor_Authentication `protobuf_oneof:"authentication"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ApiServiceDescriptor) Descriptor ¶
func (*ApiServiceDescriptor) Descriptor() ([]byte, []int)
func (*ApiServiceDescriptor) GetAuthentication ¶
func (m *ApiServiceDescriptor) GetAuthentication() isApiServiceDescriptor_Authentication
func (*ApiServiceDescriptor) GetOauth2ClientCredentialsGrant ¶
func (m *ApiServiceDescriptor) GetOauth2ClientCredentialsGrant() *OAuth2ClientCredentialsGrant
func (*ApiServiceDescriptor) GetUrl ¶
func (m *ApiServiceDescriptor) GetUrl() string
func (*ApiServiceDescriptor) ProtoMessage ¶
func (*ApiServiceDescriptor) ProtoMessage()
func (*ApiServiceDescriptor) Reset ¶
func (m *ApiServiceDescriptor) Reset()
func (*ApiServiceDescriptor) String ¶
func (m *ApiServiceDescriptor) String() string
func (*ApiServiceDescriptor) XXX_DiscardUnknown ¶
func (m *ApiServiceDescriptor) XXX_DiscardUnknown()
func (*ApiServiceDescriptor) XXX_Marshal ¶
func (m *ApiServiceDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ApiServiceDescriptor) XXX_Merge ¶
func (dst *ApiServiceDescriptor) XXX_Merge(src proto.Message)
func (*ApiServiceDescriptor) XXX_OneofFuncs ¶
func (*ApiServiceDescriptor) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*ApiServiceDescriptor) XXX_Size ¶
func (m *ApiServiceDescriptor) XXX_Size() int
func (*ApiServiceDescriptor) XXX_Unmarshal ¶
func (m *ApiServiceDescriptor) XXX_Unmarshal(b []byte) error
type ApiServiceDescriptor_Oauth2ClientCredentialsGrant ¶
type ApiServiceDescriptor_Oauth2ClientCredentialsGrant struct {
Oauth2ClientCredentialsGrant *OAuth2ClientCredentialsGrant `protobuf:"bytes,3,opt,name=oauth2_client_credentials_grant,json=oauth2ClientCredentialsGrant,oneof"`
}
type BagStateSpec ¶
type BagStateSpec struct { ElementCoderId string `protobuf:"bytes,1,opt,name=element_coder_id,json=elementCoderId" json:"element_coder_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BagStateSpec) Descriptor ¶
func (*BagStateSpec) Descriptor() ([]byte, []int)
func (*BagStateSpec) GetElementCoderId ¶
func (m *BagStateSpec) GetElementCoderId() string
func (*BagStateSpec) ProtoMessage ¶
func (*BagStateSpec) ProtoMessage()
func (*BagStateSpec) Reset ¶
func (m *BagStateSpec) Reset()
func (*BagStateSpec) String ¶
func (m *BagStateSpec) String() string
func (*BagStateSpec) XXX_DiscardUnknown ¶
func (m *BagStateSpec) XXX_DiscardUnknown()
func (*BagStateSpec) XXX_Marshal ¶
func (m *BagStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BagStateSpec) XXX_Merge ¶
func (dst *BagStateSpec) XXX_Merge(src proto.Message)
func (*BagStateSpec) XXX_Size ¶
func (m *BagStateSpec) XXX_Size() int
func (*BagStateSpec) XXX_Unmarshal ¶
func (m *BagStateSpec) XXX_Unmarshal(b []byte) error
type ClosingBehavior ¶
type ClosingBehavior struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Controls whether or not an aggregating transform should output data when a window expires.
func (*ClosingBehavior) Descriptor ¶
func (*ClosingBehavior) Descriptor() ([]byte, []int)
func (*ClosingBehavior) ProtoMessage ¶
func (*ClosingBehavior) ProtoMessage()
func (*ClosingBehavior) Reset ¶
func (m *ClosingBehavior) Reset()
func (*ClosingBehavior) String ¶
func (m *ClosingBehavior) String() string
func (*ClosingBehavior) XXX_DiscardUnknown ¶
func (m *ClosingBehavior) XXX_DiscardUnknown()
func (*ClosingBehavior) XXX_Marshal ¶
func (m *ClosingBehavior) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClosingBehavior) XXX_Merge ¶
func (dst *ClosingBehavior) XXX_Merge(src proto.Message)
func (*ClosingBehavior) XXX_Size ¶
func (m *ClosingBehavior) XXX_Size() int
func (*ClosingBehavior) XXX_Unmarshal ¶
func (m *ClosingBehavior) XXX_Unmarshal(b []byte) error
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) EnumDescriptor ¶
func (ClosingBehavior_Enum) EnumDescriptor() ([]byte, []int)
func (ClosingBehavior_Enum) String ¶
func (x ClosingBehavior_Enum) String() string
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 agree-upon. Spec *SdkFunctionSpec `protobuf:"bytes,1,opt,name=spec" 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 SdkFunctionSpec and all components must be identical, recursively. ComponentCoderIds []string `protobuf:"bytes,2,rep,name=component_coder_ids,json=componentCoderIds" json:"component_coder_ids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A coder, the binary format for serialization and deserialization of data in a pipeline.
func (*Coder) Descriptor ¶
func (*Coder) GetComponentCoderIds ¶
func (*Coder) GetSpec ¶
func (m *Coder) GetSpec() *SdkFunctionSpec
func (*Coder) ProtoMessage ¶
func (*Coder) ProtoMessage()
func (*Coder) XXX_DiscardUnknown ¶
func (m *Coder) XXX_DiscardUnknown()
func (*Coder) XXX_Marshal ¶
func (*Coder) XXX_Unmarshal ¶
type CombinePayload ¶
type CombinePayload struct { // (Required) The SdkFunctionSpec of the CombineFn. CombineFn *SdkFunctionSpec `protobuf:"bytes,1,opt,name=combine_fn,json=combineFn" 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" json:"accumulator_coder_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The payload for the special-but-not-primitive Combine transform.
func (*CombinePayload) Descriptor ¶
func (*CombinePayload) Descriptor() ([]byte, []int)
func (*CombinePayload) GetAccumulatorCoderId ¶
func (m *CombinePayload) GetAccumulatorCoderId() string
func (*CombinePayload) GetCombineFn ¶
func (m *CombinePayload) GetCombineFn() *SdkFunctionSpec
func (*CombinePayload) ProtoMessage ¶
func (*CombinePayload) ProtoMessage()
func (*CombinePayload) Reset ¶
func (m *CombinePayload) Reset()
func (*CombinePayload) String ¶
func (m *CombinePayload) String() string
func (*CombinePayload) XXX_DiscardUnknown ¶
func (m *CombinePayload) XXX_DiscardUnknown()
func (*CombinePayload) XXX_Marshal ¶
func (m *CombinePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CombinePayload) XXX_Merge ¶
func (dst *CombinePayload) XXX_Merge(src proto.Message)
func (*CombinePayload) XXX_Size ¶
func (m *CombinePayload) XXX_Size() int
func (*CombinePayload) XXX_Unmarshal ¶
func (m *CombinePayload) XXX_Unmarshal(b []byte) error
type CombiningStateSpec ¶
type CombiningStateSpec struct { AccumulatorCoderId string `protobuf:"bytes,1,opt,name=accumulator_coder_id,json=accumulatorCoderId" json:"accumulator_coder_id,omitempty"` CombineFn *SdkFunctionSpec `protobuf:"bytes,2,opt,name=combine_fn,json=combineFn" json:"combine_fn,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CombiningStateSpec) Descriptor ¶
func (*CombiningStateSpec) Descriptor() ([]byte, []int)
func (*CombiningStateSpec) GetAccumulatorCoderId ¶
func (m *CombiningStateSpec) GetAccumulatorCoderId() string
func (*CombiningStateSpec) GetCombineFn ¶
func (m *CombiningStateSpec) GetCombineFn() *SdkFunctionSpec
func (*CombiningStateSpec) ProtoMessage ¶
func (*CombiningStateSpec) ProtoMessage()
func (*CombiningStateSpec) Reset ¶
func (m *CombiningStateSpec) Reset()
func (*CombiningStateSpec) String ¶
func (m *CombiningStateSpec) String() string
func (*CombiningStateSpec) XXX_DiscardUnknown ¶
func (m *CombiningStateSpec) XXX_DiscardUnknown()
func (*CombiningStateSpec) XXX_Marshal ¶
func (m *CombiningStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CombiningStateSpec) XXX_Merge ¶
func (dst *CombiningStateSpec) XXX_Merge(src proto.Message)
func (*CombiningStateSpec) XXX_Size ¶
func (m *CombiningStateSpec) XXX_Size() int
func (*CombiningStateSpec) XXX_Unmarshal ¶
func (m *CombiningStateSpec) XXX_Unmarshal(b []byte) error
type Components ¶
type Components struct { // (Required) A map from pipeline-scoped id to PTransform. Transforms map[string]*PTransform `` /* 140-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to PCollection. Pcollections map[string]*PCollection `` /* 144-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to WindowingStrategy. WindowingStrategies map[string]*WindowingStrategy `` /* 185-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to Coder. Coders map[string]*Coder `` /* 132-byte string literal not displayed */ // (Required) A map from pipeline-scoped id to Environment. Environments map[string]*Environment `` /* 144-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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 ¶
func (*Components) Descriptor() ([]byte, []int)
func (*Components) GetCoders ¶
func (m *Components) GetCoders() map[string]*Coder
func (*Components) GetEnvironments ¶
func (m *Components) GetEnvironments() map[string]*Environment
func (*Components) GetPcollections ¶
func (m *Components) GetPcollections() map[string]*PCollection
func (*Components) GetTransforms ¶
func (m *Components) GetTransforms() map[string]*PTransform
func (*Components) GetWindowingStrategies ¶
func (m *Components) GetWindowingStrategies() map[string]*WindowingStrategy
func (*Components) ProtoMessage ¶
func (*Components) ProtoMessage()
func (*Components) Reset ¶
func (m *Components) Reset()
func (*Components) String ¶
func (m *Components) String() string
func (*Components) XXX_DiscardUnknown ¶
func (m *Components) XXX_DiscardUnknown()
func (*Components) XXX_Marshal ¶
func (m *Components) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Components) XXX_Merge ¶
func (dst *Components) XXX_Merge(src proto.Message)
func (*Components) XXX_Size ¶
func (m *Components) XXX_Size() int
func (*Components) XXX_Unmarshal ¶
func (m *Components) XXX_Unmarshal(b []byte) error
type DisplayData ¶
type DisplayData struct { // (Required) The list of display data. Items []*DisplayData_Item `protobuf:"bytes,1,rep,name=items" json:"items,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TODO: transfer javadoc here
func (*DisplayData) Descriptor ¶
func (*DisplayData) Descriptor() ([]byte, []int)
func (*DisplayData) GetItems ¶
func (m *DisplayData) GetItems() []*DisplayData_Item
func (*DisplayData) ProtoMessage ¶
func (*DisplayData) ProtoMessage()
func (*DisplayData) Reset ¶
func (m *DisplayData) Reset()
func (*DisplayData) String ¶
func (m *DisplayData) String() string
func (*DisplayData) XXX_DiscardUnknown ¶
func (m *DisplayData) XXX_DiscardUnknown()
func (*DisplayData) XXX_Marshal ¶
func (m *DisplayData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisplayData) XXX_Merge ¶
func (dst *DisplayData) XXX_Merge(src proto.Message)
func (*DisplayData) XXX_Size ¶
func (m *DisplayData) XXX_Size() int
func (*DisplayData) XXX_Unmarshal ¶
func (m *DisplayData) XXX_Unmarshal(b []byte) error
type DisplayData_Identifier ¶
type DisplayData_Identifier struct { // (Required) The transform originating this display data. TransformId string `protobuf:"bytes,1,opt,name=transform_id,json=transformId" json:"transform_id,omitempty"` // (Optional) The URN indicating the type of the originating transform, // if there is one. TransformUrn string `protobuf:"bytes,2,opt,name=transform_urn,json=transformUrn" json:"transform_urn,omitempty"` Key string `protobuf:"bytes,3,opt,name=key" json:"key,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A complete identifier for a DisplayData.Item
func (*DisplayData_Identifier) Descriptor ¶
func (*DisplayData_Identifier) Descriptor() ([]byte, []int)
func (*DisplayData_Identifier) GetKey ¶
func (m *DisplayData_Identifier) GetKey() string
func (*DisplayData_Identifier) GetTransformId ¶
func (m *DisplayData_Identifier) GetTransformId() string
func (*DisplayData_Identifier) GetTransformUrn ¶
func (m *DisplayData_Identifier) GetTransformUrn() string
func (*DisplayData_Identifier) ProtoMessage ¶
func (*DisplayData_Identifier) ProtoMessage()
func (*DisplayData_Identifier) Reset ¶
func (m *DisplayData_Identifier) Reset()
func (*DisplayData_Identifier) String ¶
func (m *DisplayData_Identifier) String() string
func (*DisplayData_Identifier) XXX_DiscardUnknown ¶
func (m *DisplayData_Identifier) XXX_DiscardUnknown()
func (*DisplayData_Identifier) XXX_Marshal ¶
func (m *DisplayData_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisplayData_Identifier) XXX_Merge ¶
func (dst *DisplayData_Identifier) XXX_Merge(src proto.Message)
func (*DisplayData_Identifier) XXX_Size ¶
func (m *DisplayData_Identifier) XXX_Size() int
func (*DisplayData_Identifier) XXX_Unmarshal ¶
func (m *DisplayData_Identifier) XXX_Unmarshal(b []byte) error
type DisplayData_Item ¶
type DisplayData_Item struct { // (Required) Id *DisplayData_Identifier `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"` // (Required) Type DisplayData_Type_Enum `protobuf:"varint,2,opt,name=type,enum=org.apache.beam.model.pipeline.v1.DisplayData_Type_Enum" json:"type,omitempty"` // (Required) Value *any.Any `protobuf:"bytes,3,opt,name=value" json:"value,omitempty"` // (Optional) ShortValue *any.Any `protobuf:"bytes,4,opt,name=short_value,json=shortValue" json:"short_value,omitempty"` // (Optional) Label string `protobuf:"bytes,5,opt,name=label" json:"label,omitempty"` // (Optional) LinkUrl string `protobuf:"bytes,6,opt,name=link_url,json=linkUrl" json:"link_url,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A single item of display data.
func (*DisplayData_Item) Descriptor ¶
func (*DisplayData_Item) Descriptor() ([]byte, []int)
func (*DisplayData_Item) GetId ¶
func (m *DisplayData_Item) GetId() *DisplayData_Identifier
func (*DisplayData_Item) GetLabel ¶
func (m *DisplayData_Item) GetLabel() string
func (*DisplayData_Item) GetLinkUrl ¶
func (m *DisplayData_Item) GetLinkUrl() string
func (*DisplayData_Item) GetShortValue ¶
func (m *DisplayData_Item) GetShortValue() *any.Any
func (*DisplayData_Item) GetType ¶
func (m *DisplayData_Item) GetType() DisplayData_Type_Enum
func (*DisplayData_Item) GetValue ¶
func (m *DisplayData_Item) GetValue() *any.Any
func (*DisplayData_Item) ProtoMessage ¶
func (*DisplayData_Item) ProtoMessage()
func (*DisplayData_Item) Reset ¶
func (m *DisplayData_Item) Reset()
func (*DisplayData_Item) String ¶
func (m *DisplayData_Item) String() string
func (*DisplayData_Item) XXX_DiscardUnknown ¶
func (m *DisplayData_Item) XXX_DiscardUnknown()
func (*DisplayData_Item) XXX_Marshal ¶
func (m *DisplayData_Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisplayData_Item) XXX_Merge ¶
func (dst *DisplayData_Item) XXX_Merge(src proto.Message)
func (*DisplayData_Item) XXX_Size ¶
func (m *DisplayData_Item) XXX_Size() int
func (*DisplayData_Item) XXX_Unmarshal ¶
func (m *DisplayData_Item) XXX_Unmarshal(b []byte) error
type DisplayData_Type ¶
type DisplayData_Type struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DisplayData_Type) Descriptor ¶
func (*DisplayData_Type) Descriptor() ([]byte, []int)
func (*DisplayData_Type) ProtoMessage ¶
func (*DisplayData_Type) ProtoMessage()
func (*DisplayData_Type) Reset ¶
func (m *DisplayData_Type) Reset()
func (*DisplayData_Type) String ¶
func (m *DisplayData_Type) String() string
func (*DisplayData_Type) XXX_DiscardUnknown ¶
func (m *DisplayData_Type) XXX_DiscardUnknown()
func (*DisplayData_Type) XXX_Marshal ¶
func (m *DisplayData_Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisplayData_Type) XXX_Merge ¶
func (dst *DisplayData_Type) XXX_Merge(src proto.Message)
func (*DisplayData_Type) XXX_Size ¶
func (m *DisplayData_Type) XXX_Size() int
func (*DisplayData_Type) XXX_Unmarshal ¶
func (m *DisplayData_Type) XXX_Unmarshal(b []byte) error
type DisplayData_Type_Enum ¶
type DisplayData_Type_Enum int32
const ( DisplayData_Type_UNSPECIFIED DisplayData_Type_Enum = 0 DisplayData_Type_STRING DisplayData_Type_Enum = 1 DisplayData_Type_INTEGER DisplayData_Type_Enum = 2 DisplayData_Type_FLOAT DisplayData_Type_Enum = 3 DisplayData_Type_BOOLEAN DisplayData_Type_Enum = 4 DisplayData_Type_TIMESTAMP DisplayData_Type_Enum = 5 DisplayData_Type_DURATION DisplayData_Type_Enum = 6 DisplayData_Type_JAVA_CLASS DisplayData_Type_Enum = 7 )
func (DisplayData_Type_Enum) EnumDescriptor ¶
func (DisplayData_Type_Enum) EnumDescriptor() ([]byte, []int)
func (DisplayData_Type_Enum) String ¶
func (x DisplayData_Type_Enum) String() string
type Environment ¶
type Environment struct { // (Required) The URL of a container // // TODO: reconcile with Fn API's DockerContainer structure by // adding adequate metadata to know how to interpret the container Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An environment for executing UDFs. Generally an SDK container URL, but there can be many for a single SDK, for example to provide dependency isolation.
func (*Environment) Descriptor ¶
func (*Environment) Descriptor() ([]byte, []int)
func (*Environment) GetUrl ¶
func (m *Environment) GetUrl() string
func (*Environment) ProtoMessage ¶
func (*Environment) ProtoMessage()
func (*Environment) Reset ¶
func (m *Environment) Reset()
func (*Environment) String ¶
func (m *Environment) String() string
func (*Environment) XXX_DiscardUnknown ¶
func (m *Environment) XXX_DiscardUnknown()
func (*Environment) XXX_Marshal ¶
func (m *Environment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Environment) XXX_Merge ¶
func (dst *Environment) XXX_Merge(src proto.Message)
func (*Environment) XXX_Size ¶
func (m *Environment) XXX_Size() int
func (*Environment) XXX_Unmarshal ¶
func (m *Environment) XXX_Unmarshal(b []byte) error
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" json:"environment,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" 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" 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" 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" 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" json:"components,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The payload for an executable stage. This will eventually be passed to an SDK in the form of a ProcessBundleDescriptor.
func (*ExecutableStagePayload) Descriptor ¶
func (*ExecutableStagePayload) Descriptor() ([]byte, []int)
func (*ExecutableStagePayload) GetComponents ¶
func (m *ExecutableStagePayload) GetComponents() *Components
func (*ExecutableStagePayload) GetEnvironment ¶
func (m *ExecutableStagePayload) GetEnvironment() *Environment
func (*ExecutableStagePayload) GetInput ¶
func (m *ExecutableStagePayload) GetInput() string
func (*ExecutableStagePayload) GetOutputs ¶
func (m *ExecutableStagePayload) GetOutputs() []string
func (*ExecutableStagePayload) GetSideInputs ¶
func (m *ExecutableStagePayload) GetSideInputs() []*ExecutableStagePayload_SideInputId
func (*ExecutableStagePayload) GetTransforms ¶
func (m *ExecutableStagePayload) GetTransforms() []string
func (*ExecutableStagePayload) ProtoMessage ¶
func (*ExecutableStagePayload) ProtoMessage()
func (*ExecutableStagePayload) Reset ¶
func (m *ExecutableStagePayload) Reset()
func (*ExecutableStagePayload) String ¶
func (m *ExecutableStagePayload) String() string
func (*ExecutableStagePayload) XXX_DiscardUnknown ¶
func (m *ExecutableStagePayload) XXX_DiscardUnknown()
func (*ExecutableStagePayload) XXX_Marshal ¶
func (m *ExecutableStagePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutableStagePayload) XXX_Merge ¶
func (dst *ExecutableStagePayload) XXX_Merge(src proto.Message)
func (*ExecutableStagePayload) XXX_Size ¶
func (m *ExecutableStagePayload) XXX_Size() int
func (*ExecutableStagePayload) XXX_Unmarshal ¶
func (m *ExecutableStagePayload) XXX_Unmarshal(b []byte) error
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" 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" json:"local_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A reference to a side input. Side inputs are uniquely identified by PTransform id and local name.
func (*ExecutableStagePayload_SideInputId) Descriptor ¶
func (*ExecutableStagePayload_SideInputId) Descriptor() ([]byte, []int)
func (*ExecutableStagePayload_SideInputId) GetLocalName ¶
func (m *ExecutableStagePayload_SideInputId) GetLocalName() string
func (*ExecutableStagePayload_SideInputId) GetTransformId ¶
func (m *ExecutableStagePayload_SideInputId) GetTransformId() string
func (*ExecutableStagePayload_SideInputId) ProtoMessage ¶
func (*ExecutableStagePayload_SideInputId) ProtoMessage()
func (*ExecutableStagePayload_SideInputId) Reset ¶
func (m *ExecutableStagePayload_SideInputId) Reset()
func (*ExecutableStagePayload_SideInputId) String ¶
func (m *ExecutableStagePayload_SideInputId) String() string
func (*ExecutableStagePayload_SideInputId) XXX_DiscardUnknown ¶
func (m *ExecutableStagePayload_SideInputId) XXX_DiscardUnknown()
func (*ExecutableStagePayload_SideInputId) XXX_Marshal ¶
func (m *ExecutableStagePayload_SideInputId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecutableStagePayload_SideInputId) XXX_Merge ¶
func (dst *ExecutableStagePayload_SideInputId) XXX_Merge(src proto.Message)
func (*ExecutableStagePayload_SideInputId) XXX_Size ¶
func (m *ExecutableStagePayload_SideInputId) XXX_Size() int
func (*ExecutableStagePayload_SideInputId) XXX_Unmarshal ¶
func (m *ExecutableStagePayload_SideInputId) XXX_Unmarshal(b []byte) error
type FixedWindowsPayload ¶
type FixedWindowsPayload struct { Size *duration.Duration `protobuf:"bytes,1,opt,name=size" json:"size,omitempty"` Offset *timestamp.Timestamp `protobuf:"bytes,2,opt,name=offset" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FixedWindowsPayload) Descriptor ¶
func (*FixedWindowsPayload) Descriptor() ([]byte, []int)
func (*FixedWindowsPayload) GetOffset ¶
func (m *FixedWindowsPayload) GetOffset() *timestamp.Timestamp
func (*FixedWindowsPayload) GetSize ¶
func (m *FixedWindowsPayload) GetSize() *duration.Duration
func (*FixedWindowsPayload) ProtoMessage ¶
func (*FixedWindowsPayload) ProtoMessage()
func (*FixedWindowsPayload) Reset ¶
func (m *FixedWindowsPayload) Reset()
func (*FixedWindowsPayload) String ¶
func (m *FixedWindowsPayload) String() string
func (*FixedWindowsPayload) XXX_DiscardUnknown ¶
func (m *FixedWindowsPayload) XXX_DiscardUnknown()
func (*FixedWindowsPayload) XXX_Marshal ¶
func (m *FixedWindowsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FixedWindowsPayload) XXX_Merge ¶
func (dst *FixedWindowsPayload) XXX_Merge(src proto.Message)
func (*FixedWindowsPayload) XXX_Size ¶
func (m *FixedWindowsPayload) XXX_Size() int
func (*FixedWindowsPayload) XXX_Unmarshal ¶
func (m *FixedWindowsPayload) XXX_Unmarshal(b []byte) error
type FixedWindowsPayload_Enum ¶
type FixedWindowsPayload_Enum int32
const ( // TODO(BEAM-3595): Change this to beam:windowfn:fixed_windows:v1 FixedWindowsPayload_PROPERTIES FixedWindowsPayload_Enum = 0 )
func (FixedWindowsPayload_Enum) EnumDescriptor ¶
func (FixedWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)
func (FixedWindowsPayload_Enum) String ¶
func (x FixedWindowsPayload_Enum) String() string
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" 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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 "urn:beam:transform:Top" or "urn:beam:windowfn: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 "urn: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 ¶
func (*FunctionSpec) Descriptor() ([]byte, []int)
func (*FunctionSpec) GetPayload ¶
func (m *FunctionSpec) GetPayload() []byte
func (*FunctionSpec) GetUrn ¶
func (m *FunctionSpec) GetUrn() string
func (*FunctionSpec) ProtoMessage ¶
func (*FunctionSpec) ProtoMessage()
func (*FunctionSpec) Reset ¶
func (m *FunctionSpec) Reset()
func (*FunctionSpec) String ¶
func (m *FunctionSpec) String() string
func (*FunctionSpec) XXX_DiscardUnknown ¶
func (m *FunctionSpec) XXX_DiscardUnknown()
func (*FunctionSpec) XXX_Marshal ¶
func (m *FunctionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FunctionSpec) XXX_Merge ¶
func (dst *FunctionSpec) XXX_Merge(src proto.Message)
func (*FunctionSpec) XXX_Size ¶
func (m *FunctionSpec) XXX_Size() int
func (*FunctionSpec) XXX_Unmarshal ¶
func (m *FunctionSpec) XXX_Unmarshal(b []byte) error
type GlobalWindowsPayload ¶
type GlobalWindowsPayload struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GlobalWindowsPayload) Descriptor ¶
func (*GlobalWindowsPayload) Descriptor() ([]byte, []int)
func (*GlobalWindowsPayload) ProtoMessage ¶
func (*GlobalWindowsPayload) ProtoMessage()
func (*GlobalWindowsPayload) Reset ¶
func (m *GlobalWindowsPayload) Reset()
func (*GlobalWindowsPayload) String ¶
func (m *GlobalWindowsPayload) String() string
func (*GlobalWindowsPayload) XXX_DiscardUnknown ¶
func (m *GlobalWindowsPayload) XXX_DiscardUnknown()
func (*GlobalWindowsPayload) XXX_Marshal ¶
func (m *GlobalWindowsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GlobalWindowsPayload) XXX_Merge ¶
func (dst *GlobalWindowsPayload) XXX_Merge(src proto.Message)
func (*GlobalWindowsPayload) XXX_Size ¶
func (m *GlobalWindowsPayload) XXX_Size() int
func (*GlobalWindowsPayload) XXX_Unmarshal ¶
func (m *GlobalWindowsPayload) XXX_Unmarshal(b []byte) error
type GlobalWindowsPayload_Enum ¶
type GlobalWindowsPayload_Enum int32
const ( // TODO(BEAM-3595): Change this to beam:windowfn:global_windows:v1 GlobalWindowsPayload_PROPERTIES GlobalWindowsPayload_Enum = 0 )
func (GlobalWindowsPayload_Enum) EnumDescriptor ¶
func (GlobalWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)
func (GlobalWindowsPayload_Enum) String ¶
func (x GlobalWindowsPayload_Enum) String() string
type IsBounded ¶
type IsBounded struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IsBounded) Descriptor ¶
func (*IsBounded) ProtoMessage ¶
func (*IsBounded) ProtoMessage()
func (*IsBounded) XXX_DiscardUnknown ¶
func (m *IsBounded) XXX_DiscardUnknown()
func (*IsBounded) XXX_Marshal ¶
func (*IsBounded) XXX_Unmarshal ¶
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) EnumDescriptor ¶
func (IsBounded_Enum) EnumDescriptor() ([]byte, []int)
func (IsBounded_Enum) String ¶
func (x IsBounded_Enum) String() string
type MapStateSpec ¶
type MapStateSpec struct { KeyCoderId string `protobuf:"bytes,1,opt,name=key_coder_id,json=keyCoderId" json:"key_coder_id,omitempty"` ValueCoderId string `protobuf:"bytes,2,opt,name=value_coder_id,json=valueCoderId" json:"value_coder_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MapStateSpec) Descriptor ¶
func (*MapStateSpec) Descriptor() ([]byte, []int)
func (*MapStateSpec) GetKeyCoderId ¶
func (m *MapStateSpec) GetKeyCoderId() string
func (*MapStateSpec) GetValueCoderId ¶
func (m *MapStateSpec) GetValueCoderId() string
func (*MapStateSpec) ProtoMessage ¶
func (*MapStateSpec) ProtoMessage()
func (*MapStateSpec) Reset ¶
func (m *MapStateSpec) Reset()
func (*MapStateSpec) String ¶
func (m *MapStateSpec) String() string
func (*MapStateSpec) XXX_DiscardUnknown ¶
func (m *MapStateSpec) XXX_DiscardUnknown()
func (*MapStateSpec) XXX_Marshal ¶
func (m *MapStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MapStateSpec) XXX_Merge ¶
func (dst *MapStateSpec) XXX_Merge(src proto.Message)
func (*MapStateSpec) XXX_Size ¶
func (m *MapStateSpec) XXX_Size() int
func (*MapStateSpec) XXX_Unmarshal ¶
func (m *MapStateSpec) XXX_Unmarshal(b []byte) error
type MergeStatus ¶
type MergeStatus struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Whether or not a PCollection's WindowFn is non-merging, merging, or merging-but-already-merged, in which case a subsequent GroupByKey is almost always going to do something the user does not want
func (*MergeStatus) Descriptor ¶
func (*MergeStatus) Descriptor() ([]byte, []int)
func (*MergeStatus) ProtoMessage ¶
func (*MergeStatus) ProtoMessage()
func (*MergeStatus) Reset ¶
func (m *MergeStatus) Reset()
func (*MergeStatus) String ¶
func (m *MergeStatus) String() string
func (*MergeStatus) XXX_DiscardUnknown ¶
func (m *MergeStatus) XXX_DiscardUnknown()
func (*MergeStatus) XXX_Marshal ¶
func (m *MergeStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MergeStatus) XXX_Merge ¶
func (dst *MergeStatus) XXX_Merge(src proto.Message)
func (*MergeStatus) XXX_Size ¶
func (m *MergeStatus) XXX_Size() int
func (*MergeStatus) XXX_Unmarshal ¶
func (m *MergeStatus) XXX_Unmarshal(b []byte) error
type MergeStatus_Enum ¶
type MergeStatus_Enum int32
const ( MergeStatus_UNSPECIFIED MergeStatus_Enum = 0 // The WindowFn does not require merging. // Examples: global window, FixedWindows, SlidingWindows MergeStatus_NON_MERGING MergeStatus_Enum = 1 // The WindowFn is merging and the PCollection has not had merging // performed. // Example: Sessions prior to a GroupByKey MergeStatus_NEEDS_MERGE MergeStatus_Enum = 2 // The WindowFn is merging and the PCollection has had merging occur // already. // Example: Sessions after a GroupByKey MergeStatus_ALREADY_MERGED MergeStatus_Enum = 3 )
func (MergeStatus_Enum) EnumDescriptor ¶
func (MergeStatus_Enum) EnumDescriptor() ([]byte, []int)
func (MergeStatus_Enum) String ¶
func (x MergeStatus_Enum) String() string
type MessageWithComponents ¶
type MessageWithComponents struct { // (Optional) The by-reference components of the root message, // enabling a standalone message. // // If this is absent, it is expected that there are no // references. Components *Components `protobuf:"bytes,1,opt,name=components" json:"components,omitempty"` // (Required) The root message that may contain pointers // that should be resolved by looking inside components. // // Types that are valid to be assigned to Root: // *MessageWithComponents_Coder // *MessageWithComponents_CombinePayload // *MessageWithComponents_SdkFunctionSpec // *MessageWithComponents_ParDoPayload // *MessageWithComponents_Ptransform // *MessageWithComponents_Pcollection // *MessageWithComponents_ReadPayload // *MessageWithComponents_SideInput // *MessageWithComponents_WindowIntoPayload // *MessageWithComponents_WindowingStrategy // *MessageWithComponents_FunctionSpec Root isMessageWithComponents_Root `protobuf_oneof:"root"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A disjoint union of all the things that may contain references that require Components to resolve.
func (*MessageWithComponents) Descriptor ¶
func (*MessageWithComponents) Descriptor() ([]byte, []int)
func (*MessageWithComponents) GetCoder ¶
func (m *MessageWithComponents) GetCoder() *Coder
func (*MessageWithComponents) GetCombinePayload ¶
func (m *MessageWithComponents) GetCombinePayload() *CombinePayload
func (*MessageWithComponents) GetComponents ¶
func (m *MessageWithComponents) GetComponents() *Components
func (*MessageWithComponents) GetFunctionSpec ¶
func (m *MessageWithComponents) GetFunctionSpec() *FunctionSpec
func (*MessageWithComponents) GetParDoPayload ¶
func (m *MessageWithComponents) GetParDoPayload() *ParDoPayload
func (*MessageWithComponents) GetPcollection ¶
func (m *MessageWithComponents) GetPcollection() *PCollection
func (*MessageWithComponents) GetPtransform ¶
func (m *MessageWithComponents) GetPtransform() *PTransform
func (*MessageWithComponents) GetReadPayload ¶
func (m *MessageWithComponents) GetReadPayload() *ReadPayload
func (*MessageWithComponents) GetRoot ¶
func (m *MessageWithComponents) GetRoot() isMessageWithComponents_Root
func (*MessageWithComponents) GetSdkFunctionSpec ¶
func (m *MessageWithComponents) GetSdkFunctionSpec() *SdkFunctionSpec
func (*MessageWithComponents) GetSideInput ¶
func (m *MessageWithComponents) GetSideInput() *SideInput
func (*MessageWithComponents) GetWindowIntoPayload ¶
func (m *MessageWithComponents) GetWindowIntoPayload() *WindowIntoPayload
func (*MessageWithComponents) GetWindowingStrategy ¶
func (m *MessageWithComponents) GetWindowingStrategy() *WindowingStrategy
func (*MessageWithComponents) ProtoMessage ¶
func (*MessageWithComponents) ProtoMessage()
func (*MessageWithComponents) Reset ¶
func (m *MessageWithComponents) Reset()
func (*MessageWithComponents) String ¶
func (m *MessageWithComponents) String() string
func (*MessageWithComponents) XXX_DiscardUnknown ¶
func (m *MessageWithComponents) XXX_DiscardUnknown()
func (*MessageWithComponents) XXX_Marshal ¶
func (m *MessageWithComponents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageWithComponents) XXX_Merge ¶
func (dst *MessageWithComponents) XXX_Merge(src proto.Message)
func (*MessageWithComponents) XXX_OneofFuncs ¶
func (*MessageWithComponents) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*MessageWithComponents) XXX_Size ¶
func (m *MessageWithComponents) XXX_Size() int
func (*MessageWithComponents) XXX_Unmarshal ¶
func (m *MessageWithComponents) XXX_Unmarshal(b []byte) error
type MessageWithComponents_Coder ¶
type MessageWithComponents_Coder struct {
Coder *Coder `protobuf:"bytes,2,opt,name=coder,oneof"`
}
type MessageWithComponents_CombinePayload ¶
type MessageWithComponents_CombinePayload struct {
CombinePayload *CombinePayload `protobuf:"bytes,3,opt,name=combine_payload,json=combinePayload,oneof"`
}
type MessageWithComponents_FunctionSpec ¶
type MessageWithComponents_FunctionSpec struct {
FunctionSpec *FunctionSpec `protobuf:"bytes,14,opt,name=function_spec,json=functionSpec,oneof"`
}
type MessageWithComponents_ParDoPayload ¶
type MessageWithComponents_ParDoPayload struct {
ParDoPayload *ParDoPayload `protobuf:"bytes,6,opt,name=par_do_payload,json=parDoPayload,oneof"`
}
type MessageWithComponents_Pcollection ¶
type MessageWithComponents_Pcollection struct {
Pcollection *PCollection `protobuf:"bytes,8,opt,name=pcollection,oneof"`
}
type MessageWithComponents_Ptransform ¶
type MessageWithComponents_Ptransform struct {
Ptransform *PTransform `protobuf:"bytes,7,opt,name=ptransform,oneof"`
}
type MessageWithComponents_ReadPayload ¶
type MessageWithComponents_ReadPayload struct {
ReadPayload *ReadPayload `protobuf:"bytes,9,opt,name=read_payload,json=readPayload,oneof"`
}
type MessageWithComponents_SdkFunctionSpec ¶
type MessageWithComponents_SdkFunctionSpec struct {
SdkFunctionSpec *SdkFunctionSpec `protobuf:"bytes,4,opt,name=sdk_function_spec,json=sdkFunctionSpec,oneof"`
}
type MessageWithComponents_SideInput ¶
type MessageWithComponents_SideInput struct {
SideInput *SideInput `protobuf:"bytes,11,opt,name=side_input,json=sideInput,oneof"`
}
type MessageWithComponents_WindowIntoPayload ¶
type MessageWithComponents_WindowIntoPayload struct {
WindowIntoPayload *WindowIntoPayload `protobuf:"bytes,12,opt,name=window_into_payload,json=windowIntoPayload,oneof"`
}
type MessageWithComponents_WindowingStrategy ¶
type MessageWithComponents_WindowingStrategy struct {
WindowingStrategy *WindowingStrategy `protobuf:"bytes,13,opt,name=windowing_strategy,json=windowingStrategy,oneof"`
}
type OAuth2ClientCredentialsGrant ¶
type OAuth2ClientCredentialsGrant struct { // (Required) The URL to submit a "client_credentials" grant type request for // an OAuth access token which will be used as a bearer token for requests. Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OAuth2ClientCredentialsGrant) Descriptor ¶
func (*OAuth2ClientCredentialsGrant) Descriptor() ([]byte, []int)
func (*OAuth2ClientCredentialsGrant) GetUrl ¶
func (m *OAuth2ClientCredentialsGrant) GetUrl() string
func (*OAuth2ClientCredentialsGrant) ProtoMessage ¶
func (*OAuth2ClientCredentialsGrant) ProtoMessage()
func (*OAuth2ClientCredentialsGrant) Reset ¶
func (m *OAuth2ClientCredentialsGrant) Reset()
func (*OAuth2ClientCredentialsGrant) String ¶
func (m *OAuth2ClientCredentialsGrant) String() string
func (*OAuth2ClientCredentialsGrant) XXX_DiscardUnknown ¶
func (m *OAuth2ClientCredentialsGrant) XXX_DiscardUnknown()
func (*OAuth2ClientCredentialsGrant) XXX_Marshal ¶
func (m *OAuth2ClientCredentialsGrant) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OAuth2ClientCredentialsGrant) XXX_Merge ¶
func (dst *OAuth2ClientCredentialsGrant) XXX_Merge(src proto.Message)
func (*OAuth2ClientCredentialsGrant) XXX_Size ¶
func (m *OAuth2ClientCredentialsGrant) XXX_Size() int
func (*OAuth2ClientCredentialsGrant) XXX_Unmarshal ¶
func (m *OAuth2ClientCredentialsGrant) XXX_Unmarshal(b []byte) error
type OnTimeBehavior ¶
type OnTimeBehavior struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Controls whether or not an aggregating transform should output data when an on-time pane is empty.
func (*OnTimeBehavior) Descriptor ¶
func (*OnTimeBehavior) Descriptor() ([]byte, []int)
func (*OnTimeBehavior) ProtoMessage ¶
func (*OnTimeBehavior) ProtoMessage()
func (*OnTimeBehavior) Reset ¶
func (m *OnTimeBehavior) Reset()
func (*OnTimeBehavior) String ¶
func (m *OnTimeBehavior) String() string
func (*OnTimeBehavior) XXX_DiscardUnknown ¶
func (m *OnTimeBehavior) XXX_DiscardUnknown()
func (*OnTimeBehavior) XXX_Marshal ¶
func (m *OnTimeBehavior) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OnTimeBehavior) XXX_Merge ¶
func (dst *OnTimeBehavior) XXX_Merge(src proto.Message)
func (*OnTimeBehavior) XXX_Size ¶
func (m *OnTimeBehavior) XXX_Size() int
func (*OnTimeBehavior) XXX_Unmarshal ¶
func (m *OnTimeBehavior) XXX_Unmarshal(b []byte) error
type OnTimeBehavior_Enum ¶
type OnTimeBehavior_Enum int32
const ( OnTimeBehavior_UNSPECIFIED OnTimeBehavior_Enum = 0 // Always fire the on-time pane. Even if there is no new data since // the previous firing, an element will be produced. OnTimeBehavior_FIRE_ALWAYS OnTimeBehavior_Enum = 1 // Only fire the on-time pane if there is new data since the previous firing. OnTimeBehavior_FIRE_IF_NONEMPTY OnTimeBehavior_Enum = 2 )
func (OnTimeBehavior_Enum) EnumDescriptor ¶
func (OnTimeBehavior_Enum) EnumDescriptor() ([]byte, []int)
func (OnTimeBehavior_Enum) String ¶
func (x OnTimeBehavior_Enum) String() string
type OutputTime ¶
type OutputTime struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
When a number of windowed, timestamped inputs are aggregated, the timestamp for the resulting output.
func (*OutputTime) Descriptor ¶
func (*OutputTime) Descriptor() ([]byte, []int)
func (*OutputTime) ProtoMessage ¶
func (*OutputTime) ProtoMessage()
func (*OutputTime) Reset ¶
func (m *OutputTime) Reset()
func (*OutputTime) String ¶
func (m *OutputTime) String() string
func (*OutputTime) XXX_DiscardUnknown ¶
func (m *OutputTime) XXX_DiscardUnknown()
func (*OutputTime) XXX_Marshal ¶
func (m *OutputTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OutputTime) XXX_Merge ¶
func (dst *OutputTime) XXX_Merge(src proto.Message)
func (*OutputTime) XXX_Size ¶
func (m *OutputTime) XXX_Size() int
func (*OutputTime) XXX_Unmarshal ¶
func (m *OutputTime) XXX_Unmarshal(b []byte) error
type OutputTime_Enum ¶
type OutputTime_Enum int32
const ( OutputTime_UNSPECIFIED OutputTime_Enum = 0 // The output has the timestamp of the end of the window. OutputTime_END_OF_WINDOW OutputTime_Enum = 1 // The output has the latest timestamp of the input elements since // the last output. OutputTime_LATEST_IN_PANE OutputTime_Enum = 2 // The output has the earliest timestamp of the input elements since // the last output. OutputTime_EARLIEST_IN_PANE OutputTime_Enum = 3 )
func (OutputTime_Enum) EnumDescriptor ¶
func (OutputTime_Enum) EnumDescriptor() ([]byte, []int)
func (OutputTime_Enum) String ¶
func (x OutputTime_Enum) String() string
type PCollection ¶
type PCollection struct { // (Required) A unique name for the PCollection. // // Ideally, this should be stable over multiple evolutions of a pipeline // for the purposes of logging and associating pipeline state with a node, // etc. // // If it is not stable, then the runner decides what will happen. But, most // importantly, it must always be here, even if it is autogenerated. UniqueName string `protobuf:"bytes,1,opt,name=unique_name,json=uniqueName" json:"unique_name,omitempty"` // (Required) The id of the Coder for this PCollection. CoderId string `protobuf:"bytes,2,opt,name=coder_id,json=coderId" json:"coder_id,omitempty"` // (Required) Whether this PCollection is bounded or unbounded IsBounded IsBounded_Enum `` /* 136-byte string literal not displayed */ // (Required) The id of the windowing strategy for this PCollection. WindowingStrategyId string `protobuf:"bytes,4,opt,name=windowing_strategy_id,json=windowingStrategyId" json:"windowing_strategy_id,omitempty"` // (Optional) Static display data for this PTransform application. If // there is none, or it is not relevant (such as use by the Fn API) // then it may be omitted. DisplayData *DisplayData `protobuf:"bytes,5,opt,name=display_data,json=displayData" json:"display_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A PCollection!
func (*PCollection) Descriptor ¶
func (*PCollection) Descriptor() ([]byte, []int)
func (*PCollection) GetCoderId ¶
func (m *PCollection) GetCoderId() string
func (*PCollection) GetDisplayData ¶
func (m *PCollection) GetDisplayData() *DisplayData
func (*PCollection) GetIsBounded ¶
func (m *PCollection) GetIsBounded() IsBounded_Enum
func (*PCollection) GetUniqueName ¶
func (m *PCollection) GetUniqueName() string
func (*PCollection) GetWindowingStrategyId ¶
func (m *PCollection) GetWindowingStrategyId() string
func (*PCollection) ProtoMessage ¶
func (*PCollection) ProtoMessage()
func (*PCollection) Reset ¶
func (m *PCollection) Reset()
func (*PCollection) String ¶
func (m *PCollection) String() string
func (*PCollection) XXX_DiscardUnknown ¶
func (m *PCollection) XXX_DiscardUnknown()
func (*PCollection) XXX_Marshal ¶
func (m *PCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PCollection) XXX_Merge ¶
func (dst *PCollection) XXX_Merge(src proto.Message)
func (*PCollection) XXX_Size ¶
func (m *PCollection) XXX_Size() int
func (*PCollection) XXX_Unmarshal ¶
func (m *PCollection) XXX_Unmarshal(b []byte) error
type PTransform ¶
type PTransform struct { // (Required) A unique name for the application node. // // Ideally, this should be stable over multiple evolutions of a pipeline // for the purposes of logging and associating pipeline state with a node, // etc. // // If it is not stable, then the runner decides what will happen. But, most // importantly, it must always be here and be unique, even if it is // autogenerated. UniqueName string `protobuf:"bytes,5,opt,name=unique_name,json=uniqueName" json:"unique_name,omitempty"` // (Optional) A URN and payload that, together, fully defined the semantics // of this transform. // // If absent, this must be an "anonymous" composite transform. // // For primitive transform in the Runner API, this is required, and the // payloads are well-defined messages. When the URN indicates ParDo it // is a ParDoPayload, and so on. // // TODO: document the standardized URNs and payloads // TODO: separate standardized payloads into a separate proto file // // For some special composite transforms, the payload is also officially // defined: // // - when the URN is "urn:beam:transforms:combine" it is a CombinePayload // Spec *FunctionSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"` // (Optional) if this node is a composite, a list of the ids of // transforms that it contains. Subtransforms []string `protobuf:"bytes,2,rep,name=subtransforms" json:"subtransforms,omitempty"` // (Required) A map from local names of inputs (unique only with this map, and // likely embedded in the transform payload and serialized user code) to // PCollection ids. // // The payload for this transform may clarify the relationship of these // inputs. For example: // // - for a Flatten transform they are merged // - for a ParDo transform, some may be side inputs // // All inputs are recorded here so that the topological ordering of // the graph is consistent whether or not the payload is understood. // Inputs map[string]string `` /* 132-byte string literal not displayed */ // (Required) A map from local names of outputs (unique only within this map, // and likely embedded in the transform payload and serialized user code) // to PCollection ids. // // The URN or payload for this transform node may clarify the type and // relationship of these outputs. For example: // // - for a ParDo transform, these are tags on PCollections, which will be // embedded in the DoFn. // Outputs map[string]string `` /* 134-byte string literal not displayed */ // (Optional) Static display data for this PTransform application. If // there is none, or it is not relevant (such as use by the Fn API) // then it may be omitted. DisplayData *DisplayData `protobuf:"bytes,6,opt,name=display_data,json=displayData" json:"display_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
An applied PTransform! This does not contain the graph data, but only the fields specific to a graph node that is a Runner API transform between PCollections.
func (*PTransform) Descriptor ¶
func (*PTransform) Descriptor() ([]byte, []int)
func (*PTransform) GetDisplayData ¶
func (m *PTransform) GetDisplayData() *DisplayData
func (*PTransform) GetInputs ¶
func (m *PTransform) GetInputs() map[string]string
func (*PTransform) GetOutputs ¶
func (m *PTransform) GetOutputs() map[string]string
func (*PTransform) GetSpec ¶
func (m *PTransform) GetSpec() *FunctionSpec
func (*PTransform) GetSubtransforms ¶
func (m *PTransform) GetSubtransforms() []string
func (*PTransform) GetUniqueName ¶
func (m *PTransform) GetUniqueName() string
func (*PTransform) ProtoMessage ¶
func (*PTransform) ProtoMessage()
func (*PTransform) Reset ¶
func (m *PTransform) Reset()
func (*PTransform) String ¶
func (m *PTransform) String() string
func (*PTransform) XXX_DiscardUnknown ¶
func (m *PTransform) XXX_DiscardUnknown()
func (*PTransform) XXX_Marshal ¶
func (m *PTransform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PTransform) XXX_Merge ¶
func (dst *PTransform) XXX_Merge(src proto.Message)
func (*PTransform) XXX_Size ¶
func (m *PTransform) XXX_Size() int
func (*PTransform) XXX_Unmarshal ¶
func (m *PTransform) XXX_Unmarshal(b []byte) error
type ParDoPayload ¶
type ParDoPayload struct { // (Required) The SdkFunctionSpec of the DoFn. DoFn *SdkFunctionSpec `protobuf:"bytes,1,opt,name=do_fn,json=doFn" json:"do_fn,omitempty"` // (Required) Additional pieces of context the DoFn may require that // are not otherwise represented in the payload. // (may force runners to execute the ParDo differently) Parameters []*Parameter `protobuf:"bytes,2,rep,name=parameters" json:"parameters,omitempty"` // (Optional) A mapping of local input names to side inputs, describing // the expected access pattern. SideInputs map[string]*SideInput `` /* 158-byte string literal not displayed */ // (Optional) A mapping of local state names to state specifications. StateSpecs map[string]*StateSpec `` /* 158-byte string literal not displayed */ // (Optional) A mapping of local timer names to timer specifications. TimerSpecs map[string]*TimerSpec `` /* 158-byte string literal not displayed */ // Whether the DoFn is splittable Splittable bool `protobuf:"varint,6,opt,name=splittable" json:"splittable,omitempty"` // (Required if splittable == true) Id of the restriction coder. RestrictionCoderId string `protobuf:"bytes,7,opt,name=restriction_coder_id,json=restrictionCoderId" json:"restriction_coder_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The payload for the primitive ParDo transform.
func (*ParDoPayload) Descriptor ¶
func (*ParDoPayload) Descriptor() ([]byte, []int)
func (*ParDoPayload) GetDoFn ¶
func (m *ParDoPayload) GetDoFn() *SdkFunctionSpec
func (*ParDoPayload) GetParameters ¶
func (m *ParDoPayload) GetParameters() []*Parameter
func (*ParDoPayload) GetRestrictionCoderId ¶
func (m *ParDoPayload) GetRestrictionCoderId() string
func (*ParDoPayload) GetSideInputs ¶
func (m *ParDoPayload) GetSideInputs() map[string]*SideInput
func (*ParDoPayload) GetSplittable ¶
func (m *ParDoPayload) GetSplittable() bool
func (*ParDoPayload) GetStateSpecs ¶
func (m *ParDoPayload) GetStateSpecs() map[string]*StateSpec
func (*ParDoPayload) GetTimerSpecs ¶
func (m *ParDoPayload) GetTimerSpecs() map[string]*TimerSpec
func (*ParDoPayload) ProtoMessage ¶
func (*ParDoPayload) ProtoMessage()
func (*ParDoPayload) Reset ¶
func (m *ParDoPayload) Reset()
func (*ParDoPayload) String ¶
func (m *ParDoPayload) String() string
func (*ParDoPayload) XXX_DiscardUnknown ¶
func (m *ParDoPayload) XXX_DiscardUnknown()
func (*ParDoPayload) XXX_Marshal ¶
func (m *ParDoPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ParDoPayload) XXX_Merge ¶
func (dst *ParDoPayload) XXX_Merge(src proto.Message)
func (*ParDoPayload) XXX_Size ¶
func (m *ParDoPayload) XXX_Size() int
func (*ParDoPayload) XXX_Unmarshal ¶
func (m *ParDoPayload) XXX_Unmarshal(b []byte) error
type Parameter ¶
type Parameter struct { Type Parameter_Type_Enum `protobuf:"varint,1,opt,name=type,enum=org.apache.beam.model.pipeline.v1.Parameter_Type_Enum" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Parameters that a UDF might require.
The details of how a runner sends these parameters to the SDK harness are the subject of the Fn API.
The details of how an SDK harness delivers them to the UDF is entirely up to the SDK. (for some SDKs there may be parameters that are not represented here if the runner doesn't need to do anything)
Here, the parameters are simply indicators to the runner that they need to run the function a particular way.
TODO: the evolution of the Fn API will influence what needs explicit representation here
func (*Parameter) Descriptor ¶
func (*Parameter) GetType ¶
func (m *Parameter) GetType() Parameter_Type_Enum
func (*Parameter) ProtoMessage ¶
func (*Parameter) ProtoMessage()
func (*Parameter) XXX_DiscardUnknown ¶
func (m *Parameter) XXX_DiscardUnknown()
func (*Parameter) XXX_Marshal ¶
func (*Parameter) XXX_Unmarshal ¶
type Parameter_Type ¶
type Parameter_Type struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Parameter_Type) Descriptor ¶
func (*Parameter_Type) Descriptor() ([]byte, []int)
func (*Parameter_Type) ProtoMessage ¶
func (*Parameter_Type) ProtoMessage()
func (*Parameter_Type) Reset ¶
func (m *Parameter_Type) Reset()
func (*Parameter_Type) String ¶
func (m *Parameter_Type) String() string
func (*Parameter_Type) XXX_DiscardUnknown ¶
func (m *Parameter_Type) XXX_DiscardUnknown()
func (*Parameter_Type) XXX_Marshal ¶
func (m *Parameter_Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Parameter_Type) XXX_Merge ¶
func (dst *Parameter_Type) XXX_Merge(src proto.Message)
func (*Parameter_Type) XXX_Size ¶
func (m *Parameter_Type) XXX_Size() int
func (*Parameter_Type) XXX_Unmarshal ¶
func (m *Parameter_Type) XXX_Unmarshal(b []byte) error
type Parameter_Type_Enum ¶
type Parameter_Type_Enum int32
const ( Parameter_Type_UNSPECIFIED Parameter_Type_Enum = 0 Parameter_Type_WINDOW Parameter_Type_Enum = 1 Parameter_Type_PIPELINE_OPTIONS Parameter_Type_Enum = 2 Parameter_Type_RESTRICTION_TRACKER Parameter_Type_Enum = 3 )
func (Parameter_Type_Enum) EnumDescriptor ¶
func (Parameter_Type_Enum) EnumDescriptor() ([]byte, []int)
func (Parameter_Type_Enum) String ¶
func (x Parameter_Type_Enum) String() string
type Pipeline ¶
type Pipeline struct { // (Required) The coders, UDFs, graph nodes, etc, that make up // this pipeline. Components *Components `protobuf:"bytes,1,opt,name=components" json:"components,omitempty"` // (Required) The ids of all PTransforms that are not contained within another PTransform. // These must be in shallow topological order, so that traversing them recursively // in this order yields a recursively topological traversal. RootTransformIds []string `protobuf:"bytes,2,rep,name=root_transform_ids,json=rootTransformIds" json:"root_transform_ids,omitempty"` // (Optional) Static display data for the pipeline. If there is none, // it may be omitted. DisplayData *DisplayData `protobuf:"bytes,3,opt,name=display_data,json=displayData" json:"display_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A Pipeline is a hierarchical graph of PTransforms, linked by PCollections.
This is represented by a number of by-reference maps to nodes, PCollections, SDK environments, UDF, etc., for supporting compact reuse and arbitrary graph structure.
All of the keys in the maps here are arbitrary strings that are only required to be internally consistent within this proto message.
func (*Pipeline) Descriptor ¶
func (*Pipeline) GetComponents ¶
func (m *Pipeline) GetComponents() *Components
func (*Pipeline) GetDisplayData ¶
func (m *Pipeline) GetDisplayData() *DisplayData
func (*Pipeline) GetRootTransformIds ¶
func (*Pipeline) ProtoMessage ¶
func (*Pipeline) ProtoMessage()
func (*Pipeline) XXX_DiscardUnknown ¶
func (m *Pipeline) XXX_DiscardUnknown()
func (*Pipeline) XXX_Marshal ¶
func (*Pipeline) XXX_Unmarshal ¶
type ReadPayload ¶
type ReadPayload struct { // (Required) The SdkFunctionSpec of the source for this Read. Source *SdkFunctionSpec `protobuf:"bytes,1,opt,name=source" json:"source,omitempty"` // (Required) Whether the source is bounded or unbounded IsBounded IsBounded_Enum `` /* 136-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The payload for the primitive Read transform.
func (*ReadPayload) Descriptor ¶
func (*ReadPayload) Descriptor() ([]byte, []int)
func (*ReadPayload) GetIsBounded ¶
func (m *ReadPayload) GetIsBounded() IsBounded_Enum
func (*ReadPayload) GetSource ¶
func (m *ReadPayload) GetSource() *SdkFunctionSpec
func (*ReadPayload) ProtoMessage ¶
func (*ReadPayload) ProtoMessage()
func (*ReadPayload) Reset ¶
func (m *ReadPayload) Reset()
func (*ReadPayload) String ¶
func (m *ReadPayload) String() string
func (*ReadPayload) XXX_DiscardUnknown ¶
func (m *ReadPayload) XXX_DiscardUnknown()
func (*ReadPayload) XXX_Marshal ¶
func (m *ReadPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadPayload) XXX_Merge ¶
func (dst *ReadPayload) XXX_Merge(src proto.Message)
func (*ReadPayload) XXX_Size ¶
func (m *ReadPayload) XXX_Size() int
func (*ReadPayload) XXX_Unmarshal ¶
func (m *ReadPayload) XXX_Unmarshal(b []byte) error
type SdkFunctionSpec ¶
type SdkFunctionSpec struct { // (Required) A full specification of this function. Spec *FunctionSpec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"` // (Required) Reference to an execution environment capable of // invoking this function. EnvironmentId string `protobuf:"bytes,2,opt,name=environment_id,json=environmentId" json:"environment_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A specification of a user defined function.
func (*SdkFunctionSpec) Descriptor ¶
func (*SdkFunctionSpec) Descriptor() ([]byte, []int)
func (*SdkFunctionSpec) GetEnvironmentId ¶
func (m *SdkFunctionSpec) GetEnvironmentId() string
func (*SdkFunctionSpec) GetSpec ¶
func (m *SdkFunctionSpec) GetSpec() *FunctionSpec
func (*SdkFunctionSpec) ProtoMessage ¶
func (*SdkFunctionSpec) ProtoMessage()
func (*SdkFunctionSpec) Reset ¶
func (m *SdkFunctionSpec) Reset()
func (*SdkFunctionSpec) String ¶
func (m *SdkFunctionSpec) String() string
func (*SdkFunctionSpec) XXX_DiscardUnknown ¶
func (m *SdkFunctionSpec) XXX_DiscardUnknown()
func (*SdkFunctionSpec) XXX_Marshal ¶
func (m *SdkFunctionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SdkFunctionSpec) XXX_Merge ¶
func (dst *SdkFunctionSpec) XXX_Merge(src proto.Message)
func (*SdkFunctionSpec) XXX_Size ¶
func (m *SdkFunctionSpec) XXX_Size() int
func (*SdkFunctionSpec) XXX_Unmarshal ¶
func (m *SdkFunctionSpec) XXX_Unmarshal(b []byte) error
type SessionsPayload ¶
type SessionsPayload struct { GapSize *duration.Duration `protobuf:"bytes,1,opt,name=gap_size,json=gapSize" json:"gap_size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SessionsPayload) Descriptor ¶
func (*SessionsPayload) Descriptor() ([]byte, []int)
func (*SessionsPayload) GetGapSize ¶
func (m *SessionsPayload) GetGapSize() *duration.Duration
func (*SessionsPayload) ProtoMessage ¶
func (*SessionsPayload) ProtoMessage()
func (*SessionsPayload) Reset ¶
func (m *SessionsPayload) Reset()
func (*SessionsPayload) String ¶
func (m *SessionsPayload) String() string
func (*SessionsPayload) XXX_DiscardUnknown ¶
func (m *SessionsPayload) XXX_DiscardUnknown()
func (*SessionsPayload) XXX_Marshal ¶
func (m *SessionsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SessionsPayload) XXX_Merge ¶
func (dst *SessionsPayload) XXX_Merge(src proto.Message)
func (*SessionsPayload) XXX_Size ¶
func (m *SessionsPayload) XXX_Size() int
func (*SessionsPayload) XXX_Unmarshal ¶
func (m *SessionsPayload) XXX_Unmarshal(b []byte) error
type SessionsPayload_Enum ¶
type SessionsPayload_Enum int32
const ( // TODO(BEAM-3595): Change this to beam:windowfn:session_windows:v1 SessionsPayload_PROPERTIES SessionsPayload_Enum = 0 )
func (SessionsPayload_Enum) EnumDescriptor ¶
func (SessionsPayload_Enum) EnumDescriptor() ([]byte, []int)
func (SessionsPayload_Enum) String ¶
func (x SessionsPayload_Enum) String() string
type SetStateSpec ¶
type SetStateSpec struct { ElementCoderId string `protobuf:"bytes,1,opt,name=element_coder_id,json=elementCoderId" json:"element_coder_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SetStateSpec) Descriptor ¶
func (*SetStateSpec) Descriptor() ([]byte, []int)
func (*SetStateSpec) GetElementCoderId ¶
func (m *SetStateSpec) GetElementCoderId() string
func (*SetStateSpec) ProtoMessage ¶
func (*SetStateSpec) ProtoMessage()
func (*SetStateSpec) Reset ¶
func (m *SetStateSpec) Reset()
func (*SetStateSpec) String ¶
func (m *SetStateSpec) String() string
func (*SetStateSpec) XXX_DiscardUnknown ¶
func (m *SetStateSpec) XXX_DiscardUnknown()
func (*SetStateSpec) XXX_Marshal ¶
func (m *SetStateSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetStateSpec) XXX_Merge ¶
func (dst *SetStateSpec) XXX_Merge(src proto.Message)
func (*SetStateSpec) XXX_Size ¶
func (m *SetStateSpec) XXX_Size() int
func (*SetStateSpec) XXX_Unmarshal ¶
func (m *SetStateSpec) XXX_Unmarshal(b []byte) error
type SideInput ¶
type SideInput struct { // (Required) URN of the access pattern required by the `view_fn` to present // the desired SDK-specific interface to a UDF. // // This access pattern defines the SDK harness <-> Runner Harness RPC // interface for accessing a side input. // // The only access pattern intended for Beam, because of its superior // performance possibilities, is "urn:beam:sideinput:multimap" (or some such // URN) AccessPattern *FunctionSpec `protobuf:"bytes,1,opt,name=access_pattern,json=accessPattern" json:"access_pattern,omitempty"` // (Required) The SdkFunctionSpec of the UDF that adapts a particular // access_pattern to a user-facing view type. // // For example, View.asSingleton() may include a `view_fn` that adapts a // specially-designed multimap to a single value per window. ViewFn *SdkFunctionSpec `protobuf:"bytes,2,opt,name=view_fn,json=viewFn" json:"view_fn,omitempty"` // (Required) The SdkFunctionSpec of the UDF that maps a main input window // to a side input window. // // For example, when the main input is in fixed windows of one hour, this // can specify that the side input should be accessed according to the day // in which that hour falls. WindowMappingFn *SdkFunctionSpec `protobuf:"bytes,3,opt,name=window_mapping_fn,json=windowMappingFn" json:"window_mapping_fn,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A specification for how to "side input" a PCollection.
func (*SideInput) Descriptor ¶
func (*SideInput) GetAccessPattern ¶
func (m *SideInput) GetAccessPattern() *FunctionSpec
func (*SideInput) GetViewFn ¶
func (m *SideInput) GetViewFn() *SdkFunctionSpec
func (*SideInput) GetWindowMappingFn ¶
func (m *SideInput) GetWindowMappingFn() *SdkFunctionSpec
func (*SideInput) ProtoMessage ¶
func (*SideInput) ProtoMessage()
func (*SideInput) XXX_DiscardUnknown ¶
func (m *SideInput) XXX_DiscardUnknown()
func (*SideInput) XXX_Marshal ¶
func (*SideInput) XXX_Unmarshal ¶
type SlidingWindowsPayload ¶
type SlidingWindowsPayload struct { Size *duration.Duration `protobuf:"bytes,1,opt,name=size" json:"size,omitempty"` Offset *timestamp.Timestamp `protobuf:"bytes,2,opt,name=offset" json:"offset,omitempty"` Period *duration.Duration `protobuf:"bytes,3,opt,name=period" json:"period,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SlidingWindowsPayload) Descriptor ¶
func (*SlidingWindowsPayload) Descriptor() ([]byte, []int)
func (*SlidingWindowsPayload) GetOffset ¶
func (m *SlidingWindowsPayload) GetOffset() *timestamp.Timestamp
func (*SlidingWindowsPayload) GetPeriod ¶
func (m *SlidingWindowsPayload) GetPeriod() *duration.Duration
func (*SlidingWindowsPayload) GetSize ¶
func (m *SlidingWindowsPayload) GetSize() *duration.Duration
func (*SlidingWindowsPayload) ProtoMessage ¶
func (*SlidingWindowsPayload) ProtoMessage()
func (*SlidingWindowsPayload) Reset ¶
func (m *SlidingWindowsPayload) Reset()
func (*SlidingWindowsPayload) String ¶
func (m *SlidingWindowsPayload) String() string
func (*SlidingWindowsPayload) XXX_DiscardUnknown ¶
func (m *SlidingWindowsPayload) XXX_DiscardUnknown()
func (*SlidingWindowsPayload) XXX_Marshal ¶
func (m *SlidingWindowsPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SlidingWindowsPayload) XXX_Merge ¶
func (dst *SlidingWindowsPayload) XXX_Merge(src proto.Message)
func (*SlidingWindowsPayload) XXX_Size ¶
func (m *SlidingWindowsPayload) XXX_Size() int
func (*SlidingWindowsPayload) XXX_Unmarshal ¶
func (m *SlidingWindowsPayload) XXX_Unmarshal(b []byte) error
type SlidingWindowsPayload_Enum ¶
type SlidingWindowsPayload_Enum int32
const ( // TODO(BEAM-3595): Change this to beam:windowfn:sliding_windows:v1 SlidingWindowsPayload_PROPERTIES SlidingWindowsPayload_Enum = 0 )
func (SlidingWindowsPayload_Enum) EnumDescriptor ¶
func (SlidingWindowsPayload_Enum) EnumDescriptor() ([]byte, []int)
func (SlidingWindowsPayload_Enum) String ¶
func (x SlidingWindowsPayload_Enum) String() string
type StandardCoders ¶
type StandardCoders struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StandardCoders) Descriptor ¶
func (*StandardCoders) Descriptor() ([]byte, []int)
func (*StandardCoders) ProtoMessage ¶
func (*StandardCoders) ProtoMessage()
func (*StandardCoders) Reset ¶
func (m *StandardCoders) Reset()
func (*StandardCoders) String ¶
func (m *StandardCoders) String() string
func (*StandardCoders) XXX_DiscardUnknown ¶
func (m *StandardCoders) XXX_DiscardUnknown()
func (*StandardCoders) XXX_Marshal ¶
func (m *StandardCoders) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StandardCoders) XXX_Merge ¶
func (dst *StandardCoders) XXX_Merge(src proto.Message)
func (*StandardCoders) XXX_Size ¶
func (m *StandardCoders) XXX_Size() int
func (*StandardCoders) XXX_Unmarshal ¶
func (m *StandardCoders) XXX_Unmarshal(b []byte) error
type StandardCoders_Enum ¶
type StandardCoders_Enum int32
const ( // Components: None StandardCoders_BYTES StandardCoders_Enum = 0 // Components: The key and value coder, in that order. StandardCoders_KV StandardCoders_Enum = 1 // Components: None StandardCoders_VARINT StandardCoders_Enum = 2 // Encodes an iterable of elements. // Components: Coder for a single element. StandardCoders_ITERABLE StandardCoders_Enum = 3 // Components: None StandardCoders_TIMESTAMP StandardCoders_Enum = 4 // Components: None StandardCoders_INTERVAL_WINDOW StandardCoders_Enum = 5 // Components: The coder to attach a length prefix to StandardCoders_LENGTH_PREFIX StandardCoders_Enum = 6 // Components: None StandardCoders_GLOBAL_WINDOW StandardCoders_Enum = 7 // Encodes an element, the window the value is in, the timestamp of the element, and the pane // of the element // Components: The element coder and the window coder, in that order StandardCoders_WINDOWED_VALUE StandardCoders_Enum = 8 )
func (StandardCoders_Enum) EnumDescriptor ¶
func (StandardCoders_Enum) EnumDescriptor() ([]byte, []int)
func (StandardCoders_Enum) String ¶
func (x StandardCoders_Enum) String() string
type StandardPTransforms ¶
type StandardPTransforms struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StandardPTransforms) Descriptor ¶
func (*StandardPTransforms) Descriptor() ([]byte, []int)
func (*StandardPTransforms) ProtoMessage ¶
func (*StandardPTransforms) ProtoMessage()
func (*StandardPTransforms) Reset ¶
func (m *StandardPTransforms) Reset()
func (*StandardPTransforms) String ¶
func (m *StandardPTransforms) String() string
func (*StandardPTransforms) XXX_DiscardUnknown ¶
func (m *StandardPTransforms) XXX_DiscardUnknown()
func (*StandardPTransforms) XXX_Marshal ¶
func (m *StandardPTransforms) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StandardPTransforms) XXX_Merge ¶
func (dst *StandardPTransforms) XXX_Merge(src proto.Message)
func (*StandardPTransforms) XXX_Size ¶
func (m *StandardPTransforms) XXX_Size() int
func (*StandardPTransforms) XXX_Unmarshal ¶
func (m *StandardPTransforms) XXX_Unmarshal(b []byte) error
type StandardPTransforms_CombineComponents ¶
type StandardPTransforms_CombineComponents int32
Payload for all of these: CombinePayload
const ( StandardPTransforms_COMBINE_PGBKCV StandardPTransforms_CombineComponents = 0 StandardPTransforms_COMBINE_MERGE_ACCUMULATORS StandardPTransforms_CombineComponents = 1 StandardPTransforms_COMBINE_EXTRACT_OUTPUTS StandardPTransforms_CombineComponents = 2 // Represents the Pre-Combine part of a lifted Combine Per Key, as described // in the following document: // https://s.apache.org/beam-runner-api-combine-model#heading=h.ta0g6ase8z07 StandardPTransforms_COMBINE_PER_KEY_PRECOMBINE StandardPTransforms_CombineComponents = 3 // Represents the Merge Accumulators part of a lifted Combine Per Key, as // described in the following document: // https://s.apache.org/beam-runner-api-combine-model#heading=h.jco9rvatld5m StandardPTransforms_COMBINE_PER_KEY_MERGE_ACCUMULATORS StandardPTransforms_CombineComponents = 4 // Represents the Extract Outputs part of a lifted Combine Per Key, as // described in the following document: // https://s.apache.org/beam-runner-api-combine-model#heading=h.i9i6p8gtl6ku StandardPTransforms_COMBINE_PER_KEY_EXTRACT_OUTPUTS StandardPTransforms_CombineComponents = 5 )
func (StandardPTransforms_CombineComponents) EnumDescriptor ¶
func (StandardPTransforms_CombineComponents) EnumDescriptor() ([]byte, []int)
func (StandardPTransforms_CombineComponents) String ¶
func (x StandardPTransforms_CombineComponents) String() string
type StandardPTransforms_Composites ¶
type StandardPTransforms_Composites int32
const ( // Represents the Combine.perKey() operation. // If this is produced by an SDK, it is assumed that the SDK understands // each of CombineComponents. // Payload: CombinePayload StandardPTransforms_COMBINE_PER_KEY StandardPTransforms_Composites = 0 // Represents the Combine.globally() operation. // If this is produced by an SDK, it is assumed that the SDK understands // each of CombineComponents. // Payload: CombinePayload StandardPTransforms_COMBINE_GLOBALLY StandardPTransforms_Composites = 1 // Represents the Combine.groupedValues() operation. // If this is produced by an SDK, it is assumed that the SDK understands // each of CombineComponents. // Payload: CombinePayload StandardPTransforms_COMBINE_GROUPED_VALUES StandardPTransforms_Composites = 2 // Represents the Reshuffle operation. StandardPTransforms_RESHUFFLE StandardPTransforms_Composites = 3 // Less well-known. Payload: WriteFilesPayload. StandardPTransforms_WRITE_FILES StandardPTransforms_Composites = 4 )
func (StandardPTransforms_Composites) EnumDescriptor ¶
func (StandardPTransforms_Composites) EnumDescriptor() ([]byte, []int)
func (StandardPTransforms_Composites) String ¶
func (x StandardPTransforms_Composites) String() string
type StandardPTransforms_DeprecatedPrimitives ¶
type StandardPTransforms_DeprecatedPrimitives int32
const ( // Represents the operation to read a Bounded or Unbounded source. // Payload: ReadPayload. StandardPTransforms_READ StandardPTransforms_DeprecatedPrimitives = 0 // Runners should move away from translating `CreatePCollectionView` and treat this as // part of the translation for a `ParDo` side input. StandardPTransforms_CREATE_VIEW StandardPTransforms_DeprecatedPrimitives = 1 )
func (StandardPTransforms_DeprecatedPrimitives) EnumDescriptor ¶
func (StandardPTransforms_DeprecatedPrimitives) EnumDescriptor() ([]byte, []int)
func (StandardPTransforms_DeprecatedPrimitives) String ¶
func (x StandardPTransforms_DeprecatedPrimitives) String() string
type StandardPTransforms_Primitives ¶
type StandardPTransforms_Primitives int32
const ( // Represents Beam's parallel do operation. // Payload: ParDoPayload. // TODO(BEAM-3595): Change this to beam:transform:pardo:v1. StandardPTransforms_PAR_DO StandardPTransforms_Primitives = 0 // Represents Beam's flatten operation. // Payload: None. StandardPTransforms_FLATTEN StandardPTransforms_Primitives = 1 // Represents Beam's group-by-key operation. // Payload: None StandardPTransforms_GROUP_BY_KEY StandardPTransforms_Primitives = 2 // Represents the operation generating a single empty element. StandardPTransforms_IMPULSE StandardPTransforms_Primitives = 3 // Represents the Window.into() operation. // Payload: WindowIntoPayload. StandardPTransforms_ASSIGN_WINDOWS StandardPTransforms_Primitives = 4 // Represents the TestStream. // Payload: TestStreamPayload StandardPTransforms_TEST_STREAM StandardPTransforms_Primitives = 5 // Represents mapping of main input window into side input window. // Payload: serialized WindowMappingFn. StandardPTransforms_MAP_WINDOWS StandardPTransforms_Primitives = 6 )
func (StandardPTransforms_Primitives) EnumDescriptor ¶
func (StandardPTransforms_Primitives) EnumDescriptor() ([]byte, []int)
func (StandardPTransforms_Primitives) String ¶
func (x StandardPTransforms_Primitives) String() string
type StandardPTransforms_SplittableParDoComponents ¶
type StandardPTransforms_SplittableParDoComponents int32
Payload for all of these: ParDoPayload containing the user's SDF
const ( StandardPTransforms_PAIR_WITH_RESTRICTION StandardPTransforms_SplittableParDoComponents = 0 StandardPTransforms_SPLIT_RESTRICTION StandardPTransforms_SplittableParDoComponents = 1 StandardPTransforms_PROCESS_KEYED_ELEMENTS StandardPTransforms_SplittableParDoComponents = 2 )
func (StandardPTransforms_SplittableParDoComponents) EnumDescriptor ¶
func (StandardPTransforms_SplittableParDoComponents) EnumDescriptor() ([]byte, []int)
func (StandardPTransforms_SplittableParDoComponents) String ¶
func (x StandardPTransforms_SplittableParDoComponents) String() string
type StandardSideInputTypes ¶
type StandardSideInputTypes struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StandardSideInputTypes) Descriptor ¶
func (*StandardSideInputTypes) Descriptor() ([]byte, []int)
func (*StandardSideInputTypes) ProtoMessage ¶
func (*StandardSideInputTypes) ProtoMessage()
func (*StandardSideInputTypes) Reset ¶
func (m *StandardSideInputTypes) Reset()
func (*StandardSideInputTypes) String ¶
func (m *StandardSideInputTypes) String() string
func (*StandardSideInputTypes) XXX_DiscardUnknown ¶
func (m *StandardSideInputTypes) XXX_DiscardUnknown()
func (*StandardSideInputTypes) XXX_Marshal ¶
func (m *StandardSideInputTypes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StandardSideInputTypes) XXX_Merge ¶
func (dst *StandardSideInputTypes) XXX_Merge(src proto.Message)
func (*StandardSideInputTypes) XXX_Size ¶
func (m *StandardSideInputTypes) XXX_Size() int
func (*StandardSideInputTypes) XXX_Unmarshal ¶
func (m *StandardSideInputTypes) XXX_Unmarshal(b []byte) error
type StandardSideInputTypes_Enum ¶
type StandardSideInputTypes_Enum int32
const ( StandardSideInputTypes_ITERABLE StandardSideInputTypes_Enum = 0 StandardSideInputTypes_MULTIMAP StandardSideInputTypes_Enum = 1 )
func (StandardSideInputTypes_Enum) EnumDescriptor ¶
func (StandardSideInputTypes_Enum) EnumDescriptor() ([]byte, []int)
func (StandardSideInputTypes_Enum) String ¶
func (x StandardSideInputTypes_Enum) String() string
type StateSpec ¶
type StateSpec struct { // Types that are valid to be assigned to Spec: // *StateSpec_ValueSpec // *StateSpec_BagSpec // *StateSpec_CombiningSpec // *StateSpec_MapSpec // *StateSpec_SetSpec Spec isStateSpec_Spec `protobuf_oneof:"spec"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StateSpec) Descriptor ¶
func (*StateSpec) GetBagSpec ¶
func (m *StateSpec) GetBagSpec() *BagStateSpec
func (*StateSpec) GetCombiningSpec ¶
func (m *StateSpec) GetCombiningSpec() *CombiningStateSpec
func (*StateSpec) GetMapSpec ¶
func (m *StateSpec) GetMapSpec() *MapStateSpec
func (*StateSpec) GetSetSpec ¶
func (m *StateSpec) GetSetSpec() *SetStateSpec
func (*StateSpec) GetValueSpec ¶
func (m *StateSpec) GetValueSpec() *ValueStateSpec
func (*StateSpec) ProtoMessage ¶
func (*StateSpec) ProtoMessage()
func (*StateSpec) XXX_DiscardUnknown ¶
func (m *StateSpec) XXX_DiscardUnknown()
func (*StateSpec) XXX_Marshal ¶
func (*StateSpec) XXX_OneofFuncs ¶
func (*StateSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*StateSpec) XXX_Unmarshal ¶
type StateSpec_BagSpec ¶
type StateSpec_BagSpec struct {
BagSpec *BagStateSpec `protobuf:"bytes,2,opt,name=bag_spec,json=bagSpec,oneof"`
}
type StateSpec_CombiningSpec ¶
type StateSpec_CombiningSpec struct {
CombiningSpec *CombiningStateSpec `protobuf:"bytes,3,opt,name=combining_spec,json=combiningSpec,oneof"`
}
type StateSpec_MapSpec ¶
type StateSpec_MapSpec struct {
MapSpec *MapStateSpec `protobuf:"bytes,4,opt,name=map_spec,json=mapSpec,oneof"`
}
type StateSpec_SetSpec ¶
type StateSpec_SetSpec struct {
SetSpec *SetStateSpec `protobuf:"bytes,5,opt,name=set_spec,json=setSpec,oneof"`
}
type StateSpec_ValueSpec ¶
type StateSpec_ValueSpec struct {
ValueSpec *ValueStateSpec `protobuf:"bytes,1,opt,name=value_spec,json=valueSpec,oneof"`
}
type TestStreamPayload ¶
type TestStreamPayload struct { // (Required) the coder for elements in the TestStream events CoderId string `protobuf:"bytes,1,opt,name=coder_id,json=coderId" json:"coder_id,omitempty"` Events []*TestStreamPayload_Event `protobuf:"bytes,2,rep,name=events" json:"events,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The payload for the test-only primitive TestStream
func (*TestStreamPayload) Descriptor ¶
func (*TestStreamPayload) Descriptor() ([]byte, []int)
func (*TestStreamPayload) GetCoderId ¶
func (m *TestStreamPayload) GetCoderId() string
func (*TestStreamPayload) GetEvents ¶
func (m *TestStreamPayload) GetEvents() []*TestStreamPayload_Event
func (*TestStreamPayload) ProtoMessage ¶
func (*TestStreamPayload) ProtoMessage()
func (*TestStreamPayload) Reset ¶
func (m *TestStreamPayload) Reset()
func (*TestStreamPayload) String ¶
func (m *TestStreamPayload) String() string
func (*TestStreamPayload) XXX_DiscardUnknown ¶
func (m *TestStreamPayload) XXX_DiscardUnknown()
func (*TestStreamPayload) XXX_Marshal ¶
func (m *TestStreamPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestStreamPayload) XXX_Merge ¶
func (dst *TestStreamPayload) XXX_Merge(src proto.Message)
func (*TestStreamPayload) XXX_Size ¶
func (m *TestStreamPayload) XXX_Size() int
func (*TestStreamPayload) XXX_Unmarshal ¶
func (m *TestStreamPayload) XXX_Unmarshal(b []byte) error
type TestStreamPayload_Event ¶
type TestStreamPayload_Event struct { // Types that are valid to be assigned to Event: // *TestStreamPayload_Event_WatermarkEvent // *TestStreamPayload_Event_ProcessingTimeEvent // *TestStreamPayload_Event_ElementEvent Event isTestStreamPayload_Event_Event `protobuf_oneof:"event"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestStreamPayload_Event) Descriptor ¶
func (*TestStreamPayload_Event) Descriptor() ([]byte, []int)
func (*TestStreamPayload_Event) GetElementEvent ¶
func (m *TestStreamPayload_Event) GetElementEvent() *TestStreamPayload_Event_AddElements
func (*TestStreamPayload_Event) GetEvent ¶
func (m *TestStreamPayload_Event) GetEvent() isTestStreamPayload_Event_Event
func (*TestStreamPayload_Event) GetProcessingTimeEvent ¶
func (m *TestStreamPayload_Event) GetProcessingTimeEvent() *TestStreamPayload_Event_AdvanceProcessingTime
func (*TestStreamPayload_Event) GetWatermarkEvent ¶
func (m *TestStreamPayload_Event) GetWatermarkEvent() *TestStreamPayload_Event_AdvanceWatermark
func (*TestStreamPayload_Event) ProtoMessage ¶
func (*TestStreamPayload_Event) ProtoMessage()
func (*TestStreamPayload_Event) Reset ¶
func (m *TestStreamPayload_Event) Reset()
func (*TestStreamPayload_Event) String ¶
func (m *TestStreamPayload_Event) String() string
func (*TestStreamPayload_Event) XXX_DiscardUnknown ¶
func (m *TestStreamPayload_Event) XXX_DiscardUnknown()
func (*TestStreamPayload_Event) XXX_Marshal ¶
func (m *TestStreamPayload_Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestStreamPayload_Event) XXX_Merge ¶
func (dst *TestStreamPayload_Event) XXX_Merge(src proto.Message)
func (*TestStreamPayload_Event) XXX_OneofFuncs ¶
func (*TestStreamPayload_Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*TestStreamPayload_Event) XXX_Size ¶
func (m *TestStreamPayload_Event) XXX_Size() int
func (*TestStreamPayload_Event) XXX_Unmarshal ¶
func (m *TestStreamPayload_Event) XXX_Unmarshal(b []byte) error
type TestStreamPayload_Event_AddElements ¶
type TestStreamPayload_Event_AddElements struct { Elements []*TestStreamPayload_TimestampedElement `protobuf:"bytes,1,rep,name=elements" json:"elements,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestStreamPayload_Event_AddElements) Descriptor ¶
func (*TestStreamPayload_Event_AddElements) Descriptor() ([]byte, []int)
func (*TestStreamPayload_Event_AddElements) GetElements ¶
func (m *TestStreamPayload_Event_AddElements) GetElements() []*TestStreamPayload_TimestampedElement
func (*TestStreamPayload_Event_AddElements) ProtoMessage ¶
func (*TestStreamPayload_Event_AddElements) ProtoMessage()
func (*TestStreamPayload_Event_AddElements) Reset ¶
func (m *TestStreamPayload_Event_AddElements) Reset()
func (*TestStreamPayload_Event_AddElements) String ¶
func (m *TestStreamPayload_Event_AddElements) String() string
func (*TestStreamPayload_Event_AddElements) XXX_DiscardUnknown ¶
func (m *TestStreamPayload_Event_AddElements) XXX_DiscardUnknown()
func (*TestStreamPayload_Event_AddElements) XXX_Marshal ¶
func (m *TestStreamPayload_Event_AddElements) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestStreamPayload_Event_AddElements) XXX_Merge ¶
func (dst *TestStreamPayload_Event_AddElements) XXX_Merge(src proto.Message)
func (*TestStreamPayload_Event_AddElements) XXX_Size ¶
func (m *TestStreamPayload_Event_AddElements) XXX_Size() int
func (*TestStreamPayload_Event_AddElements) XXX_Unmarshal ¶
func (m *TestStreamPayload_Event_AddElements) XXX_Unmarshal(b []byte) error
type TestStreamPayload_Event_AdvanceProcessingTime ¶
type TestStreamPayload_Event_AdvanceProcessingTime struct { AdvanceDuration int64 `protobuf:"varint,1,opt,name=advance_duration,json=advanceDuration" json:"advance_duration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestStreamPayload_Event_AdvanceProcessingTime) Descriptor ¶
func (*TestStreamPayload_Event_AdvanceProcessingTime) Descriptor() ([]byte, []int)
func (*TestStreamPayload_Event_AdvanceProcessingTime) GetAdvanceDuration ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) GetAdvanceDuration() int64
func (*TestStreamPayload_Event_AdvanceProcessingTime) ProtoMessage ¶
func (*TestStreamPayload_Event_AdvanceProcessingTime) ProtoMessage()
func (*TestStreamPayload_Event_AdvanceProcessingTime) Reset ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) Reset()
func (*TestStreamPayload_Event_AdvanceProcessingTime) String ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) String() string
func (*TestStreamPayload_Event_AdvanceProcessingTime) XXX_DiscardUnknown ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_DiscardUnknown()
func (*TestStreamPayload_Event_AdvanceProcessingTime) XXX_Marshal ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestStreamPayload_Event_AdvanceProcessingTime) XXX_Merge ¶
func (dst *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Merge(src proto.Message)
func (*TestStreamPayload_Event_AdvanceProcessingTime) XXX_Size ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Size() int
func (*TestStreamPayload_Event_AdvanceProcessingTime) XXX_Unmarshal ¶
func (m *TestStreamPayload_Event_AdvanceProcessingTime) XXX_Unmarshal(b []byte) error
type TestStreamPayload_Event_AdvanceWatermark ¶
type TestStreamPayload_Event_AdvanceWatermark struct { NewWatermark int64 `protobuf:"varint,1,opt,name=new_watermark,json=newWatermark" json:"new_watermark,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestStreamPayload_Event_AdvanceWatermark) Descriptor ¶
func (*TestStreamPayload_Event_AdvanceWatermark) Descriptor() ([]byte, []int)
func (*TestStreamPayload_Event_AdvanceWatermark) GetNewWatermark ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) GetNewWatermark() int64
func (*TestStreamPayload_Event_AdvanceWatermark) ProtoMessage ¶
func (*TestStreamPayload_Event_AdvanceWatermark) ProtoMessage()
func (*TestStreamPayload_Event_AdvanceWatermark) Reset ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) Reset()
func (*TestStreamPayload_Event_AdvanceWatermark) String ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) String() string
func (*TestStreamPayload_Event_AdvanceWatermark) XXX_DiscardUnknown ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_DiscardUnknown()
func (*TestStreamPayload_Event_AdvanceWatermark) XXX_Marshal ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestStreamPayload_Event_AdvanceWatermark) XXX_Merge ¶
func (dst *TestStreamPayload_Event_AdvanceWatermark) XXX_Merge(src proto.Message)
func (*TestStreamPayload_Event_AdvanceWatermark) XXX_Size ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_Size() int
func (*TestStreamPayload_Event_AdvanceWatermark) XXX_Unmarshal ¶
func (m *TestStreamPayload_Event_AdvanceWatermark) XXX_Unmarshal(b []byte) error
type TestStreamPayload_Event_ElementEvent ¶
type TestStreamPayload_Event_ElementEvent struct {
ElementEvent *TestStreamPayload_Event_AddElements `protobuf:"bytes,3,opt,name=element_event,json=elementEvent,oneof"`
}
type TestStreamPayload_Event_ProcessingTimeEvent ¶
type TestStreamPayload_Event_ProcessingTimeEvent struct {
ProcessingTimeEvent *TestStreamPayload_Event_AdvanceProcessingTime `protobuf:"bytes,2,opt,name=processing_time_event,json=processingTimeEvent,oneof"`
}
type TestStreamPayload_Event_WatermarkEvent ¶
type TestStreamPayload_Event_WatermarkEvent struct {
WatermarkEvent *TestStreamPayload_Event_AdvanceWatermark `protobuf:"bytes,1,opt,name=watermark_event,json=watermarkEvent,oneof"`
}
type TestStreamPayload_TimestampedElement ¶
type TestStreamPayload_TimestampedElement struct { EncodedElement []byte `protobuf:"bytes,1,opt,name=encoded_element,json=encodedElement,proto3" json:"encoded_element,omitempty"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TestStreamPayload_TimestampedElement) Descriptor ¶
func (*TestStreamPayload_TimestampedElement) Descriptor() ([]byte, []int)
func (*TestStreamPayload_TimestampedElement) GetEncodedElement ¶
func (m *TestStreamPayload_TimestampedElement) GetEncodedElement() []byte
func (*TestStreamPayload_TimestampedElement) GetTimestamp ¶
func (m *TestStreamPayload_TimestampedElement) GetTimestamp() int64
func (*TestStreamPayload_TimestampedElement) ProtoMessage ¶
func (*TestStreamPayload_TimestampedElement) ProtoMessage()
func (*TestStreamPayload_TimestampedElement) Reset ¶
func (m *TestStreamPayload_TimestampedElement) Reset()
func (*TestStreamPayload_TimestampedElement) String ¶
func (m *TestStreamPayload_TimestampedElement) String() string
func (*TestStreamPayload_TimestampedElement) XXX_DiscardUnknown ¶
func (m *TestStreamPayload_TimestampedElement) XXX_DiscardUnknown()
func (*TestStreamPayload_TimestampedElement) XXX_Marshal ¶
func (m *TestStreamPayload_TimestampedElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TestStreamPayload_TimestampedElement) XXX_Merge ¶
func (dst *TestStreamPayload_TimestampedElement) XXX_Merge(src proto.Message)
func (*TestStreamPayload_TimestampedElement) XXX_Size ¶
func (m *TestStreamPayload_TimestampedElement) XXX_Size() int
func (*TestStreamPayload_TimestampedElement) XXX_Unmarshal ¶
func (m *TestStreamPayload_TimestampedElement) XXX_Unmarshal(b []byte) error
type TimeDomain ¶
type TimeDomain struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The different time domains in the Beam model.
func (*TimeDomain) Descriptor ¶
func (*TimeDomain) Descriptor() ([]byte, []int)
func (*TimeDomain) ProtoMessage ¶
func (*TimeDomain) ProtoMessage()
func (*TimeDomain) Reset ¶
func (m *TimeDomain) Reset()
func (*TimeDomain) String ¶
func (m *TimeDomain) String() string
func (*TimeDomain) XXX_DiscardUnknown ¶
func (m *TimeDomain) XXX_DiscardUnknown()
func (*TimeDomain) XXX_Marshal ¶
func (m *TimeDomain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimeDomain) XXX_Merge ¶
func (dst *TimeDomain) XXX_Merge(src proto.Message)
func (*TimeDomain) XXX_Size ¶
func (m *TimeDomain) XXX_Size() int
func (*TimeDomain) XXX_Unmarshal ¶
func (m *TimeDomain) XXX_Unmarshal(b []byte) error
type TimeDomain_Enum ¶
type TimeDomain_Enum int32
const ( TimeDomain_UNSPECIFIED TimeDomain_Enum = 0 // Event time is time from the perspective of the data TimeDomain_EVENT_TIME TimeDomain_Enum = 1 // Processing time is time from the perspective of the // execution of your pipeline TimeDomain_PROCESSING_TIME TimeDomain_Enum = 2 // Synchronized processing time is the minimum of the // processing time of all pending elements. // // The "processing time" of an element refers to // the local processing time at which it was emitted TimeDomain_SYNCHRONIZED_PROCESSING_TIME TimeDomain_Enum = 3 )