| "": |
| 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 |
