playground/frontend/playground_components/assets/symbols/go.g.yaml (6,641 lines of code) (raw):

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