playground/frontend/playground_components/assets/symbols/go.g.yaml (6,641 lines of code) (raw):
"":
methods:
- Accelerator
- AddClasspaths
- AddExtraPackages
- AddFakeImpulses
- AddFixedKey
- AfterAll
- AfterAny
- AfterCount
- AfterEach
- AfterEndOfWindow
- AfterProcessingTime
- AfterSynchronizedProcessingTime
- AllWithinBounds
- AllowedLateness
- Always
- ApplySdkImageOverrides
- ApproximateQuantiles
- ApproximateWeightedQuantiles
- AsCombineFn
- AsDoFn
- Bind
- BoolToBounded
- Bounded
- BucketExists
- BuildTempWorkerBinary
- BuildWorkerBinary
- CallNoPanic
- CheckConcrete
- ClassOf
- CleanupTopic
- CoGBKMainInput
- CoGroupByKey
- CoderFrom
- Combine
- CombinePerKey
- Combiner1
- Combiner2
- Combiner3
- Commit
- CommitOffsetInFinalize
- Compile
- ConnectionInitSQLs
- ConnectionProperties
- ConsumerConfigs
- ContainerImages
- Convert
- ConvertFn
- Copy
- Count
- CountElms
- Create
- Create2
- CreateBucket
- CreateDisposition
- CreateEnvironment
- CreateList
- CreateList2
- CreateWithEndpoint
- CrossLanguage
- CrossLanguagePayload
- Debug
- Debugf
- Debugln
- Decode
- DecodeBase64
- DecodeBool
- DecodeByte
- DecodeBytes
- DecodeCoder
- DecodeCoderRef
- DecodeCoderRefs
- DecodeDouble
- DecodeEventTime
- DecodeFn
- DecodeInt32
- DecodeMultiEdge
- DecodePane
- DecodeSinglePrecisionFloat
- DecodeStringUTF8
- DecodeStructPayload
- DecodeType
- DecodeUint32
- DecodeUint64
- DecodeVarInt
- DecodeVarUint64
- DecodeWindowedValueHeader
- DecoderForSlice
- Default
- DefaultDial
- DefaultRunner
- DefaultSourceConfig
- DefaultStepConfig
- DefaultWindowingStrategy
- Deidentify
- DeserializeHooksFromOptions
- Dialect
- Diff
- DisableHook
- Discard
- Distinct
- DoFn0x0
- DoFn0x1
- DoFn0x2
- DoFn0x3
- DoFn0x4
- DoFn0x5
- DoFn10x0
- DoFn10x1
- DoFn10x2
- DoFn10x3
- DoFn10x4
- DoFn10x5
- DoFn1x0
- DoFn1x1
- DoFn1x2
- DoFn1x3
- DoFn1x4
- DoFn1x5
- DoFn2x0
- DoFn2x1
- DoFn2x2
- DoFn2x3
- DoFn2x4
- DoFn2x5
- DoFn3x0
- DoFn3x1
- DoFn3x2
- DoFn3x3
- DoFn3x4
- DoFn3x5
- DoFn4x0
- DoFn4x1
- DoFn4x2
- DoFn4x3
- DoFn4x4
- DoFn4x5
- DoFn5x0
- DoFn5x1
- DoFn5x2
- DoFn5x3
- DoFn5x4
- DoFn5x5
- DoFn6x0
- DoFn6x1
- DoFn6x2
- DoFn6x3
- DoFn6x4
- DoFn6x5
- DoFn7x0
- DoFn7x1
- DoFn7x2
- DoFn7x3
- DoFn7x4
- DoFn7x5
- DoFn8x0
- DoFn8x1
- DoFn8x2
- DoFn8x3
- DoFn8x4
- DoFn8x5
- DoFn9x0
- DoFn9x1
- DoFn9x2
- DoFn9x3
- DoFn9x4
- DoFn9x5
- DontUseFlagAsPipelineOption
- DropKey
- DropValue
- DumpToLog
- DumpToLogFromStore
- DumpToOutFromContext
- DumpToOutFromStore
- Emitter1
- Emitter2
- Emitter3
- Empty
- EnableCaptureHook
- EnableHeapCaptureHook
- EnableHook
- EnableProfCaptureHook
- EnableTraceCaptureHook
- Encode
- EncodeBase64
- EncodeBool
- EncodeByte
- EncodeBytes
- EncodeCoder
- EncodeCoderRef
- EncodeCoderRefs
- EncodeDouble
- EncodeElement
- EncodeEventTime
- EncodeFn
- EncodeInt32
- EncodeMultiEdge
- EncodePane
- EncodePayload
- EncodeSinglePrecisionFloat
- EncodeStringUTF8
- EncodeStructPayload
- EncodeType
- EncodeUint32
- EncodeUint64
- EncodeVarInt
- EncodeVarUint64
- EncodeWindow
- EncodeWindowedValueHeader
- EncoderForSlice
- EnsureSubscription
- EnsureTopic
- Equals
- EqualsFloat
- EqualsList
- Error
- Errorf
- Errorln
- Evaluate
- Exclude
- Execute
- ExecuteBundles
- ExecuteEnv
- ExecutionMsecUrn
- Exit
- Exitf
- Exitln
- Expand
- ExpandedComponents
- ExpandedTransform
- ExpansionAddr
- ExpansionAddrRead
- ExpansionAddrWrite
- Explode
- External
- ExternalInputs
- ExternalOutputs
- ExternalTagged
- "False"
- Fatal
- Fatalf
- Fatalln
- FetchSize
- FieldIndexByTag
- File
- Flatten
- FreeDiskSpace
- FromDuration
- FromMetricUpdates
- FromMilliseconds
- FromMonitoringInfos
- FromQuery
- FromTable
- FromTime
- FromType
- FuncName
- Function0x0
- Function0x1
- Function0x2
- Function0x3
- Function0x4
- Function0x5
- Function10x0
- Function10x1
- Function10x2
- Function10x3
- Function10x4
- Function10x5
- Function1x0
- Function1x1
- Function1x2
- Function1x3
- Function1x4
- Function1x5
- Function2x0
- Function2x1
- Function2x2
- Function2x3
- Function2x4
- Function2x5
- Function3x0
- Function3x1
- Function3x2
- Function3x3
- Function3x4
- Function3x5
- Function4x0
- Function4x1
- Function4x2
- Function4x3
- Function4x4
- Function4x5
- Function5x0
- Function5x1
- Function5x2
- Function5x3
- Function5x4
- Function5x5
- Function6x0
- Function6x1
- Function6x2
- Function6x3
- Function6x4
- Function6x5
- Function7x0
- Function7x1
- Function7x2
- Function7x3
- Function7x4
- Function7x5
- Function8x0
- Function8x1
- Function8x2
- Function8x3
- Function8x4
- Function8x5
- Function9x0
- Function9x1
- Function9x2
- Function9x3
- Function9x4
- Function9x5
- FunctionName
- FunctionReg
- GetBeamJar
- GetDefaultRepositoryURL
- GetEndpoint
- GetEnvironmentConfig
- GetEnvironmentUrn
- GetExperiments
- GetJobName
- GetMetrics
- GetPipelineResourceHints
- GetProject
- GetProjectFromFlagOrEnvironment
- GetRegion
- GetRunningJobByName
- GetSdkImageOverrides
- GetStore
- GroupByKey
- Hash
- Head
- HeapDumpFrequency
- IDs
- Immediate
- Import
- Impulse
- ImpulseValue
- InboundTagToNode
- Include
- InferFieldNames
- Info
- Infof
- Infoln
- Init
- Initialize
- Initialized
- Input
- Int64Counter
- Int64Distribution
- Int64Latest
- Interface
- Invoke
- InvokeWithoutEventTime
- IsBound
- IsCoGBK
- IsComplex
- IsComposite
- IsConcrete
- IsContainer
- IsEmit
- IsEmitWithEventTime
- IsEmitterRegistered
- IsEnabled
- IsEqual
- IsEqualList
- IsFieldNil
- IsFloat
- IsInputRegistered
- IsInteger
- IsIter
- IsKV
- IsLifecycleMethod
- IsList
- IsLoopback
- IsMalformedEmit
- IsMalformedIter
- IsMalformedMultiMap
- IsMalformedReIter
- IsMultiMap
- IsNullable
- IsNumber
- IsReIter
- IsStructurallyAssignable
- IsUniversal
- IsW
- IsWorkerCompatibleBinary
- Iter1
- Iter2
- JSONToProto
- Join
- KvEmitFn
- KvFn
- Largest
- LargestPerKey
- LegacyMultiRetrieve
- LoadFunction
- LookupCustomCoder
- LookupType
- Main
- MainCalled
- MainRet
- MainRetWithDefault
- MainWithDefault
- MakeBagState
- MakeCombiningState
- MakeElementDecoder
- MakeElementEncoder
- MakeFunc
- MakeFunc0x0
- MakeFunc0x1
- MakeFunc0x2
- MakeFunc0x3
- MakeFunc0x4
- MakeFunc1x0
- MakeFunc1x1
- MakeFunc1x2
- MakeFunc1x3
- MakeFunc1x4
- MakeFunc2x0
- MakeFunc2x1
- MakeFunc2x2
- MakeFunc2x3
- MakeFunc2x4
- MakeFunc3x0
- MakeFunc3x1
- MakeFunc3x2
- MakeFunc3x3
- MakeFunc3x4
- MakeFunc4x0
- MakeFunc4x1
- MakeFunc4x2
- MakeFunc4x3
- MakeFunc4x4
- MakeFunc5x0
- MakeFunc5x1
- MakeFunc5x2
- MakeFunc5x3
- MakeFunc5x4
- MakeFunc6x0
- MakeFunc6x1
- MakeFunc6x2
- MakeFunc6x3
- MakeFunc6x4
- MakeFunc7x0
- MakeFunc7x1
- MakeFunc7x2
- MakeFunc7x3
- MakeFunc7x4
- MakeFunc8x0
- MakeFunc8x1
- MakeFunc8x2
- MakeFunc8x3
- MakeFunc8x4
- MakeGBKUnionCoder
- MakeJar
- MakeKVUnionCoder
- MakeMapState
- MakeObject
- MakePredicate
- MakeQualifiedSubscriptionName
- MakeQualifiedTopicName
- MakeSetState
- MakeSlice
- MakeValueState
- MakeWindowDecoder
- MakeWindowEncoder
- Marshal
- MarshalCoders
- MarshalTo
- MarshalWindowingStrategy
- Materialize
- Max
- MaxNumRecords
- MaxPerKey
- MaxReadSecs
- MaxRecord
- Mean
- MeanPerKey
- MergeCounters
- MergeDistributions
- MergeGauges
- MergeMsecs
- MergePCols
- Min
- MinPerKey
- MinRAMBytes
- MultiFinishBundle
- MultiRetrieve
- MultiStage
- MultiStartBundle
- Must
- MustEncode
- MustEncodeBase64
- MustEncodePayload
- MustExtractFilePayload
- MustN
- MustSatisfy
- MustTaggedN
- Name
- NameType
- NamedInboundLinks
- NamedOutboundLinks
- Never
- New
- NewArtifactRetrievalServiceClient
- NewArtifactStagingServiceClient
- NewBeamFnControlClient
- NewBeamFnDataClient
- NewBeamFnExternalWorkerPoolClient
- NewBeamFnLoggingClient
- NewBeamFnStateClient
- NewBeamFnWorkerStatusClient
- NewBool
- NewBytes
- NewClient
- NewCoGBK
- NewCoder
- NewCoderMarshaller
- NewCoderUnmarshaller
- NewCombine
- NewCombineFn
- NewConfig
- NewCounter
- NewCrossLanguage
- NewCustomCoder
- NewDistribution
- NewDoFn
- NewDouble
- NewElementDecoder
- NewElementEncoder
- NewExpansionServiceClient
- NewExpansionServiceRunner
- NewExternal
- NewExternalTransform
- NewExtractor
- NewFixedWindows
- NewFlatten
- NewFloat
- NewFn
- NewGauge
- NewGlobalWindow
- NewGlobalWindows
- NewGrowableTracker
- NewHints
- NewI
- NewImpulse
- NewIntervalWindow
- NewIntervalWindowCoder
- NewJobServiceClient
- NewKV
- NewLegacyArtifactRetrievalServiceClient
- NewLegacyArtifactStagingServiceClient
- NewLockRTracker
- NewMutation
- NewN
- NewNamespaceGenerator
- NewOptions
- NewPI
- NewPTransformState
- NewPW
- NewPane
- NewParDo
- NewPipeline
- NewPipelineWithRoot
- NewPlan
- NewProvisionServiceClient
- NewPyExpansionServiceRunner
- NewQualifiedTableName
- NewR
- NewRegistry
- NewReshuffle
- NewResults
- NewRetrievalServer
- NewSampler
- NewScopeTree
- NewScopedDataManager
- NewScopedStateReader
- NewScopedStateReaderWithCache
- NewSessions
- NewSideInputAdapter
- NewSlidingWindows
- NewStagingServer
- NewString
- NewT
- NewTaggedExternal
- NewTestStreamServiceClient
- NewTracker
- NewUnauthenticatedClient
- NewUserStateAdapter
- NewVarInt
- NewVarIntZ
- NewVarUintZ
- NewW
- NewWindowInto
- NewWrappedTracker
- NoFiringPane
- NodeTypes
- NonEmpty
- Normalize
- Now
- NullableDecoder
- NullableEncoder
- NumMainInputs
- OptionsToProto
- OrFinally
- OutboundTagToNode
- Output
- OutputParallelization
- OutputType
- PCollectionLabels
- PTransformLabels
- PackBase64Proto
- PackBytes
- PackProto
- PanesAccumulate
- PanesDiscard
- ParDo
- ParDo0
- ParDo2
- ParDo3
- ParDo4
- ParDo5
- ParDo6
- ParDo7
- ParDoN
- ParseMinRAM
- ParseObject
- Partition
- Performant
- PhysicalMemorySize
- Prepare
- Print
- PrintJob
- Printf
- ProducerConfigs
- ProtoToJSON
- ProtoToOptions
- Publish
- Query
- QueryAutomatedExpansionService
- QueryExpansionService
- QueryPythonExpansionService
- Read
- ReadAll
- ReadAllSdf
- ReadClasspaths
- ReadConnectionInitSQLs
- ReadConnectionProperties
- ReadExpansionAddr
- ReadFromPostgres
- ReadN
- ReadNBufUnsafe
- ReadObject
- ReadProxyManifest
- ReadQuery
- ReadRowHeader
- ReadSdf
- ReadSimpleRowHeader
- ReadUnsafe
- ReadWorkerID
- Register
- RegisterArtifactRetrievalServiceServer
- RegisterArtifactStagingServiceServer
- RegisterBeamFnControlServer
- RegisterBeamFnDataServer
- RegisterBeamFnExternalWorkerPoolServer
- RegisterBeamFnLoggingServer
- RegisterBeamFnStateServer
- RegisterBeamFnWorkerStatusServer
- RegisterCaptureHook
- RegisterCoder
- RegisterDoFn
- RegisterEmitter
- RegisterExpansionServiceServer
- RegisterFunc
- RegisterFunction
- RegisterHandler
- RegisterHeapCaptureHook
- RegisterHook
- RegisterInit
- RegisterInput
- RegisterJobServiceServer
- RegisterLegacyArtifactRetrievalServiceServer
- RegisterLegacyArtifactStagingServiceServer
- RegisterLogicalType
- RegisterLogicalTypeProvider
- RegisterOverrideForUrn
- RegisterProfCaptureHook
- RegisterProvisionServiceServer
- RegisterRunner
- RegisterSchemaProvider
- RegisterSchemaProviderWithURN
- RegisterSchemaProviders
- RegisterStructWrapper
- RegisterTestStreamServiceServer
- RegisterTraceCaptureHook
- RegisterType
- Registered
- RemoveFakeImpulses
- Rename
- Render
- Repeat
- Replace
- Require
- RequireAllFieldsExported
- Reshuffle
- ResolveArtifacts
- ResolveArtifactsWithConfig
- ResolveFunction
- ResolveOutputIsBounded
- ResolveXLangArtifacts
- ResultsExtractor
- ResumeProcessingIn
- Retrieve
- RowDecoderForStruct
- RowEncoderForStruct
- Run
- RunAndValidate
- RunInitHooks
- RunRequestHooks
- RunResponseHooks
- RunWithMetrics
- SampleForHeapProfile
- SampleInterval
- Satisfy
- Search
- Seq
- SerializeHooksToOptions
- SetBundleID
- SetDefaultRepositoryURL
- SetLogger
- SetPTransformID
- SetProcessMemoryCeiling
- SetTopLevelMsg
- SetTopLevelMsgf
- SetUpPythonEnvironment
- ShallowClone
- ShallowClonePTransform
- ShimNeeded
- SideInputCacheCapacity
- SkipK
- SkipPtr
- SkipW
- SklearnModel
- Smallest
- SmallestPerKey
- Source
- SourceSingle
- Stage
- StageDir
- StageFile
- StageModel
- StageViaLegacyAPI
- StageViaPortableAPI
- StartLoopback
- StartReadTimestamp
- Step
- StopProcessing
- SubParams
- SubReturns
- Submit
- Substitute
- Sum
- SumPerKey
- SwapKV
- TimestampPolicy
- ToFunc0x0
- ToFunc0x1
- ToFunc0x2
- ToFunc0x3
- ToFunc0x4
- ToFunc1x0
- ToFunc1x1
- ToFunc1x2
- ToFunc1x3
- ToFunc1x4
- ToFunc2x0
- ToFunc2x1
- ToFunc2x2
- ToFunc2x3
- ToFunc2x4
- ToFunc3x0
- ToFunc3x1
- ToFunc3x2
- ToFunc3x3
- ToFunc3x4
- ToFunc4x0
- ToFunc4x1
- ToFunc4x2
- ToFunc4x3
- ToFunc4x4
- ToFunc5x0
- ToFunc5x1
- ToFunc5x2
- ToFunc5x3
- ToFunc5x4
- ToFunc6x0
- ToFunc6x1
- ToFunc6x2
- ToFunc6x3
- ToFunc6x4
- ToFunc7x0
- ToFunc7x1
- ToFunc7x2
- ToFunc7x3
- ToFunc7x4
- ToFunc8x0
- ToFunc8x1
- ToFunc8x2
- ToFunc8x3
- ToFunc8x4
- ToLogicalType
- ToType
- TopologicalSort
- Transform
- Translate
- Trigger
- TrimCoders
- "True"
- TryCoGroupByKey
- TryCombine
- TryCombinePerKey
- TryCreate
- TryCreateList
- TryCrossLanguage
- TryEqualsFloat
- TryExternal
- TryExternalTagged
- TryFlatten
- TryGroupByKey
- TryParDo
- TryReshuffle
- TryWindowInto
- TypeKey
- TypeReg
- Types
- UnderlyingType
- UnfoldEmit
- UnfoldIter
- UnfoldMultiMap
- UnfoldReIter
- Unmarshal
- UnmarshalCoders
- UnmarshalFrom
- UnmarshalPlan
- UnnamedInput
- UnnamedOutput
- UnnamedOutputTag
- Unpack
- UnpackBase64Proto
- UnpackBytes
- UnpackProto
- Update
- UpdateArtifactTypeFromFileToURL
- UpdateDefaultEnvWorkerType
- UpdateGoEnvironmentWorker
- UpdateMap
- Upload
- UploadHeapProfile
- UrnToString
- UrnToType
- UseAutomatedJavaExpansionService
- UseAutomatedPythonExpansionService
- UseBatchSize
- UseStandardSQL
- UserLabels
- UserStateCoderID
- UserStateKeyCoderID
- VFloat64Fn
- VFn
- ValidateKVType
- ValidateNonCompositeType
- ValidateScheme
- ValueOf
- VerifyNamedOutputs
- WaitForCompletion
- Warn
- Warnf
- Warnln
- WindowInto
- WithArgs
- WithContext
- WithContextf
- WithExpansionAddr
- WithExtraPackages
- WithIndexes
- WithQueryLocation
- WithReadBucketAuto
- WithReadBundleSize
- WithReadFilter
- WithWriteBatchSize
- WithWriteOrdered
- Wrap
- WrapIterable
- WrapMethods
- WrapWindowed
- Wrapf
- Write
- WriteBatch
- WriteClasspaths
- WriteConnectionProperties
- WriteExpansionAddr
- WriteObject
- WriteRowHeader
- WriteSimpleRowHeader
- WriteStatement
- WriteToPostgres
- WriteUnsafe
- WriteWithBatchSize
- WriteWorkerID
AccumulationMode:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
AccumulationMode_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
AfterAllTrigger:
methods:
- String
- SubTriggers
AfterAnyTrigger:
methods:
- String
- SubTriggers
AfterCountTrigger:
methods:
- ElementCount
- String
AfterEachTrigger:
methods:
- String
- Subtriggers
AfterEndOfWindowTrigger:
methods:
- Early
- EarlyFiring
- Late
- LateFiring
- String
AfterProcessingTimeTrigger:
methods:
- AlignedTo
- PlusDelay
- String
- TimestampTransforms
AfterSynchronizedProcessingTimeTrigger:
methods:
- String
AlignToTransform:
methods:
- String
properties:
- Period
AlwaysTrigger:
methods:
- String
Annotation:
methods:
- Descriptor
- GetKey
- GetValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- Value
ApiServiceDescriptor:
methods:
- Descriptor
- GetAuthentication
- GetUrl
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Authentication
- Url
ArrayType:
methods:
- Descriptor
- GetElementType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ElementType
ArrayTypeValue:
methods:
- Descriptor
- GetElement
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Element
ArtifactChunk:
methods:
- Descriptor
- GetData
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
ArtifactFilePayload:
methods:
- Descriptor
- GetPath
- GetSha256
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Path
- Sha256
ArtifactInformation:
methods:
- Descriptor
- GetRolePayload
- GetRoleUrn
- GetTypePayload
- GetTypeUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- RolePayload
- RoleUrn
- TypePayload
- TypeUrn
ArtifactMetadata:
methods:
- Descriptor
- GetName
- GetPermissions
- GetSha256
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
- Permissions
- Sha256
ArtifactRequestWrapper:
methods:
- Descriptor
- GetGetArtifact
- GetRequest
- GetResolveArtifact
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Request
ArtifactRequestWrapper_GetArtifact:
properties:
- GetArtifact
ArtifactRequestWrapper_ResolveArtifact:
properties:
- ResolveArtifact
ArtifactResponseWrapper:
methods:
- Descriptor
- GetGetArtifactResponse
- GetIsLast
- GetResolveArtifactResponse
- GetResponse
- GetStagingToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- IsLast
- Response
- StagingToken
ArtifactResponseWrapper_GetArtifactResponse:
properties:
- GetArtifactResponse
ArtifactResponseWrapper_ResolveArtifactResponse:
properties:
- ResolveArtifactResponse
ArtifactRetrievalService_GetArtifactClient:
methods:
- Recv
ArtifactRetrievalService_GetArtifactServer:
methods:
- Send
ArtifactRetrievalServiceClient:
methods:
- GetArtifact
- ResolveArtifacts
ArtifactRetrievalServiceServer:
methods:
- GetArtifact
- ResolveArtifacts
ArtifactStagingService_ReverseArtifactRetrievalServiceClient:
methods:
- Recv
- Send
ArtifactStagingService_ReverseArtifactRetrievalServiceServer:
methods:
- Recv
- Send
ArtifactStagingServiceClient:
methods:
- ReverseArtifactRetrievalService
ArtifactStagingServiceServer:
methods:
- ReverseArtifactRetrievalService
ArtifactStagingToRolePayload:
methods:
- Descriptor
- GetStagedName
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- StagedName
ArtifactUrlPayload:
methods:
- Descriptor
- GetSha256
- GetUrl
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Sha256
- Url
AtomicType:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
AtomicTypeValue:
methods:
- Descriptor
- GetBoolean
- GetByte
- GetBytes
- GetDouble
- GetFloat
- GetInt16
- GetInt32
- GetInt64
- GetString_
- GetValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Value
AtomicTypeValue_Boolean:
properties:
- Boolean
AtomicTypeValue_Byte:
properties:
- Byte
AtomicTypeValue_Bytes:
properties:
- Bytes
AtomicTypeValue_Double:
properties:
- Double
AtomicTypeValue_Float:
properties:
- Float
AtomicTypeValue_Int16:
properties:
- Int16
AtomicTypeValue_Int32:
properties:
- Int32
AtomicTypeValue_Int64:
properties:
- Int64
AtomicTypeValue_String_:
properties:
- String_
AuthenticationSpec:
methods:
- Descriptor
- GetPayload
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Payload
- Urn
Bag:
methods:
- Add
- Clear
- CoderType
- KeyCoderType
- Read
- StateKey
- StateType
properties:
- Key
BagStateSpec:
methods:
- Descriptor
- GetElementCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ElementCoderId
BeamConstants:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
BeamConstants_Constants:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
BeamFnControl_ControlClient:
methods:
- Recv
- Send
BeamFnControl_ControlServer:
methods:
- Recv
- Send
BeamFnControlClient:
methods:
- Control
- GetProcessBundleDescriptor
BeamFnControlServer:
methods:
- Control
- GetProcessBundleDescriptor
BeamFnData_DataClient:
methods:
- Recv
- Send
BeamFnData_DataServer:
methods:
- Recv
- Send
BeamFnDataClient:
methods:
- Data
BeamFnDataServer:
methods:
- Data
BeamFnExternalWorkerPoolClient:
methods:
- StartWorker
- StopWorker
BeamFnExternalWorkerPoolServer:
methods:
- StartWorker
- StopWorker
BeamFnLogging_LoggingClient:
methods:
- Recv
- Send
BeamFnLogging_LoggingServer:
methods:
- Recv
- Send
BeamFnLoggingClient:
methods:
- Logging
BeamFnLoggingServer:
methods:
- Logging
BeamFnState_StateClient:
methods:
- Recv
- Send
BeamFnState_StateServer:
methods:
- Recv
- Send
BeamFnStateClient:
methods:
- State
BeamFnStateServer:
methods:
- State
BeamFnWorkerStatus_WorkerStatusClient:
methods:
- Recv
- Send
BeamFnWorkerStatus_WorkerStatusServer:
methods:
- Recv
- Send
BeamFnWorkerStatusClient:
methods:
- WorkerStatus
BeamFnWorkerStatusServer:
methods:
- WorkerStatus
BoundableRTracker:
methods:
- IsBounded
BoundedQuery:
properties:
- End
- Start
BuilderMethod:
methods:
- Descriptor
- GetName
- GetPayload
- GetSchema
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
- Payload
- Schema
BundleApplication:
methods:
- Descriptor
- GetElement
- GetInputId
- GetIsBounded
- GetOutputWatermarks
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Element
- InputId
- IsBounded
- OutputWatermarks
- TransformId
BundleFinalization:
methods:
- RegisterCallback
BundleState:
methods:
- String
CacheMetrics:
properties:
- Hits
CancelJobRequest:
methods:
- Descriptor
- GetJobId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
CancelJobResponse:
methods:
- Descriptor
- GetState
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- State
Checkpoint:
properties:
- Reapply
- SR
Class:
methods:
- String
ClosingBehavior:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
ClosingBehavior_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
CoGBK:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Edge
- Out
- UID
Coder:
methods:
- Descriptor
- Equals
- GetComponentCoderIds
- GetSpec
- IsValid
- ProtoMessage
- ProtoReflect
- Reset
- String
- Type
properties:
- ComponentCoderIds
- Components
- Custom
- ID
- Kind
- Spec
- T
- Window
CoderMarshaller:
methods:
- Add
- AddMulti
- AddWindowCoder
- Build
properties:
- Namespace
CoderRef:
properties:
- Components
- IsPairLike
- IsStreamLike
- IsWrapper
- PipelineProtoCoderID
- Type
CoderUnmarshaller:
methods:
- Coder
- Coders
- WindowCoder
Combine:
methods:
- Down
- FinishBundle
- GetPID
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Out
- PID
- UID
- UsesKey
CombineFn:
methods:
- AddInputFn
- CompactFn
- CreateAccumulatorFn
- ExtractOutputFn
- MergeAccumulatorsFn
- Name
- SetupFn
- TeardownFn
CombinePayload:
methods:
- Descriptor
- GetAccumulatorCoderId
- GetCombineFn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- AccumulatorCoderId
- CombineFn
Combining:
methods:
- Add
- Clear
- CoderType
- GetCombineFn
- KeyCoderType
- Read
- StateKey
- StateType
properties:
- Key
CombiningPipelineState:
methods:
- GetCombineFn
CombiningStateSpec:
methods:
- Descriptor
- GetAccumulatorCoderId
- GetCombineFn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- AccumulatorCoderId
- CombineFn
CommitManifestRequest:
methods:
- Descriptor
- GetManifest
- GetStagingSessionToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Manifest
- StagingSessionToken
CommitManifestResponse:
methods:
- Descriptor
- GetRetrievalToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- RetrievalToken
CommitManifestResponse_Constants:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Components:
methods:
- Descriptor
- GetCoders
- GetEnvironments
- GetPcollections
- GetTransforms
- GetWindowingStrategies
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Coders
- Environments
- Pcollections
- Transforms
- WindowingStrategies
Config:
methods:
- AddElementList
- AddElements
- AdvanceProcessingTime
- AdvanceProcessingTimeToInfinity
- AdvanceWatermark
- AdvanceWatermarkToInfinity
ContentStructure:
methods:
- String
ConvertToAccumulators:
methods:
- ProcessElement
- String
Copier:
methods:
- Copy
Counter:
methods:
- Dec
- Inc
- String
CounterResult:
methods:
- Name
- Namespace
- Result
- Transform
properties:
- Attempted
- Key
CustomCoder:
methods:
- Descriptor
- Equals
- GetDec
- GetEnc
- GetName
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Dec
- Enc
- ID
- Name
- Type
DataChannel:
methods:
- OpenRead
- OpenWrite
DataChannelManager:
methods:
- Open
DataContext:
properties:
- Data
- State
DataManager:
methods:
- OpenRead
- OpenWrite
DataSink:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Coder
- PCol
- SID
- UID
DataSource:
methods:
- Down
- FinishBundle
- ID
- InitSplittable
- Process
- Progress
- Split
- StartBundle
- String
- Up
properties:
- Coder
- Name
- Out
- PCol
- SID
- UID
Decoder:
methods:
- Decode
DefaultTrigger:
methods:
- String
DeferredArtifactPayload:
methods:
- Descriptor
- GetData
- GetKey
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
- Key
DelayTransform:
methods:
- String
properties:
- Delay
DelayedBundleApplication:
methods:
- Descriptor
- GetApplication
- GetRequestedTimeDelay
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Application
- RequestedTimeDelay
DescribePipelineOptionsRequest:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
DescribePipelineOptionsResponse:
methods:
- Descriptor
- GetOptions
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Options
Discard:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- UID
DiscoverSchemaTransformRequest:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
DiscoverSchemaTransformResponse:
methods:
- Descriptor
- GetError
- GetSchemaTransformConfigs
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Error
- SchemaTransformConfigs
DisplayData:
methods:
- Descriptor
- GetPayload
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Payload
- Urn
Distribution:
methods:
- String
- Update
DistributionResult:
methods:
- Name
- Namespace
- Result
- Transform
properties:
- Attempted
- Key
DistributionValue:
properties:
- Count
DoFn:
methods:
- Annotations
- FinishBundleFn
- IsSplittable
- Name
- PipelineState
- ProcessElementFn
- SetupFn
- StartBundleFn
- TeardownFn
DockerPayload:
methods:
- Descriptor
- GetContainerImage
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ContainerImage
DynFn:
methods:
- Descriptor
- GetData
- GetGen
- GetName
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
- Gen
- Name
- T
- Type
ElementDecoder:
methods:
- Decode
- DecodeTo
ElementEncoder:
methods:
- Encode
ElementProcessor:
methods:
- ProcessElement
Elements:
methods:
- Descriptor
- GetData
- GetTimers
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
- Timers
Elements_Data:
methods:
- Descriptor
- GetData
- GetInstructionId
- GetIsLast
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
- InstructionId
- IsLast
- TransformId
Elements_Timers:
methods:
- Descriptor
- GetInstructionId
- GetIsLast
- GetTimerFamilyId
- GetTimers
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- InstructionId
- IsLast
- TimerFamilyId
- Timers
- TransformId
EmbeddedFilePayload:
methods:
- Descriptor
- GetData
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
Emitter:
properties:
- Key
- Name
- Time
EncodedCoder:
methods:
- MarshalJSON
- UnmarshalJSON
properties:
- Coder
EncodedFunc:
methods:
- MarshalJSON
- UnmarshalJSON
properties:
- Fn
EncodedType:
methods:
- MarshalJSON
- UnmarshalJSON
properties:
- T
Encoder:
methods:
- Encode
Entry:
methods:
- Descriptor
- GetElems
- GetFooter
- GetHeader
- GetInstReq
- GetInstResp
- GetKind
- GetLogEntries
- GetMsg
- GetTimestamp
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Kind
- Msg
- Timestamp
Entry_Elems:
properties:
- Elems
Entry_Footer:
properties:
- Footer
Entry_Header:
properties:
- Header
Entry_InstReq:
properties:
- InstReq
Entry_InstResp:
properties:
- InstResp
Entry_LogEntries:
properties:
- LogEntries
EntryHeader:
methods:
- Descriptor
- GetKind
- GetLen
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Kind
- Len
Environment:
methods:
- Descriptor
- GetCapabilities
- GetDependencies
- GetDisplayData
- GetPayload
- GetResourceHints
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Capabilities
- Dependencies
- DisplayData
- Payload
- ResourceHints
- Urn
Eval:
methods:
- AllExported
- Bytes
- Generate
- Performant
- Print
- Printf
- RequiresRegistrations
- UsesDefaultReflectionShims
EventsRequest:
methods:
- Descriptor
- GetOutputIds
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- OutputIds
ExecutableStagePayload:
methods:
- Descriptor
- GetComponents
- GetEnvironment
- GetInput
- GetOutputs
- GetSideInputs
- GetTimerFamilies
- GetTimers
- GetTransforms
- GetUserStates
- GetWireCoderSettings
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Components
- Environment
- Input
- Outputs
- SideInputs
- TimerFamilies
- Timers
- Transforms
- UserStates
- WireCoderSettings
ExecutableStagePayload_SideInputId:
methods:
- Descriptor
- GetLocalName
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- LocalName
- TransformId
ExecutableStagePayload_TimerFamilyId:
methods:
- Descriptor
- GetLocalName
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- LocalName
- TransformId
ExecutableStagePayload_TimerId:
methods:
- Descriptor
- GetLocalName
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- LocalName
- TransformId
ExecutableStagePayload_UserStateId:
methods:
- Descriptor
- GetLocalName
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- LocalName
- TransformId
ExecutableStagePayload_WireCoderSetting:
methods:
- Descriptor
- GetInputOrOutputId
- GetPayload
- GetTarget
- GetTimer
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Payload
- Target
- Urn
ExecutableStagePayload_WireCoderSetting_InputOrOutputId:
properties:
- InputOrOutputId
ExecutableStagePayload_WireCoderSetting_Timer:
properties:
- Timer
ExecutionState:
methods:
- String
properties:
- IsProcessing
- State
- TotalTime
Expand:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Out
- UID
- ValueDecoders
ExpandedTransform:
properties:
- Components
- Requirements
- Transform
ExpansionMethods:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
ExpansionMethods_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
ExpansionPayload:
properties:
- Dialect
- Query
ExpansionRequest:
methods:
- Descriptor
- GetComponents
- GetNamespace
- GetOutputCoderRequests
- GetTransform
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Components
- Namespace
- OutputCoderRequests
- Transform
ExpansionResponse:
methods:
- Descriptor
- GetComponents
- GetError
- GetRequirements
- GetTransform
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Components
- Error
- Requirements
- Transform
ExpansionServiceClient:
methods:
- DiscoverSchemaTransform
- Expand
ExpansionServiceRunner:
methods:
- Endpoint
- StartService
- StopService
- String
ExpansionServiceServer:
methods:
- DiscoverSchemaTransform
- Expand
ExternalConfigurationPayload:
methods:
- Descriptor
- GetPayload
- GetSchema
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Payload
- Schema
ExternalPayload:
methods:
- Descriptor
- GetEndpoint
- GetParams
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Endpoint
- Params
ExternalTransform:
methods:
- WithNamedInputs
- WithNamedOutputs
properties:
- Expanded
- ExpansionAddr
- InputsMap
- Namespace
- OutputsMap
- Payload
- Urn
ExtractOutput:
methods:
- ProcessElement
- String
Extractor:
methods:
- Bytes
- ExtractFrom
- FromAsts
- Generate
- NameType
- Print
- Printf
- Summary
properties:
- Debug
- DistributionInt64
- GaugeInt64
- Ids
- LegacyIdentifiers
- MsecsInt64
- Package
- SumInt64
Field:
methods:
- Descriptor
- GetDescription
- GetEncodingPosition
- GetId
- GetName
- GetOptions
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Description
- EncodingPosition
- Id
- Name
- Options
- Type
FieldType:
methods:
- Descriptor
- GetArrayType
- GetAtomicType
- GetIterableType
- GetLogicalType
- GetMapType
- GetNullable
- GetRowType
- GetTypeInfo
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Nullable
- TypeInfo
FieldType_ArrayType:
properties:
- ArrayType
FieldType_AtomicType:
properties:
- AtomicType
FieldType_IterableType:
properties:
- IterableType
FieldType_LogicalType:
properties:
- LogicalType
FieldType_MapType:
properties:
- MapType
FieldType_RowType:
properties:
- RowType
FieldValue:
methods:
- Descriptor
- GetArrayValue
- GetAtomicValue
- GetFieldValue
- GetIterableValue
- GetLogicalTypeValue
- GetMapValue
- GetRowValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- FieldValue
FieldValue_ArrayValue:
properties:
- ArrayValue
FieldValue_AtomicValue:
properties:
- AtomicValue
FieldValue_IterableValue:
properties:
- IterableValue
FieldValue_LogicalTypeValue:
properties:
- LogicalTypeValue
FieldValue_MapValue:
properties:
- MapValue
FieldValue_RowValue:
properties:
- RowValue
FinalizeBundleRequest:
methods:
- Descriptor
- GetInstructionId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- InstructionId
FinalizeBundleResponse:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
FixedKey:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Key
- Out
- UID
FixedReStream:
methods:
- Open
properties:
- Buf
FixedStream:
methods:
- Close
- Read
properties:
- Buf
FixedWindowsPayload:
methods:
- Descriptor
- GetOffset
- GetSize
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Offset
- Size
FixedWindowsPayload_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Flatten:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- "N"
- Out
- UID
Fn:
methods:
- BundleFinalization
- Coder
- Context
- Descriptor
- Emits
- Equals
- Error
- EventTime
- GetDynfn
- GetFn
- GetOpt
- GetType
- Inputs
- Name
- OutEventTime
- Pane
- Params
- ProcessContinuation
- ProtoMessage
- ProtoReflect
- RTracker
- Reset
- Returns
- StateProvider
- String
- Type
- WatermarkEstimator
- Window
properties:
- DynFn
- Dynfn
- Fn
- Gap
- Kind
- Opt
- Param
- Period
- Recv
- Ret
- Size
- Type
FnParam:
properties:
- Kind
- T
FnParamKind:
methods:
- String
Footer:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
FullType:
methods:
- Class
- Components
- Descriptor
- GetComponents
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
- Type
properties:
- Components
- Type
FullValue:
methods:
- String
properties:
- Continuation
- Elm
- Elm2
- Pane
- Timestamp
- Windows
Func:
methods:
- Call
- Name
- Type
properties:
- In
- Name
Func0x0:
methods:
- Call0x0
Func0x1:
methods:
- Call0x1
Func0x2:
methods:
- Call0x2
Func0x3:
methods:
- Call0x3
Func0x4:
methods:
- Call0x4
Func1x0:
methods:
- Call1x0
Func1x1:
methods:
- Call1x1
Func1x2:
methods:
- Call1x2
Func1x3:
methods:
- Call1x3
Func1x4:
methods:
- Call1x4
Func2x0:
methods:
- Call2x0
Func2x1:
methods:
- Call2x1
Func2x2:
methods:
- Call2x2
Func2x3:
methods:
- Call2x3
Func2x4:
methods:
- Call2x4
Func3x0:
methods:
- Call3x0
Func3x1:
methods:
- Call3x1
Func3x2:
methods:
- Call3x2
Func3x3:
methods:
- Call3x3
Func3x4:
methods:
- Call3x4
Func4x0:
methods:
- Call4x0
Func4x1:
methods:
- Call4x1
Func4x2:
methods:
- Call4x2
Func4x3:
methods:
- Call4x3
Func4x4:
methods:
- Call4x4
Func5x0:
methods:
- Call5x0
Func5x1:
methods:
- Call5x1
Func5x2:
methods:
- Call5x2
Func5x3:
methods:
- Call5x3
Func5x4:
methods:
- Call5x4
Func6x0:
methods:
- Call6x0
Func6x1:
methods:
- Call6x1
Func6x2:
methods:
- Call6x2
Func6x3:
methods:
- Call6x3
Func6x4:
methods:
- Call6x4
Func7x0:
methods:
- Call7x0
Func7x1:
methods:
- Call7x1
Func7x2:
methods:
- Call7x2
Func7x3:
methods:
- Call7x3
Func7x4:
methods:
- Call7x4
Func8x0:
methods:
- Call8x0
Func8x1:
methods:
- Call8x1
Func8x2:
methods:
- Call8x2
Func8x3:
methods:
- Call8x3
Func8x4:
methods:
- Call8x4
FunctionSpec:
methods:
- Descriptor
- GetPayload
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Payload
- Urn
Gauge:
methods:
- Set
- String
GaugeResult:
methods:
- Name
- Namespace
- Result
- Transform
properties:
- Attempted
- Key
GaugeValue:
properties:
- Timestamp
- Value
GenID:
methods:
- New
GetArtifactRequest:
methods:
- Descriptor
- GetArtifact
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Artifact
GetArtifactResponse:
methods:
- Descriptor
- GetData
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
GetJobMetricsRequest:
methods:
- Descriptor
- GetJobId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
GetJobMetricsResponse:
methods:
- Descriptor
- GetMetrics
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Metrics
GetJobPipelineRequest:
methods:
- Descriptor
- GetJobId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
GetJobPipelineResponse:
methods:
- Descriptor
- GetPipeline
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Pipeline
GetJobStateRequest:
methods:
- Descriptor
- GetJobId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
GetJobsRequest:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
GetJobsResponse:
methods:
- Descriptor
- GetJobInfo
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobInfo
GetManifestRequest:
methods:
- Descriptor
- GetRetrievalToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- RetrievalToken
GetManifestResponse:
methods:
- Descriptor
- GetManifest
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Manifest
GetProcessBundleDescriptorRequest:
methods:
- Descriptor
- GetProcessBundleDescriptorId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ProcessBundleDescriptorId
GetProvisionInfoRequest:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
GetProvisionInfoResponse:
methods:
- Descriptor
- GetInfo
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Info
GlobalWindow:
methods:
- Equals
- MaxTimestamp
- String
GlobalWindowsPayload:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
GlobalWindowsPayload_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Graph:
methods:
- Build
- NewEdge
- NewNode
- NewScope
- Root
- String
GroupIntoBatchesPayload:
methods:
- Descriptor
- GetBatchSize
- GetBatchSizeBytes
- GetMaxBufferingDurationMillis
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- BatchSize
- BatchSizeBytes
- MaxBufferingDurationMillis
GrowableTracker:
methods:
- End
- GetProgress
- IsBounded
- Start
- TrySplit
GuardedError:
methods:
- Error
- TrySetError
HandlerParams:
methods:
- CoderMarshaller
- Inputs
- Outputs
properties:
- Config
- Req
HarnessMonitoringInfosRequest:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
HarnessMonitoringInfosResponse:
methods:
- Descriptor
- GetMonitoringData
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- MonitoringData
Header:
methods:
- Descriptor
- GetMaxMsgLen
- GetSdkVersion
- GetVersion
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- MaxMsgLen
- SdkVersion
- Version
Hint:
methods:
- MergeWithOuter
- Payload
- URN
Hints:
methods:
- Equal
- MergeWithOuter
- Payloads
Hook:
properties:
- Dialer
- Init
- Req
- Resp
Impulse:
methods:
- Down
- FinishBundle
- ID
- Process
- StartBundle
- String
- Up
properties:
- Out
- UID
- Value
Inbound:
methods:
- String
properties:
- From
- Kind
- Type
Inject:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- "N"
- Out
- UID
- ValueEncoder
InjectPayload:
methods:
- Descriptor
- GetN
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- "N"
Input:
properties:
- Key
- Name
- Time
InstructionRequest:
methods:
- Descriptor
- GetFinalizeBundle
- GetHarnessMonitoringInfos
- GetInstructionId
- GetMonitoringInfos
- GetProcessBundle
- GetProcessBundleProgress
- GetProcessBundleSplit
- GetRegister
- GetRequest
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- InstructionId
- Request
InstructionRequest_FinalizeBundle:
properties:
- FinalizeBundle
InstructionRequest_HarnessMonitoringInfos:
properties:
- HarnessMonitoringInfos
InstructionRequest_MonitoringInfos:
properties:
- MonitoringInfos
InstructionRequest_ProcessBundle:
properties:
- ProcessBundle
InstructionRequest_ProcessBundleProgress:
properties:
- ProcessBundleProgress
InstructionRequest_ProcessBundleSplit:
properties:
- ProcessBundleSplit
InstructionRequest_Register:
properties:
- Register
InstructionResponse:
methods:
- Descriptor
- GetError
- GetFinalizeBundle
- GetHarnessMonitoringInfos
- GetInstructionId
- GetMonitoringInfos
- GetProcessBundle
- GetProcessBundleProgress
- GetProcessBundleSplit
- GetRegister
- GetResponse
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Error
- InstructionId
- Response
InstructionResponse_FinalizeBundle:
properties:
- FinalizeBundle
InstructionResponse_HarnessMonitoringInfos:
properties:
- HarnessMonitoringInfos
InstructionResponse_MonitoringInfos:
properties:
- MonitoringInfos
InstructionResponse_ProcessBundle:
properties:
- ProcessBundle
InstructionResponse_ProcessBundleProgress:
properties:
- ProcessBundleProgress
InstructionResponse_ProcessBundleSplit:
properties:
- ProcessBundleSplit
InstructionResponse_Register:
properties:
- Register
Interface:
methods:
- List
- OpenRead
- OpenWrite
- Size
IntervalWindow:
methods:
- Equals
- MaxTimestamp
- String
properties:
- Start
IsBounded:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
IsBounded_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
IterableType:
methods:
- Descriptor
- GetElementType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ElementType
IterableTypeValue:
methods:
- Descriptor
- GetElement
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Element
JavaClassLookupPayload:
methods:
- Descriptor
- GetBuilderMethods
- GetClassName
- GetConstructorMethod
- GetConstructorPayload
- GetConstructorSchema
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- BuilderMethods
- ClassName
- ConstructorMethod
- ConstructorPayload
- ConstructorSchema
JobInfo:
methods:
- Descriptor
- GetJobId
- GetJobName
- GetPipelineOptions
- GetState
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
- JobName
- PipelineOptions
- State
JobMessage:
methods:
- Descriptor
- GetImportance
- GetMessageId
- GetMessageText
- GetTime
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Importance
- MessageId
- MessageText
- Time
JobMessage_MessageImportance:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
JobMessagesRequest:
methods:
- Descriptor
- GetJobId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
JobMessagesResponse:
methods:
- Descriptor
- GetMessageResponse
- GetResponse
- GetStateResponse
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Response
JobMessagesResponse_MessageResponse:
properties:
- MessageResponse
JobMessagesResponse_StateResponse:
properties:
- StateResponse
JobOptions:
properties:
- Algorithm
- ArtifactURLs
- ContainerImage
- DataflowServiceOptions
- DiskSizeGb
- DiskType
- EnableHotKeyLogging
- Experiments
- FlexRSGoal
- KmsKey
- Labels
- MachineType
- MaxNumWorkers
- Name
- Network
- NoUsePublicIPs
- NumWorkers
- Options
- Parallelism
- Project
- Region
- RetainDocker
- ServiceAccountEmail
- Streaming
- Subnetwork
- TeardownPolicy
- TempLocation
- TemplateLocation
- TransformNameMapping
- Update
- Worker
- WorkerHarnessThreads
- WorkerRegion
- WorkerZone
- Zone
JobService_GetMessageStreamClient:
methods:
- Recv
JobService_GetMessageStreamServer:
methods:
- Send
JobService_GetStateStreamClient:
methods:
- Recv
JobService_GetStateStreamServer:
methods:
- Send
JobServiceClient:
methods:
- Cancel
- DescribePipelineOptions
- GetJobMetrics
- GetJobs
- GetMessageStream
- GetPipeline
- GetState
- GetStateStream
- Prepare
- Run
JobServiceServer:
methods:
- Cancel
- DescribePipelineOptions
- GetJobMetrics
- GetJobs
- GetMessageStream
- GetPipeline
- GetState
- GetStateStream
- Prepare
- Run
JobState:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
JobState_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
JobStateEvent:
methods:
- Descriptor
- GetState
- GetTimestamp
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- State
- Timestamp
KV: {}
KeyedFile:
properties:
- Key
Kind:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
LabelledPayload:
methods:
- Descriptor
- GetBoolValue
- GetDoubleValue
- GetIntValue
- GetKey
- GetLabel
- GetNamespace
- GetStringValue
- GetValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- Label
- Namespace
- Value
LabelledPayload_BoolValue:
properties:
- BoolValue
LabelledPayload_DoubleValue:
properties:
- DoubleValue
LabelledPayload_IntValue:
properties:
- IntValue
LabelledPayload_StringValue:
properties:
- StringValue
Labels:
methods:
- Map
- Name
- Namespace
- PCollection
- Transform
LegacyArtifactRetrievalService_GetArtifactClient:
methods:
- Recv
LegacyArtifactRetrievalService_GetArtifactServer:
methods:
- Send
LegacyArtifactRetrievalServiceClient:
methods:
- GetArtifact
- GetManifest
LegacyArtifactRetrievalServiceServer:
methods:
- GetArtifact
- GetManifest
LegacyArtifactStagingService_PutArtifactClient:
methods:
- CloseAndRecv
- Send
LegacyArtifactStagingService_PutArtifactServer:
methods:
- Recv
- SendAndClose
LegacyArtifactStagingServiceClient:
methods:
- CommitManifest
- PutArtifact
LegacyArtifactStagingServiceServer:
methods:
- CommitManifest
- PutArtifact
LegacyGetArtifactRequest:
methods:
- Descriptor
- GetName
- GetRetrievalToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
- RetrievalToken
LiftedCombine:
methods:
- Down
- FinishBundle
- ProcessElement
- StartBundle
- String
- Up
properties:
- KeyCoder
- WindowCoder
LockRTracker:
methods:
- GetError
- GetProgress
- GetRestriction
- IsBounded
- IsDone
- String
- TryClaim
- TrySplit
properties:
- Mu
- Rt
LogControl:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
LogEntry:
methods:
- Descriptor
- GetInstructionId
- GetLogLocation
- GetMessage
- GetSeverity
- GetThread
- GetTimestamp
- GetTrace
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- InstructionId
- LogLocation
- Message
- Severity
- Thread
- Timestamp
- Trace
- TransformId
LogEntry_List:
methods:
- Descriptor
- GetLogEntries
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- LogEntries
LogEntry_Severity:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
LogEntry_Severity_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Logger:
methods:
- Log
LogicalType:
methods:
- ArgumentType
- ArgumentValue
- Descriptor
- GetArgument
- GetArgumentType
- GetPayload
- GetRepresentation
- GetUrn
- GoType
- ID
- ProtoMessage
- ProtoReflect
- Reset
- StorageType
- String
properties:
- Argument
- ArgumentType
- Payload
- Representation
- Urn
LogicalTypeValue:
methods:
- Descriptor
- GetValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Value
LogicalTypes:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
LogicalTypes_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Loopback:
methods:
- EnvironmentConfig
- StartWorker
- Stop
- StopWorker
MainInput:
properties:
- Key
- RTracker
- Values
Manifest:
methods:
- Descriptor
- GetArtifact
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Artifact
ManualWatermarkEstimator:
methods:
- CurrentWatermark
- UpdateWatermark
properties:
- State
Map:
methods:
- Clear
- CoderType
- Get
- KeyCoderType
- Keys
- Put
- Remove
- StateKey
- StateType
properties:
- Key
MapLoader:
methods:
- LoadMap
MapStateSpec:
methods:
- Descriptor
- GetKeyCoderId
- GetValueCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- KeyCoderId
- ValueCoderId
MapType:
methods:
- Descriptor
- GetKeyType
- GetValueType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- KeyType
- ValueType
MapTypeEntry:
methods:
- Descriptor
- GetKey
- GetValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- Value
MapTypeValue:
methods:
- Descriptor
- GetEntries
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Entries
MapWindows:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Out
- UID
MavenPayload:
methods:
- Descriptor
- GetArtifact
- GetRepositoryUrl
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Artifact
- RepositoryUrl
MergeAccumulators:
methods:
- ProcessElement
- String
- Up
MergeStatus:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
MergeStatus_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
MessageWithComponents:
methods:
- Descriptor
- GetCoder
- GetCombinePayload
- GetComponents
- GetFunctionSpec
- GetParDoPayload
- GetPcollection
- GetPtransform
- GetReadPayload
- GetRoot
- GetSideInput
- GetWindowIntoPayload
- GetWindowingStrategy
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Components
- Root
MessageWithComponents_Coder:
properties:
- Coder
MessageWithComponents_CombinePayload:
properties:
- CombinePayload
MessageWithComponents_FunctionSpec:
properties:
- FunctionSpec
MessageWithComponents_ParDoPayload:
properties:
- ParDoPayload
MessageWithComponents_Pcollection:
properties:
- Pcollection
MessageWithComponents_Ptransform:
properties:
- Ptransform
MessageWithComponents_ReadPayload:
properties:
- ReadPayload
MessageWithComponents_SideInput:
properties:
- SideInput
MessageWithComponents_WindowIntoPayload:
properties:
- WindowIntoPayload
MessageWithComponents_WindowingStrategy:
properties:
- WindowingStrategy
MetricResults:
methods:
- Descriptor
- GetAttempted
- GetCommitted
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Attempted
- Committed
MonitoringInfo:
methods:
- Descriptor
- GetLabels
- GetPayload
- GetStartTime
- GetType
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Labels
- Payload
- StartTime
- Type
- Urn
MonitoringInfo_MonitoringInfoLabels:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
MonitoringInfoLabelProps:
methods:
- Descriptor
- GetName
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
MonitoringInfoSpec:
methods:
- Descriptor
- GetAnnotations
- GetRequiredLabels
- GetType
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Annotations
- RequiredLabels
- Type
- Urn
MonitoringInfoSpecs:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
MonitoringInfoSpecs_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
MonitoringInfoTypeUrns:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
MonitoringInfoTypeUrns_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
MonitoringInfosMetadataRequest:
methods:
- Descriptor
- GetMonitoringInfoId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- MonitoringInfoId
MonitoringInfosMetadataResponse:
methods:
- Descriptor
- GetMonitoringInfo
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- MonitoringInfo
MsecResult:
methods:
- Name
- Namespace
- Result
- Transform
properties:
- Attempted
- Key
MsecValue:
properties:
- Start
MultiEdge:
methods:
- Descriptor
- GetFn
- GetInbound
- GetOpcode
- GetOutbound
- GetWindowFn
- ID
- Name
- ProtoMessage
- ProtoReflect
- Reset
- Scope
- String
properties:
- AccumCoder
- CombineFn
- DoFn
- External
- Fn
- Inbound
- Input
- Op
- Opcode
- Outbound
- Output
- Payload
- RestrictionCoder
- StateCoders
- Value
- WindowFn
MultiEdge_Inbound:
methods:
- Descriptor
- GetKind
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Kind
- Type
MultiEdge_Inbound_InputKind:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
MultiEdge_Outbound:
methods:
- Descriptor
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Type
Multiplex:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Out
- UID
Mutation:
methods:
- Set
- WithGroupKey
properties:
- GroupKey
- Ops
- RowKey
NamedEdge:
properties:
- Edge
- Name
NamedScope:
properties:
- Name
- Scope
NeverTrigger:
methods:
- String
Node:
methods:
- Bounded
- ID
- String
- Type
- WindowingStrategy
properties:
- Coder
Nullable: {}
OnTimeBehavior:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
OnTimeBehavior_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Operation:
properties:
- Column
- Family
- Ts
- Value
Option:
methods:
- Descriptor
- GetName
- GetType
- GetValue
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
- Payload
- Type
- Urn
- Value
Options:
methods:
- Add
- Export
- Get
- Import
- LoadOptionsFromFlags
- Set
properties:
- Environment
- PipelineResourceHints
Opts:
properties:
- InternalSharding
- K
- NumQuantiles
OrFinallyTrigger:
methods:
- Finally
- Main
- String
OrderedListStateSpec:
methods:
- Descriptor
- GetElementCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ElementCoderId
Outbound:
methods:
- String
properties:
- To
- Type
OutputTime:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
OutputTime_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
PCol:
methods:
- ID
- WSID
- WindowingStrategy
properties:
- Bounded
- Coder
- Index
- Local
PColResult:
methods:
- Name
- Namespace
- Result
- Transform
properties:
- Attempted
- Key
PColValue:
properties:
- ElementCount
- SampledByteSize
PCollection:
methods:
- Coder
- Descriptor
- Down
- FinishBundle
- GetCoderId
- GetDisplayData
- GetIsBounded
- GetUniqueName
- GetWindowingStrategyId
- ID
- IsValid
- ProcessElement
- ProtoMessage
- ProtoReflect
- Reset
- SetCoder
- StartBundle
- String
- Type
- Up
properties:
- Coder
- CoderId
- DisplayData
- IsBounded
- Out
- PColID
- Seed
- UID
- UniqueName
- WindowingStrategyId
PCollectionSnapshot:
properties:
- ElementCount
- ID
- SizeCount
PTransform:
methods:
- Descriptor
- GetAnnotations
- GetDisplayData
- GetEnvironmentId
- GetInputs
- GetOutputs
- GetSpec
- GetSubtransforms
- GetUniqueName
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Annotations
- DisplayData
- EnvironmentId
- Inputs
- Outputs
- Spec
- Subtransforms
- UniqueName
PTransformState:
methods:
- Set
PairWithRestriction:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Out
- UID
PaneInfo:
properties:
- Index
- IsFirst
- Timing
ParDo:
methods:
- AttachFinalizer
- Down
- FinishBundle
- GetPID
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Inbound
- Out
- PID
- Side
- UID
- UState
ParDoPayload:
methods:
- Descriptor
- GetDoFn
- GetOnWindowExpirationTimerFamilySpec
- GetRequestsFinalization
- GetRequiresStableInput
- GetRequiresTimeSortedInput
- GetRestrictionCoderId
- GetSideInputs
- GetStateSpecs
- GetTimerFamilySpecs
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- DoFn
- OnWindowExpirationTimerFamilySpec
- RequestsFinalization
- RequiresStableInput
- RequiresTimeSortedInput
- RestrictionCoderId
- SideInputs
- StateSpecs
- TimerFamilySpecs
Payload:
properties:
- Config
- Data
- DataSchema
- InputsMap
- Location
- OutputsMap
- URN
Pipeline:
methods:
- Build
- Descriptor
- GetComponents
- GetDisplayData
- GetRequirements
- GetRootTransformIds
- ProtoMessage
- ProtoReflect
- Reset
- Root
- String
properties:
- Components
- DisplayData
- Requirements
- RootTransformIds
PipelineOptionDescriptor:
methods:
- Descriptor
- GetDefaultValue
- GetDescription
- GetGroup
- GetName
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- DefaultValue
- Description
- Group
- Name
- Type
PipelineOptionType:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
PipelineOptionType_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
PipelineResult:
methods:
- JobID
- Metrics
PipelineState:
methods:
- CoderType
- KeyCoderType
- StateKey
- StateType
Plan:
methods:
- Checkpoint
- Down
- Execute
- Finalize
- GetExpirationTime
- ID
- Progress
- SourcePTransformID
- Split
- String
PlanSnapshot:
properties:
- PCols
- Source
Port:
properties:
- URL
PredictionResult:
properties:
- Example
- Inference
PrepareJobRequest:
methods:
- Descriptor
- GetJobName
- GetPipeline
- GetPipelineOptions
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobName
- Pipeline
- PipelineOptions
PrepareJobResponse:
methods:
- Descriptor
- GetArtifactStagingEndpoint
- GetPreparationId
- GetStagingSessionToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ArtifactStagingEndpoint
- PreparationId
- StagingSessionToken
ProcessBundleDescriptor:
methods:
- Descriptor
- GetCoders
- GetEnvironments
- GetId
- GetPcollections
- GetStateApiServiceDescriptor
- GetTimerApiServiceDescriptor
- GetTransforms
- GetWindowingStrategies
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Coders
- Environments
- Id
- Pcollections
- StateApiServiceDescriptor
- TimerApiServiceDescriptor
- Transforms
- WindowingStrategies
ProcessBundleProgressRequest:
methods:
- Descriptor
- GetInstructionId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- InstructionId
ProcessBundleProgressResponse:
methods:
- Descriptor
- GetMonitoringData
- GetMonitoringInfos
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- MonitoringData
- MonitoringInfos
ProcessBundleRequest:
methods:
- Descriptor
- GetCacheTokens
- GetElements
- GetProcessBundleDescriptorId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- CacheTokens
- Elements
- ProcessBundleDescriptorId
ProcessBundleRequest_CacheToken:
methods:
- Descriptor
- GetSideInput
- GetToken
- GetType
- GetUserState
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Token
- Type
ProcessBundleRequest_CacheToken_SideInput:
methods:
- Descriptor
- GetSideInputId
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- SideInputId
- TransformId
ProcessBundleRequest_CacheToken_SideInput_:
properties:
- SideInput
ProcessBundleRequest_CacheToken_UserState:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
ProcessBundleRequest_CacheToken_UserState_:
properties:
- UserState
ProcessBundleResponse:
methods:
- Descriptor
- GetElements
- GetMonitoringData
- GetMonitoringInfos
- GetRequiresFinalization
- GetResidualRoots
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Elements
- MonitoringData
- MonitoringInfos
- RequiresFinalization
- ResidualRoots
ProcessBundleSplitRequest:
methods:
- Descriptor
- GetDesiredSplits
- GetInstructionId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- DesiredSplits
- InstructionId
ProcessBundleSplitRequest_DesiredSplit:
methods:
- Descriptor
- GetAllowedSplitPoints
- GetEstimatedInputElements
- GetFractionOfRemainder
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- AllowedSplitPoints
- EstimatedInputElements
- FractionOfRemainder
ProcessBundleSplitResponse:
methods:
- Descriptor
- GetChannelSplits
- GetPrimaryRoots
- GetResidualRoots
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ChannelSplits
- PrimaryRoots
- ResidualRoots
ProcessBundleSplitResponse_ChannelSplit:
methods:
- Descriptor
- GetFirstResidualElement
- GetLastPrimaryElement
- GetTransformId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- FirstResidualElement
- LastPrimaryElement
- TransformId
ProcessContinuation:
methods:
- ResumeDelay
- ShouldResume
ProcessPayload:
methods:
- Descriptor
- GetArch
- GetCommand
- GetEnv
- GetOs
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Arch
- Command
- Env
- Os
ProcessSizedElementsAndRestrictions:
methods:
- AttachFinalizer
- Checkpoint
- Down
- FinishBundle
- GetInputId
- GetOutputWatermark
- GetProgress
- GetTransformId
- ID
- ProcessElement
- Split
- StartBundle
- String
- Up
properties:
- PDo
- SU
- TfId
ProgressReportSnapshot:
properties:
- Count
- ID
Provider:
methods:
- AddInputFn
- ClearBagState
- ClearMapState
- ClearMapStateKey
- ClearValueState
- CreateAccumulatorFn
- ExtractOutputFn
- MergeAccumulatorsFn
- ReadBagState
- ReadMapStateKeys
- ReadMapStateValue
- ReadValueState
- WriteBagState
- WriteMapState
- WriteValueState
ProvisionInfo:
methods:
- Descriptor
- GetArtifactEndpoint
- GetControlEndpoint
- GetDependencies
- GetLoggingEndpoint
- GetMetadata
- GetPipelineOptions
- GetRetrievalToken
- GetRunnerCapabilities
- GetSiblingWorkerIds
- GetStatusEndpoint
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ArtifactEndpoint
- ControlEndpoint
- Dependencies
- LoggingEndpoint
- Metadata
- PipelineOptions
- RetrievalToken
- RunnerCapabilities
- SiblingWorkerIds
- StatusEndpoint
ProvisionServiceClient:
methods:
- GetProvisionInfo
ProvisionServiceServer:
methods:
- GetProvisionInfo
ProxyManifest:
methods:
- Descriptor
- GetLocation
- GetManifest
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Location
- Manifest
ProxyManifest_Location:
methods:
- Descriptor
- GetName
- GetUri
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
- Uri
PubSubReadPayload:
methods:
- Descriptor
- GetIdAttribute
- GetSubscription
- GetSubscriptionRuntimeOverridden
- GetTimestampAttribute
- GetTopic
- GetTopicRuntimeOverridden
- GetWithAttributes
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- IdAttribute
- Subscription
- SubscriptionRuntimeOverridden
- TimestampAttribute
- Topic
- TopicRuntimeOverridden
- WithAttributes
PubSubWritePayload:
methods:
- Descriptor
- GetIdAttribute
- GetTimestampAttribute
- GetTopic
- GetTopicRuntimeOverridden
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- IdAttribute
- TimestampAttribute
- Topic
- TopicRuntimeOverridden
PutArtifactMetadata:
methods:
- Descriptor
- GetMetadata
- GetStagingSessionToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Metadata
- StagingSessionToken
PutArtifactRequest:
methods:
- Descriptor
- GetContent
- GetData
- GetMetadata
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Content
PutArtifactRequest_Data:
properties:
- Data
PutArtifactRequest_Metadata:
properties:
- Metadata
PutArtifactResponse:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
PyPIPayload:
methods:
- Descriptor
- GetArtifactId
- GetVersion
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ArtifactId
- Version
QualifiedTableName:
methods:
- String
properties:
- Dataset
- Project
- Table
QueryOptions:
properties:
- UseStandardSQL
QueryResults:
methods:
- Counters
- Distributions
- Gauges
- Msecs
- PCols
RTracker:
methods:
- GetError
- GetProgress
- GetRestriction
- IsDone
- TryClaim
- TrySplit
RangeEndEstimator:
methods:
- Estimate
RawOptions:
properties:
- Options
RawOptionsWrapper:
properties:
- AppName
- Experiments
- Options
- Parallelism
- RetainDocker
- Runner
ReStream:
methods:
- Open
ReadModifyWriteStateSpec:
methods:
- Descriptor
- GetCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- CoderId
ReadOption:
properties:
- BucketAuto
- BundleSize
- Filter
ReadOptions:
properties:
- IDAttribute
- Subscription
- TimestampAttribute
- WithAttributes
ReadPayload:
methods:
- Descriptor
- GetIsBounded
- GetSource
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- IsBounded
- Source
RegisterRequest:
methods:
- Descriptor
- GetProcessBundleDescriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ProcessBundleDescriptor
RegisterResponse:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
Registry:
methods:
- FromType
- RegisterLogicalType
- RegisterLogicalTypeProvider
- RegisterType
- Registered
- ToType
RemoteGrpcPort:
methods:
- Descriptor
- GetApiServiceDescriptor
- GetCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ApiServiceDescriptor
- CoderId
Remover:
methods:
- Remove
Renamer:
methods:
- Rename
RepeatTrigger:
methods:
- String
- SubTrigger
ReshuffleInput:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Coder
- Out
- SID
- Seed
- UID
ReshuffleOutput:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Coder
- Out
- SID
- UID
ReshufflePayload:
methods:
- Descriptor
- GetCoderId
- GetCoderPayloads
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- CoderId
- CoderPayloads
ResolveArtifactsRequest:
methods:
- Descriptor
- GetArtifacts
- GetPreferredUrns
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Artifacts
- PreferredUrns
ResolveArtifactsResponse:
methods:
- Descriptor
- GetReplacements
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Replacements
ResolveConfig:
properties:
- JoinFn
- SdkPath
Restriction:
methods:
- EvenSplits
- Size
- SizedSplits
properties:
- Start
Results:
methods:
- AllMetrics
- Query
RetrievalServer:
methods:
- GetArtifact
- GetManifest
ReturnKind:
methods:
- String
ReturnParam:
properties:
- Kind
- T
ReusableEmitter:
methods:
- Init
- Value
ReusableInput:
methods:
- Init
- Reset
- Value
ReusableTimestampObservingWatermarkEmitter:
methods:
- AttachEstimator
Root:
methods:
- Process
Row:
methods:
- Descriptor
- GetValues
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Values
RowDecoderBuilder:
methods:
- Build
- Register
properties:
- RequireAllFieldsExported
RowEncoderBuilder:
methods:
- Build
- Register
properties:
- RequireAllFieldsExported
RowType:
methods:
- Descriptor
- GetSchema
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Schema
RunJobRequest:
methods:
- Descriptor
- GetPreparationId
- GetRetrievalToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- PreparationId
- RetrievalToken
RunJobResponse:
methods:
- Descriptor
- GetJobId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- JobId
SCombine:
methods:
- MergeAccumulators
Schema:
methods:
- Descriptor
- GetEncodingPositionsSet
- GetFields
- GetId
- GetOptions
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- EncodingPositionsSet
- Fields
- Id
- Options
SchemaCoder:
methods:
- Register
- Validate
properties:
- CmpOptions
SchemaProvider:
methods:
- BuildDecoder
- BuildEncoder
- FromLogicalType
SchemaTransformConfig:
methods:
- Descriptor
- GetConfigSchema
- GetInputPcollectionNames
- GetOutputPcollectionNames
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ConfigSchema
- InputPcollectionNames
- OutputPcollectionNames
SchemaTransformPayload:
methods:
- Descriptor
- GetConfigurationRow
- GetConfigurationSchema
- GetIdentifier
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ConfigurationRow
- ConfigurationSchema
- Identifier
Scope:
methods:
- ID
- IsValid
- Scope
- String
properties:
- Label
- Parent
ScopeTree:
properties:
- Children
- Edges
- Scope
ScopedDataManager:
methods:
- Close
- OpenRead
- OpenWrite
ScopedStateReader:
methods:
- Close
- GetSideInputCache
- OpenBagUserStateAppender
- OpenBagUserStateClearer
- OpenBagUserStateReader
- OpenIterable
- OpenIterableSideInput
- OpenMultiMapSideInput
- OpenMultimapKeysUserStateClearer
- OpenMultimapKeysUserStateReader
- OpenMultimapUserStateAppender
- OpenMultimapUserStateClearer
- OpenMultimapUserStateReader
SdfFallback:
methods:
- AttachFinalizer
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- PDo
SearchQuery:
properties:
- Identifier
- Parameters
- ResourceType
SessionWindowsPayload:
methods:
- Descriptor
- GetGapSize
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- GapSize
SessionWindowsPayload_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Set:
methods:
- Add
- Clear
- CoderType
- Contains
- KeyCoderType
- Keys
- Remove
- StateKey
- StateType
properties:
- Key
SetStateSpec:
methods:
- Descriptor
- GetElementCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ElementCoderId
SideCache:
methods:
- QueryCache
- SetCache
SideInput:
methods:
- Descriptor
- GetAccessPattern
- GetViewFn
- GetWindowMappingFn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- AccessPattern
- Input
- ViewFn
- WindowMappingFn
SideInputAdapter:
methods:
- NewIterable
- NewKeyedIterable
SideInputCache:
methods:
- CacheMetrics
- CompleteBundle
- Init
- QueryCache
- SetCache
- SetValidTokens
Signature:
methods:
- String
properties:
- Args
- OptArgs
- OptReturn
- Return
SingleResult:
methods:
- Name
- Namespace
- Transform
SliceLoader:
methods:
- LoadSlice
SlidingWindowsPayload:
methods:
- Descriptor
- GetOffset
- GetPeriod
- GetSize
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Offset
- Period
- Size
SlidingWindowsPayload_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
SourceConfig:
properties:
- HotKeyFraction
- InitialSplits
- KeySize
- NumElements
- NumHotKeys
- ValueSize
SourceConfigBuilder:
methods:
- Build
- BuildFromJSON
- HotKeyFraction
- InitialSplits
- KeySize
- NumElements
- NumHotKeys
- ValueSize
SplitAndSizeRestrictions:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Out
- UID
SplitPoints:
properties:
- BufSize
- Frac
- Splits
SplitResult:
properties:
- InId
- OW
- PI
- PS
- RI
- RS
- TId
- Unsuccessful
SplittableDoFn:
methods:
- CreateInitialRestrictionFn
- CreateTrackerFn
- CreateWatermarkEstimatorFn
- HasTruncateRestriction
- InitialWatermarkEstimatorStateFn
- IsStatefulWatermarkEstimating
- IsWatermarkEstimating
- Name
- RestrictionSizeFn
- RestrictionT
- SplitRestrictionFn
- TruncateRestrictionFn
- WatermarkEstimatorStateFn
- WatermarkEstimatorStateT
- WatermarkEstimatorT
SplittableUnit:
methods:
- Checkpoint
- GetInputId
- GetOutputWatermark
- GetProgress
- GetTransformId
- Split
StagingServer:
methods:
- CommitManifest
- PutArtifact
Standard:
methods:
- Log
properties:
- Level
StandardArtifacts:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardArtifacts_Roles:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardArtifacts_Types:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardCoders:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardCoders_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardDisplayData:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardDisplayData_DisplayData:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardEnvironments:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardEnvironments_Environments:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardPTransforms:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardPTransforms_CombineComponents:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardPTransforms_Composites:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardPTransforms_DeprecatedPrimitives:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardPTransforms_GroupIntoBatchesComponents:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardPTransforms_Primitives:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardPTransforms_SplittableParDoComponents:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardProtocols:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardProtocols_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardRequirements:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardRequirements_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardResourceHints:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardResourceHints_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardRunnerProtocols:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardRunnerProtocols_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardSideInputTypes:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardSideInputTypes_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StandardUserStateTypes:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StandardUserStateTypes_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
StartWorkerRequest:
methods:
- Descriptor
- GetArtifactEndpoint
- GetControlEndpoint
- GetLoggingEndpoint
- GetParams
- GetProvisionEndpoint
- GetWorkerId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ArtifactEndpoint
- ControlEndpoint
- LoggingEndpoint
- Params
- ProvisionEndpoint
- WorkerId
StartWorkerResponse:
methods:
- Descriptor
- GetError
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Error
StateAppendRequest:
methods:
- Descriptor
- GetData
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Data
StateAppendResponse:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StateChannel:
methods:
- Send
properties:
- DoneCh
StateChannelManager:
methods:
- Open
StateClearRequest:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StateClearResponse:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
StateGetRequest:
methods:
- Descriptor
- GetContinuationToken
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ContinuationToken
StateGetResponse:
methods:
- Descriptor
- GetContinuationToken
- GetData
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ContinuationToken
- Data
StateKey:
methods:
- Descriptor
- GetBagUserState
- GetIterableSideInput
- GetMultimapKeysSideInput
- GetMultimapKeysUserState
- GetMultimapSideInput
- GetMultimapUserState
- GetRunner
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Type
StateKey_BagUserState:
methods:
- Descriptor
- GetKey
- GetTransformId
- GetUserStateId
- GetWindow
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- TransformId
- UserStateId
- Window
StateKey_BagUserState_:
properties:
- BagUserState
StateKey_IterableSideInput:
methods:
- Descriptor
- GetSideInputId
- GetTransformId
- GetWindow
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- SideInputId
- TransformId
- Window
StateKey_IterableSideInput_:
properties:
- IterableSideInput
StateKey_MultimapKeysSideInput:
methods:
- Descriptor
- GetSideInputId
- GetTransformId
- GetWindow
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- SideInputId
- TransformId
- Window
StateKey_MultimapKeysSideInput_:
properties:
- MultimapKeysSideInput
StateKey_MultimapKeysUserState:
methods:
- Descriptor
- GetKey
- GetTransformId
- GetUserStateId
- GetWindow
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- TransformId
- UserStateId
- Window
StateKey_MultimapKeysUserState_:
properties:
- MultimapKeysUserState
StateKey_MultimapSideInput:
methods:
- Descriptor
- GetKey
- GetSideInputId
- GetTransformId
- GetWindow
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- SideInputId
- TransformId
- Window
StateKey_MultimapSideInput_:
properties:
- MultimapSideInput
StateKey_MultimapUserState:
methods:
- Descriptor
- GetKey
- GetMapKey
- GetTransformId
- GetUserStateId
- GetWindow
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
- MapKey
- TransformId
- UserStateId
- Window
StateKey_MultimapUserState_:
properties:
- MultimapUserState
StateKey_Runner:
methods:
- Descriptor
- GetKey
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Key
StateKey_Runner_:
properties:
- Runner
StateReader:
methods:
- GetSideInputCache
- OpenBagUserStateAppender
- OpenBagUserStateClearer
- OpenBagUserStateReader
- OpenIterable
- OpenIterableSideInput
- OpenMultiMapSideInput
- OpenMultimapKeysUserStateClearer
- OpenMultimapKeysUserStateReader
- OpenMultimapUserStateAppender
- OpenMultimapUserStateClearer
- OpenMultimapUserStateReader
StateRequest:
methods:
- Descriptor
- GetAppend
- GetClear
- GetGet
- GetId
- GetInstructionId
- GetRequest
- GetStateKey
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Id
- InstructionId
- Request
- StateKey
StateRequest_Append:
properties:
- Append
StateRequest_Clear:
properties:
- Clear
StateRequest_Get:
properties:
- Get
StateResponse:
methods:
- Descriptor
- GetAppend
- GetClear
- GetError
- GetGet
- GetId
- GetResponse
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Error
- Id
- Response
StateResponse_Append:
properties:
- Append
StateResponse_Clear:
properties:
- Clear
StateResponse_Get:
properties:
- Get
StateSampler:
methods:
- Sample
- SetLogInterval
StateSpec:
methods:
- Descriptor
- GetBagSpec
- GetCombiningSpec
- GetMapSpec
- GetOrderedListSpec
- GetProtocol
- GetReadModifyWriteSpec
- GetSetSpec
- GetSpec
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Protocol
- Spec
StateSpec_BagSpec:
properties:
- BagSpec
StateSpec_CombiningSpec:
properties:
- CombiningSpec
StateSpec_MapSpec:
properties:
- MapSpec
StateSpec_OrderedListSpec:
properties:
- OrderedListSpec
StateSpec_ReadModifyWriteSpec:
properties:
- ReadModifyWriteSpec
StateSpec_SetSpec:
properties:
- SetSpec
Status:
methods:
- String
StepConfig:
properties:
- FilterRatio
- InitialSplits
- OutputPerInput
- Splittable
StepConfigBuilder:
methods:
- Build
- FilterRatio
- InitialSplits
- OutputPerInput
- Splittable
StepKey:
properties:
- Step
StopWorkerRequest:
methods:
- Descriptor
- GetWorkerId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- WorkerId
StopWorkerResponse:
methods:
- Descriptor
- GetError
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Error
Store:
methods:
- BundleState
- StateRegistry
Stream:
methods:
- Read
StreamID:
methods:
- String
properties:
- Port
- PtransformID
SymbolResolver:
methods:
- Sym2Addr
SymbolTable:
methods:
- Addr2Sym
- Sym2Addr
T:
methods:
- Errorf
- FailNow
- Failed
- Helper
- Run
TestStreamPayload:
methods:
- Descriptor
- GetCoderId
- GetEndpoint
- GetEvents
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- CoderId
- Endpoint
- Events
TestStreamPayload_Event:
methods:
- Descriptor
- GetElementEvent
- GetEvent
- GetProcessingTimeEvent
- GetWatermarkEvent
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Event
TestStreamPayload_Event_AddElements:
methods:
- Descriptor
- GetElements
- GetTag
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Elements
- Tag
TestStreamPayload_Event_AdvanceProcessingTime:
methods:
- Descriptor
- GetAdvanceDuration
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- AdvanceDuration
TestStreamPayload_Event_AdvanceWatermark:
methods:
- Descriptor
- GetNewWatermark
- GetTag
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- NewWatermark
- Tag
TestStreamPayload_Event_ElementEvent:
properties:
- ElementEvent
TestStreamPayload_Event_ProcessingTimeEvent:
properties:
- ProcessingTimeEvent
TestStreamPayload_Event_WatermarkEvent:
properties:
- WatermarkEvent
TestStreamPayload_TimestampedElement:
methods:
- Descriptor
- GetEncodedElement
- GetTimestamp
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- EncodedElement
- Timestamp
TestStreamService_EventsClient:
methods:
- Recv
TestStreamService_EventsServer:
methods:
- Send
TestStreamServiceClient:
methods:
- Events
TestStreamServiceServer:
methods:
- Events
Time:
methods:
- Add
- Milliseconds
- String
- Subtract
- ToTime
TimeDomain:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
TimeDomain_Enum:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
TimerFamilySpec:
methods:
- Descriptor
- GetTimeDomain
- GetTimerFamilyCoderId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- TimeDomain
- TimerFamilyCoderId
TimerMap:
properties:
- Clear
- FireTimestamp
- Key
- Pane
- Windows
Timers:
properties:
- Clear
- FireTimestamp
- Key
- Pane
- Tag
- Windows
TimestampObservingEstimator:
methods:
- ObserveTimestamp
TimestampObservingWatermarkEstimator:
methods:
- CurrentWatermark
- ObserveTimestamp
properties:
- State
TimestampTransform:
methods:
- Descriptor
- GetAlignTo
- GetDelay
- GetTimestampTransform
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- TimestampTransform
TimestampTransform_AlignTo:
methods:
- Descriptor
- GetOffset
- GetPeriod
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Offset
- Period
TimestampTransform_AlignTo_:
properties:
- AlignTo
TimestampTransform_Delay:
methods:
- Descriptor
- GetDelayMillis
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- DelayMillis
TimestampTransform_Delay_:
properties:
- Delay
Top:
properties:
- Emitters
- FileName
- Functions
- Imports
- Inputs
- Shims
- Types
- Wraps
Tracker:
methods:
- GetError
- GetProgress
- GetRestriction
- IsBounded
- IsDone
- String
- TryClaim
- TrySplit
Transaction:
properties:
- Key
- MapKey
- Type
- Val
TransformPayload:
methods:
- Descriptor
- GetEdge
- GetInject
- GetReshuffle
- GetUrn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Edge
- Inject
- Reshuffle
- Urn
Trigger:
methods:
- Descriptor
- GetAfterAll
- GetAfterAny
- GetAfterEach
- GetAfterEndOfWindow
- GetAfterProcessingTime
- GetAfterSynchronizedProcessingTime
- GetAlways
- GetDefault
- GetElementCount
- GetNever
- GetOrFinally
- GetRepeat
- GetTrigger
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Trigger
Trigger_AfterAll:
methods:
- Descriptor
- GetSubtriggers
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Subtriggers
Trigger_AfterAll_:
properties:
- AfterAll
Trigger_AfterAny:
methods:
- Descriptor
- GetSubtriggers
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Subtriggers
Trigger_AfterAny_:
properties:
- AfterAny
Trigger_AfterEach:
methods:
- Descriptor
- GetSubtriggers
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Subtriggers
Trigger_AfterEach_:
properties:
- AfterEach
Trigger_AfterEndOfWindow:
methods:
- Descriptor
- GetEarlyFirings
- GetLateFirings
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- EarlyFirings
- LateFirings
Trigger_AfterEndOfWindow_:
properties:
- AfterEndOfWindow
Trigger_AfterProcessingTime:
methods:
- Descriptor
- GetTimestampTransforms
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- TimestampTransforms
Trigger_AfterProcessingTime_:
properties:
- AfterProcessingTime
Trigger_AfterSynchronizedProcessingTime:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
Trigger_AfterSynchronizedProcessingTime_:
properties:
- AfterSynchronizedProcessingTime
Trigger_Always:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
Trigger_Always_:
properties:
- Always
Trigger_Default:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
Trigger_Default_:
properties:
- Default
Trigger_ElementCount:
methods:
- Descriptor
- GetElementCount
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ElementCount
Trigger_ElementCount_:
properties:
- ElementCount
Trigger_Never:
methods:
- Descriptor
- ProtoMessage
- ProtoReflect
- Reset
- String
Trigger_Never_:
properties:
- Never
Trigger_OrFinally:
methods:
- Descriptor
- GetFinally
- GetMain
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Finally
- Main
Trigger_OrFinally_:
properties:
- OrFinally
Trigger_Repeat:
methods:
- Descriptor
- GetSubtrigger
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Subtrigger
Trigger_Repeat_:
properties:
- Repeat
TruncateSizedRestriction:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Out
- UID
Type:
methods:
- Descriptor
- GetChanDir
- GetElement
- GetExternalKey
- GetFields
- GetIsVariadic
- GetKind
- GetParameterTypes
- GetReturnTypes
- GetSpecial
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- ChanDir
- Element
- ExternalKey
- Fields
- IsVariadic
- Kind
- ParameterTypes
- ReturnTypes
- Special
Type_ChanDir:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Type_Kind:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Type_Special:
methods:
- Descriptor
- Enum
- EnumDescriptor
- Number
- String
- Type
Type_StructField:
methods:
- Descriptor
- GetAnonymous
- GetIndex
- GetName
- GetOffset
- GetPkgPath
- GetTag
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Anonymous
- Index
- Name
- Offset
- PkgPath
- Tag
- Type
TypeDefinition:
properties:
- T
- Var
TypeMismatchError:
methods:
- Error
properties:
- Got
UnimplementedArtifactRetrievalServiceServer:
methods:
- GetArtifact
- ResolveArtifacts
UnimplementedArtifactStagingServiceServer:
methods:
- ReverseArtifactRetrievalService
UnimplementedBeamFnControlServer:
methods:
- Control
- GetProcessBundleDescriptor
UnimplementedBeamFnDataServer:
methods:
- Data
UnimplementedBeamFnExternalWorkerPoolServer:
methods:
- StartWorker
- StopWorker
UnimplementedBeamFnLoggingServer:
methods:
- Logging
UnimplementedBeamFnStateServer:
methods:
- State
UnimplementedBeamFnWorkerStatusServer:
methods:
- WorkerStatus
UnimplementedExpansionServiceServer:
methods:
- DiscoverSchemaTransform
- Expand
UnimplementedJobServiceServer:
methods:
- Cancel
- DescribePipelineOptions
- GetJobMetrics
- GetJobs
- GetMessageStream
- GetPipeline
- GetState
- GetStateStream
- Prepare
- Run
UnimplementedLegacyArtifactRetrievalServiceServer:
methods:
- GetArtifact
- GetManifest
UnimplementedLegacyArtifactStagingServiceServer:
methods:
- CommitManifest
- PutArtifact
UnimplementedProvisionServiceServer:
methods:
- GetProvisionInfo
UnimplementedTestStreamServiceServer:
methods:
- Events
Unit:
methods:
- Down
- FinishBundle
- ID
- StartBundle
- Up
UnsafeArtifactRetrievalServiceServer: {}
UnsafeArtifactStagingServiceServer: {}
UnsafeBeamFnControlServer: {}
UnsafeBeamFnDataServer: {}
UnsafeBeamFnExternalWorkerPoolServer: {}
UnsafeBeamFnLoggingServer: {}
UnsafeBeamFnStateServer: {}
UnsafeBeamFnWorkerStatusServer: {}
UnsafeExpansionServiceServer: {}
UnsafeJobServiceServer: {}
UnsafeLegacyArtifactRetrievalServiceServer: {}
UnsafeLegacyArtifactStagingServiceServer: {}
UnsafeProvisionServiceServer: {}
UnsafeTestStreamServiceServer: {}
UserFn:
methods:
- Descriptor
- GetName
- GetType
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Name
- Type
UserStateAdapter:
methods:
- NewStateProvider
Value:
methods:
- Clear
- CoderType
- KeyCoderType
- Read
- StateKey
- StateType
- Write
properties:
- Key
WallTimeWatermarkEstimator:
methods:
- CurrentWatermark
WatermarkEstimator:
methods:
- CurrentWatermark
Window:
methods:
- Equals
- MaxTimestamp
WindowCoder:
methods:
- Equals
- String
properties:
- Kind
- Payload
WindowDecoder:
methods:
- Decode
- DecodeSingle
WindowEncoder:
methods:
- Encode
- EncodeSingle
WindowFn:
methods:
- Descriptor
- GetGapMs
- GetKind
- GetPeriodMs
- GetSizeMs
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- GapMs
- Kind
- PeriodMs
- SizeMs
WindowInto:
methods:
- Down
- FinishBundle
- ID
- ProcessElement
- StartBundle
- String
- Up
properties:
- Fn
- Out
- UID
WindowIntoOption: {}
WindowIntoPayload:
methods:
- Descriptor
- GetWindowFn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- WindowFn
WindowMapper:
methods:
- MapWindow
WindowedValue: {}
WindowingStrategy:
methods:
- Descriptor
- Equals
- GetAccumulationMode
- GetAllowedLateness
- GetAssignsToOneWindow
- GetClosingBehavior
- GetEnvironmentId
- GetMergeStatus
- GetOnTimeBehavior
- GetOutputTime
- GetTrigger
- GetWindowCoderId
- GetWindowFn
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- AccumulationMode
- AllowedLateness
- AssignsToOneWindow
- ClosingBehavior
- EnvironmentId
- Fn
- MergeStatus
- OnTimeBehavior
- OutputTime
- Trigger
- WindowCoderId
- WindowFn
WorkerStatusRequest:
methods:
- Descriptor
- GetId
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Id
WorkerStatusResponse:
methods:
- Descriptor
- GetError
- GetId
- GetStatusInfo
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- Error
- Id
- StatusInfo
Wrap:
properties:
- Methods
- Name
WrappedTracker:
methods:
- IsBounded
WriteFilesPayload:
methods:
- Descriptor
- GetFormatFunction
- GetRunnerDeterminedSharding
- GetSideInputs
- GetSink
- GetWindowedWrites
- ProtoMessage
- ProtoReflect
- Reset
- String
properties:
- FormatFunction
- RunnerDeterminedSharding
- SideInputs
- Sink
- WindowedWrites
WriteOption:
properties:
- BatchSize
- Ordered
Writer:
methods:
- SaveData