| AbstractBeamJob: |
| methods: |
| - artifact_staging_endpoint |
| - cancel |
| - get_message_stream |
| - get_pipeline |
| - get_state |
| - get_state_stream |
| - is_terminal_state |
| - prepare |
| - run |
| - set_state |
| - state |
| - to_runner_api |
| - with_state_history |
| AbstractComponentCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| - get_estimated_size_and_observables |
| AbstractDoFnWrapper: |
| methods: |
| - finish_bundle |
| - process |
| - setup |
| - start_bundle |
| - teardown |
| - wrapper |
| AbstractJobServiceServicer: |
| methods: |
| - Cancel |
| - create_beam_job |
| - DescribePipelineOptions |
| - GetJobs |
| - GetMessageStream |
| - GetPipeline |
| - GetState |
| - GetStateStream |
| - Prepare |
| - Run |
| AcceleratorHint: |
| properties: |
| - urn |
| AccumulatingRuntimeState: |
| methods: |
| - add |
| - clear |
| - commit |
| - read |
| AccumulationMode: |
| properties: |
| - ACCUMULATING |
| - DISCARDING |
| AccumulatorCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| AccumulatorCombineFnCounter: |
| methods: |
| - reset |
| - update |
| - update_n |
| AdaptiveThrottler: |
| methods: |
| - successful_request |
| - throttle_request |
| properties: |
| - MIN_REQUESTS |
| AddBitbucketServerConnectedRepositoryRequest: |
| properties: |
| - connectedRepository |
| AddBitbucketServerConnectedRepositoryResponse: |
| properties: |
| - config |
| - connectedRepository |
| AddThenMultiply: |
| methods: |
| - expand |
| AddThenMultiplyDoFn: |
| methods: |
| - process |
| AddTimestampFn: |
| methods: |
| - process |
| AddWithProductDoFn: |
| methods: |
| - process |
| AfterAll: |
| properties: |
| - combine_op |
| AfterAny: |
| properties: |
| - combine_op |
| AfterCount: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| properties: |
| - COUNT_TAG |
| AfterEach: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| properties: |
| - INDEX_TAG |
| AfterProcessingTime: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| properties: |
| - STATE_TAG |
| AfterWatermark: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - is_late |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| properties: |
| - LATE_TAG |
| AggregateClassificationMetrics: |
| properties: |
| - accuracy |
| - f1Score |
| - logLoss |
| - precision |
| - recall |
| - rocAuc |
| - threshold |
| AllAccumulator: |
| methods: |
| - add_input |
| - extract_output |
| - merge |
| AllCombineFn: {} |
| AllPrimitives: |
| properties: |
| - field_bool |
| - field_bytes |
| - field_float32 |
| - field_float64 |
| - field_int16 |
| - field_int32 |
| - field_int64 |
| - field_int8 |
| - field_optional_bool |
| - field_optional_bytes |
| - field_optional_float32 |
| - field_optional_float64 |
| - field_optional_int16 |
| - field_optional_int32 |
| - field_optional_int64 |
| - field_optional_int8 |
| - field_optional_str |
| - field_str |
| Always: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| AlwaysPassMatcher: {} |
| ANamedTuple: |
| properties: |
| - a |
| - b |
| AnnotateImage: |
| methods: |
| - expand |
| properties: |
| - MAX_BATCH_SIZE |
| - MIN_BATCH_SIZE |
| AnnotateImageWithContext: |
| methods: |
| - expand |
| AnnotateVideo: |
| methods: |
| - expand |
| AnnotateVideoWithContext: |
| methods: |
| - expand |
| AnnotationBasedPayloadBuilder: {} |
| AnnotationTests: |
| methods: |
| - check_annotation |
| - check_custom_annotation |
| - setUp |
| - test_deprecated_custom_no_replacements |
| - test_deprecated_with_since_current |
| - test_deprecated_with_since_current_message |
| - test_deprecated_with_since_current_message_class |
| - test_deprecated_with_since_current_message_custom |
| - test_deprecated_without_current |
| - test_deprecated_without_since_custom_should_fail |
| - test_deprecated_without_since_should_fail |
| - test_enforce_custom_since_deprecated_must_fail |
| - test_experimental_with_current |
| - test_experimental_with_current_message |
| - test_experimental_with_current_message_class |
| - test_experimental_with_current_message_custom |
| - test_experimental_without_current |
| AnyAccumulator: |
| methods: |
| - add_input |
| - extract_output |
| - merge |
| AnyCombineFn: {} |
| AnyTypeConstraint: |
| methods: |
| - type_check |
| AppendDestinationsFn: |
| methods: |
| - display_data |
| - process |
| AppliedPTransform: |
| methods: |
| - add_output |
| - add_part |
| - from_runner_api |
| - inputs |
| - is_composite |
| - named_inputs |
| - named_outputs |
| - replace_inputs |
| - replace_output |
| - replace_side_inputs |
| - to_runner_api |
| - visit |
| ApprovalConfig: |
| properties: |
| - approvalRequired |
| ApprovalResult: |
| properties: |
| - approvalTime |
| - approverAccount |
| - comment |
| - decision |
| - url |
| ApproveBuildRequest: |
| properties: |
| - approvalResult |
| ApproximateProgress: |
| properties: |
| - percentComplete |
| - position |
| - remainingTime |
| ApproximateQuantiles: {} |
| ApproximateQuantilesCombineFn: |
| methods: |
| - add_input |
| - create |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| ApproximateReportedProgress: |
| properties: |
| - consumedParallelism |
| - fractionConsumed |
| - position |
| - remainingParallelism |
| ApproximateSplitRequest: |
| properties: |
| - fractionConsumed |
| - fractionOfRemainder |
| - position |
| ApproximateUnique: |
| methods: |
| - parse_input_params |
| ApproximateUniqueCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - display_data |
| - extract_output |
| - merge_accumulators |
| Arbitrary: |
| methods: |
| - check |
| - is_subpartitioning_of |
| - test_partition_fn |
| Argument: |
| properties: |
| - argumentKind |
| - dataType |
| - mode |
| - name |
| ArgumentPlaceholder: {} |
| ArimaCoefficients: |
| properties: |
| - autoRegressiveCoefficients |
| - interceptCoefficient |
| - movingAverageCoefficients |
| ArimaFittingMetrics: |
| properties: |
| - aic |
| - logLikelihood |
| - variance |
| ArimaForecastingMetrics: |
| properties: |
| - arimaFittingMetrics |
| - arimaSingleModelForecastingMetrics |
| - hasDrift |
| - nonSeasonalOrder |
| - seasonalPeriods |
| - timeSeriesId |
| ArimaModelInfo: |
| properties: |
| - arimaCoefficients |
| - arimaFittingMetrics |
| - hasDrift |
| - nonSeasonalOrder |
| - seasonalPeriods |
| - timeSeriesId |
| ArimaOrder: |
| properties: |
| - d |
| - p |
| - q |
| ArimaResult: |
| properties: |
| - arimaModelInfo |
| - seasonalPeriods |
| ArimaSingleModelForecastingMetrics: |
| properties: |
| - arimaFittingMetrics |
| - hasDrift |
| - nonSeasonalOrder |
| - seasonalPeriods |
| - timeSeriesId |
| ArrayMultiplyDoFn: |
| methods: |
| - infer_output_type |
| - process_batch |
| ArtifactObjects: |
| properties: |
| - location |
| - paths |
| - timing |
| ArtifactResult: |
| properties: |
| - fileHash |
| - location |
| ArtifactRetrievalService: |
| methods: |
| - GetArtifact |
| - ResolveArtifacts |
| Artifacts: |
| properties: |
| - images |
| - objects |
| ArtifactStagingService: |
| methods: |
| - register_job |
| - resolved_deps |
| - ReverseArtifactRetrievalService |
| AsDict: {} |
| AsIter: |
| methods: |
| - element_type |
| AsList: {} |
| AsMultiMap: |
| methods: |
| - requires_keyed_input |
| AsSideInput: |
| methods: |
| - element_type |
| - from_runner_api |
| - requires_keyed_input |
| - to_runner_api |
| AssignTimestamps: |
| methods: |
| - process |
| AssignUniqueID: |
| methods: |
| - process |
| AsSingleton: |
| methods: |
| - element_type |
| Auction: |
| properties: |
| - CODER |
| AuctionBid: |
| properties: |
| - CODER |
| AuctionBidCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| AuctionBidCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| AuctionByIdFn: |
| methods: |
| - process |
| AuctionBySellerFn: |
| methods: |
| - process |
| AuctionCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| AuctionCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| AuctionOrBidWindow: |
| methods: |
| - for_auction |
| - for_bid |
| - is_auction_window_fn |
| AuctionOrBidWindowCoder: |
| methods: |
| - is_deterministic |
| AuctionOrBidWindowCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| AuctionOrBidWindowFn: |
| methods: |
| - assign |
| - get_transformed_output_time |
| - get_window_coder |
| - merge |
| AuditConfig: |
| properties: |
| - auditLogConfigs |
| - service |
| AuditLogConfig: |
| properties: |
| - exemptedMembers |
| - logType |
| AugmentedPipeline: |
| methods: |
| - augment |
| - augmented_pipeline |
| - background_recording_pipeline |
| - cacheables |
| AugmentedTestResults: {} |
| AutocompleteIT: |
| methods: |
| - test_autocomplete_output_files_on_small_input |
| properties: |
| - EXPECTED_PREFIXES |
| - WORDS |
| AutoscalingEvent: |
| properties: |
| - currentNumWorkers |
| - description |
| - eventType |
| - targetNumWorkers |
| - time |
| - workerPool |
| AutoscalingSettings: |
| properties: |
| - algorithm |
| - maxNumWorkers |
| AvroBase: |
| methods: |
| - setUp |
| - tearDown |
| - test_corrupted_file |
| - test_dynamic_work_rebalancing_exhaustive |
| - test_read_all_continuously_new |
| - test_read_all_continuously_update |
| - test_read_all_from_avro_file_pattern |
| - test_read_all_from_avro_many_file_patterns |
| - test_read_all_from_avro_many_single_files |
| - test_read_all_from_avro_single_file |
| - test_read_all_from_avro_with_filename |
| - test_read_display_data |
| - test_read_from_avro |
| - test_read_reantrant_with_splitting |
| - test_read_reentrant_without_splitting |
| - test_read_with_splitting |
| - test_read_with_splitting_compressed_deflate |
| - test_read_with_splitting_compressed_snappy |
| - test_read_with_splitting_multiple_blocks |
| - test_read_with_splitting_pattern |
| - test_read_without_splitting |
| - test_read_without_splitting_compressed_deflate |
| - test_read_without_splitting_compressed_snappy |
| - test_read_without_splitting_multiple_blocks |
| - test_read_without_splitting_pattern |
| - test_sink_display_data |
| - test_sink_transform |
| - test_sink_transform_snappy |
| - test_source_display_data |
| - test_split_points |
| - test_write_display_data |
| - test_writer_open_and_close |
| AvroCoderImpl: |
| methods: |
| - decode |
| - encode |
| AvroGenericCoder: |
| methods: |
| - from_runner_api_parameter |
| - is_deterministic |
| - to_runner_api_parameter |
| - to_type_hint |
| AvroRecord: {} |
| AvroRowWriter: |
| methods: |
| - close |
| - closed |
| - flush |
| - read |
| - tell |
| - writable |
| - write |
| AvroTestCoder: |
| properties: |
| - SCHEMA |
| AvroTestRecord: {} |
| AzureOptions: |
| methods: |
| - validate |
| BackgroundCachingJob: |
| methods: |
| - cancel |
| - is_done |
| - is_running |
| - state |
| Bacon: {} |
| BagInStateOutputAfterTimer: |
| methods: |
| - emit_values |
| - process |
| properties: |
| - EMIT_TIMER |
| - SET_STATE |
| BagRuntimeState: |
| methods: |
| - add |
| - clear |
| - read |
| BagStateSpec: |
| methods: |
| - to_runner_api |
| Base64PickleCoder: |
| methods: |
| - decode |
| - encode |
| - is_deterministic |
| - is_kv_coder |
| - key_coder |
| - value_coder |
| BaseTimer: |
| methods: |
| - clear |
| - set |
| BasicLoggingService: |
| methods: |
| - Logging |
| BasicProvisionService: |
| methods: |
| - GetProvisionInfo |
| BatchConverter: |
| methods: |
| - batch_type |
| - combine_batches |
| - element_type |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| - register |
| BatchCreateBitbucketServerConnectedRepositoriesRequest: |
| properties: |
| - requests |
| BatchCreateBitbucketServerConnectedRepositoriesResponse: |
| properties: |
| - bitbucketServerConnectedRepositories |
| BatchCreateBitbucketServerConnectedRepositoriesResponseMetadata: |
| properties: |
| - completeTime |
| - config |
| - createTime |
| BatchDoFn: |
| methods: |
| - process_batch |
| BatchElements: |
| methods: |
| - expand |
| BatchGlobalTriggerDriver: |
| methods: |
| - process_elements |
| - process_timer |
| properties: |
| - GLOBAL_WINDOW_TUPLE |
| - ONLY_FIRING |
| BatchingPreference: |
| methods: |
| - requires_batches |
| - supports_batches |
| - supports_elements |
| properties: |
| - BATCH_FORBIDDEN |
| - BATCH_REQUIRED |
| - DO_NOT_CARE |
| BatchRowsAsDataFrame: |
| methods: |
| - expand |
| BatchToElementDoFn: |
| methods: |
| - process_batch |
| BeamAssertException: {} |
| BeamDataframeDoctestRunner: |
| methods: |
| - fake_pandas_module |
| - report_success |
| - run |
| - summarize |
| - summary |
| BeamDeprecationWarning: {} |
| BeamError: {} |
| BeamFilesystemHandler: |
| methods: |
| - file_reader |
| - file_writer |
| BeamFnControlServicer: |
| methods: |
| - Control |
| BeamFnDataServicer: |
| methods: |
| - Data |
| - get_conn_by_worker_id |
| BeamFnExternalWorkerPoolServicer: |
| methods: |
| - start |
| - StartWorker |
| - StopWorker |
| BeamFnLoggingServicer: |
| methods: |
| - Logging |
| BeamFnStatusServicer: |
| methods: |
| - WorkerStatus |
| BeamIOError: {} |
| BeamJarExpansionService: {} |
| BeamJob: |
| methods: |
| - artifact_staging_endpoint |
| - cancel |
| - get_message_stream |
| - get_state_stream |
| - pipeline_options |
| - prepare |
| - run |
| - set_state |
| BeamPlugin: |
| methods: |
| - get_all_plugin_paths |
| - get_all_subclasses |
| BeamSchemaConversionDoFn: |
| methods: |
| - infer_output_type |
| - process |
| BeamSqlMagics: |
| methods: |
| - beam_sql |
| BeamSqlParser: |
| methods: |
| - parse |
| - print_help |
| BeamTransformFactory: |
| methods: |
| - augment_oldstyle_op |
| - create_operation |
| - extract_timers_info |
| - get_coder |
| - get_input_coders |
| - get_input_windowing |
| - get_only_input_coder |
| - get_only_output_coder |
| - get_output_coders |
| - get_windowed_coder |
| - register_urn |
| BenchmarkConfig: |
| properties: |
| - benchmark |
| - num_runs |
| - size |
| Bid: |
| properties: |
| - CODER |
| BidByAuctionIdFn: |
| methods: |
| - process |
| BidCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| BidCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| BigIntegerCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| BigIntegerCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| BigQueryBatchFileLoads: |
| methods: |
| - expand |
| - verify |
| properties: |
| - COUNT |
| - DESTINATION_COPY_JOBID_PAIRS |
| - DESTINATION_FILE_PAIRS |
| - DESTINATION_JOBID_PAIRS |
| BigQueryClient: |
| methods: |
| - save |
| BigqueryDatasetsDeleteRequest: |
| properties: |
| - datasetId |
| - deleteContents |
| - projectId |
| BigqueryDatasetsDeleteResponse: {} |
| BigqueryDatasetsGetRequest: |
| properties: |
| - datasetId |
| - projectId |
| BigqueryDatasetsInsertRequest: |
| properties: |
| - dataset |
| - projectId |
| BigqueryDatasetsListRequest: |
| properties: |
| - all |
| - filter |
| - maxResults |
| - pageToken |
| - projectId |
| BigqueryDatasetsPatchRequest: |
| properties: |
| - dataset |
| - datasetId |
| - projectId |
| BigqueryDatasetsUpdateRequest: |
| properties: |
| - dataset |
| - datasetId |
| - projectId |
| BigQueryDisposition: |
| methods: |
| - validate_create |
| - validate_write |
| properties: |
| - CREATE_IF_NEEDED |
| - CREATE_NEVER |
| - WRITE_APPEND |
| - WRITE_EMPTY |
| - WRITE_TRUNCATE |
| BigQueryFileLoadsIntegrationTests: |
| methods: |
| - setUp |
| - tearDown |
| - test_avro_file_load |
| properties: |
| - BIG_QUERY_DATASET_ID |
| BigQueryFileLoadsIT: |
| methods: |
| - setUp |
| - tearDown |
| - test_bqfl_streaming |
| - test_bqfl_streaming_with_copy_jobs |
| - test_bqfl_streaming_with_dynamic_destinations |
| - test_multiple_destinations_transform |
| - test_one_job_fails_all_jobs_fail |
| properties: |
| - BIG_QUERY_DATASET_ID |
| - BIG_QUERY_SCHEMA |
| - BIG_QUERY_SCHEMA_2 |
| - BIG_QUERY_STREAMING_SCHEMA |
| BigqueryFullResultMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| BigqueryFullResultStreamingMatcher: |
| properties: |
| - DEFAULT_TIMEOUT |
| BigQueryIODetails: |
| properties: |
| - dataset |
| - projectId |
| - query |
| - table |
| BigQueryIOMetadata: |
| methods: |
| - add_additional_bq_job_labels |
| BigqueryIOReadIT: |
| methods: |
| - run_bigquery_io_read_pipeline |
| - test_bigquery_read_1M_python |
| - test_bigquery_read_custom_1M_python |
| properties: |
| - DEFAULT_DATASET |
| - DEFAULT_TABLE_PREFIX |
| - NUM_RECORDS |
| BigqueryJobsCancelRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| BigqueryJobsGetQueryResultsRequest: |
| properties: |
| - jobId |
| - location |
| - maxResults |
| - pageToken |
| - projectId |
| - startIndex |
| - timeoutMs |
| BigqueryJobsGetRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| BigqueryJobsInsertRequest: |
| properties: |
| - job |
| - projectId |
| BigqueryJobsListRequest: |
| properties: |
| - allUsers |
| - maxCreationTime |
| - maxResults |
| - minCreationTime |
| - pageToken |
| - parentJobId |
| - projectId |
| - projection |
| - stateFilter |
| BigqueryJobsQueryRequest: |
| properties: |
| - projectId |
| - queryRequest |
| BigQueryJobTypes: |
| properties: |
| - COPY |
| - EXPORT |
| - LOAD |
| - QUERY |
| BigQueryJsonIT: |
| methods: |
| - generate_data |
| - generate_query_data |
| - generate_schema |
| - read_and_validate_rows |
| - run_test_write |
| - setUpClass |
| - test_direct_read |
| - test_export_read |
| - test_file_loads_write |
| - test_query_read |
| - test_streaming_inserts |
| BigqueryMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| BigQueryMetricsFetcher: |
| methods: |
| - fetch |
| BigQueryMetricsPublisher: |
| methods: |
| - publish |
| BigqueryModelsDeleteRequest: |
| properties: |
| - datasetId |
| - modelId |
| - projectId |
| BigqueryModelsDeleteResponse: {} |
| BigqueryModelsGetRequest: |
| properties: |
| - datasetId |
| - modelId |
| - projectId |
| BigqueryModelsListRequest: |
| properties: |
| - datasetId |
| - maxResults |
| - pageToken |
| - projectId |
| BigqueryModelsPatchRequest: |
| properties: |
| - datasetId |
| - model |
| - modelId |
| - projectId |
| BigQueryModelTraining: |
| properties: |
| - currentIteration |
| - expectedTotalIterations |
| BigqueryProjectsGetServiceAccountRequest: |
| properties: |
| - projectId |
| BigqueryProjectsListRequest: |
| properties: |
| - maxResults |
| - pageToken |
| BigQueryQueryPriority: |
| properties: |
| - BATCH |
| - INTERACTIVE |
| BigQueryQueryToTableIT: |
| methods: |
| - setUp |
| - tearDown |
| - test_big_query_legacy_sql |
| - test_big_query_new_types |
| - test_big_query_new_types_avro |
| - test_big_query_standard_sql |
| BigQueryReadIntegrationTests: |
| methods: |
| - setUpClass |
| - tearDownClass |
| properties: |
| - BIG_QUERY_DATASET_ID |
| BigqueryRoutinesDeleteRequest: |
| properties: |
| - datasetId |
| - projectId |
| - routineId |
| BigqueryRoutinesDeleteResponse: {} |
| BigqueryRoutinesGetRequest: |
| properties: |
| - datasetId |
| - projectId |
| - readMask |
| - routineId |
| BigqueryRoutinesInsertRequest: |
| properties: |
| - datasetId |
| - projectId |
| - routine |
| BigqueryRoutinesListRequest: |
| properties: |
| - datasetId |
| - filter |
| - maxResults |
| - pageToken |
| - projectId |
| - readMask |
| BigqueryRoutinesUpdateRequest: |
| properties: |
| - datasetId |
| - projectId |
| - routine |
| - routineId |
| BigqueryRowAccessPoliciesListRequest: |
| properties: |
| - datasetId |
| - pageSize |
| - pageToken |
| - projectId |
| - tableId |
| BigQuerySideInputIT: |
| methods: |
| - setUp |
| - test_bigquery_side_input_it |
| properties: |
| - DEFAULT_OUTPUT_FILE |
| BigQueryStreamingInsertsErrorHandling: |
| methods: |
| - test_insert_all_retries_if_structured_retriable |
| - test_insert_all_retries_if_unstructured_retriable |
| - test_insert_all_unretriable_errors |
| - test_insert_all_unretriable_errors_streaming |
| BigQueryStreamingInsertTransformIntegrationTests: |
| methods: |
| - setUp |
| - tearDown |
| - test_multiple_destinations_transform |
| - test_value_provider_transform |
| properties: |
| - BIG_QUERY_DATASET_ID |
| BigQueryStreamingInsertTransformTests: |
| methods: |
| - test_dofn_client_finish_bundle_flush_called |
| - test_dofn_client_no_records |
| - test_dofn_client_process_flush_called |
| - test_dofn_client_process_performs_batching |
| - test_with_batched_input |
| BigqueryTabledataInsertAllRequest: |
| properties: |
| - datasetId |
| - projectId |
| - tableDataInsertAllRequest |
| - tableId |
| BigqueryTabledataListRequest: |
| properties: |
| - datasetId |
| - maxResults |
| - pageToken |
| - projectId |
| - selectedFields |
| - startIndex |
| - tableId |
| BigQueryTableMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| BigqueryTablesDeleteRequest: |
| properties: |
| - datasetId |
| - projectId |
| - tableId |
| BigqueryTablesDeleteResponse: {} |
| BigqueryTablesGetIamPolicyRequest: |
| properties: |
| - getIamPolicyRequest |
| - resource |
| BigqueryTablesGetRequest: |
| properties: |
| - datasetId |
| - projectId |
| - selectedFields |
| - tableId |
| BigqueryTablesInsertRequest: |
| properties: |
| - datasetId |
| - projectId |
| - table |
| BigqueryTablesListRequest: |
| properties: |
| - datasetId |
| - maxResults |
| - pageToken |
| - projectId |
| BigqueryTablesPatchRequest: |
| properties: |
| - datasetId |
| - projectId |
| - table |
| - tableId |
| BigqueryTablesSetIamPolicyRequest: |
| properties: |
| - resource |
| - setIamPolicyRequest |
| BigqueryTablesTestIamPermissionsRequest: |
| properties: |
| - resource |
| - testIamPermissionsRequest |
| BigqueryTablesUpdateRequest: |
| properties: |
| - datasetId |
| - projectId |
| - table |
| - tableId |
| BigqueryTornadoesIT: |
| methods: |
| - test_bigquery_tornadoes_it |
| properties: |
| - DEFAULT_CHECKSUM |
| BigqueryV2: |
| properties: |
| - BASE_URL |
| - MESSAGES_MODULE |
| - MTLS_BASE_URL |
| BigQueryWrapper: |
| methods: |
| - clean_up_temporary_dataset |
| - convert_row_to_dict |
| - create_temporary_dataset |
| - get_job |
| - get_or_create_dataset |
| - get_or_create_table |
| - get_query_location |
| - get_table |
| - get_table_location |
| - insert_rows |
| - is_user_configured_dataset |
| - perform_extract_job |
| - perform_load_job |
| - run_query |
| - unique_row_id |
| - wait_for_bq_job |
| properties: |
| - HISTOGRAM_METRIC_LOGGER |
| - TEMP_DATASET |
| - TEMP_TABLE |
| BigQueryWriteFn: |
| methods: |
| - display_data |
| - finish_bundle |
| - get_table_schema |
| - process |
| - start_bundle |
| properties: |
| - DEFAULT_MAX_BATCH_SIZE |
| - DEFAULT_MAX_BUFFERED_ROWS |
| - FAILED_ROWS |
| - FAILED_ROWS_WITH_ERRORS |
| - STREAMING_API_LOGGING_FREQUENCY_SEC |
| BigQueryWriteIntegrationTests: |
| methods: |
| - create_table |
| - setUp |
| - tearDown |
| - test_big_query_write |
| - test_big_query_write_insert_errors_reporting |
| - test_big_query_write_new_types |
| - test_big_query_write_schema_autodetect |
| - test_big_query_write_temp_table_append_schema_update |
| - test_big_query_write_without_schema |
| properties: |
| - BIG_QUERY_DATASET_ID |
| BigtableColumn: |
| properties: |
| - encoding |
| - fieldName |
| - onlyReadLatest |
| - qualifierEncoded |
| - qualifierString |
| - type |
| BigtableColumnFamily: |
| properties: |
| - columns |
| - encoding |
| - familyId |
| - onlyReadLatest |
| - type |
| BigTableIODetails: |
| properties: |
| - instanceId |
| - projectId |
| - tableId |
| BigtableOptions: |
| properties: |
| - columnFamilies |
| - ignoreUnspecifiedColumnFamilies |
| - readRowkeyAsString |
| BinaryClassificationMetrics: |
| properties: |
| - aggregateClassificationMetrics |
| - binaryConfusionMatrixList |
| - negativeLabel |
| - positiveLabel |
| BinaryConfusionMatrix: |
| properties: |
| - accuracy |
| - f1Score |
| - falseNegatives |
| - falsePositives |
| - positiveClassThreshold |
| - precision |
| - recall |
| - trueNegatives |
| - truePositives |
| Binding: |
| properties: |
| - condition |
| - members |
| - role |
| BitbucketServerConfig: |
| properties: |
| - apiKey |
| - connectedRepositories |
| - createTime |
| - hostUri |
| - name |
| - peeredNetwork |
| - secrets |
| - sslCa |
| - username |
| - webhookKey |
| BitbucketServerConnectedRepository: |
| properties: |
| - parent |
| - repo |
| - status |
| BitbucketServerRepository: |
| properties: |
| - browseUri |
| - description |
| - displayName |
| - name |
| - repoId |
| BitbucketServerRepositoryId: |
| properties: |
| - projectKey |
| - repoSlug |
| - webhookId |
| BitbucketServerSecrets: |
| properties: |
| - adminAccessTokenVersionName |
| - readAccessTokenVersionName |
| - webhookSecretVersionName |
| BitbucketServerTriggerConfig: |
| properties: |
| - bitbucketServerConfig |
| - bitbucketServerConfigResource |
| - projectKey |
| - pullRequest |
| - push |
| - repoSlug |
| BitcoinTxnCountDoFn: |
| methods: |
| - process |
| Blob: {} |
| BlobStorageDownloader: |
| methods: |
| - get_range |
| - size |
| BlobStorageError: {} |
| BlobStorageFileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| properties: |
| - AZURE_FILE_SYSTEM_PREFIX |
| - CHUNK_SIZE |
| BlobStorageIO: |
| methods: |
| - checksum |
| - copy |
| - copy_paths |
| - copy_tree |
| - delete |
| - delete_files |
| - delete_paths |
| - delete_tree |
| - exists |
| - last_updated |
| - list_files |
| - list_prefix |
| - open |
| - rename |
| - rename_files |
| - size |
| BlobStorageIOError: {} |
| BlobStorageUploader: |
| methods: |
| - finish |
| - put |
| BooleanCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| BooleanCoderImpl: |
| methods: |
| - decode |
| - decode_from_stream |
| - encode |
| - encode_to_stream |
| - estimate_size |
| BoundedSource: |
| methods: |
| - default_output_coder |
| - estimate_size |
| - get_range_tracker |
| - is_bounded |
| - read |
| - split |
| BoundedWindow: |
| methods: |
| - end |
| - max_timestamp |
| - start |
| BoundMethod: {} |
| BqmlIterationResult: |
| properties: |
| - durationMs |
| - evalLoss |
| - index |
| - learnRate |
| - trainingLoss |
| BqmlTrainingRun: |
| properties: |
| - iterationResults |
| - startTime |
| - state |
| - trainingOptions |
| Breakfast: {} |
| Bucket: |
| properties: |
| - acl |
| - billing |
| - cors |
| - defaultEventBasedHold |
| - defaultObjectAcl |
| - encryption |
| - etag |
| - id |
| - kind |
| - labels |
| - lifecycle |
| - location |
| - logging |
| - metageneration |
| - name |
| - owner |
| - projectNumber |
| - retentionPolicy |
| - selfLink |
| - storageClass |
| - timeCreated |
| - updated |
| - versioning |
| - website |
| BucketAccessControl: |
| properties: |
| - bucket |
| - domain |
| - email |
| - entity |
| - entityId |
| - etag |
| - id |
| - kind |
| - projectTeam |
| - role |
| - selfLink |
| BucketAccessControls: |
| properties: |
| - items |
| - kind |
| Buckets: |
| properties: |
| - items |
| - kind |
| - nextPageToken |
| BucketType: |
| methods: |
| - accumulated_bucket_size |
| - bucket_index |
| - bucket_size |
| - num_buckets |
| - range_from |
| - range_to |
| Buffer: |
| methods: |
| - append |
| - extend |
| build: |
| properties: |
| - sub_commands |
| Build: |
| properties: |
| - approval |
| - artifacts |
| - availableSecrets |
| - buildTriggerId |
| - createTime |
| - failureInfo |
| - finishTime |
| - id |
| - images |
| - logsBucket |
| - logUrl |
| - name |
| - options |
| - projectId |
| - queueTtl |
| - results |
| - secrets |
| - serviceAccount |
| - source |
| - sourceProvenance |
| - startTime |
| - status |
| - statusDetail |
| - steps |
| - substitutions |
| - tags |
| - timeout |
| - timing |
| - warnings |
| BuildApproval: |
| properties: |
| - config |
| - result |
| - state |
| BuildOperationMetadata: |
| properties: |
| - build |
| BuildOptions: |
| properties: |
| - diskSizeGb |
| - dynamicSubstitutions |
| - env |
| - logging |
| - logStreamingOption |
| - machineType |
| - pool |
| - requestedVerifyOption |
| - secretEnv |
| - sourceProvenanceHash |
| - substitutionOption |
| - volumes |
| - workerPool |
| BuildStep: |
| properties: |
| - args |
| - dir |
| - entrypoint |
| - env |
| - id |
| - name |
| - pullTiming |
| - script |
| - secretEnv |
| - status |
| - timeout |
| - timing |
| - volumes |
| - waitFor |
| BuildTrigger: |
| properties: |
| - approvalConfig |
| - autodetect |
| - bitbucketServerTriggerConfig |
| - build |
| - createTime |
| - description |
| - disabled |
| - eventType |
| - filename |
| - filter |
| - gitFileSource |
| - github |
| - id |
| - ignoredFiles |
| - includedFiles |
| - name |
| - pubsubConfig |
| - resourceName |
| - serviceAccount |
| - sourceToBuild |
| - substitutions |
| - tags |
| - triggerTemplate |
| - webhookConfig |
| BuiltImage: |
| properties: |
| - digest |
| - name |
| - pushTiming |
| BundleBasedDirectRunner: |
| methods: |
| - is_fnapi_compatible |
| - run_pipeline |
| BundleContextManager: |
| methods: |
| - data_api_service_descriptor |
| - get_buffer |
| - get_coder_impl |
| - get_input_coder_impl |
| - get_timer_coder_impl |
| - input_for |
| - process_bundle_descriptor |
| - state_api_service_descriptor |
| - worker_handlers |
| BundleFactory: |
| methods: |
| - create_bundle |
| - create_empty_committed_bundle |
| BundleManager: |
| methods: |
| - process_bundle |
| BundleProcessor: |
| methods: |
| - bundle_application |
| - construct_bundle_application |
| - create_execution_tree |
| - delayed_bundle_application |
| - finalize_bundle |
| - monitoring_infos |
| - process_bundle |
| - requires_finalization |
| - reset |
| - shutdown |
| - try_split |
| BundleProcessorCache: |
| methods: |
| - activate |
| - discard |
| - get |
| - lookup |
| - register |
| - release |
| - shutdown |
| properties: |
| - periodic_shutdown |
| ByteCountingOutputStream: |
| methods: |
| - get |
| - get_count |
| - write |
| - write_byte |
| BytesCoder: |
| methods: |
| - as_cloud_object |
| - is_deterministic |
| - to_type_hint |
| BytesCoderImpl: |
| methods: |
| - decode |
| - decode_from_stream |
| - encode |
| - encode_to_stream |
| Cacheable: |
| methods: |
| - from_pcoll |
| - to_key |
| properties: |
| - pcoll |
| - producer_version |
| - var |
| - version |
| CacheAware: |
| methods: |
| - get_referents_for_cache |
| CacheKey: |
| methods: |
| - from_pcoll |
| - from_str |
| - to_str |
| properties: |
| - pipeline_id |
| - producer_version |
| - var |
| - version |
| CacheManager: |
| methods: |
| - cleanup |
| - clear |
| - exists |
| - is_latest_version |
| - load_pcoder |
| - read |
| - save_pcoder |
| - sink |
| - size |
| - source |
| - write |
| CachingStateHandler: |
| methods: |
| - blocking_get |
| - clear |
| - done |
| - extend |
| - process_instruction_id |
| CalculateSpammyUsers: |
| methods: |
| - expand |
| properties: |
| - SCORE_WEIGHT |
| CalculateTeamScores: |
| methods: |
| - expand |
| CalculateUserScores: |
| methods: |
| - expand |
| CallableWrapperCombineFn: |
| methods: |
| - add_input |
| - add_inputs |
| - compact |
| - create_accumulator |
| - default_type_hints |
| - display_data |
| - extract_output |
| - for_input_type |
| - infer_output_type |
| - merge_accumulators |
| CallableWrapperDoFn: |
| methods: |
| - default_type_hints |
| - display_data |
| - infer_output_type |
| CallableWrapperPartitionFn: |
| methods: |
| - partition_for |
| CallbackCoderImpl: |
| methods: |
| - decode |
| - decode_from_stream |
| - encode |
| - encode_to_stream |
| - estimate_size |
| - get_estimated_size_and_observables |
| CallSequenceEnforcingCombineFn: |
| methods: |
| - add_input |
| - add_inputs |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| - setup |
| - teardown |
| properties: |
| - instances |
| CallSequenceEnforcingDoFn: |
| methods: |
| - finish_bundle |
| - process |
| - setup |
| - start_bundle |
| - teardown |
| CancelBuildRequest: |
| properties: |
| - id |
| - name |
| - projectId |
| CancelOperationRequest: {} |
| CaptureControl: |
| methods: |
| - limiters |
| - set_limiters_for_test |
| CategoricalValue: |
| properties: |
| - categoryCounts |
| CategoryCount: |
| properties: |
| - category |
| - count |
| Channel: |
| properties: |
| - address |
| - expiration |
| - id |
| - kind |
| - params |
| - payload |
| - resourceId |
| - resourceUri |
| - token |
| - type |
| Client: |
| methods: |
| - complete_multipart_upload |
| - copy |
| - create_multipart_upload |
| - delete |
| - delete_batch |
| - get_object_metadata |
| - get_range |
| - get_stream |
| - list |
| - upload_part |
| Clock: |
| methods: |
| - advance_time |
| - time |
| ClosableOutputStream: |
| methods: |
| - close |
| - create |
| - flush |
| - maybe_flush |
| CloudbuildLocationsRegionalWebhookRequest: |
| properties: |
| - httpBody |
| - location |
| - webhookKey |
| CloudbuildOperationsCancelRequest: |
| properties: |
| - cancelOperationRequest |
| - name |
| CloudbuildOperationsGetRequest: |
| properties: |
| - name |
| CloudbuildProjectsBuildsApproveRequest: |
| properties: |
| - approveBuildRequest |
| - name |
| CloudbuildProjectsBuildsCreateRequest: |
| properties: |
| - build |
| - parent |
| - projectId |
| CloudbuildProjectsBuildsGetRequest: |
| properties: |
| - id |
| - name |
| - projectId |
| CloudbuildProjectsBuildsListRequest: |
| properties: |
| - filter |
| - pageSize |
| - pageToken |
| - parent |
| - projectId |
| CloudbuildProjectsGithubEnterpriseConfigsCreateRequest: |
| properties: |
| - gheConfigId |
| - gitHubEnterpriseConfig |
| - parent |
| - projectId |
| CloudbuildProjectsGithubEnterpriseConfigsDeleteRequest: |
| properties: |
| - configId |
| - name |
| - projectId |
| CloudbuildProjectsGithubEnterpriseConfigsGetRequest: |
| properties: |
| - configId |
| - name |
| - projectId |
| CloudbuildProjectsGithubEnterpriseConfigsListRequest: |
| properties: |
| - parent |
| - projectId |
| CloudbuildProjectsGithubEnterpriseConfigsPatchRequest: |
| properties: |
| - gitHubEnterpriseConfig |
| - name |
| - updateMask |
| CloudbuildProjectsLocationsBitbucketServerConfigsAddBitbucketServerConnectedRepositoryRequest: |
| properties: |
| - addBitbucketServerConnectedRepositoryRequest |
| - config |
| CloudbuildProjectsLocationsBitbucketServerConfigsConnectedRepositoriesBatchCreateRequest: |
| properties: |
| - batchCreateBitbucketServerConnectedRepositoriesRequest |
| - parent |
| CloudbuildProjectsLocationsBitbucketServerConfigsCreateRequest: |
| properties: |
| - bitbucketServerConfig |
| - bitbucketServerConfigId |
| - parent |
| CloudbuildProjectsLocationsBitbucketServerConfigsDeleteRequest: |
| properties: |
| - name |
| CloudbuildProjectsLocationsBitbucketServerConfigsGetRequest: |
| properties: |
| - name |
| CloudbuildProjectsLocationsBitbucketServerConfigsListRequest: |
| properties: |
| - pageSize |
| - pageToken |
| - parent |
| CloudbuildProjectsLocationsBitbucketServerConfigsPatchRequest: |
| properties: |
| - bitbucketServerConfig |
| - name |
| - updateMask |
| CloudbuildProjectsLocationsBitbucketServerConfigsRemoveBitbucketServerConnectedRepositoryRequest: |
| properties: |
| - config |
| - removeBitbucketServerConnectedRepositoryRequest |
| CloudbuildProjectsLocationsBitbucketServerConfigsReposListRequest: |
| properties: |
| - pageSize |
| - pageToken |
| - parent |
| CloudbuildProjectsLocationsBuildsApproveRequest: |
| properties: |
| - approveBuildRequest |
| - name |
| CloudbuildProjectsLocationsBuildsCreateRequest: |
| properties: |
| - build |
| - parent |
| - projectId |
| CloudbuildProjectsLocationsBuildsGetRequest: |
| properties: |
| - id |
| - name |
| - projectId |
| CloudbuildProjectsLocationsBuildsListRequest: |
| properties: |
| - filter |
| - pageSize |
| - pageToken |
| - parent |
| - projectId |
| CloudbuildProjectsLocationsGithubEnterpriseConfigsCreateRequest: |
| properties: |
| - gheConfigId |
| - gitHubEnterpriseConfig |
| - parent |
| - projectId |
| CloudbuildProjectsLocationsGithubEnterpriseConfigsDeleteRequest: |
| properties: |
| - configId |
| - name |
| - projectId |
| CloudbuildProjectsLocationsGithubEnterpriseConfigsGetRequest: |
| properties: |
| - configId |
| - name |
| - projectId |
| CloudbuildProjectsLocationsGithubEnterpriseConfigsListRequest: |
| properties: |
| - parent |
| - projectId |
| CloudbuildProjectsLocationsGithubEnterpriseConfigsPatchRequest: |
| properties: |
| - gitHubEnterpriseConfig |
| - name |
| - updateMask |
| CloudbuildProjectsLocationsOperationsCancelRequest: |
| properties: |
| - cancelOperationRequest |
| - name |
| CloudbuildProjectsLocationsOperationsGetRequest: |
| properties: |
| - name |
| CloudbuildProjectsLocationsTriggersCreateRequest: |
| properties: |
| - buildTrigger |
| - parent |
| - projectId |
| CloudbuildProjectsLocationsTriggersDeleteRequest: |
| properties: |
| - name |
| - projectId |
| - triggerId |
| CloudbuildProjectsLocationsTriggersGetRequest: |
| properties: |
| - name |
| - projectId |
| - triggerId |
| CloudbuildProjectsLocationsTriggersListRequest: |
| properties: |
| - pageSize |
| - pageToken |
| - parent |
| - projectId |
| CloudbuildProjectsLocationsTriggersPatchRequest: |
| properties: |
| - buildTrigger |
| - projectId |
| - resourceName |
| - triggerId |
| CloudbuildProjectsLocationsTriggersRunRequest: |
| properties: |
| - name |
| - runBuildTriggerRequest |
| CloudbuildProjectsLocationsTriggersWebhookRequest: |
| properties: |
| - httpBody |
| - name |
| - projectId |
| - secret |
| - trigger |
| CloudbuildProjectsLocationsWorkerPoolsCreateRequest: |
| properties: |
| - parent |
| - validateOnly |
| - workerPool |
| - workerPoolId |
| CloudbuildProjectsLocationsWorkerPoolsDeleteRequest: |
| properties: |
| - allowMissing |
| - etag |
| - name |
| - validateOnly |
| CloudbuildProjectsLocationsWorkerPoolsGetRequest: |
| properties: |
| - name |
| CloudbuildProjectsLocationsWorkerPoolsListRequest: |
| properties: |
| - pageSize |
| - pageToken |
| - parent |
| CloudbuildProjectsLocationsWorkerPoolsPatchRequest: |
| properties: |
| - name |
| - updateMask |
| - validateOnly |
| - workerPool |
| CloudbuildProjectsTriggersCreateRequest: |
| properties: |
| - buildTrigger |
| - parent |
| - projectId |
| CloudbuildProjectsTriggersDeleteRequest: |
| properties: |
| - name |
| - projectId |
| - triggerId |
| CloudbuildProjectsTriggersGetRequest: |
| properties: |
| - name |
| - projectId |
| - triggerId |
| CloudbuildProjectsTriggersListRequest: |
| properties: |
| - pageSize |
| - pageToken |
| - parent |
| - projectId |
| CloudbuildProjectsTriggersPatchRequest: |
| properties: |
| - buildTrigger |
| - projectId |
| - triggerId |
| CloudbuildProjectsTriggersRunRequest: |
| properties: |
| - name |
| - projectId |
| - repoSource |
| - triggerId |
| CloudbuildProjectsTriggersWebhookRequest: |
| properties: |
| - httpBody |
| - name |
| - projectId |
| - secret |
| - trigger |
| CloudbuildV1: |
| properties: |
| - BASE_URL |
| - MESSAGES_MODULE |
| - MTLS_BASE_URL |
| CloudbuildWebhookRequest: |
| properties: |
| - httpBody |
| - webhookKey |
| CloudDLPIT: |
| methods: |
| - setUp |
| - test_deidentification |
| - test_inspection |
| Cluster: |
| properties: |
| - centroidId |
| - count |
| - featureValues |
| ClusterInfo: |
| properties: |
| - centroidId |
| - clusterRadius |
| - clusterSize |
| Clustering: |
| properties: |
| - fields |
| ClusteringMetrics: |
| properties: |
| - clusters |
| - daviesBouldinIndex |
| - meanSquaredDistance |
| ClusterMetadata: |
| methods: |
| - reset_name |
| properties: |
| - cluster_name |
| - dashboard |
| - machine_type |
| - master_url |
| - num_workers |
| - project_id |
| - region |
| - subnetwork |
| Clusters: |
| methods: |
| - cleanup |
| - cluster_metadata |
| - create |
| - describe |
| - set_default_cluster |
| properties: |
| - DATAPROC_FLINK_VERSION |
| - DATAPROC_MINIMUM_WORKER_NUM |
| Coder: |
| methods: |
| - as_cloud_object |
| - as_deterministic_coder |
| - decode |
| - decode_nested |
| - encode |
| - encode_nested |
| - estimate_size |
| - from_runner_api |
| - from_type_hint |
| - get_impl |
| - is_deterministic |
| - is_kv_coder |
| - key_coder |
| - register_structured_urn |
| - register_urn |
| - register_urn |
| - register_urn |
| - to_runner_api |
| - to_runner_api_parameter |
| - to_type_hint |
| - value_coder |
| CoderImpl: |
| methods: |
| - decode |
| - decode_all |
| - decode_from_stream |
| - decode_nested |
| - encode |
| - encode_all |
| - encode_nested |
| - encode_to_stream |
| - estimate_size |
| - get_estimated_size_and_observables |
| CoderRegistry: |
| methods: |
| - get_coder |
| - get_custom_type_coder_tuples |
| - register_coder |
| - register_fallback_coder |
| - register_standard_coders |
| - verify_deterministic |
| CodersIT: |
| methods: |
| - test_coders_output_files_on_small_input |
| properties: |
| - EXPECTED_RESULT |
| - SAMPLE_RECORDS |
| CoGBKTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| CoGroupByKey: |
| methods: |
| - expand |
| CollectingFn: |
| methods: |
| - process |
| properties: |
| - BUFFER_STATE |
| - COUNT_STATE |
| CombineFn: |
| methods: |
| - add_input |
| - add_inputs |
| - apply |
| - compact |
| - create_accumulator |
| - default_label |
| - extract_output |
| - for_input_type |
| - from_callable |
| - get_accumulator_coder |
| - maybe_from_callable |
| - merge_accumulators |
| - setup |
| - teardown |
| CombineGlobally: |
| methods: |
| - as_singleton_view |
| - default_label |
| - display_data |
| - expand |
| - from_runner_api_parameter |
| - with_defaults |
| - with_fanout |
| - without_defaults |
| properties: |
| - as_view |
| - fanout |
| - has_defaults |
| CombineGloballyTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| CombineOperation: |
| methods: |
| - finish |
| - process |
| - setup |
| - teardown |
| CombinePerKey: |
| methods: |
| - default_label |
| - default_type_hints |
| - display_data |
| - expand |
| - from_runner_api_parameter |
| - make_fn |
| - runner_api_requires_keyed_input |
| - to_runner_api_parameter |
| - with_hot_key_fanout |
| CombinePerKeyTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| CombinerWithoutDefaults: |
| methods: |
| - with_defaults |
| - without_defaults |
| CombineValues: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - make_fn |
| - to_runner_api_parameter |
| CombineValuesDoFn: |
| methods: |
| - default_type_hints |
| - process |
| - setup |
| - teardown |
| CombineValuesPTransformOverride: |
| methods: |
| - get_replacement_transform |
| - matches |
| CombiningTriggerDriver: |
| methods: |
| - process_elements |
| - process_timer |
| CombiningValueRuntimeState: |
| methods: |
| - add |
| - clear |
| - commit |
| - finalize |
| - read |
| CombiningValueStateSpec: |
| methods: |
| - to_runner_api |
| Command: |
| methods: |
| - run |
| ComparableValue: |
| methods: |
| - hydrate |
| CompleteMultipartUploadRequest: {} |
| ComplexSchema: |
| properties: |
| - array_optional |
| - id |
| - name |
| - optional_array |
| - optional_map |
| - timestamp |
| ComponentIdMap: |
| methods: |
| - get_or_assign |
| ComponentSource: |
| properties: |
| - name |
| - originalTransformOrCollection |
| - userName |
| ComponentTransform: |
| properties: |
| - name |
| - originalTransform |
| - userName |
| ComposeRequest: |
| properties: |
| - destination |
| - kind |
| - sourceObjects |
| CompositeTypeHint: {} |
| CompositeTypeHintError: {} |
| CompressedFile: |
| methods: |
| - close |
| - closed |
| - flush |
| - read |
| - readable |
| - readline |
| - seek |
| - seekable |
| - tell |
| - write |
| - writeable |
| CompressionTypes: |
| methods: |
| - detect_compression_type |
| - is_valid_compression_type |
| - mime_type |
| properties: |
| - AUTO |
| - BZIP2 |
| - DEFLATE |
| - GZIP |
| - UNCOMPRESSED |
| - ZSTD |
| ComputationTopology: |
| properties: |
| - computationId |
| - inputs |
| - keyRanges |
| - outputs |
| - stateFamilies |
| - systemStageName |
| ComputedExpression: |
| methods: |
| - args |
| - evaluate_at |
| - placeholders |
| - preserves_partition_by |
| - requires_partition_by |
| ComputeSessions: |
| methods: |
| - expand |
| ComputeTopSessions: |
| methods: |
| - expand |
| ComputeTopSessionsIT: |
| methods: |
| - test_top_wikipedia_sessions_output_files_on_small_input |
| properties: |
| - EDITS |
| - EXPECTED |
| ConcatPosition: {} |
| ConcatRangeTracker: |
| methods: |
| - fraction_consumed |
| - global_to_local |
| - local_to_global |
| - position_at_fraction |
| - set_current_position |
| - start_position |
| - stop_position |
| - sub_range_tracker |
| - try_claim |
| - try_split |
| ConcatSource: |
| methods: |
| - default_output_coder |
| - estimate_size |
| - get_range_tracker |
| - read |
| - sources |
| - split |
| ConfusionMatrix: |
| properties: |
| - confidenceThreshold |
| - rows |
| ConnectionProperty: |
| properties: |
| - key |
| - value |
| ConsoleMetricsPublisher: |
| methods: |
| - publish |
| Const: |
| methods: |
| - unwrap |
| - unwrap_all |
| ConstantExpression: |
| methods: |
| - args |
| - evaluate_at |
| - placeholders |
| - preserves_partition_by |
| - requires_partition_by |
| ConsumerSet: |
| methods: |
| - create |
| - current_element_progress |
| - try_split |
| - update_counters_batch |
| - update_counters_finish |
| - update_counters_start |
| ConsumerTrackingPipelineVisitor: |
| methods: |
| - views |
| - visit_transform |
| ContainerSpec: |
| properties: |
| - defaultEnvironment |
| - image |
| - metadata |
| - sdkInfo |
| ControlConnection: |
| methods: |
| - abort |
| - close |
| - get_req |
| - push |
| - push |
| - push |
| - set_input |
| ControlFuture: |
| methods: |
| - abort |
| - get |
| - is_done |
| - set |
| ConvertToPubSubMessage: |
| methods: |
| - process |
| CopyRequest: {} |
| CorruptMainSessionException: {} |
| Count: |
| methods: |
| - expand |
| Count1: |
| methods: |
| - expand |
| CountAccumulator: |
| methods: |
| - add_input |
| - add_input_n |
| - extract_output |
| - merge |
| CountAndLog: |
| methods: |
| - expand |
| CountCombineFn: |
| methods: |
| - add_input |
| - add_inputs |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| Counter: |
| methods: |
| - error |
| - get |
| - increment |
| CounterAggregator: |
| methods: |
| - combine |
| - identity_element |
| - result |
| CounterCell: |
| methods: |
| - combine |
| - dec |
| - get_cumulative |
| - inc |
| - reset |
| - to_runner_api_monitoring_info_impl |
| - update |
| CounterFactory: |
| methods: |
| - get_counter |
| - get_counters |
| - reset |
| CounterMetadata: |
| properties: |
| - description |
| - kind |
| - otherUnits |
| - standardUnits |
| CounterMetric: {} |
| CounterName: |
| properties: |
| - SYSTEM |
| - USER |
| CounterStructuredName: |
| properties: |
| - componentStepName |
| - executionStepName |
| - inputIndex |
| - name |
| - origin |
| - originalRequestingStepName |
| - originalStepName |
| - originNamespace |
| - portion |
| - workerId |
| CounterStructuredNameAndMetadata: |
| properties: |
| - metadata |
| - name |
| CounterUpdate: |
| properties: |
| - boolean |
| - cumulative |
| - distribution |
| - floatingPoint |
| - floatingPointList |
| - floatingPointMean |
| - integer |
| - integerGauge |
| - integerList |
| - integerMean |
| - internal |
| - nameAndKind |
| - shortId |
| - stringList |
| - structuredNameAndMetadata |
| CountingSource: |
| methods: |
| - estimate_size |
| - get_range_tracker |
| - read |
| - split |
| CountLimiter: |
| methods: |
| - is_triggered |
| - update |
| CountMessages: |
| methods: |
| - process |
| properties: |
| - LABEL |
| CountPerElementTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| CountWords: |
| methods: |
| - expand |
| CPUTime: |
| properties: |
| - rate |
| - timestamp |
| - totalMs |
| Create: |
| methods: |
| - apply |
| CreateBitbucketServerConfigOperationMetadata: |
| properties: |
| - bitbucketServerConfig |
| - completeTime |
| - createTime |
| CreateBitbucketServerConnectedRepositoryRequest: |
| properties: |
| - bitbucketServerConnectedRepository |
| - parent |
| CreateCatalogItem: |
| methods: |
| - expand |
| CreateDisposition: |
| methods: |
| - VerifyParam |
| properties: |
| - CREATE_IF_NEEDED |
| - CREATE_NEVER |
| CreateFolderFn: |
| methods: |
| - process |
| CreateGitHubEnterpriseConfigOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - githubEnterpriseConfig |
| CreateGitLabConfigOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - gitlabConfig |
| CreateGrid: |
| methods: |
| - expand |
| CreateJobFromTemplateRequest: |
| properties: |
| - environment |
| - gcsPath |
| - jobName |
| - location |
| - parameters |
| CreatePTransformOverride: |
| methods: |
| - get_replacement_transform_for_applied_ptransform |
| - matches |
| CreateTransportData: |
| methods: |
| - process |
| CreateWorkerPoolOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - workerPool |
| CrossLanguageKafkaIO: |
| methods: |
| - build_read_pipeline |
| - build_write_pipeline |
| - run_xlang_kafkaio |
| CrossLanguageOptions: {} |
| CrossLanguageTestPipelines: |
| methods: |
| - run_cogroup_by_key |
| - run_combine_globally |
| - run_combine_per_key |
| - run_flatten |
| - run_group_by_key |
| - run_multi_input_output_with_sideinput |
| - run_partition |
| - run_prefix |
| CsvOptions: |
| properties: |
| - allowJaggedRows |
| - allowQuotedNewlines |
| - encoding |
| - fieldDelimiter |
| - quote |
| - skipLeadingRows |
| CustomClass: {} |
| CustomCoder: |
| methods: |
| - decode |
| - encode |
| - is_deterministic |
| CustomCommands: |
| methods: |
| - finalize_options |
| - initialize_options |
| - run |
| - RunCustomCommand |
| CustomMergingWindowFn: |
| methods: |
| - assign |
| - get_window_coder |
| - merge |
| CustomPTransformIT: |
| methods: |
| - test_custom_ptransform_output_files_on_small_input |
| properties: |
| - EXPECTED_RESULT |
| - WORDS |
| CustomPytorchModelHandlerKeyedTensor: |
| methods: |
| - load_model |
| CustomSklearnModelHandlerNumpy: |
| methods: |
| - batch_elements_kwargs |
| - run_inference |
| CustomSourceLocation: |
| properties: |
| - stateful |
| CustomTimestampingFixedWindowsWindowFn: |
| methods: |
| - get_transformed_output_time |
| DaskBagOp: |
| methods: |
| - apply |
| - transform |
| properties: |
| - applied |
| DaskOptions: {} |
| DaskRunner: |
| methods: |
| - is_fnapi_compatible |
| - run_pipeline |
| - to_dask_bag_visitor |
| DaskRunnerResult: |
| methods: |
| - cancel |
| - metrics |
| - wait_until_finish |
| properties: |
| - client |
| - futures |
| DataChannel: |
| methods: |
| - close |
| - input_elements |
| - output_stream |
| - output_timer_stream |
| DataChannelFactory: |
| methods: |
| - close |
| - create_data_channel |
| - create_data_channel_from_url |
| DataclassBasedPayloadBuilder: {} |
| DataDiskAssignment: |
| properties: |
| - dataDisks |
| - vmInstance |
| DataflowApplicationClient: |
| methods: |
| - create_job |
| - create_job_description |
| - get_job |
| - get_job_metrics |
| - job_id_for_name |
| - list_messages |
| - modify_job_state |
| - stage_file |
| - submit_job_description |
| DataflowBeamJob: |
| methods: |
| - cancel |
| DataflowDistributionCounter: |
| methods: |
| - add_input |
| - add_input_n |
| - calculate_bucket_index |
| - extract_output |
| - merge |
| - translate_to_histogram |
| properties: |
| - BUCKET_PER_TEN |
| - MAX_BUCKET_SIZE |
| DataflowDistributionCounterFn: {} |
| DataflowJobAlreadyExistsError: {} |
| DataflowMetrics: |
| methods: |
| - all_metrics |
| - query |
| DataflowOptionsForm: |
| methods: |
| - additional_options |
| - display_actions |
| DataflowPipelineResult: |
| methods: |
| - api_jobstate_to_pipeline_state |
| - cancel |
| - has_job |
| - is_in_terminal_state |
| - job_id |
| - metrics |
| - monitoring_infos |
| - state |
| - wait_until_finish |
| DataflowProjectsDeleteSnapshotsRequest: |
| properties: |
| - location |
| - projectId |
| - snapshotId |
| DataflowProjectsJobsAggregatedRequest: |
| properties: |
| - filter |
| - location |
| - pageSize |
| - pageToken |
| - projectId |
| - view |
| DataflowProjectsJobsCreateRequest: |
| properties: |
| - job |
| - location |
| - projectId |
| - replaceJobId |
| - view |
| DataflowProjectsJobsDebugGetConfigRequest: |
| properties: |
| - getDebugConfigRequest |
| - jobId |
| - projectId |
| DataflowProjectsJobsDebugSendCaptureRequest: |
| properties: |
| - jobId |
| - projectId |
| - sendDebugCaptureRequest |
| DataflowProjectsJobsGetMetricsRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - startTime |
| DataflowProjectsJobsGetRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - view |
| DataflowProjectsJobsListRequest: |
| properties: |
| - filter |
| - location |
| - pageSize |
| - pageToken |
| - projectId |
| - view |
| DataflowProjectsJobsMessagesListRequest: |
| properties: |
| - endTime |
| - jobId |
| - location |
| - minimumImportance |
| - pageSize |
| - pageToken |
| - projectId |
| - startTime |
| DataflowProjectsJobsSnapshotRequest: |
| properties: |
| - jobId |
| - projectId |
| - snapshotJobRequest |
| DataflowProjectsJobsUpdateRequest: |
| properties: |
| - job |
| - jobId |
| - location |
| - projectId |
| DataflowProjectsJobsWorkItemsLeaseRequest: |
| properties: |
| - jobId |
| - leaseWorkItemRequest |
| - projectId |
| DataflowProjectsJobsWorkItemsReportStatusRequest: |
| properties: |
| - jobId |
| - projectId |
| - reportWorkItemStatusRequest |
| DataflowProjectsLocationsFlexTemplatesLaunchRequest: |
| properties: |
| - launchFlexTemplateRequest |
| - location |
| - projectId |
| DataflowProjectsLocationsJobsCreateRequest: |
| properties: |
| - job |
| - location |
| - projectId |
| - replaceJobId |
| - view |
| DataflowProjectsLocationsJobsDebugGetConfigRequest: |
| properties: |
| - getDebugConfigRequest |
| - jobId |
| - location |
| - projectId |
| DataflowProjectsLocationsJobsDebugSendCaptureRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - sendDebugCaptureRequest |
| DataflowProjectsLocationsJobsGetExecutionDetailsRequest: |
| properties: |
| - jobId |
| - location |
| - pageSize |
| - pageToken |
| - projectId |
| DataflowProjectsLocationsJobsGetMetricsRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - startTime |
| DataflowProjectsLocationsJobsGetRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - view |
| DataflowProjectsLocationsJobsListRequest: |
| properties: |
| - filter |
| - location |
| - pageSize |
| - pageToken |
| - projectId |
| - view |
| DataflowProjectsLocationsJobsMessagesListRequest: |
| properties: |
| - endTime |
| - jobId |
| - location |
| - minimumImportance |
| - pageSize |
| - pageToken |
| - projectId |
| - startTime |
| DataflowProjectsLocationsJobsSnapshotRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - snapshotJobRequest |
| DataflowProjectsLocationsJobsSnapshotsListRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| DataflowProjectsLocationsJobsStagesGetExecutionDetailsRequest: |
| properties: |
| - endTime |
| - jobId |
| - location |
| - pageSize |
| - pageToken |
| - projectId |
| - stageId |
| - startTime |
| DataflowProjectsLocationsJobsUpdateRequest: |
| properties: |
| - job |
| - jobId |
| - location |
| - projectId |
| DataflowProjectsLocationsJobsWorkItemsLeaseRequest: |
| properties: |
| - jobId |
| - leaseWorkItemRequest |
| - location |
| - projectId |
| DataflowProjectsLocationsJobsWorkItemsReportStatusRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| - reportWorkItemStatusRequest |
| DataflowProjectsLocationsSnapshotsDeleteRequest: |
| properties: |
| - location |
| - projectId |
| - snapshotId |
| DataflowProjectsLocationsSnapshotsGetRequest: |
| properties: |
| - location |
| - projectId |
| - snapshotId |
| DataflowProjectsLocationsSnapshotsListRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| DataflowProjectsLocationsSqlValidateRequest: |
| properties: |
| - location |
| - projectId |
| - query |
| DataflowProjectsLocationsTemplatesCreateRequest: |
| properties: |
| - createJobFromTemplateRequest |
| - location |
| - projectId |
| DataflowProjectsLocationsTemplatesGetRequest: |
| properties: |
| - gcsPath |
| - location |
| - projectId |
| - view |
| DataflowProjectsLocationsTemplatesLaunchRequest: |
| properties: |
| - dynamicTemplate_gcsPath |
| - dynamicTemplate_stagingLocation |
| - gcsPath |
| - launchTemplateParameters |
| - location |
| - projectId |
| - validateOnly |
| DataflowProjectsLocationsWorkerMessagesRequest: |
| properties: |
| - location |
| - projectId |
| - sendWorkerMessagesRequest |
| DataflowProjectsSnapshotsGetRequest: |
| properties: |
| - location |
| - projectId |
| - snapshotId |
| DataflowProjectsSnapshotsListRequest: |
| properties: |
| - jobId |
| - location |
| - projectId |
| DataflowProjectsTemplatesCreateRequest: |
| properties: |
| - createJobFromTemplateRequest |
| - projectId |
| DataflowProjectsTemplatesGetRequest: |
| properties: |
| - gcsPath |
| - location |
| - projectId |
| - view |
| DataflowProjectsTemplatesLaunchRequest: |
| properties: |
| - dynamicTemplate_gcsPath |
| - dynamicTemplate_stagingLocation |
| - gcsPath |
| - launchTemplateParameters |
| - location |
| - projectId |
| - validateOnly |
| DataflowProjectsWorkerMessagesRequest: |
| properties: |
| - projectId |
| - sendWorkerMessagesRequest |
| DataflowRunner: |
| methods: |
| - add_pcoll_with_auto_sharding |
| - apply |
| - apply_GroupByKey |
| - byte_array_to_json_string |
| - combinefn_visitor |
| - deserialize_windowing_strategy |
| - flatten_input_visitor |
| - get_default_gcp_region |
| - get_pcoll_with_auto_sharding |
| - is_fnapi_compatible |
| - json_string_to_byte_array |
| - poll_for_job_completion |
| - run__NativeWrite |
| - run_CombineValuesReplacement |
| - run_ExternalTransform |
| - run_Flatten |
| - run_GroupByKey |
| - run_Impulse |
| - run_ParDo |
| - run_pipeline |
| - run_Read |
| - run_TestStream |
| - serialize_windowing_strategy |
| - side_input_visitor |
| DataflowRuntimeException: {} |
| DataflowV1b3: |
| properties: |
| - BASE_URL |
| - MESSAGES_MODULE |
| - MTLS_BASE_URL |
| DataFrameBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| DataFrameBatchConverterDropIndex: |
| methods: |
| - produce_batch |
| DataFrameBatchConverterKeepIndex: |
| methods: |
| - produce_batch |
| DataFrameToRowsFn: |
| methods: |
| - infer_output_type |
| - process |
| DataframeTransform: |
| methods: |
| - expand |
| DataInput: |
| properties: |
| - data |
| - timers |
| DataInputOperation: |
| methods: |
| - finish |
| - monitoring_infos |
| - process |
| - process_encoded |
| - reset |
| - setup |
| - start |
| - try_split |
| DataLossReason: |
| properties: |
| - CONDITION_NOT_GUARANTEED |
| - MAY_FINISH |
| - NO_POTENTIAL_LOSS |
| DataOutputOperation: |
| methods: |
| - finish |
| - process |
| - set_output_stream |
| DataprocClusterManager: |
| methods: |
| - cleanup |
| - cleanup_staging_files |
| - create_cluster |
| - create_flink_cluster |
| - get_cluster_details |
| - get_master_url_and_dashboard |
| - get_staging_location |
| - parse_master_url_and_dashboard |
| - stage_init_action |
| - wait_for_cluster_to_provision |
| Dataset: |
| properties: |
| - access |
| - creationTime |
| - datasetReference |
| - defaultEncryptionConfiguration |
| - defaultPartitionExpirationMs |
| - defaultTableExpirationMs |
| - description |
| - etag |
| - friendlyName |
| - id |
| - kind |
| - labels |
| - lastModifiedTime |
| - location |
| - satisfiesPZS |
| - selfLink |
| DatasetList: |
| properties: |
| - datasets |
| - etag |
| - kind |
| - nextPageToken |
| DatasetReference: |
| properties: |
| - datasetId |
| - projectId |
| DataSplitResult: |
| properties: |
| - evaluationTable |
| - trainingTable |
| DatastoreIODetails: |
| properties: |
| - namespace |
| - projectId |
| DatastoreWordCountIT: |
| methods: |
| - test_datastore_wordcount_it |
| properties: |
| - DATASTORE_WORDCOUNT_KIND |
| - EXPECTED_CHECKSUM |
| DatastoreWriteIT: |
| methods: |
| - run_datastore_write |
| - test_datastore_write_limit |
| properties: |
| - LIMIT |
| - NUM_ENTITIES |
| DebugOptions: |
| properties: |
| - enableHotKeyLogging |
| DecimalCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| DecimalCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| properties: |
| - BIG_INT_CODER_IMPL |
| DecimalLogicalType: |
| methods: |
| - language_type |
| - representation_type |
| - to_language_type |
| - to_representation_type |
| - urn |
| Decode: |
| methods: |
| - process |
| DecodePrediction: |
| methods: |
| - process |
| DecodePubSubMessage: |
| methods: |
| - process |
| DecoratorHelpers: |
| methods: |
| - test_getcallargs_forhints |
| - test_getcallargs_forhints_builtins |
| - test_hint_helper |
| - test_positional_arg_hints |
| Deduplicate: |
| methods: |
| - expand |
| DeduplicatePerKey: |
| methods: |
| - expand |
| DefaultEnvironment: |
| methods: |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| DefaultRootBundleProvider: |
| methods: |
| - get_root_bundles |
| DefaultTrigger: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| DeferredBase: |
| methods: |
| - wrap |
| DeferredDataFrame: |
| methods: |
| - aggregate |
| - align |
| - append |
| - assign |
| - axes |
| - clip |
| - columns |
| - columns |
| - corr |
| - corrwith |
| - cov |
| - dot |
| - drop_duplicates |
| - dropna |
| - dtypes |
| - duplicated |
| - eval |
| - explode |
| - from_dict |
| - from_records |
| - get |
| - idxmax |
| - idxmin |
| - insert |
| - join |
| - keys |
| - melt |
| - merge |
| - mode |
| - nlargest |
| - nsmallest |
| - pivot |
| - pop |
| - quantile |
| - query |
| - rename |
| - round |
| - sample |
| - set_axis |
| - set_index |
| - shift |
| properties: |
| - add_prefix |
| - add_suffix |
| - agg |
| - all |
| - any |
| - applymap |
| - asof |
| - count |
| - cummax |
| - cummin |
| - cumprod |
| - cumsum |
| - describe |
| - diff |
| - first_valid_index |
| - head |
| - iat |
| - info |
| - interpolate |
| - isnull |
| - items |
| - iteritems |
| - iterrows |
| - itertuples |
| - kurt |
| - kurtosis |
| - last_valid_index |
| - lookup |
| - mad |
| - max |
| - mean |
| - median |
| - memory_usage |
| - min |
| - notnull |
| - nunique |
| - pct_change |
| - plot |
| - prod |
| - rename_axis |
| - select_dtypes |
| - sem |
| - shape |
| - skew |
| - stack |
| - std |
| - style |
| - sum |
| - T |
| - tail |
| - take |
| - to_dict |
| - to_numpy |
| - to_records |
| - to_sparse |
| - to_string |
| - transpose |
| - update |
| - values |
| - var |
| DeferredDataFrameOrSeries: |
| methods: |
| - astype |
| - bool |
| - drop |
| - droplevel |
| - dtype |
| - empty |
| - equals |
| - fillna |
| - first |
| - groupby |
| - iloc |
| - index |
| - last |
| - length |
| - loc |
| - mask |
| - ndim |
| - pipe |
| - replace |
| - reset_index |
| - size |
| - sort_index |
| - sort_values |
| - swaplevel |
| - truncate |
| - tz_localize |
| - unstack |
| - where |
| - xs |
| properties: |
| - abs |
| - at_time |
| - attrs |
| - between_time |
| - combine |
| - combine_first |
| - copy |
| - ewm |
| - expanding |
| - hist |
| - infer_object |
| - isin |
| - reindex |
| - reorder_levels |
| - resample |
| - rolling |
| - sparse |
| - swapaxes |
| - to_clipboard |
| - to_xarray |
| - transform |
| - tz_convert |
| DeferredFrame: {} |
| DeferredGroupBy: |
| methods: |
| - agg |
| - apply |
| - dtypes |
| - filter |
| - ndim |
| - pipe |
| - transform |
| properties: |
| - aggregate |
| - backfill |
| - bfill |
| - boxplot |
| - cumcount |
| - cummax |
| - cummin |
| - cumprod |
| - cumsum |
| - diff |
| - ewm |
| - expanding |
| - ffill |
| - fillna |
| - first |
| - groups |
| - head |
| - hist |
| - indices |
| - last |
| - nth |
| - ohlc |
| - pad |
| - pct_change |
| - plot |
| - resample |
| - rolling |
| - shift |
| - tail |
| - tshift |
| DeferredPandasModule: |
| methods: |
| - concat |
| properties: |
| - array |
| - bdate_range |
| - date_range |
| - describe_option |
| - factorize |
| - get_option |
| - interval_range |
| - isna |
| - isnull |
| - json_normalize |
| - melt |
| - melt |
| - merge |
| - merge_ordered |
| - notna |
| - notna |
| - notnull |
| - option_context |
| - period_range |
| - pivot |
| - pivot_table |
| - show_versions |
| - test |
| - timedelta_range |
| - to_datetime |
| - to_pickle |
| DeferredSeries: |
| methods: |
| - aggregate |
| - align |
| - append |
| - axes |
| - cat |
| - corr |
| - cov |
| - dot |
| - drop_duplicates |
| - dropna |
| - dt |
| - dtype |
| - duplicated |
| - explode |
| - hasnans |
| - idxmax |
| - idxmin |
| - is_unique |
| - keys |
| - kurt |
| - kurtosis |
| - mean |
| - mode |
| - name |
| - name |
| - nlargest |
| - nsmallest |
| - nunique |
| - quantile |
| - repeat |
| - sample |
| - set_axis |
| - skew |
| - std |
| - str |
| - unique |
| - update |
| - value_counts |
| - var |
| properties: |
| - add_prefix |
| - add_suffix |
| - agg |
| - all |
| - any |
| - apply |
| - argmax |
| - argmin |
| - argsort |
| - array |
| - asof |
| - autocorr |
| - between |
| - clip |
| - count |
| - cummax |
| - cummin |
| - cumprod |
| - cumsum |
| - describe |
| - diff |
| - dtypes |
| - factorize |
| - filter |
| - first_valid_index |
| - get |
| - head |
| - iat |
| - info |
| - interpolate |
| - is_monotonic |
| - is_monotonic_decreasing |
| - is_monotonic_increasing |
| - isnull |
| - items |
| - iteritems |
| - last_valid_index |
| - mad |
| - map |
| - max |
| - median |
| - memory_usage |
| - min |
| - nbytes |
| - notnull |
| - pct_change |
| - plot |
| - pop |
| - prod |
| - ravel |
| - rename |
| - rename_axis |
| - round |
| - searchsorted |
| - sem |
| - shape |
| - shift |
| - slice_shift |
| - sum |
| - T |
| - tail |
| - take |
| - to_dict |
| - to_frame |
| - to_list |
| - to_numpy |
| - to_string |
| - tolist |
| - transpose |
| - tshift |
| - values |
| - view |
| DefinesGetAndSetState: {} |
| DefinesGetState: {} |
| DeleteBatchRequest: {} |
| DeleteBatchResponse: {} |
| DeleteBitbucketServerConfigOperationMetadata: |
| properties: |
| - bitbucketServerConfig |
| - completeTime |
| - createTime |
| DeleteFromDatastore: {} |
| DeleteGitHubEnterpriseConfigOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - githubEnterpriseConfig |
| DeleteGitLabConfigOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - gitlabConfig |
| DeleteRequest: {} |
| DeleteSnapshotResponse: {} |
| DeleteTablesFn: |
| methods: |
| - process |
| - start_bundle |
| DeleteWorkerPoolOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - workerPool |
| DependsOnlyOnWindow: |
| methods: |
| - merge |
| DerivedSource: |
| properties: |
| - derivationMode |
| - source |
| DestinationTableProperties: |
| properties: |
| - description |
| - friendlyName |
| - labels |
| DeterministicFastPrimitivesCoder: |
| methods: |
| - is_deterministic |
| - is_kv_coder |
| - key_coder |
| - to_type_hint |
| - value_coder |
| DeterministicMapCoder: |
| methods: |
| - is_deterministic |
| DeterministicProtoCoder: |
| methods: |
| - as_deterministic_coder |
| - is_deterministic |
| DeterministicProtoCoderImpl: |
| methods: |
| - encode |
| DicomApiHttpClient: |
| methods: |
| - dicomweb_store_instance |
| - get_session |
| - qido_search |
| properties: |
| - healthcare_base_url |
| - session |
| DicomSearch: |
| methods: |
| - expand |
| DictHint: {} |
| DictToObject: {} |
| DillCoder: {} |
| DirectMetric: |
| methods: |
| - commit_logical |
| - commit_physical |
| - extract_committed |
| - extract_latest_attempted |
| - update_physical |
| DirectMetrics: |
| methods: |
| - commit_logical |
| - commit_physical |
| - query |
| - update_physical |
| DirectOptions: {} |
| DirectPipelineResult: |
| methods: |
| - aggregated_values |
| - cancel |
| - metrics |
| - wait_until_finish |
| DirectRunnerRetryTests: |
| methods: |
| - test_no_partial_writeouts |
| - test_retry_fork_graph |
| DirectRuntimeState: |
| methods: |
| - for_spec |
| DirectStepContext: |
| methods: |
| - get_keyed_state |
| DirectUnmergedState: {} |
| DirectUserStateContext: |
| methods: |
| - commit |
| - get_state |
| - get_timer |
| - reset |
| Disk: |
| properties: |
| - diskType |
| - mountPoint |
| - sizeGb |
| DisplayData: |
| properties: |
| - boolValue |
| - durationValue |
| - floatValue |
| - int64Value |
| - javaClassValue |
| - key |
| - label |
| - namespace |
| - shortStrValue |
| - strValue |
| - timestampValue |
| - url |
| DisplayDataItem: |
| methods: |
| - drop_if_default |
| - drop_if_none |
| - get_dict |
| - is_valid |
| - should_drop |
| properties: |
| - typeDict |
| DisplayDataItemMatcher: |
| methods: |
| - describe_to |
| properties: |
| - IGNORED |
| DisplayManager: |
| methods: |
| - start_periodic_update |
| - stop_periodic_update |
| - update_display |
| Distribution: |
| methods: |
| - update |
| DistributionAggregator: |
| methods: |
| - combine |
| - identity_element |
| - result |
| DistributionCell: |
| methods: |
| - combine |
| - get_cumulative |
| - reset |
| - to_runner_api_monitoring_info_impl |
| - update |
| DistributionData: |
| methods: |
| - combine |
| - get_cumulative |
| - singleton |
| DistributionInt64Accumulator: |
| methods: |
| - add_input |
| - add_input_n |
| - extract_output |
| - merge |
| DistributionInt64Fn: {} |
| DistributionMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| DistributionMetric: {} |
| DistributionResult: |
| methods: |
| - count |
| - max |
| - mean |
| - min |
| - sum |
| DistributionUpdate: |
| properties: |
| - count |
| - histogram |
| - max |
| - min |
| - sum |
| - sumOfSquares |
| DockerEnvironment: |
| methods: |
| - default_docker_image |
| - from_container_image |
| - from_options |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| DockerRPCManager: {} |
| DockerSdkWorkerHandler: |
| methods: |
| - host_from_worker |
| - start_worker |
| - stop_worker |
| - watch_container |
| Document: |
| methods: |
| - to_dict |
| DoFn: |
| methods: |
| - default_label |
| - default_type_hints |
| - finish_bundle |
| - from_callable |
| - get_function_arguments |
| - get_input_batch_type |
| - get_output_batch_type |
| - infer_output_type |
| - process |
| - process_batch |
| - setup |
| - start_bundle |
| - teardown |
| - unbounded_per_element |
| - yields_batches |
| - yields_elements |
| properties: |
| - BundleFinalizerParam |
| - DoFnProcessParams |
| - DynamicTimerTagParam |
| - ElementParam |
| - KeyParam |
| - PaneInfoParam |
| - RestrictionParam |
| - SideInputParam |
| - StateParam |
| - TimerParam |
| - TimestampParam |
| - WatermarkEstimatorParam |
| - WindowParam |
| DoFnContext: |
| methods: |
| - element |
| - set_element |
| - timestamp |
| - windows |
| DoFnInfo: |
| methods: |
| - create |
| - from_runner_api |
| - register_stateless_dofn |
| - serialized_dofn_data |
| DoFnInvoker: |
| methods: |
| - create_invoker |
| - invoke_create_tracker |
| - invoke_create_watermark_estimator |
| - invoke_finish_bundle |
| - invoke_initial_restriction |
| - invoke_process |
| - invoke_process_batch |
| - invoke_setup |
| - invoke_split |
| - invoke_start_bundle |
| - invoke_teardown |
| - invoke_user_timer |
| DoFnProcessContext: |
| methods: |
| - set_element |
| DoFnRunner: |
| methods: |
| - current_element_progress |
| - finalize |
| - finish |
| - process |
| - process_batch |
| - process_user_timer |
| - process_with_sized_restriction |
| - setup |
| - start |
| - teardown |
| - try_split |
| DoFnSignature: |
| methods: |
| - get_restriction_coder |
| - get_restriction_provider |
| - get_watermark_estimator_provider |
| - has_bundle_finalization |
| - has_timers |
| - is_splittable_dofn |
| - is_stateful_dofn |
| - is_unbounded_per_element |
| DoFnState: |
| methods: |
| - counter_for |
| DoOperation: |
| methods: |
| - add_timer_info |
| - finalize_bundle |
| - finish |
| - get_batching_preference |
| - get_input_batch_converter |
| - get_output_batch_converter |
| - needs_finalization |
| - pcollection_count_monitoring_infos |
| - process |
| - process_batch |
| - process_timer |
| - reset |
| - setup |
| - start |
| - teardown |
| DoOutputsTuple: {} |
| DoubleParDo: |
| methods: |
| - expand |
| - to_runner_api_parameter |
| Downloader: |
| methods: |
| - get_range |
| - size |
| DownloaderStream: |
| methods: |
| - readable |
| - readall |
| - readinto |
| - seek |
| - seekable |
| - tell |
| DriverClassName: |
| properties: |
| - DB2 |
| - MYSQL |
| - ORACLE |
| - POSTGRESQL |
| DummyClass: |
| methods: |
| - func |
| DummyCoder: |
| methods: |
| - decode |
| - encode |
| - to_type_hint |
| DummyTestClass1: {} |
| DummyTestClass2: {} |
| Duration: |
| methods: |
| - from_proto |
| - of |
| - to_proto |
| DurationLimiter: |
| methods: |
| - is_triggered |
| DynamicBatchSizer: |
| methods: |
| - get_batch_size |
| - report_latency |
| DynamicSourceSplit: |
| properties: |
| - primary |
| - residual |
| DynamicSplitRequest: {} |
| DynamicSplitResult: {} |
| DynamicSplitResultWithPosition: {} |
| Eggs: {} |
| EitherDoFn: |
| methods: |
| - process |
| - process_batch |
| ElementAndRestriction: {} |
| ElementCounter: |
| methods: |
| - increment |
| - reset |
| - set_breakpoint |
| ElementDoFn: |
| methods: |
| - process |
| ElementEvent: |
| methods: |
| - to_runner_api |
| ElementLimiter: |
| methods: |
| - update |
| ElementsToSeriesFn: |
| methods: |
| - process_batch |
| ElementStream: |
| methods: |
| - cache_key |
| - display_id |
| - is_computed |
| - is_done |
| - pcoll |
| - read |
| - var |
| ElementToBatchDoFn: |
| methods: |
| - infer_output_type |
| - process |
| EmbeddedGrpcWorkerHandler: |
| methods: |
| - start_worker |
| - stop_worker |
| EmbeddedJobServer: |
| methods: |
| - start |
| - stop |
| EmbeddedPythonEnvironment: |
| methods: |
| - default |
| - from_options |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| EmbeddedPythonGrpcEnvironment: |
| methods: |
| - default |
| - from_options |
| - from_runner_api_parameter |
| - parse_config |
| - to_runner_api_parameter |
| EmbeddedWorkerHandler: |
| methods: |
| - data_api_service_descriptor |
| - done |
| - logging_api_service_descriptor |
| - push |
| - start_worker |
| - state_api_service_descriptor |
| - stop_worker |
| Empty: {} |
| EmptyMatchTreatment: |
| methods: |
| - allow_empty_match |
| properties: |
| - ALLOW |
| - ALLOW_IF_WILDCARD |
| - DISALLOW |
| EmptySideInput: {} |
| EmulatedIterable: {} |
| EncryptionConfiguration: |
| properties: |
| - kmsKeyName |
| Entity: |
| methods: |
| - from_client_entity |
| - set_properties |
| - to_client_entity |
| EntityWrapper: |
| methods: |
| - make_entity |
| Entry: |
| properties: |
| - itemCount |
| - predictedLabel |
| Environment: |
| properties: |
| - clusterManagerApiService |
| - dataset |
| - debugOptions |
| - experiments |
| - flexResourceSchedulingGoal |
| - internalExperiments |
| - sdkPipelineOptions |
| - serviceAccountEmail |
| - serviceKmsKeyName |
| - serviceOptions |
| - shuffleMode |
| - tempStoragePrefix |
| - userAgent |
| - version |
| - workerPools |
| - workerRegion |
| - workerZone |
| EOL: |
| properties: |
| - CRLF |
| - CUSTOM_DELIMITER |
| - LF |
| - LF_WITH_NOTHING_AT_LAST_LINE |
| - MIXED |
| ErrorProto: |
| properties: |
| - debugInfo |
| - location |
| - message |
| - reason |
| EstimatePiIT: |
| methods: |
| - test_estimate_pi_output_file |
| EstimatePiTransform: |
| methods: |
| - expand |
| EvaluationContext: |
| methods: |
| - create_bundle |
| - create_empty_committed_bundle |
| - extract_all_timers |
| - get_aggregator_values |
| - get_execution_context |
| - get_value_or_block_until_ready |
| - handle_result |
| - is_done |
| - is_root_transform |
| - metrics |
| - schedule_pending_unblocked_tasks |
| - shutdown |
| EvaluationMetrics: |
| properties: |
| - arimaForecastingMetrics |
| - binaryClassificationMetrics |
| - clusteringMetrics |
| - multiClassClassificationMetrics |
| - rankingMetrics |
| - regressionMetrics |
| Event: |
| methods: |
| - from_runner_api |
| - to_runner_api |
| EventRecorder: |
| methods: |
| - cleanup |
| - events |
| - record |
| EventsReader: |
| methods: |
| - read_multiple |
| Exec: |
| methods: |
| - setUp |
| - test_method_forwarding_not_windows |
| - test_method_forwarding_windows |
| ExecutionContext: {} |
| ExecutionStageState: |
| properties: |
| - currentStateTime |
| - executionStageName |
| - executionStageState |
| ExecutionStageSummary: |
| properties: |
| - componentSource |
| - componentTransform |
| - id |
| - inputSource |
| - kind |
| - name |
| - outputSource |
| - prerequisiteStage |
| Executor: |
| methods: |
| - await_completion |
| - shutdown |
| - start |
| ExpandStrings: |
| methods: |
| - process |
| ExpandStringsProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_size |
| - split |
| ExpansionAndArtifactRetrievalStub: |
| methods: |
| - artifact_service |
| ExpansionServiceServicer: |
| methods: |
| - Expand |
| ExpectedSplitOutcome: |
| properties: |
| - MUST_BE_CONSISTENT_IF_SUCCEEDS |
| - MUST_FAIL |
| - MUST_SUCCEED_AND_BE_CONSISTENT |
| ExpectingSideInputsFn: |
| methods: |
| - default_label |
| - process |
| ExplainQueryStage: |
| properties: |
| - completedParallelInputs |
| - computeMsAvg |
| - computeMsMax |
| - computeRatioAvg |
| - computeRatioMax |
| - endMs |
| - id |
| - inputStages |
| - name |
| - parallelInputs |
| - readMsAvg |
| - readMsMax |
| - readRatioAvg |
| - readRatioMax |
| - recordsRead |
| - recordsWritten |
| - shuffleOutputBytes |
| - shuffleOutputBytesSpilled |
| - slotMs |
| - startMs |
| - status |
| - steps |
| - waitMsAvg |
| - waitMsMax |
| - waitRatioAvg |
| - waitRatioMax |
| - writeMsAvg |
| - writeMsMax |
| - writeRatioAvg |
| - writeRatioMax |
| ExplainQueryStep: |
| properties: |
| - kind |
| - substeps |
| Explanation: |
| properties: |
| - attribution |
| - featureName |
| ExplodeWindowsFn: |
| methods: |
| - process |
| ExportCompression: |
| properties: |
| - DEFLATE |
| - GZIP |
| - NONE |
| - SNAPPY |
| Expr: |
| properties: |
| - description |
| - expression |
| - location |
| - title |
| Expression: |
| methods: |
| - evaluate_at |
| - placeholders |
| - preserves_partition_by |
| - proxy |
| - requires_partition_by |
| ExpressionCache: |
| methods: |
| - replace_with_cached |
| ExtendedProvisionInfo: |
| methods: |
| - for_environment |
| ExternalDataConfiguration: |
| properties: |
| - autodetect |
| - bigtableOptions |
| - compression |
| - connectionId |
| - csvOptions |
| - googleSheetsOptions |
| - hivePartitioningOptions |
| - ignoreUnknownValues |
| - maxBadRecords |
| - schema |
| - sourceFormat |
| - sourceUris |
| ExternalEnvironment: |
| methods: |
| - from_options |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| ExternalJobServer: |
| methods: |
| - start |
| - stop |
| ExternalTransform: |
| methods: |
| - default_label |
| - expand |
| - get_local_namespace |
| - outer_namespace |
| - replace_named_inputs |
| - replace_named_outputs |
| - service |
| - to_runner_api_transform |
| - with_output_types |
| ExternalTransformFinder: |
| methods: |
| - contains_external_transforms |
| - enter_composite_transform |
| - visit_transform |
| ExternalTransformIT: |
| methods: |
| - test_job_python_from_python_it |
| ExternalWorkerHandler: |
| methods: |
| - host_from_worker |
| - start_worker |
| - stop_worker |
| ExtraAssertionsMixin: |
| methods: |
| - assertUnhashableCountEqual |
| ExtractAndSumScore: |
| methods: |
| - expand |
| ExtractHtmlTitleDoFn: |
| methods: |
| - process |
| ExtractHtmlTitleTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| ExtractInferences: |
| methods: |
| - process |
| ExtractUserAndTimestampDoFn: |
| methods: |
| - process |
| FailedLocation: |
| properties: |
| - name |
| FailureInfo: |
| properties: |
| - detail |
| - type |
| FakeApiCall: {} |
| FakeBatch: |
| methods: |
| - begin |
| - commit |
| - delete |
| - put |
| FakeBatchApiRequest: |
| methods: |
| - Add |
| - Execute |
| FakeClock: |
| methods: |
| - time_ns |
| FakeDeterministicFastPrimitivesCoder: |
| methods: |
| - is_deterministic |
| FakeDownloader: |
| methods: |
| - get_range |
| - size |
| FakeFile: |
| methods: |
| - get_metadata |
| FakeGcsBuckets: |
| methods: |
| - Get |
| - get_bucket |
| FakeGcsClient: {} |
| FakeGcsObjects: |
| methods: |
| - add_file |
| - Delete |
| - delete_file |
| - Get |
| - get_file |
| - get_last_generation |
| - Insert |
| - List |
| - Rewrite |
| properties: |
| - REWRITE_TOKEN |
| FakeHdfs: |
| methods: |
| - checksum |
| - delete |
| - list |
| - makedirs |
| - read |
| - rename |
| - status |
| - walk |
| - write |
| FakeHdfsError: {} |
| FakeHttpClient: |
| methods: |
| - dicomweb_store_instance |
| - qido_search |
| FakeLogger: |
| methods: |
| - log |
| FakeModel: |
| methods: |
| - predict |
| FakeModelHandler: |
| methods: |
| - load_model |
| - run_inference |
| FakeModelHandlerExpectedInferenceArgs: |
| methods: |
| - run_inference |
| - validate_inference_args |
| FakeModelHandlerFailsOnInferenceArgs: |
| methods: |
| - run_inference |
| FakeModelHandlerNeedsBigBatch: |
| methods: |
| - batch_elements_kwargs |
| - run_inference |
| FakeMutation: |
| methods: |
| - ByteSize |
| FakeNumpyModelDictOut: |
| methods: |
| - predict |
| FakePandasModelDictOut: |
| methods: |
| - predict |
| FakePandasObject: {} |
| FakeS3Client: |
| methods: |
| - add_file |
| - complete_multipart_upload |
| - copy |
| - create_multipart_upload |
| - delete |
| - delete_batch |
| - delete_file |
| - get_file |
| - get_object_metadata |
| - get_range |
| - list |
| - upload_part |
| FakeSource: |
| methods: |
| - reader |
| FakeSourceReader: |
| methods: |
| - returns_windowed_values |
| FakeUnboundedSource: |
| methods: |
| - is_bounded |
| - reader |
| FakeUploader: |
| methods: |
| - finish |
| - last_error |
| - put |
| FastavroIT: |
| methods: |
| - setUp |
| - test_avro_it |
| properties: |
| - SCHEMA_STRING |
| FastCoder: |
| methods: |
| - decode |
| - encode |
| - estimate_size |
| FastCoders: |
| methods: |
| - test_using_fast_impl |
| FastPrimitivesCoder: |
| methods: |
| - as_cloud_object |
| - as_deterministic_coder |
| - is_deterministic |
| - is_kv_coder |
| - key_coder |
| - to_type_hint |
| - value_coder |
| FastPrimitivesCoderImpl: |
| methods: |
| - decode_from_stream |
| - decode_type |
| - encode_special_deterministic |
| - encode_to_stream |
| - encode_type |
| - get_estimated_size_and_observables |
| - register_iterable_like_type |
| FeatureValue: |
| properties: |
| - categoricalValue |
| - featureColumn |
| - numericalValue |
| FibTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| FieldNames: |
| properties: |
| - AUCTION |
| - BIDDER |
| - CATEGORY |
| - CITY |
| - CREDIT_CARD |
| - DATE_TIME |
| - DESCRIPTION |
| - EMAIL_ADDRESS |
| - EXPIRES |
| - EXTRA |
| - ID |
| - INITIAL_BID |
| - ITEM_NAME |
| - NAME |
| - PRICE |
| - RESERVE |
| - SELLER |
| - STATE |
| FileBasedCacheManager: |
| methods: |
| - cleanup |
| - clear |
| - exists |
| - load_pcoder |
| - read |
| - save_pcoder |
| - sink |
| - size |
| - source |
| - write |
| FileBasedIOTestOptions: {} |
| FileBasedSink: |
| methods: |
| - close |
| - display_data |
| - finalize_write |
| - initialize_write |
| - open |
| - open_writer |
| - pre_finalize |
| - write_encoded_record |
| - write_record |
| FileBasedSinkWriter: |
| methods: |
| - at_capacity |
| - close |
| - write |
| FileBasedSource: |
| methods: |
| - display_data |
| - estimate_size |
| - get_range_tracker |
| - open_file |
| - read |
| - read_records |
| - split |
| - splittable |
| properties: |
| - MIN_FRACTION_OF_FILES_TO_STAT |
| - MIN_NUMBER_OF_FILES_TO_STAT |
| FileChecksumMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| FileFormat: |
| properties: |
| - AVRO |
| - CSV |
| - JSON |
| FileHashes: |
| properties: |
| - fileHash |
| FileIODetails: |
| properties: |
| - filePattern |
| FileMetadata: {} |
| FileRecordsBuilder: |
| methods: |
| - add_element |
| - advance_processing_time |
| - advance_watermark |
| - build |
| FileResult: {} |
| FileSink: |
| methods: |
| - create_metadata |
| - flush |
| - open |
| - write |
| FileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - match |
| - match_files |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| - translate_pattern |
| properties: |
| - CHUNK_SIZE |
| FileSystems: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - get_chunk_size |
| - get_filesystem |
| - get_scheme |
| - join |
| - last_updated |
| - match |
| - mkdirs |
| - open |
| - rename |
| - set_options |
| - split |
| properties: |
| - URI_SCHEMA_PATTERN |
| FilterLessThanTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| FilterTextFn: |
| methods: |
| - process |
| FinishCombine: |
| methods: |
| - default_type_hints |
| - process |
| - setup |
| - teardown |
| FirstOf: |
| methods: |
| - from_type_hint |
| FixedBytes: |
| methods: |
| - argument |
| - argument_type |
| - language_type |
| - to_language_type |
| - urn |
| FixedPrecisionDecimalLogicalType: |
| methods: |
| - argument |
| - argument_type |
| - language_type |
| - representation_type |
| - to_language_type |
| - to_representation_type |
| - urn |
| FixedString: |
| methods: |
| - argument |
| - argument_type |
| - language_type |
| - to_language_type |
| - urn |
| FixedWindows: |
| methods: |
| - assign |
| - from_runner_api_parameter |
| - get_window_coder |
| - to_runner_api_parameter |
| Flatten: |
| methods: |
| - apply |
| FlattenAndDouble: |
| methods: |
| - expand |
| FlattenAndTriple: |
| methods: |
| - expand |
| FlattenInstruction: |
| properties: |
| - inputs |
| FlattenOperation: |
| methods: |
| - process |
| FlattenTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| FlexTemplateRuntimeEnvironment: |
| properties: |
| - additionalExperiments |
| - additionalUserLabels |
| - autoscalingAlgorithm |
| - diskSizeGb |
| - dumpHeapOnOom |
| - enableStreamingEngine |
| - flexrsGoal |
| - ipConfiguration |
| - kmsKeyName |
| - launcherMachineType |
| - machineType |
| - maxWorkers |
| - network |
| - numWorkers |
| - saveHeapDumpsToGcsPath |
| - sdkContainerImage |
| - serviceAccountEmail |
| - stagingLocation |
| - subnetwork |
| - tempLocation |
| - workerRegion |
| - workerZone |
| - zone |
| FlinkBeamJob: |
| methods: |
| - cancel |
| - delete |
| - delete_jar |
| - get |
| - get_message_stream |
| - get_metrics |
| - get_state |
| - get_state_stream |
| - post |
| - request |
| - run |
| FlinkJarJobServer: |
| methods: |
| - java_arguments |
| - path_to_jar |
| FlinkRunner: |
| methods: |
| - add_http_scheme |
| - create_job_service_handle |
| - default_job_server |
| - run_pipeline |
| FlinkRunnerOptions: |
| properties: |
| - PUBLISHED_FLINK_VERSIONS |
| FlinkRunnerTestOptimized: |
| methods: |
| - create_options |
| - test_expand_kafka_read |
| - test_expand_kafka_write |
| - test_external_transform |
| - test_pack_combiners |
| - test_sql |
| FlinkRunnerTestStreaming: |
| methods: |
| - create_options |
| - setUp |
| - test_callbacks_with_exception |
| - test_register_finalizations |
| FlinkStreamingImpulseSource: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - get_windowing |
| - infer_output_type |
| - set_interval_ms |
| - set_message_count |
| - to_runner_api_parameter |
| properties: |
| - config |
| - URN |
| FlinkUberJarJobServer: |
| methods: |
| - create_beam_job |
| - executable_jar |
| - flink_version |
| - GetJobMetrics |
| - start |
| - stop |
| FloatCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| FloatCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| FloatingPointList: |
| properties: |
| - elements |
| FloatingPointMean: |
| properties: |
| - count |
| - sum |
| FnApiLogRecordHandler: |
| methods: |
| - close |
| - connect |
| - emit |
| - map_log_level |
| FnApiMetrics: |
| methods: |
| - monitoring_infos |
| - query |
| FnApiRunner: |
| methods: |
| - create_stages |
| - embed_default_docker_image |
| - get_cache_token_generator |
| - maybe_profile |
| - run_pipeline |
| - run_stages |
| - run_via_runner_api |
| - supported_requirements |
| properties: |
| - NUM_FUSED_STAGES_COUNTER |
| FnApiRunnerExecutionContext: |
| methods: |
| - bundle_manager_for |
| - commit_side_inputs_to_state |
| - next_uid |
| - setup |
| - state_servicer |
| FnApiRunnerTestWithBundleRepeat: |
| methods: |
| - create_pipeline |
| - test_register_finalizations |
| FnApiRunnerTestWithBundleRepeatAndMultiWorkers: |
| methods: |
| - create_pipeline |
| - test_draining_sdf_with_sdf_initiated_checkpointing |
| - test_metrics |
| - test_register_finalizations |
| - test_sdf_with_dofn_as_watermark_estimator |
| - test_sdf_with_sdf_initiated_checkpointing |
| - test_sdf_with_watermark_tracking |
| FnApiRunnerTestWithDisabledCaching: |
| methods: |
| - create_pipeline |
| FnApiRunnerTestWithGrpc: |
| methods: |
| - create_pipeline |
| FnApiRunnerTestWithGrpcAndMultiWorkers: |
| methods: |
| - create_pipeline |
| - test_draining_sdf_with_sdf_initiated_checkpointing |
| - test_metrics |
| - test_register_finalizations |
| - test_sdf_with_dofn_as_watermark_estimator |
| - test_sdf_with_sdf_initiated_checkpointing |
| - test_sdf_with_watermark_tracking |
| FnApiRunnerTestWithMultiWorkers: |
| methods: |
| - create_pipeline |
| - test_draining_sdf_with_sdf_initiated_checkpointing |
| - test_metrics |
| - test_register_finalizations |
| - test_sdf_with_dofn_as_watermark_estimator |
| - test_sdf_with_sdf_initiated_checkpointing |
| - test_sdf_with_watermark_tracking |
| FnApiUserStateContext: |
| methods: |
| - add_timer_info |
| - commit |
| - get_state |
| - get_timer |
| - reset |
| FnApiWorkerStatusHandler: |
| methods: |
| - close |
| - generate_status_response |
| FnRunnerStatefulTriggerContext: |
| methods: |
| - add_state |
| - clear_state |
| - clear_timer |
| - for_window |
| - get_current_time |
| - get_state |
| - merge_windows |
| - set_timer |
| - windows_to_elements_map |
| FormatDoFn: |
| methods: |
| - process |
| FormatOutputDoFn: |
| methods: |
| - process |
| FormatToQido: |
| methods: |
| - expand |
| FrameState: |
| methods: |
| - closure_type |
| - const_type |
| - copy |
| - get_closure |
| - get_global |
| - get_name |
| FrozenSetHint: {} |
| FullyQualifiedNamedTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| - with_filter |
| FuzzedExponentialIntervals: {} |
| GameStatsIT: |
| methods: |
| - setUp |
| - test_game_stats_it |
| properties: |
| - DEFAULT_EXPECTED_CHECKSUM |
| - DEFAULT_INPUT_COUNT |
| - INPUT_EVENT |
| - INPUT_SUB |
| - INPUT_TOPIC |
| - OUTPUT_DATASET |
| - OUTPUT_TABLE_SESSIONS |
| - OUTPUT_TABLE_TEAMS |
| - WAIT_UNTIL_FINISH_DURATION |
| Gauge: |
| methods: |
| - set |
| GaugeAggregator: |
| methods: |
| - combine |
| - identity_element |
| - result |
| GaugeCell: |
| methods: |
| - combine |
| - get_cumulative |
| - reset |
| - set |
| - to_runner_api_monitoring_info_impl |
| - update |
| GaugeData: |
| methods: |
| - combine |
| - get_cumulative |
| - singleton |
| GaugeResult: |
| methods: |
| - timestamp |
| - value |
| GBKTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| GcpTestIOError: {} |
| GCSFileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| properties: |
| - CHUNK_SIZE |
| - GCS_PREFIX |
| GcsIO: |
| methods: |
| - checksum |
| - copy |
| - copy_batch |
| - copytree |
| - create_bucket |
| - delete |
| - delete_batch |
| - exists |
| - get_bucket |
| - get_project_number |
| - kms_key |
| - last_updated |
| - list_files |
| - list_prefix |
| - open |
| - rename |
| - size |
| GcsIOError: {} |
| GcsIOOverrides: |
| methods: |
| - retry_func |
| GeneralPurposeConsumerSet: |
| methods: |
| - flush |
| - receive |
| - receive_batch |
| properties: |
| - MAX_BATCH_SIZE |
| GeneralTriggerDriver: |
| methods: |
| - process_elements |
| - process_timer |
| properties: |
| - ELEMENTS |
| - INDEX |
| - NONSPECULATIVE_INDEX |
| - TOMBSTONE |
| GeneralTriggerManagerDoFn: |
| methods: |
| - process |
| - processing_time_trigger |
| - watermark_trigger |
| properties: |
| - FINISHED_WINDOWS |
| - KNOWN_WINDOWS |
| - LAST_KNOWN_TIME |
| - LAST_KNOWN_WATERMARK |
| - PROCESSING_TIME_TIMER |
| - WATERMARK_TIMER |
| - WINDOW_ELEMENT_PAIRS |
| - WINDOW_TAG_VALUES |
| GeneratedClassRowTypeConstraint: {} |
| GenerateDocs: |
| methods: |
| - process |
| GenerateSequence: |
| properties: |
| - URN |
| GenerateTestRows: |
| methods: |
| - expand |
| GeneratorHint: {} |
| GeneratorWrapper: |
| properties: |
| - next |
| GenericMergingWindowFn: |
| methods: |
| - assign |
| - from_runner_api_parameter |
| - get_window_coder |
| - make_process_bundle_descriptor |
| - merge |
| - payload |
| - uid |
| - worker_handle |
| properties: |
| - FROM_SDK_TRANSFORM |
| - TO_SDK_TRANSFORM |
| - URN |
| GenericNonMergingWindowFn: |
| methods: |
| - assign |
| - from_runner_api_parameter |
| - get_window_coder |
| properties: |
| - URN |
| GenericRowColumnEncoder: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - finalize_write |
| - null_flags |
| GetDebugConfigRequest: |
| properties: |
| - componentId |
| - location |
| - workerId |
| GetDebugConfigResponse: |
| properties: |
| - config |
| GetIamPolicyRequest: |
| properties: |
| - options |
| GetitemConstructor: {} |
| GetPolicyOptions: |
| properties: |
| - requestedPolicyVersion |
| GetQueryResultsResponse: |
| properties: |
| - cacheHit |
| - errors |
| - etag |
| - jobComplete |
| - jobReference |
| - kind |
| - numDmlAffectedRows |
| - pageToken |
| - rows |
| - schema |
| - totalBytesProcessed |
| - totalRows |
| GetRequest: {} |
| GetServiceAccountResponse: |
| properties: |
| - email |
| - kind |
| GetTemplateResponse: |
| properties: |
| - metadata |
| - runtimeMetadata |
| - status |
| - templateType |
| GetUpdates: |
| methods: |
| - process |
| GitFileSource: |
| properties: |
| - bitbucketServerConfig |
| - githubEnterpriseConfig |
| - path |
| - repoType |
| - revision |
| - uri |
| GitHubEnterpriseConfig: |
| properties: |
| - appId |
| - createTime |
| - displayName |
| - hostUrl |
| - name |
| - peeredNetwork |
| - secrets |
| - sslCa |
| - webhookKey |
| GitHubEnterpriseSecrets: |
| properties: |
| - oauthClientIdName |
| - oauthClientIdVersionName |
| - oauthSecretName |
| - oauthSecretVersionName |
| - privateKeyName |
| - privateKeyVersionName |
| - webhookSecretName |
| - webhookSecretVersionName |
| GitHubEventsConfig: |
| properties: |
| - enterpriseConfigResourceName |
| - installationId |
| - name |
| - owner |
| - pullRequest |
| - push |
| GitHubIssueMetaData: |
| properties: |
| - change_point |
| - change_point_timestamp |
| - issue_number |
| - issue_timestamp |
| - issue_url |
| - metric_name |
| - test_id |
| - test_name |
| GitRepoSource: |
| properties: |
| - bitbucketServerConfig |
| - githubEnterpriseConfig |
| - ref |
| - repoType |
| - uri |
| GlobalCachingStateHandler: |
| methods: |
| - blocking_get |
| - clear |
| - done |
| - extend |
| - process_instruction_id |
| GlobalExplanation: |
| properties: |
| - classLabel |
| - explanations |
| GlobalWindow: |
| methods: |
| - start |
| GlobalWindowCoder: |
| methods: |
| - as_cloud_object |
| GlobalWindows: |
| methods: |
| - assign |
| - from_runner_api_parameter |
| - get_window_coder |
| - to_runner_api_parameter |
| - windowed_batch |
| - windowed_value |
| - windowed_value_at_end_of_window |
| GoogleCloudOptions: |
| methods: |
| - validate |
| properties: |
| - BIGQUERY_API_SERVICE |
| - COMPUTE_API_SERVICE |
| - DATAFLOW_ENDPOINT |
| - OAUTH_SCOPES |
| - STORAGE_API_SERVICE |
| GoogleDevtoolsCloudbuildV2OperationMetadata: |
| properties: |
| - apiVersion |
| - createTime |
| - endTime |
| - requestedCancellation |
| - statusMessage |
| - target |
| - verb |
| GoogleSheetsOptions: |
| properties: |
| - range |
| - skipLeadingRows |
| GroupBy: |
| methods: |
| - aggregate_field |
| - default_label |
| - expand |
| - force_tuple_keys |
| GroupByKey: |
| methods: |
| - apply |
| GroupingBuffer: |
| methods: |
| - append |
| - clear |
| - copy |
| - extend |
| - partition |
| - reset |
| properties: |
| - cleared |
| GroupIntoBatches: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| GroupIntoBatchesWithShardedKeyPTransformOverride: |
| methods: |
| - get_replacement_transform_for_applied_ptransform |
| - matches |
| GRPCChannelFactory: |
| methods: |
| - insecure_channel |
| - secure_channel |
| properties: |
| - DEFAULT_OPTIONS |
| GrpcClientDataChannel: {} |
| GrpcClientDataChannelFactory: |
| methods: |
| - close |
| - create_data_channel |
| - create_data_channel_from_url |
| GrpcServer: |
| methods: |
| - close |
| GrpcStateHandler: |
| methods: |
| - append_raw |
| - clear |
| - done |
| - get_raw |
| - process_instruction_id |
| - start |
| GrpcStateHandlerFactory: |
| methods: |
| - close |
| - create_state_handler |
| GrpcStateServicer: |
| methods: |
| - State |
| GrpcWorkerHandler: |
| methods: |
| - artifact_api_service_descriptor |
| - close |
| - control_api_service_descriptor |
| - data_api_service_descriptor |
| - host_from_worker |
| - logging_api_service_descriptor |
| - port_from_worker |
| - state_api_service_descriptor |
| HadoopFileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| HadoopFileSystemOptions: |
| methods: |
| - validate |
| HasDisplayData: |
| methods: |
| - display_data |
| Hash: |
| properties: |
| - type |
| - value |
| HdfsDownloader: |
| methods: |
| - get_range |
| - size |
| HdfsUploader: |
| methods: |
| - finish |
| - put |
| Histogram: |
| properties: |
| - bucketCounts |
| - firstBucketOffset |
| HistogramAggregator: |
| methods: |
| - combine |
| - identity_element |
| - result |
| HistogramCell: |
| methods: |
| - combine |
| - get_cumulative |
| - reset |
| - to_runner_api_monitoring_info |
| - update |
| HistogramCellFactory: {} |
| HistogramData: |
| methods: |
| - combine |
| - get_cumulative |
| HistogramResult: |
| methods: |
| - p90 |
| - p95 |
| - p99 |
| HivePartitioningOptions: |
| properties: |
| - mode |
| - requirePartitionFilter |
| - sourceUriPrefix |
| HomogeneousWindowedBatch: |
| methods: |
| - as_empty_windowed_value |
| - as_windowed_values |
| - from_batch_and_windowed_value |
| - from_windowed_values |
| - of |
| - pane_info |
| - timestamp |
| - values |
| - windows |
| - windows |
| - with_values |
| HotKeyDetection: |
| properties: |
| - hotKeyAge |
| - systemName |
| - userStepName |
| HourlyTeamScore: |
| methods: |
| - expand |
| HourlyTeamScoreIT: |
| methods: |
| - setUp |
| - test_hourly_team_score_it |
| - test_hourly_team_score_output_checksum_on_small_input |
| properties: |
| - DEFAULT_EXPECTED_CHECKSUM |
| - DEFAULT_INPUT_FILE |
| - OUTPUT_DATASET |
| - OUTPUT_TABLE |
| HttpBody: |
| properties: |
| - contentType |
| - data |
| - extensions |
| HTTPDelivery: |
| properties: |
| - uri |
| HuggingFaceStripBatchingWrapper: |
| methods: |
| - forward |
| IdOrName: {} |
| IFrameParser: |
| methods: |
| - handle_starttag |
| - srcdocs |
| ImplicitSchemaPayloadBuilder: {} |
| ImportCatalogItems: |
| methods: |
| - expand |
| ImportUserEvents: |
| methods: |
| - expand |
| Impulse: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - get_windowing |
| - infer_output_type |
| - to_runner_api_parameter |
| ImpulseReadOperation: |
| methods: |
| - process |
| ImpulseSeqGenDoFn: |
| methods: |
| - process |
| ImpulseSeqGenRestrictionProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_size |
| - truncate |
| Index: |
| methods: |
| - check |
| - is_subpartitioning_of |
| - partition_fn |
| IndexableTypeConstraint: {} |
| IndexAssigningDoFn: |
| methods: |
| - process |
| properties: |
| - state_param |
| InefficientExecutionWarning: {} |
| InfluxDBMetricsPublisher: |
| methods: |
| - publish |
| InfluxDBMetricsPublisherOptions: |
| methods: |
| - http_auth_enabled |
| - validate |
| InitialPositionInStream: |
| methods: |
| - validate_param |
| properties: |
| - AT_TIMESTAMP |
| - LATEST |
| - TRIM_HORIZON |
| InlineSecret: |
| properties: |
| - envMap |
| - kmsKeyName |
| InMemoryCache: |
| methods: |
| - cleanup |
| - clear |
| - exists |
| - load_pcoder |
| - read |
| - save_pcoder |
| - sink |
| - size |
| - source |
| - write |
| InMemoryDataChannel: |
| methods: |
| - close |
| - input_elements |
| - inverse |
| - output_stream |
| - output_timer_stream |
| InMemoryDataChannelFactory: |
| methods: |
| - close |
| - create_data_channel |
| - create_data_channel_from_url |
| InMemoryFileManager: |
| methods: |
| - file_reader |
| - file_writer |
| - get |
| InMemoryUnmergedState: |
| methods: |
| - add_state |
| - clear_state |
| - clear_timer |
| - copy |
| - get_and_clear_timers |
| - get_earliest_hold |
| - get_global_state |
| - get_state |
| - get_timers |
| - get_window |
| - set_global_state |
| - set_timer |
| InMemoryWriteOperation: |
| methods: |
| - process |
| InputStream: |
| methods: |
| - read |
| - read_all |
| - read_bigendian_double |
| - read_bigendian_float |
| - read_bigendian_int32 |
| - read_bigendian_int64 |
| - read_bigendian_uint64 |
| - read_byte |
| - read_var_int64 |
| - size |
| InspectForDetails: |
| methods: |
| - expand |
| InstructionInput: |
| properties: |
| - outputNum |
| - producerInstructionIndex |
| InstructionOutput: |
| properties: |
| - codec |
| - name |
| - onlyCountKeyBytes |
| - onlyCountValueBytes |
| - originalName |
| - systemName |
| IntegerGauge: |
| properties: |
| - timestamp |
| - value |
| IntegerList: |
| properties: |
| - elements |
| IntegerMean: |
| properties: |
| - count |
| - sum |
| InteractiveEnvironment: |
| methods: |
| - add_derived_pipeline |
| - add_user_pipeline |
| - cleanup |
| - cleanup_environment |
| - cleanup_pipeline |
| - computed_pcollections |
| - describe_all_recordings |
| - evict_background_caching_job |
| - evict_cache_manager |
| - evict_cached_source_signature |
| - evict_computed_pcollections |
| - evict_pipeline_result |
| - evict_recording_manager |
| - evict_test_stream_service_controller |
| - evict_tracked_pipelines |
| - get_background_caching_job |
| - get_cache_manager |
| - get_cached_source_signature |
| - get_recording_manager |
| - get_sql_chain |
| - get_test_stream_service_controller |
| - import_html_to_head |
| - inspector |
| - inspector_with_synthetic |
| - is_in_ipython |
| - is_in_notebook |
| - is_interactive_ready |
| - is_terminated |
| - load_jquery_with_datatable |
| - mark_pcollection_computed |
| - options |
| - pipeline_id_to_pipeline |
| - pipeline_result |
| - set_background_caching_job |
| - set_cache_manager |
| - set_cached_source_signature |
| - set_pipeline_result |
| - set_recording_manager |
| - set_test_stream_service_controller |
| - track_user_pipelines |
| - tracked_user_pipelines |
| - user_pipeline |
| - watch |
| - watching |
| InteractiveEnvironmentInspector: |
| methods: |
| - get_cluster_master_url |
| - get_pcoll_data |
| - get_val |
| - inspectable_pipelines |
| - inspectables |
| - list_clusters |
| - list_inspectables |
| InteractiveOptions: |
| methods: |
| - capture_control |
| InteractivePipelineGraph: |
| methods: |
| - update_pcollection_stats |
| InteractiveRunner: |
| methods: |
| - apply |
| - configure_for_flink |
| - end_session |
| - is_fnapi_compatible |
| - run_pipeline |
| - set_render_option |
| - start_session |
| IntervalWindow: |
| methods: |
| - intersects |
| - union |
| IntervalWindowCoder: |
| methods: |
| - as_cloud_object |
| - is_deterministic |
| IntervalWindowCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| IOTypeHints: |
| methods: |
| - debug_str |
| - empty |
| - from_callable |
| - has_simple_output_type |
| - simple_output_type |
| - strip_iterable |
| - strip_pcoll |
| - strip_pcoll_helper |
| - with_defaults |
| - with_input_types |
| - with_input_types_from |
| - with_output_types |
| - with_output_types_from |
| properties: |
| - input_types |
| - origin |
| - output_types |
| IPythonLogHandler: |
| methods: |
| - emit |
| properties: |
| - log_template |
| - logging_to_alert_level_map |
| Item: {} |
| IterableCoder: |
| methods: |
| - to_type_hint |
| IterableCoderImpl: {} |
| IterableHint: {} |
| IterationResult: |
| properties: |
| - arimaResult |
| - clusterInfos |
| - durationMs |
| - evalLoss |
| - index |
| - learnRate |
| - trainingLoss |
| IteratorHint: {} |
| JarArtifactManager: |
| methods: |
| - close |
| - file_writer |
| - zipfile_handle |
| JavaClassLookupPayloadBuilder: |
| methods: |
| - add_builder_method |
| - build |
| - with_constructor |
| - with_constructor_method |
| properties: |
| - IGNORED_ARG_FORMAT |
| JavaExternalTransform: |
| methods: |
| - expand |
| JavaJarExpansionService: {} |
| JavaJarJobServer: |
| methods: |
| - java_arguments |
| - local_jar |
| - path_to_beam_jar |
| - path_to_jar |
| - subprocess_cmd_and_endpoint |
| JavaJarJobServerStub: |
| methods: |
| - java_arguments |
| - local_jar |
| - path_to_jar |
| JavaJarServer: |
| methods: |
| - beam_services |
| - jar_name |
| - local_jar |
| - make_classpath_jar |
| - path_to_beam_jar |
| - path_to_maven_jar |
| - start_process |
| - stop_process |
| properties: |
| - BEAM_GROUP_ID |
| - JAR_CACHE |
| - MAVEN_CENTRAL_REPOSITORY |
| Job: |
| properties: |
| - clientRequestId |
| - createdFromSnapshotId |
| - createTime |
| - currentState |
| - currentStateTime |
| - environment |
| - executionInfo |
| - id |
| - jobMetadata |
| - labels |
| - location |
| - name |
| - pipelineDescription |
| - projectId |
| - replacedByJobId |
| - replaceJobId |
| - requestedState |
| - satisfiesPzs |
| - stageStates |
| - startTime |
| - steps |
| - stepsLocation |
| - tempFiles |
| - transformNameMapping |
| - type |
| JobCancelResponse: |
| properties: |
| - job |
| - kind |
| JobConfiguration: |
| properties: |
| - copy |
| - dryRun |
| - extract |
| - jobTimeoutMs |
| - jobType |
| - labels |
| - load |
| - query |
| JobConfigurationExtract: |
| properties: |
| - compression |
| - destinationFormat |
| - destinationUri |
| - destinationUris |
| - fieldDelimiter |
| - printHeader |
| - sourceModel |
| - sourceTable |
| - useAvroLogicalTypes |
| JobConfigurationLoad: |
| properties: |
| - allowJaggedRows |
| - allowQuotedNewlines |
| - autodetect |
| - clustering |
| - createDisposition |
| - decimalTargetTypes |
| - destinationEncryptionConfiguration |
| - destinationTable |
| - destinationTableProperties |
| - encoding |
| - fieldDelimiter |
| - hivePartitioningOptions |
| - ignoreUnknownValues |
| - maxBadRecords |
| - nullMarker |
| - projectionFields |
| - quote |
| - rangePartitioning |
| - schema |
| - schemaInline |
| - schemaInlineFormat |
| - schemaUpdateOptions |
| - skipLeadingRows |
| - sourceFormat |
| - sourceUris |
| - timePartitioning |
| - useAvroLogicalTypes |
| - writeDisposition |
| JobConfigurationQuery: |
| properties: |
| - allowLargeResults |
| - clustering |
| - connectionProperties |
| - createDisposition |
| - defaultDataset |
| - destinationEncryptionConfiguration |
| - destinationTable |
| - flattenResults |
| - maximumBillingTier |
| - maximumBytesBilled |
| - parameterMode |
| - preserveNulls |
| - priority |
| - query |
| - queryParameters |
| - rangePartitioning |
| - schemaUpdateOptions |
| - tableDefinitions |
| - timePartitioning |
| - useLegacySql |
| - useQueryCache |
| - userDefinedFunctionResources |
| - writeDisposition |
| JobConfigurationTableCopy: |
| properties: |
| - createDisposition |
| - destinationEncryptionConfiguration |
| - destinationExpirationTime |
| - destinationTable |
| - operationType |
| - sourceTable |
| - sourceTables |
| - writeDisposition |
| JobExecutionDetails: |
| properties: |
| - nextPageToken |
| - stages |
| JobExecutionInfo: |
| properties: |
| - stages |
| JobExecutionStageInfo: |
| properties: |
| - stepName |
| JobList: |
| properties: |
| - etag |
| - jobs |
| - kind |
| - nextPageToken |
| JobLogHandler: |
| methods: |
| - emit |
| properties: |
| - LOG_LEVEL_MAP |
| JobLogQueues: |
| methods: |
| - append |
| - cache |
| - put |
| JobMessage: |
| properties: |
| - id |
| - messageImportance |
| - messageText |
| - time |
| JobMetadata: |
| properties: |
| - bigqueryDetails |
| - bigTableDetails |
| - datastoreDetails |
| - fileDetails |
| - pubsubDetails |
| - sdkVersion |
| - spannerDetails |
| JobMetrics: |
| properties: |
| - metrics |
| - metricTime |
| JobReference: |
| properties: |
| - jobId |
| - location |
| - projectId |
| JobServer: |
| methods: |
| - start |
| - stop |
| JobServerOptions: {} |
| JobServiceHandle: |
| methods: |
| - encode_pipeline_options |
| - get_pipeline_options |
| - prepare |
| - run |
| - stage |
| - submit |
| JobStatistics: |
| properties: |
| - completionRatio |
| - creationTime |
| - endTime |
| - extract |
| - load |
| - numChildJobs |
| - parentJobId |
| - query |
| - quotaDeferments |
| - reservation_id |
| - reservationUsage |
| - rowLevelSecurityStatistics |
| - scriptStatistics |
| - startTime |
| - totalBytesProcessed |
| - totalSlotMs |
| - transactionInfoTemplate |
| JobStatistics2: |
| properties: |
| - billingTier |
| - cacheHit |
| - ddlAffectedRowAccessPolicyCount |
| - ddlOperationPerformed |
| - ddlTargetRoutine |
| - ddlTargetRowAccessPolicy |
| - ddlTargetTable |
| - estimatedBytesProcessed |
| - modelTraining |
| - modelTrainingCurrentIteration |
| - modelTrainingExpectedTotalIteration |
| - numDmlAffectedRows |
| - queryPlan |
| - referencedRoutines |
| - referencedTables |
| - reservationUsage |
| - schema |
| - statementType |
| - timeline |
| - totalBytesBilled |
| - totalBytesProcessed |
| - totalBytesProcessedAccuracy |
| - totalPartitionsProcessed |
| - totalSlotMs |
| - undeclaredQueryParameters |
| JobStatistics3: |
| properties: |
| - badRecords |
| - inputFileBytes |
| - inputFiles |
| - outputBytes |
| - outputRows |
| JobStatistics4: |
| properties: |
| - destinationUriFileCounts |
| - inputBytes |
| JobStatus: |
| properties: |
| - errorResult |
| - errors |
| - state |
| JoinAuctionBidFn: |
| methods: |
| - higher_bid |
| - process |
| JoinFn: |
| methods: |
| - expiry |
| - process |
| properties: |
| - auction_spec |
| - AUCTIONS |
| - PERSON |
| - PERSON_EXPIRING |
| - person_spec |
| - person_timer_spec |
| JoinIndex: |
| methods: |
| - check |
| - is_subpartitioning_of |
| - test_partition_fn |
| JoinPersonAuctionFn: |
| methods: |
| - process |
| JsonCoder: |
| methods: |
| - decode |
| - encode |
| JsonLogFormatter: |
| methods: |
| - format |
| JsonObject: |
| properties: |
| - additionalProperties |
| JsonRowWriter: |
| methods: |
| - close |
| - closed |
| - flush |
| - read |
| - tell |
| - writable |
| - write |
| JuliaSetTestIT: |
| methods: |
| - test_run_example_with_setup_file |
| properties: |
| - GRID_SIZE |
| JustAuctions: |
| methods: |
| - expand |
| JustBids: |
| methods: |
| - expand |
| JustPerson: |
| methods: |
| - expand |
| KafkaIOTestOptions: {} |
| Key: |
| methods: |
| - from_client_key |
| - to_client_key |
| KeyedDefaultDict: {} |
| KeyedModelHandler: |
| methods: |
| - batch_elements_kwargs |
| - get_metrics_namespace |
| - get_num_bytes |
| - get_resource_hints |
| - load_model |
| - run_inference |
| - validate_inference_args |
| KeyedWorkItem: {} |
| KeyRangeDataDiskAssignment: |
| properties: |
| - dataDisk |
| - end |
| - start |
| KeyRangeLocation: |
| properties: |
| - dataDisk |
| - deliveryEndpoint |
| - deprecatedPersistentDirectory |
| - end |
| - start |
| Keys: |
| methods: |
| - expand |
| KeywordOnlyArgsTests: |
| methods: |
| - test_combine_keyword_only_args |
| - test_do_fn_keyword_only_args |
| - test_side_input_keyword_only_args |
| KinesisHelper: |
| methods: |
| - create_stream |
| - delete_stream |
| - get_first_shard_id |
| - read_from_stream |
| KVHint: {} |
| Largest: |
| methods: |
| - default_label |
| Latest: {} |
| LatestCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| LaunchFlexTemplateParameter: |
| properties: |
| - containerSpec |
| - containerSpecGcsPath |
| - environment |
| - jobName |
| - launchOptions |
| - parameters |
| - transformNameMappings |
| - update |
| LaunchFlexTemplateRequest: |
| properties: |
| - launchParameter |
| - validateOnly |
| LaunchFlexTemplateResponse: |
| properties: |
| - job |
| LaunchTemplateParameters: |
| properties: |
| - environment |
| - jobName |
| - parameters |
| - transformNameMapping |
| - update |
| LaunchTemplateResponse: |
| properties: |
| - job |
| LeaderBoardIT: |
| methods: |
| - setUp |
| - test_leader_board_it |
| properties: |
| - DEFAULT_EXPECTED_CHECKSUM |
| - DEFAULT_INPUT_COUNT |
| - INPUT_EVENT |
| - INPUT_SUB |
| - INPUT_TOPIC |
| - OUTPUT_DATASET |
| - OUTPUT_TABLE_TEAMS |
| - OUTPUT_TABLE_USERS |
| - WAIT_UNTIL_FINISH_DURATION |
| LeaseWorkItemRequest: |
| properties: |
| - currentWorkerTime |
| - location |
| - requestedLeaseDuration |
| - unifiedWorkerRequest |
| - workerCapabilities |
| - workerId |
| - workItemTypes |
| LeaseWorkItemResponse: |
| properties: |
| - unifiedWorkerResponse |
| - workItems |
| LengthPrefixCoder: |
| methods: |
| - as_cloud_object |
| - estimate_size |
| - is_deterministic |
| - value_coder |
| LengthPrefixCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| LexicographicKeyRangeTracker: |
| methods: |
| - fraction_to_position |
| - position_to_fraction |
| LiftedCombinePerKey: |
| methods: |
| - expand |
| Limiter: |
| methods: |
| - is_triggered |
| LinearBucket: |
| methods: |
| - accumulated_bucket_size |
| - bucket_index |
| - bucket_size |
| - num_buckets |
| - range_from |
| - range_to |
| LinearRegression: |
| methods: |
| - forward |
| LinearRegressionBenchmarkConfig: |
| properties: |
| - benchmark |
| - increment |
| - num_runs |
| - starting_point |
| LineSource: |
| methods: |
| - read_records |
| ListBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| properties: |
| - MAX_SAMPLES |
| - SAMPLE_FRACTION |
| - SAMPLED_BATCH_SIZE |
| ListBitbucketServerConfigsResponse: |
| properties: |
| - bitbucketServerConfigs |
| - nextPageToken |
| ListBitbucketServerRepositoriesResponse: |
| properties: |
| - bitbucketServerRepositories |
| - nextPageToken |
| ListBuffer: |
| methods: |
| - append |
| - clear |
| - copy |
| - extend |
| - partition |
| - reset |
| ListBuildsResponse: |
| properties: |
| - builds |
| - nextPageToken |
| ListBuildTriggersResponse: |
| properties: |
| - nextPageToken |
| - triggers |
| ListCoder: |
| methods: |
| - to_type_hint |
| ListCoderImpl: {} |
| ListGithubEnterpriseConfigsResponse: |
| properties: |
| - configs |
| ListHint: {} |
| ListJobMessagesResponse: |
| properties: |
| - autoscalingEvents |
| - jobMessages |
| - nextPageToken |
| ListJobsResponse: |
| properties: |
| - failedLocation |
| - jobs |
| - nextPageToken |
| ListLikeCoder: |
| methods: |
| - as_cloud_object |
| - as_deterministic_coder |
| - from_type_hint |
| - is_deterministic |
| - value_coder |
| ListModelsResponse: |
| properties: |
| - models |
| - nextPageToken |
| ListPlusOneDoFn: |
| methods: |
| - infer_output_type |
| - process_batch |
| ListRequest: {} |
| ListResponse: {} |
| ListRoutinesResponse: |
| properties: |
| - nextPageToken |
| - routines |
| ListRowAccessPoliciesResponse: |
| properties: |
| - nextPageToken |
| - rowAccessPolicies |
| ListSnapshotsResponse: |
| properties: |
| - snapshots |
| ListWorkerPoolsResponse: |
| properties: |
| - nextPageToken |
| - workerPools |
| LoadDataframe: |
| methods: |
| - process |
| LoadTestOptions: {} |
| LocalFileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| LocalJobServicer: |
| methods: |
| - create_beam_job |
| - get_bind_address |
| - get_service_address |
| - GetJobMetrics |
| - start_grpc_server |
| - stop |
| LocationMetadata: |
| properties: |
| - legacyLocationId |
| LogElements: |
| methods: |
| - expand |
| LogicalType: |
| methods: |
| - argument |
| - argument_type |
| - from_runner_api |
| - from_typing |
| - language_type |
| - register_logical_type |
| - representation_type |
| - to_language_type |
| - to_representation_type |
| - urn |
| LogicalTypeCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| LogicalTypeCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| LogicalTypeRegistry: |
| methods: |
| - add |
| - get_logical_type_by_language_type |
| - get_logical_type_by_urn |
| - get_urn_by_logial_type |
| ManualWatermarkEstimator: |
| methods: |
| - current_watermark |
| - default_provider |
| - get_estimator_state |
| - observe_timestamp |
| - set_watermark |
| Map: |
| methods: |
| - apply |
| MapCoder: |
| methods: |
| - as_deterministic_coder |
| - from_type_hint |
| - is_deterministic |
| - to_type_hint |
| MapCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| MapTask: |
| properties: |
| - counterPrefix |
| - instructions |
| - stageName |
| - systemName |
| MapToUnionTypesTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| Marker: {} |
| MaskDetectedDetails: |
| methods: |
| - expand |
| MatchAll: |
| methods: |
| - expand |
| MatchContinuously: |
| methods: |
| - expand |
| MatchFiles: |
| methods: |
| - expand |
| MatchResult: {} |
| MaterializedViewDefinition: |
| properties: |
| - enableRefresh |
| - lastRefreshTime |
| - query |
| - refreshIntervalMs |
| MaxDoubleAccumulator: |
| methods: |
| - add_input |
| - extract_output |
| - merge |
| MaxFloatFn: {} |
| MaxInt64Accumulator: |
| methods: |
| - add_input |
| - add_input_n |
| - extract_output |
| - merge |
| MaxInt64Fn: {} |
| MaybeKeyedModelHandler: |
| methods: |
| - batch_elements_kwargs |
| - get_metrics_namespace |
| - get_num_bytes |
| - get_resource_hints |
| - load_model |
| - run_inference |
| - validate_inference_args |
| Mean: {} |
| MeanCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - for_input_type |
| - merge_accumulators |
| MeanDoubleAccumulator: |
| methods: |
| - add_input |
| - extract_output |
| - merge |
| MeanFloatFn: {} |
| MeanInt64Accumulator: |
| methods: |
| - add_input |
| - add_input_n |
| - extract_output |
| - merge |
| MeanInt64Fn: {} |
| MeasureBytes: |
| methods: |
| - process |
| properties: |
| - LABEL |
| MeasureLatency: |
| methods: |
| - process |
| properties: |
| - LABEL |
| MeasureTime: |
| methods: |
| - finish_bundle |
| - process |
| - start_bundle |
| MemInfo: |
| properties: |
| - currentLimitBytes |
| - currentOoms |
| - currentRssBytes |
| - timestamp |
| - totalGbMs |
| MergeableStateAdapter: |
| methods: |
| - add_state |
| - clear_state |
| - clear_timer |
| - get_state |
| - get_window |
| - known_windows |
| - merge |
| - set_timer |
| properties: |
| - WINDOW_IDS |
| MethodWrapper: |
| methods: |
| - invoke_timer_callback |
| Metric: |
| methods: |
| - as_dict |
| MetricAggregator: |
| methods: |
| - combine |
| - identity_element |
| - result |
| MetricCell: |
| methods: |
| - get_cumulative |
| - reset |
| - to_runner_api_monitoring_info |
| - to_runner_api_monitoring_info_impl |
| - update |
| MetricCellFactory: {} |
| MetricKey: {} |
| MetricLogger: |
| methods: |
| - log_metrics |
| - update |
| MetricName: |
| methods: |
| - fast_name |
| MetricResult: |
| methods: |
| - result |
| MetricResultMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| MetricResults: |
| methods: |
| - matches |
| - query |
| properties: |
| - COUNTERS |
| - DISTRIBUTIONS |
| - GAUGES |
| Metrics: |
| methods: |
| - counter |
| - histogram |
| MetricsContainer: |
| methods: |
| - get_counter |
| - get_cumulative |
| - get_distribution |
| - get_gauge |
| - get_metric_cell |
| - reset |
| - to_runner_api |
| - to_runner_api_monitoring_infos |
| MetricsFilter: |
| methods: |
| - names |
| - namespaces |
| - steps |
| - with_metric |
| - with_name |
| - with_names |
| - with_namespace |
| - with_namespaces |
| - with_step |
| - with_steps |
| MetricShortId: |
| properties: |
| - metricIndex |
| - shortId |
| MetricsPublisher: |
| methods: |
| - publish |
| MetricsReader: |
| methods: |
| - get_counter_metric |
| - publish_metrics |
| - publish_values |
| MetricStructuredName: |
| properties: |
| - context |
| - name |
| - origin |
| MetricStructuredNameMatcher: |
| methods: |
| - describe_to |
| MetricUpdate: |
| properties: |
| - cumulative |
| - distribution |
| - gauge |
| - internal |
| - kind |
| - meanCount |
| - meanSum |
| - name |
| - scalar |
| - set |
| - updateTime |
| MetricUpdateMatcher: |
| methods: |
| - describe_to |
| MetricUpdater: {} |
| MetricUpdates: {} |
| MetricUpdateTranslators: |
| methods: |
| - translate_boolean |
| - translate_scalar_counter_float |
| - translate_scalar_counter_int |
| - translate_scalar_mean_float |
| - translate_scalar_mean_int |
| MicrosInstant: |
| methods: |
| - language_type |
| - representation_type |
| - to_language_type |
| - to_representation_type |
| - urn |
| MillisInstant: |
| methods: |
| - language_type |
| - representation_type |
| - to_language_type |
| - urn |
| MinDoubleAccumulator: |
| methods: |
| - add_input |
| - extract_output |
| - merge |
| MinFloatFn: {} |
| MinInt64Accumulator: |
| methods: |
| - add_input |
| - add_input_n |
| - extract_output |
| - merge |
| MinInt64Fn: {} |
| MinRamHint: |
| methods: |
| - get_merged_value |
| - parse |
| properties: |
| - urn |
| MismatchedBatchProducingDoFn: |
| methods: |
| - process |
| - process_batch |
| MismatchedElementProducingDoFn: |
| methods: |
| - process |
| - process_batch |
| MockBuckets: |
| methods: |
| - Get |
| MockCluster: {} |
| MockClusterMetadata: |
| properties: |
| - master_url |
| MockException: {} |
| MockFileIO: |
| methods: |
| - readlines |
| MockFileSystem: |
| methods: |
| - open |
| MockPipelineResult: |
| methods: |
| - cancel |
| - set_state |
| - state |
| - wait_until_finish |
| MockProperty: {} |
| MockRunners: {} |
| MockStorageClient: {} |
| Model: |
| properties: |
| - creationTime |
| - description |
| - encryptionConfiguration |
| - etag |
| - expirationTime |
| - featureColumns |
| - friendlyName |
| - labelColumns |
| - labels |
| - lastModifiedTime |
| - location |
| - modelReference |
| - modelType |
| - trainingRuns |
| ModelDefinition: |
| properties: |
| - modelOptions |
| - trainingRuns |
| ModelFileType: |
| properties: |
| - JOBLIB |
| - PICKLE |
| ModelHandler: |
| methods: |
| - batch_elements_kwargs |
| - get_metrics_namespace |
| - get_num_bytes |
| - get_resource_hints |
| - load_model |
| - run_inference |
| - validate_inference_args |
| ModelReference: |
| properties: |
| - datasetId |
| - modelId |
| - projectId |
| ModelWrapper: |
| methods: |
| - forward |
| - mean_pooling |
| Monitor: {} |
| MonitorDoFn: |
| methods: |
| - finish_bundle |
| - process |
| - start_bundle |
| MonitorSuffix: |
| properties: |
| - ELEMENT_COUNTER |
| - EVENT_TIME |
| - EVENT_TIMESTAMP |
| MonotonicWatermarkEstimator: |
| methods: |
| - current_watermark |
| - default_provider |
| - get_estimator_state |
| - observe_timestamp |
| MostBidCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| MountedDataDisk: |
| properties: |
| - dataDisk |
| MovingMeanSellingPriceFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| MovingSum: |
| methods: |
| - add |
| - count |
| - has_data |
| - sum |
| MultiClassClassificationMetrics: |
| properties: |
| - aggregateClassificationMetrics |
| - confusionMatrixList |
| MultiOutputInfo: |
| properties: |
| - tag |
| MultipleOutputParDo: |
| methods: |
| - get_wordcount_results |
| - test_multiple_output_pardo |
| properties: |
| - EXPECTED_SHORT_WORDS |
| - EXPECTED_WORDS |
| - SAMPLE_TEXT |
| MultipleReadFromPubSub: |
| methods: |
| - expand |
| MultiProcessShared: |
| methods: |
| - acquire |
| - release |
| MutationGroup: |
| methods: |
| - info |
| - primary |
| MuteRenderer: |
| methods: |
| - option |
| - render_pipeline_graph |
| MutltiTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| MyDoFn: |
| methods: |
| - finish_bundle |
| - process |
| - setup |
| - start_bundle |
| - teardown |
| MyDoFnBadAnnotation: |
| methods: |
| - process |
| MyEnum: |
| properties: |
| - E1 |
| - E2 |
| - E3 |
| MyFileBasedSink: |
| methods: |
| - close |
| - open |
| - write_encoded_record |
| MyRow: |
| properties: |
| - timestamp |
| - value |
| NameAndKind: |
| properties: |
| - kind |
| - name |
| NameContext: |
| methods: |
| - logging_name |
| - metrics_name |
| NamedObject: |
| methods: |
| - get_name |
| NamedTupleBasedPayloadBuilder: {} |
| NativeReadPTransformOverride: |
| methods: |
| - get_replacement_transform |
| - matches |
| NativeSink: |
| methods: |
| - writer |
| NativeSinkWriter: |
| methods: |
| - takes_windowed_values |
| - Write |
| NativeSource: |
| methods: |
| - is_bounded |
| - reader |
| properties: |
| - coder |
| NativeSourceReader: |
| methods: |
| - get_progress |
| - request_dynamic_split |
| - returns_windowed_values |
| NaturalLanguageMlTestIT: |
| methods: |
| - test_analyzing_syntax |
| NestedContext: |
| methods: |
| - add_state |
| - clear_state |
| - clear_timer |
| - get_current_time |
| - get_state |
| - set_timer |
| NestedInput: |
| methods: |
| - process |
| NestedOutput: |
| methods: |
| - process |
| NestedValueProvider: |
| methods: |
| - get |
| - is_accessible |
| NetworkConfig: |
| properties: |
| - egressOption |
| - peeredNetwork |
| NexmarkLauncher: |
| methods: |
| - cleanup |
| - generate_events |
| - get_performance |
| - log_performance |
| - monitor |
| - parse_args |
| - publish_performance_influxdb |
| - read_from_file |
| - read_from_pubsub |
| - run |
| - run_query |
| properties: |
| - DONE_DELAY |
| - PERF_DELAY |
| - TERMINATE_DELAY |
| - WARNING_DELAY |
| NexmarkPerf: |
| methods: |
| - has_progress |
| NoArgumentLogicalType: |
| methods: |
| - argument |
| - argument_type |
| NoElementOutputAnnotation: |
| methods: |
| - process_batch |
| NoInputAnnotation: |
| methods: |
| - process_batch |
| NonLiquidShardingOffsetRangeTracker: |
| methods: |
| - checkpoint |
| - try_split |
| NonMergingWindowFn: |
| methods: |
| - is_merging |
| - merge |
| NonParallelOperation: {} |
| NoOp: |
| methods: |
| - apply |
| NoopSink: |
| methods: |
| - expand |
| NoOpTransformIOCounter: |
| methods: |
| - add_bytes_read |
| - update_current_step |
| NoOpWatermarkEstimatorProvider: |
| methods: |
| - create_watermark_estimator |
| - initial_estimator_state |
| NoOutputTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| NoReturnAnnotation: |
| methods: |
| - process_batch |
| NormalizeEmbedding: |
| methods: |
| - process |
| NoSideInputsCallableWrapperCombineFn: |
| methods: |
| - add_input |
| - add_inputs |
| - compact |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| NotebookExecutor: |
| methods: |
| - cleanup |
| - execute |
| - notebook_path_to_execution_id |
| - output_html_dir |
| - output_html_paths |
| Notification: |
| properties: |
| - filter |
| - httpDelivery |
| - slackDelivery |
| - smtpDelivery |
| - structDelivery |
| Notifications: |
| properties: |
| - items |
| - kind |
| NotifierConfig: |
| properties: |
| - apiVersion |
| - kind |
| - metadata |
| - spec |
| NotifierMetadata: |
| properties: |
| - name |
| - notifier |
| NotifierSecret: |
| properties: |
| - name |
| - value |
| NotifierSecretRef: |
| properties: |
| - secretRef |
| NotifierSpec: |
| properties: |
| - notification |
| - secrets |
| NullableCoder: |
| methods: |
| - as_deterministic_coder |
| - from_type_hint |
| - is_deterministic |
| - to_type_hint |
| NullableCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| properties: |
| - ENCODE_NULL |
| - ENCODE_PRESENT |
| NumpyBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| NumpyTypeHint: {} |
| Object: |
| properties: |
| - acl |
| - bucket |
| - cacheControl |
| - componentCount |
| - contentDisposition |
| - contentEncoding |
| - contentLanguage |
| - contentType |
| - crc32c |
| - customerEncryption |
| - etag |
| - eventBasedHold |
| - generation |
| - id |
| - kind |
| - kmsKeyName |
| - md5Hash |
| - mediaLink |
| - metadata |
| - metageneration |
| - name |
| - owner |
| - retentionExpirationTime |
| - selfLink |
| - size |
| - storageClass |
| - temporaryHold |
| - timeCreated |
| - timeDeleted |
| - timeStorageClassUpdated |
| - updated |
| ObjectAccessControl: |
| properties: |
| - bucket |
| - domain |
| - email |
| - entity |
| - entityId |
| - etag |
| - generation |
| - id |
| - kind |
| - object |
| - projectTeam |
| - role |
| - selfLink |
| ObjectAccessControls: |
| properties: |
| - items |
| - kind |
| Objects: |
| properties: |
| - items |
| - kind |
| - nextPageToken |
| - prefixes |
| ObjectThatDoesNotImplementLen: {} |
| ObservableMixin: |
| methods: |
| - notify_observers |
| - register_observer |
| OffsetRange: |
| methods: |
| - new_tracker |
| - size |
| - split |
| - split_at |
| OffsetRangeProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_size |
| - split |
| OffsetRangeProviderWithTruncate: |
| methods: |
| - truncate |
| OffsetRangeTracker: |
| methods: |
| - fraction_consumed |
| - last_attempted_record_start |
| - last_record_start |
| - position_at_fraction |
| - position_to_fraction |
| - set_current_position |
| - set_split_points_unclaimed_callback |
| - split_points |
| - start_position |
| - stop_position |
| - try_claim |
| - try_split |
| properties: |
| - OFFSET_INFINITY |
| OffsetRestrictionTracker: |
| methods: |
| - check_done |
| - current_progress |
| - current_restriction |
| - is_bounded |
| - start_position |
| - stop_position |
| - try_claim |
| - try_split |
| OldClassThatDoesNotImplementLen: {} |
| Operation: |
| methods: |
| - add_receiver |
| - current_element_progress |
| - execution_time_monitoring_infos |
| - finalize_bundle |
| - finish |
| - get_batching_preference |
| - get_input_batch_converter |
| - get_output_batch_converter |
| - monitoring_infos |
| - needs_finalization |
| - output |
| - pcollection_count_monitoring_infos |
| - process |
| - process_batch |
| - reset |
| - setup |
| - start |
| - str_internal |
| - teardown |
| - try_split |
| - user_monitoring_infos |
| OperationCounters: |
| methods: |
| - do_sample |
| - restart_sampling |
| - should_sample |
| - type_check |
| - update_collect |
| - update_from |
| - update_from_batch |
| OperationMetadata: |
| properties: |
| - apiVersion |
| - cancelRequested |
| - createTime |
| - endTime |
| - statusDetail |
| - target |
| - verb |
| OptimizeGrid: |
| methods: |
| - expand |
| OptionalHint: {} |
| OptionalUnionType: |
| properties: |
| - unnamed |
| Options: |
| methods: |
| - cache_root |
| - cache_root |
| - display_timestamp_format |
| - display_timestamp_format |
| - display_timezone |
| - display_timezone |
| - enable_recording_replay |
| - enable_recording_replay |
| - recordable_sources |
| - recording_duration |
| - recording_duration |
| - recording_size_limit |
| - recording_size_limit |
| OptionsContext: |
| methods: |
| - augment_options |
| properties: |
| - overrides |
| OptionsEntry: |
| properties: |
| - arg_builder |
| - cls |
| - default |
| - help |
| - label |
| OptionsForm: |
| methods: |
| - add |
| - additional_options |
| - display_actions |
| - display_for_input |
| - to_options |
| OrderedPositionRangeTracker: |
| methods: |
| - fraction_consumed |
| - fraction_to_position |
| - position_at_fraction |
| - position_to_fraction |
| - start_position |
| - stop_position |
| - try_claim |
| - try_split |
| properties: |
| - UNSTARTED |
| OrFinally: |
| methods: |
| - from_runner_api |
| - to_runner_api |
| OutputAtEarliestInputTimestampImpl: |
| methods: |
| - assign_output_time |
| - combine |
| OutputAtEarliestTransformedInputTimestampImpl: |
| methods: |
| - assign_output_time |
| - combine |
| OutputAtEndOfWindowImpl: |
| methods: |
| - assign_output_time |
| - combine |
| OutputAtLatestInputTimestampImpl: |
| methods: |
| - assign_output_time |
| - combine |
| OutputCheckWrapperDoFn: |
| methods: |
| - wrapper |
| OutputFile: {} |
| OutputFormat: |
| properties: |
| - SERIALIZED_TEST_STREAM_FILE_RECORDS |
| - TEST_STREAM_EVENTS |
| - TEST_STREAM_FILE_RECORDS |
| OutputHandler: |
| methods: |
| - handle_process_batch_outputs |
| - handle_process_outputs |
| OutputStream: |
| methods: |
| - get |
| - size |
| - write |
| - write_bigendian_double |
| - write_bigendian_float |
| - write_bigendian_int32 |
| - write_bigendian_int64 |
| - write_bigendian_uint64 |
| - write_byte |
| - write_var_int64 |
| OutputTimer: |
| methods: |
| - clear |
| - set |
| OverrideTypeInference: |
| methods: |
| - get_input_batch_type |
| - get_output_batch_type |
| - process_batch |
| Package: |
| properties: |
| - location |
| - name |
| PairWithRestrictionFn: |
| methods: |
| - process |
| - start_bundle |
| PairWithTiming: |
| methods: |
| - expand |
| properties: |
| - URN |
| PaneInfo: |
| methods: |
| - encoded_byte |
| - from_encoded_byte |
| - index |
| - is_first |
| - is_last |
| - nonspeculative_index |
| - timing |
| PaneInfoCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| PaneInfoEncoding: |
| properties: |
| - FIRST |
| - ONE_INDEX |
| - TWO_INDICES |
| PaneInfoTiming: |
| methods: |
| - from_string |
| - to_string |
| properties: |
| - EARLY |
| - LATE |
| - ON_TIME |
| - UNKNOWN |
| ParallelBundleManager: |
| methods: |
| - process_bundle |
| ParallelInstruction: |
| properties: |
| - flatten |
| - name |
| - originalName |
| - outputs |
| - parDo |
| - partialGroupByKey |
| - read |
| - systemName |
| - write |
| Parameter: |
| properties: |
| - key |
| - value |
| ParameterMetadata: |
| properties: |
| - customMetadata |
| - helpText |
| - isOptional |
| - label |
| - name |
| - paramType |
| - regexes |
| ParamWindowedValueCoder: |
| methods: |
| - as_cloud_object |
| - from_runner_api_parameter |
| - is_deterministic |
| - to_runner_api_parameter |
| ParamWindowedValueCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - get_estimated_size_and_observables |
| ParDo: |
| methods: |
| - apply |
| ParDoInstruction: |
| properties: |
| - input |
| - multiOutputInfos |
| - numOutputs |
| - sideInputs |
| - userFn |
| ParseEventFn: |
| methods: |
| - process |
| ParseGameEventFn: |
| methods: |
| - process |
| ParseJsonEventFn: |
| methods: |
| - process |
| PartialGroupByKeyCombiningValues: |
| methods: |
| - default_type_hints |
| - finish_bundle |
| - process |
| - setup |
| - start_bundle |
| - teardown |
| PartialGroupByKeyInstruction: |
| properties: |
| - input |
| - inputElementCodec |
| - originalCombineValuesInputStoreName |
| - originalCombineValuesStepName |
| - sideInputs |
| - valueCombiningFn |
| Partition: |
| methods: |
| - expand |
| - make_fn |
| PartitionableBuffer: |
| methods: |
| - clear |
| - cleared |
| - copy |
| - partition |
| - reset |
| PartitionFiles: |
| methods: |
| - process |
| properties: |
| - MULTIPLE_PARTITIONS_TAG |
| - SINGLE_PARTITION_TAG |
| PartitionFn: |
| methods: |
| - default_label |
| - partition_for |
| Partitioning: |
| methods: |
| - is_subpartitioning_of |
| - partition_fn |
| - test_partition_fn |
| PartitioningSession: |
| methods: |
| - evaluate |
| PartitionTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| PassThroughLogicalType: |
| methods: |
| - representation_type |
| - to_language_type |
| - to_representation_type |
| PayloadBase: |
| methods: |
| - get_payload_from_beam_typehints |
| - get_payload_from_typing_hints |
| - test_optional_error |
| - test_typehints_payload_builder |
| - test_typing_payload_builder |
| properties: |
| - bytes_values |
| - values |
| PayloadBuilder: |
| methods: |
| - build |
| - payload |
| PayloadTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| PBegin: {} |
| PCollection: |
| methods: |
| - from_ |
| - from_runner_api |
| - to_runner_api |
| - windowing |
| PCollectionVisualization: |
| methods: |
| - display |
| - display_plain_text |
| PDone: {} |
| People: |
| properties: |
| - partner |
| - primary |
| PerformanceTypeCheckVisitor: |
| methods: |
| - get_input_type_hints |
| - get_output_type_hints |
| - visit_transform |
| PeriodicImpulse: |
| methods: |
| - expand |
| PeriodicSequence: |
| methods: |
| - expand |
| PeriodicSequenceIT: |
| methods: |
| - setUp |
| - test_periodicsequence_outputs_valid_watermarks_it |
| PeriodicThread: |
| methods: |
| - cancel |
| - run |
| PermanentException: {} |
| Person: |
| properties: |
| - CODER |
| PersonByIdFn: |
| methods: |
| - process |
| PersonCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| PersonCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| PerWindowInvoker: |
| methods: |
| - current_element_progress |
| - invoke_process |
| - invoke_process_batch |
| - try_split |
| PerWindowTriggerContext: |
| methods: |
| - add_state |
| - clear_state |
| - clear_timer |
| - get_current_time |
| - get_state |
| - set_timer |
| PGBKCVOperation: |
| methods: |
| - finish |
| - output_key |
| - process |
| - setup |
| - teardown |
| PGBKOperation: |
| methods: |
| - finish |
| - flush |
| - process |
| PhasedCombineFnExecutor: |
| methods: |
| - add_only |
| - convert_to_accumulator |
| - extract_only |
| - full_combine |
| - merge_only |
| PickleCoder: |
| methods: |
| - as_deterministic_coder |
| - to_type_hint |
| PickledDoFnInfo: |
| methods: |
| - serialized_dofn_data |
| - to_runner_api |
| PickledObject: {} |
| Pipeline: |
| methods: |
| - allow_unsafe_triggers |
| - apply |
| - from_runner_api |
| - merge_compatible_environments |
| - options |
| - replace_all |
| - run |
| - runner_implemented_transforms |
| - to_runner_api |
| - visit |
| PipelineContext: |
| methods: |
| - add_requirement |
| - coder_id_from_element_type |
| - default_environment_id |
| - element_type_from_coder_id |
| - from_runner_api |
| - get_environment_id_for_resource_hints |
| - requirements |
| - to_runner_api |
| PipelineDescription: |
| properties: |
| - displayData |
| - executionPipelineStage |
| - originalPipelineTransform |
| PipelineError: {} |
| PipelineFragment: |
| methods: |
| - deduce_fragment |
| - run |
| PipelineGraph: |
| methods: |
| - display_graph |
| - get_dot |
| PipelineGraphRenderer: |
| methods: |
| - option |
| - render_pipeline_graph |
| PipelineInstrument: |
| methods: |
| - background_caching_pipeline_proto |
| - cache_key |
| - cacheables |
| - find_cacheables |
| - has_unbounded_sources |
| - instrument |
| - instrumented_pipeline_proto |
| - original_pipeline_proto |
| - pcoll_id |
| - preprocess |
| - prune_subgraph_for |
| - runner_pcoll_to_user_pcoll |
| - user_pipeline |
| PipelineOptions: |
| methods: |
| - display_data |
| - from_dictionary |
| - get_all_options |
| - view_as |
| PipelineOptionsValidator: |
| methods: |
| - is_full_string_match |
| - is_service_runner |
| - validate |
| - validate_cloud_options |
| - validate_container_prebuilding_options |
| - validate_environment_options |
| - validate_gcs_path |
| - validate_num_workers |
| - validate_optional_argument_positive |
| - validate_repeatable_argument_passed_as_list |
| - validate_sdk_container_image_options |
| - validate_test_matcher |
| - validate_worker_region_zone |
| properties: |
| - ENDPOINT_PATTERN |
| - ERR_ENVIRONMENT_CONFIG |
| - ERR_INVALID_ENVIRONMENT |
| - ERR_INVALID_GCS_BUCKET |
| - ERR_INVALID_GCS_OBJECT |
| - ERR_INVALID_GCS_PATH |
| - ERR_INVALID_JOB_NAME |
| - ERR_INVALID_NOT_POSITIVE |
| - ERR_INVALID_PROJECT_ID |
| - ERR_INVALID_PROJECT_NUMBER |
| - ERR_INVALID_TEST_MATCHER_TYPE |
| - ERR_INVALID_TEST_MATCHER_UNPICKLABLE |
| - ERR_INVALID_TRANSFORM_NAME_MAPPING |
| - ERR_MISSING_GCS_PATH |
| - ERR_MISSING_OPTION |
| - ERR_MISSING_REQUIRED_ENVIRONMENT_OPTION |
| - ERR_NUM_WORKERS_TOO_HIGH |
| - ERR_REPEATABLE_OPTIONS_NOT_SET_AS_LIST |
| - GCS_BUCKET |
| - GCS_SCHEME |
| - GCS_URI |
| - JOB_PATTERN |
| - OPTIONAL_ENVIRONMENT_OPTIONS |
| - OPTIONS |
| - PROJECT_ID_PATTERN |
| - PROJECT_NUMBER_PATTERN |
| - REQUIRED_ENVIRONMENT_OPTIONS |
| PipelineRenderer: |
| methods: |
| - info |
| - is_leaf |
| - layout_dot |
| - page |
| - page_callback_data |
| - pcoll_leaf_consumers |
| - pcoll_leaf_consumers_iter |
| - render_data |
| - render_json |
| - style |
| - to_dot |
| - to_dot_iter |
| - transform_attributes |
| - transform_node |
| - transform_to_dot |
| - update |
| PipelineResult: |
| methods: |
| - cancel |
| - metrics |
| - pipeline_state_to_runner_api_state |
| - runner_api_state_to_pipeline_state |
| - state |
| - wait_until_finish |
| PipelineRunner: |
| methods: |
| - apply |
| - apply_PTransform |
| - is_fnapi_compatible |
| - run |
| - run_async |
| - run_pipeline |
| - run_transform |
| - visit_transforms |
| PipelineState: |
| methods: |
| - is_terminal |
| properties: |
| - CANCELLED |
| - CANCELLING |
| - DONE |
| - DRAINED |
| - DRAINING |
| - FAILED |
| - PENDING |
| - RESOURCE_CLEANING_UP |
| - RUNNING |
| - STARTING |
| - STOPPED |
| - UNKNOWN |
| - UNRECOGNIZED |
| - UPDATED |
| PipelineStateMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| PipelineVisitor: |
| methods: |
| - enter_composite_transform |
| - leave_composite_transform |
| - visit_transform |
| - visit_value |
| PipeStream: |
| methods: |
| - read |
| - seek |
| - tell |
| PlaceholderExpression: |
| methods: |
| - args |
| - evaluate_at |
| - placeholders |
| - preserves_partition_by |
| - requires_partition_by |
| Player: {} |
| PlayerCoder: |
| methods: |
| - decode |
| - encode |
| - is_deterministic |
| Point: |
| properties: |
| - time |
| - value |
| Policy: |
| properties: |
| - bindings |
| - etag |
| - kind |
| - resourceId |
| PoolOption: |
| properties: |
| - name |
| PortableMetrics: |
| methods: |
| - query |
| PortableObject: |
| methods: |
| - from_runner_api |
| - to_runner_api |
| PortableOptions: |
| methods: |
| - add_environment_option |
| - lookup_environment_option |
| - validate |
| PortableRunner: |
| methods: |
| - create_job_service |
| - create_job_service_handle |
| - default_job_server |
| - get_proto_pipeline |
| - run_pipeline |
| PortableRunnerOptimized: |
| methods: |
| - create_options |
| PortableRunnerOptimizedWithoutFusion: |
| methods: |
| - create_options |
| PortableRunnerTestWithExternalEnv: |
| methods: |
| - create_options |
| - setUpClass |
| - tearDownClass |
| PortableRunnerTestWithLocalDocker: |
| methods: |
| - create_options |
| PortableRunnerTestWithSubprocesses: |
| methods: |
| - create_options |
| - test_batch_rebatch_pardos |
| PortableRunnerTestWithSubprocessesAndMultiWorkers: |
| methods: |
| - create_options |
| Position: |
| properties: |
| - byteOffset |
| - concatPosition |
| - end |
| - key |
| - recordIndex |
| - shufflePosition |
| Postprocess: |
| methods: |
| - process |
| PostProcessor: |
| methods: |
| - process |
| PredictUserEvent: |
| methods: |
| - expand |
| PrefetchingSourceSetIterable: |
| methods: |
| - add_byte_counter |
| PrefixTransform: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| Preprocess: |
| methods: |
| - process |
| PrintFn: |
| methods: |
| - process |
| PrivatePoolV1Config: |
| properties: |
| - networkConfig |
| - workerConfig |
| ProcessAppManifestCallbackOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - githubEnterpriseConfig |
| ProcessContinuation: |
| methods: |
| - resume |
| ProcessElements: |
| methods: |
| - expand |
| - new_process_fn |
| ProcessEnvironment: |
| methods: |
| - from_options |
| - from_runner_api_parameter |
| - parse_environment_variables |
| - to_runner_api_parameter |
| ProcessFn: |
| methods: |
| - process |
| - set_process_element_invoker |
| - step_context |
| - step_context |
| ProcessInferenceToString: |
| methods: |
| - process |
| ProcessingTimeEvent: |
| methods: |
| - to_runner_api |
| ProcessingTimeLimiter: |
| methods: |
| - is_triggered |
| - update |
| ProcessKeyedElements: |
| methods: |
| - expand |
| ProcessKeyedElementsViaKeyedWorkItems: |
| methods: |
| - expand |
| ProcessKeyedElementsViaKeyedWorkItemsOverride: |
| methods: |
| - get_replacement_transform_for_applied_ptransform |
| - matches |
| ProducerFn: |
| methods: |
| - get_int |
| - get_string |
| - process |
| Profile: |
| methods: |
| - default_file_copy_fn |
| - factory_from_options |
| properties: |
| - profile_output |
| - SORTBY |
| - stats |
| ProfilingOptions: {} |
| ProgressIndicator: |
| properties: |
| - spinner_removal_template |
| - spinner_template |
| ProgressRequester: |
| methods: |
| - run |
| - stop |
| ProgressTimeseries: |
| properties: |
| - currentProgress |
| - dataPoints |
| ProjectList: |
| properties: |
| - etag |
| - kind |
| - nextPageToken |
| - projects |
| - totalItems |
| ProjectReference: |
| properties: |
| - projectId |
| ProjectToCategoryPriceFn: |
| methods: |
| - process |
| PropertyNames: |
| properties: |
| - ALLOWS_SHARDABLE_STATE |
| - BIGQUERY_CREATE_DISPOSITION |
| - BIGQUERY_DATASET |
| - BIGQUERY_EXPORT_FORMAT |
| - BIGQUERY_FLATTEN_RESULTS |
| - BIGQUERY_KMS_KEY |
| - BIGQUERY_PROJECT |
| - BIGQUERY_QUERY |
| - BIGQUERY_SCHEMA |
| - BIGQUERY_TABLE |
| - BIGQUERY_USE_LEGACY_SQL |
| - BIGQUERY_WRITE_DISPOSITION |
| - DISPLAY_DATA |
| - ELEMENT |
| - ELEMENTS |
| - ENCODING |
| - FILE_NAME_PREFIX |
| - FILE_NAME_SUFFIX |
| - FILE_PATTERN |
| - FORMAT |
| - IMPULSE_ELEMENT |
| - INPUTS |
| - NON_PARALLEL_INPUTS |
| - NUM_SHARDS |
| - OUT |
| - OUTPUT |
| - OUTPUT_INFO |
| - OUTPUT_NAME |
| - PARALLEL_INPUT |
| - PIPELINE_PROTO_TRANSFORM_ID |
| - PRESERVES_KEYS |
| - PUBSUB_ID_LABEL |
| - PUBSUB_SERIALIZED_ATTRIBUTES_FN |
| - PUBSUB_SUBSCRIPTION |
| - PUBSUB_TIMESTAMP_ATTRIBUTE |
| - PUBSUB_TOPIC |
| - RESOURCE_HINTS |
| - RESTRICTION_ENCODING |
| - SERIALIZED_FN |
| - SERIALIZED_TEST_STREAM |
| - SHARD_NAME_TEMPLATE |
| - SOURCE_STEP_INPUT |
| - STEP_NAME |
| - USE_INDEXED_FORMAT |
| - USER_FN |
| - USER_NAME |
| - USES_KEYED_STATE |
| - VALIDATE_SINK |
| - VALIDATE_SOURCE |
| - VALUE |
| - WINDOWING_STRATEGY |
| ProperyTestingCoders: |
| methods: |
| - test_float_coder |
| - test_row_coder |
| - test_string_coder |
| ProtoCoder: |
| methods: |
| - as_deterministic_coder |
| - from_type_hint |
| - is_deterministic |
| - to_type_hint |
| ProtoCoderImpl: |
| methods: |
| - decode |
| - encode |
| ProtoPlusCoder: |
| methods: |
| - from_type_hint |
| - is_deterministic |
| - to_type_hint |
| ProtoPlusCoderImpl: |
| methods: |
| - decode |
| - encode |
| ProtoPlusMessageA: |
| properties: |
| - field1 |
| - field2 |
| ProtoPlusMessageB: |
| properties: |
| - field1 |
| ProtoPlusMessageWithMap: |
| properties: |
| - field1 |
| PTransform: |
| methods: |
| - annotations |
| - default_label |
| - default_type_hints |
| - expand |
| - from_runner_api |
| - get_resource_hints |
| - get_windowing |
| - infer_output_type |
| - label |
| - label |
| - register_urn |
| - register_urn |
| - register_urn |
| - register_urn |
| - register_urn |
| - runner_api_requires_keyed_input |
| - to_runner_api |
| - to_runner_api_parameter |
| - to_runner_api_pickled |
| - type_check_inputs |
| - type_check_inputs_or_outputs |
| - type_check_outputs |
| - with_input_types |
| - with_output_types |
| - with_resource_hints |
| properties: |
| - pipeline |
| - side_inputs |
| PTransformOverride: |
| methods: |
| - get_replacement_inputs |
| - get_replacement_transform |
| - get_replacement_transform_for_applied_ptransform |
| - matches |
| PTransformTestDisplayData: |
| methods: |
| - test_filter_anonymous_function |
| - test_filter_named_function |
| - test_flatmap_anonymous_function |
| - test_flatmap_named_function |
| - test_map_anonymous_function |
| - test_map_named_function |
| PTransformWithSideInputs: |
| methods: |
| - default_label |
| - make_fn |
| - type_check_inputs |
| - with_input_types |
| PubSubBigQueryIT: |
| methods: |
| - setUp |
| - tearDown |
| - test_file_loads |
| - test_streaming_inserts |
| properties: |
| - BIG_QUERY_DATASET_ID |
| - INPUT_SUB |
| - INPUT_TOPIC |
| - SCHEMA |
| - WAIT_UNTIL_FINISH_DURATION |
| PubsubConfig: |
| properties: |
| - serviceAccountEmail |
| - state |
| - subscription |
| - topic |
| PubSubIODetails: |
| properties: |
| - subscription |
| - topic |
| PubsubLocation: |
| properties: |
| - dropLateData |
| - idLabel |
| - subscription |
| - timestampLabel |
| - topic |
| - trackingSubscription |
| - withAttributes |
| PubsubMessage: {} |
| PubSubMessageMatcher: |
| methods: |
| - describe_mismatch |
| - describe_to |
| PubsubSnapshotMetadata: |
| properties: |
| - expireTime |
| - snapshotName |
| - topicName |
| PubSubSourceDescriptor: |
| properties: |
| - id_label |
| - source |
| - timestamp_attribute |
| PullRequestFilter: |
| properties: |
| - branch |
| - commentControl |
| - invertRegex |
| PullResponseMessage: {} |
| PushFilter: |
| properties: |
| - branch |
| - invertRegex |
| - tag |
| PValue: |
| methods: |
| - apply |
| PValueCache: |
| methods: |
| - cache_output |
| - clear_pvalue |
| - get_pvalue |
| - get_unwindowed_pvalue |
| - is_cached |
| - key |
| - to_cache_key |
| PValueError: {} |
| PyarrowArrayBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| PyarrowBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| PydotRenderer: |
| methods: |
| - option |
| - render_pipeline_graph |
| PyPIArtifactRegistry: |
| methods: |
| - get_artifacts |
| - register_artifact |
| PythonCallable: |
| methods: |
| - language_type |
| - representation_type |
| - to_language_type |
| - to_representation_type |
| - urn |
| PythonCallableWithSource: |
| methods: |
| - default_label |
| - get_source |
| - load_from_expression |
| - load_from_fully_qualified_name |
| - load_from_script |
| - load_from_source |
| PytorchBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| PyTorchInference: |
| methods: |
| - test_torch_run_inference_bert_for_masked_lm |
| - test_torch_run_inference_coco_maskrcnn_resnet50_fpn |
| - test_torch_run_inference_imagenet_mobilenetv2 |
| PytorchLinearRegression: |
| methods: |
| - forward |
| - generate |
| PytorchLinearRegressionDict: |
| methods: |
| - forward |
| PytorchLinearRegressionKeyedBatchAndExtraInferenceArgs: |
| methods: |
| - forward |
| PytorchModelHandlerKeyedTensor: |
| methods: |
| - get_metrics_namespace |
| - get_num_bytes |
| - load_model |
| - run_inference |
| - validate_inference_args |
| PytorchModelHandlerTensor: |
| methods: |
| - get_metrics_namespace |
| - get_num_bytes |
| - load_model |
| - run_inference |
| - validate_inference_args |
| PytorchNoBatchModelHandler: |
| methods: |
| - batch_elements_kwargs |
| PytorchTypeHint: {} |
| Query: |
| methods: |
| - clone |
| QueryInfo: |
| properties: |
| - queryProperty |
| QueryParameter: |
| properties: |
| - name |
| - parameterType |
| - parameterValue |
| QueryParameterType: |
| properties: |
| - arrayType |
| - structTypes |
| - type |
| QueryParameterValue: |
| properties: |
| - arrayValues |
| - structValues |
| - value |
| QueryRequest: |
| properties: |
| - connectionProperties |
| - defaultDataset |
| - dryRun |
| - kind |
| - labels |
| - location |
| - maximumBytesBilled |
| - maxResults |
| - parameterMode |
| - preserveNulls |
| - query |
| - queryParameters |
| - requestId |
| - timeoutMs |
| - useLegacySql |
| - useQueryCache |
| QueryResponse: |
| properties: |
| - cacheHit |
| - errors |
| - jobComplete |
| - jobReference |
| - kind |
| - numDmlAffectedRows |
| - pageToken |
| - rows |
| - schema |
| - totalBytesProcessed |
| - totalRows |
| QuerySplitterError: {} |
| QueryTimelineSample: |
| properties: |
| - activeUnits |
| - completedUnits |
| - elapsedMs |
| - pendingUnits |
| - totalSlotMs |
| RampupThrottlingFn: |
| methods: |
| - process |
| RandomUniqueKeyFn: |
| methods: |
| - process |
| RangePartitioning: |
| properties: |
| - field |
| - range |
| RangeSource: |
| methods: |
| - estimate_size |
| - get_range_tracker |
| - read |
| - split |
| RangeTracker: |
| methods: |
| - fraction_consumed |
| - position_at_fraction |
| - set_current_position |
| - set_split_points_unclaimed_callback |
| - split_points |
| - start_position |
| - stop_position |
| - try_claim |
| - try_split |
| properties: |
| - SPLIT_POINTS_UNKNOWN |
| RankingMetrics: |
| properties: |
| - averageRank |
| - meanAveragePrecision |
| - meanSquaredError |
| - normalizedDiscountedCumulativeGain |
| Read: |
| methods: |
| - display_data |
| - expand |
| - from_runner_api_parameter |
| - get_desired_chunk_size |
| - get_windowing |
| - to_runner_api_parameter |
| ReadableFile: |
| methods: |
| - open |
| - read |
| - read_utf8 |
| ReadAllBQTests: |
| methods: |
| - create_bq_schema |
| - create_table |
| - setUpClass |
| - test_read_queries |
| properties: |
| - TABLE_DATA_1 |
| - TABLE_DATA_2 |
| - TABLE_DATA_3 |
| ReadAllFiles: |
| methods: |
| - expand |
| ReadAllFromAvro: |
| methods: |
| - expand |
| properties: |
| - DEFAULT_DESIRED_BUNDLE_SIZE |
| ReadAllFromAvroContinuously: |
| methods: |
| - expand |
| ReadAllFromBigQuery: |
| methods: |
| - expand |
| properties: |
| - COUNTER |
| ReadAllFromParquet: |
| methods: |
| - expand |
| ReadAllFromParquetBatched: |
| methods: |
| - expand |
| properties: |
| - DEFAULT_DESIRED_BUNDLE_SIZE |
| ReadAllFromText: |
| methods: |
| - expand |
| properties: |
| - DEFAULT_DESIRED_BUNDLE_SIZE |
| ReadAllFromTextContinuously: |
| methods: |
| - expand |
| ReadAllFromTFRecord: |
| methods: |
| - expand |
| ReadCache: |
| methods: |
| - read_cache |
| ReadDataFromKinesis: |
| properties: |
| - URN |
| ReaderPosition: {} |
| ReaderProgress: |
| methods: |
| - consumed_split_points |
| - percent_complete |
| - position |
| - remaining_split_points |
| - remaining_time |
| ReadFiles: |
| methods: |
| - process |
| ReadFilesProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_size |
| ReadFromAvro: |
| methods: |
| - display_data |
| - expand |
| ReadFromBigQuery: |
| methods: |
| - expand |
| properties: |
| - COUNTER |
| ReadFromBigQueryRequest: |
| methods: |
| - validate |
| ReadFromCountingSource: |
| methods: |
| - expand |
| ReadFromDatastore: |
| methods: |
| - display_data |
| - expand |
| ReadFromDebezium: |
| methods: |
| - expand |
| properties: |
| - URN |
| ReadFromJdbc: |
| properties: |
| - URN |
| ReadFromKafka: |
| properties: |
| - byte_array_deserializer |
| - create_time_policy |
| - log_append_time |
| - processing_time_policy |
| - URN_WITH_METADATA |
| - URN_WITHOUT_METADATA |
| ReadFromMongoDB: |
| methods: |
| - expand |
| ReadFromParquet: |
| methods: |
| - display_data |
| - expand |
| ReadFromParquetBatched: |
| methods: |
| - display_data |
| - expand |
| ReadFromPubSub: |
| methods: |
| - expand |
| properties: |
| - URN |
| ReadFromPubSubLite: |
| methods: |
| - expand |
| ReadFromSnowflake: |
| methods: |
| - expand |
| properties: |
| - URN |
| ReadFromSpanner: |
| methods: |
| - display_data |
| - expand |
| ReadFromSpannerSchema: |
| properties: |
| - batching |
| - database_id |
| - emulator_host |
| - host |
| - instance_id |
| - project_id |
| - read_timestamp |
| - schema |
| - sql |
| - staleness |
| - table |
| - time_unit |
| - timestamp_bound_mode |
| ReadFromText: |
| methods: |
| - expand |
| ReadFromTextWithFilename: {} |
| ReadFromTFRecord: |
| methods: |
| - expand |
| ReadGbqTransformTests: |
| methods: |
| - test_bad_schema_public_api_direct_read |
| - test_ReadGbq_unsupported_param |
| - test_unsupported_callable |
| ReadInstruction: |
| properties: |
| - source |
| ReadInteractiveRunnerTests: |
| methods: |
| - test_read_in_interactive_runner |
| ReadMatches: |
| methods: |
| - expand |
| ReadModifyWriteRuntimeState: |
| methods: |
| - clear |
| - commit |
| - read |
| - write |
| ReadModifyWriteStateSpec: |
| methods: |
| - to_runner_api |
| ReadNewTypesTests: |
| methods: |
| - create_table |
| - get_expected_data |
| - setUpClass |
| - test_iobase_source |
| - test_native_source |
| ReadOperation: |
| methods: |
| - start |
| ReadPTransformOverride: |
| methods: |
| - get_replacement_transform_for_applied_ptransform |
| - matches |
| ReadTests: |
| methods: |
| - create_table |
| - setUpClass |
| - test_iobase_source |
| - test_native_source |
| - test_table_schema_retrieve |
| - test_table_schema_retrieve_specifying_only_table |
| - test_table_schema_retrieve_with_direct_read |
| properties: |
| - TABLE_DATA |
| ReadUsingReadGbqTests: |
| methods: |
| - test_ReadGbq |
| - test_ReadGbq_direct_read |
| - test_ReadGbq_direct_read_with_project |
| - test_ReadGbq_export_with_project |
| - test_ReadGbq_with_computation |
| ReadUsingStorageApiTests: |
| methods: |
| - setUpClass |
| - tearDownClass |
| - test_iobase_source |
| - test_iobase_source_with_column_selection |
| - test_iobase_source_with_column_selection_and_row_restriction |
| - test_iobase_source_with_native_datetime |
| - test_iobase_source_with_query |
| - test_iobase_source_with_query_and_filters |
| - test_iobase_source_with_row_restriction |
| - test_iobase_source_with_very_selective_filters |
| properties: |
| - TABLE_DATA |
| ReadViaPandas: |
| methods: |
| - expand |
| RealClock: |
| methods: |
| - time |
| Receiver: |
| methods: |
| - flush |
| - receive |
| - receive_batch |
| ReceiveTriggerWebhookResponse: {} |
| RecommendationAIIT: |
| methods: |
| - tearDownClass |
| - test_create_catalog_item |
| - test_create_user_event |
| - test_predict |
| Record: |
| properties: |
| - age |
| - height |
| - name |
| Recording: |
| methods: |
| - cancel |
| - computed |
| - describe |
| - is_computed |
| - stream |
| - uncomputed |
| - wait_until_finish |
| RecordingManager: |
| methods: |
| - cancel |
| - clear |
| - describe |
| - read |
| - record |
| - record_pipeline |
| Recordings: |
| methods: |
| - clear |
| - describe |
| - record |
| - stop |
| RecursiveClass: |
| properties: |
| - SELF_TYPE |
| Regex: |
| methods: |
| - all_matches |
| - find |
| - find_all |
| - find_kv |
| - matches |
| - matches_kv |
| - replace_all |
| - replace_first |
| - split |
| properties: |
| - ALL |
| RegressionMetrics: |
| properties: |
| - meanAbsoluteError |
| - meanSquaredError |
| - meanSquaredLogError |
| - medianAbsoluteError |
| - rSquared |
| Reify: |
| methods: |
| - process |
| ReifyWindowsFn: |
| methods: |
| - process |
| RekeyElements: |
| methods: |
| - process |
| RemoveBitbucketServerConnectedRepositoryRequest: |
| properties: |
| - connectedRepository |
| RenderOptions: {} |
| RenderPipelineResult: |
| methods: |
| - monitoring_infos |
| - wait_until_finish |
| RenderRunner: |
| methods: |
| - run_pipeline |
| Repeatedly: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| ReportedParallelism: |
| properties: |
| - isInfinite |
| - value |
| ReportWorkItemStatusRequest: |
| properties: |
| - currentWorkerTime |
| - location |
| - unifiedWorkerRequest |
| - workerId |
| - workItemStatuses |
| ReportWorkItemStatusResponse: |
| properties: |
| - unifiedWorkerResponse |
| - workItemServiceStates |
| RepoSource: |
| properties: |
| - branchName |
| - commitSha |
| - dir |
| - invertRegex |
| - projectId |
| - repoName |
| - substitutions |
| - tagName |
| Reshuffle: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| ReshufflePerKey: |
| methods: |
| - expand |
| ResourceHint: |
| methods: |
| - get_by_name |
| - get_by_urn |
| - get_merged_value |
| - is_registered |
| - parse |
| - register_resource_hint |
| properties: |
| - urn |
| ResourceUtilizationReport: |
| properties: |
| - containers |
| - cpuTime |
| - memoryInfo |
| ResourceUtilizationReportResponse: {} |
| RestrictionProgress: |
| methods: |
| - completed_work |
| - fraction_completed |
| - fraction_remaining |
| - remaining_work |
| - total_work |
| - with_completed |
| RestrictionProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_coder |
| - restriction_size |
| - split |
| - split_and_size |
| - truncate |
| RestrictionTracker: |
| methods: |
| - check_done |
| - current_progress |
| - current_restriction |
| - is_bounded |
| - try_claim |
| - try_split |
| RestrictionTrackerView: |
| methods: |
| - current_restriction |
| - defer_remainder |
| - is_bounded |
| - try_claim |
| ResultNames: |
| properties: |
| - AUCTION_ID |
| - BID_COUNT |
| - BIDDER_ID |
| - CATEGORY |
| - CITY |
| - ID |
| - IS_LAST |
| - NAME |
| - NUM |
| - PRICE |
| - RESERVE |
| - SELLER |
| - STATE |
| Results: |
| properties: |
| - artifactManifest |
| - artifactTiming |
| - buildStepImages |
| - buildStepOutputs |
| - images |
| - numArtifacts |
| RetryBuildRequest: |
| properties: |
| - id |
| - name |
| - projectId |
| RetryStrategy: |
| methods: |
| - should_retry |
| properties: |
| - RETRY_ALWAYS |
| - RETRY_NEVER |
| - RETRY_ON_TRANSIENT_ERROR |
| ReverseTestStream: |
| methods: |
| - expand |
| RewriteResponse: |
| properties: |
| - done |
| - kind |
| - objectSize |
| - resource |
| - rewriteToken |
| - totalBytesRewritten |
| RootBundleProvider: |
| methods: |
| - get_root_bundles |
| RoundTripFn: |
| methods: |
| - process |
| Routine: |
| properties: |
| - arguments |
| - creationTime |
| - definitionBody |
| - description |
| - determinismLevel |
| - etag |
| - importedLibraries |
| - language |
| - lastModifiedTime |
| - returnType |
| - routineReference |
| - routineType |
| RoutineReference: |
| properties: |
| - datasetId |
| - projectId |
| - routineId |
| Row: |
| properties: |
| - actualLabel |
| - entries |
| RowAccessPolicy: |
| properties: |
| - creationTime |
| - etag |
| - filterPredicate |
| - lastModifiedTime |
| - rowAccessPolicyReference |
| RowAccessPolicyReference: |
| properties: |
| - datasetId |
| - policyId |
| - projectId |
| - tableId |
| RowAsDictJsonCoder: |
| methods: |
| - decode |
| - encode |
| - to_type_hint |
| RowCoder: |
| methods: |
| - as_cloud_object |
| - as_deterministic_coder |
| - from_payload |
| - from_runner_api_parameter |
| - from_type_hint |
| - is_deterministic |
| - to_runner_api_parameter |
| - to_type_hint |
| RowCoderImpl: |
| methods: |
| - decode_batch_from_stream |
| - decode_from_stream |
| - encode_batch_to_stream |
| - encode_to_stream |
| RowColumnEncoder: |
| methods: |
| - create |
| - decode_from_stream |
| - encode_to_stream |
| - finalize_write |
| - null_flags |
| - register |
| properties: |
| - ROW_ENCODERS |
| RowLevelSecurityStatistics: |
| properties: |
| - rowLevelSecurityApplied |
| RowsToDataFrameFn: |
| methods: |
| - process_batch |
| RowToStringWithSlowDown: |
| methods: |
| - process |
| RowTypeConstraint: |
| methods: |
| - field_options |
| - from_fields |
| - from_user_type |
| - get_type_for |
| - schema_id |
| - schema_options |
| - set_schema_id |
| - type_check |
| - user_type |
| RunBuildTriggerRequest: |
| properties: |
| - projectId |
| - source |
| - triggerId |
| RunInference: |
| methods: |
| - expand |
| - from_callable |
| RunnerApiFn: |
| methods: |
| - from_runner_api |
| - register_pickle_urn |
| - register_urn |
| - register_urn |
| - register_urn |
| - register_urn |
| - register_urn |
| - to_runner_api |
| - to_runner_api_parameter |
| RunnerError: {} |
| RunnerIOOperation: {} |
| RunnerResult: |
| methods: |
| - metrics |
| - monitoring_infos |
| - monitoring_metrics |
| - wait_until_finish |
| RuntimeEnvironment: |
| properties: |
| - additionalExperiments |
| - additionalUserLabels |
| - bypassTempDirValidation |
| - enableStreamingEngine |
| - ipConfiguration |
| - kmsKeyName |
| - machineType |
| - maxWorkers |
| - network |
| - numWorkers |
| - serviceAccountEmail |
| - subnetwork |
| - tempLocation |
| - workerRegion |
| - workerZone |
| - zone |
| RuntimeMetadata: |
| properties: |
| - parameters |
| - sdkInfo |
| RuntimeMetric: {} |
| RuntimeState: |
| methods: |
| - finalize |
| - prefetch |
| RuntimeTimer: |
| methods: |
| - clear |
| - set |
| RuntimeValueProvider: |
| methods: |
| - get |
| - get_value |
| - is_accessible |
| - set_runtime_options |
| properties: |
| - experiments |
| - runtime_options |
| RuntimeValueProviderError: {} |
| RunWorkflowCustomOperationMetadata: |
| properties: |
| - apiVersion |
| - createTime |
| - endTime |
| - pipelineRunId |
| - requestedCancellation |
| - target |
| - verb |
| S3ClientError: {} |
| S3Downloader: |
| methods: |
| - get_range |
| - size |
| S3FileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| properties: |
| - CHUNK_SIZE |
| - S3_PREFIX |
| S3IO: |
| methods: |
| - checksum |
| - copy |
| - copy_paths |
| - copy_tree |
| - delete |
| - delete_files |
| - delete_paths |
| - delete_tree |
| - exists |
| - last_updated |
| - list_files |
| - list_prefix |
| - open |
| - rename |
| - rename_files |
| - size |
| S3Options: {} |
| S3Uploader: |
| methods: |
| - finish |
| - put |
| SafeFastPrimitivesCoder: |
| methods: |
| - decode |
| - encode |
| Sample: {} |
| SampleCombineFn: |
| methods: |
| - add_input |
| - compact |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| - setup |
| - teardown |
| SampleOptions: {} |
| SchemaAwareExternalTransform: |
| methods: |
| - discover |
| - expand |
| SchemaBasedPayloadBuilder: |
| methods: |
| - build |
| SchemaLoadedSqlTransform: |
| methods: |
| - expand |
| SchemaTransformPayloadBuilder: |
| methods: |
| - build |
| SchemaTranslation: |
| methods: |
| - atomic_value_from_runner_api |
| - atomic_value_to_runner_api |
| - named_tuple_from_schema |
| - option_from_runner_api |
| - option_to_runner_api |
| - typing_from_runner_api |
| - typing_to_runner_api |
| - value_from_runner_api |
| - value_to_runner_api |
| SchemaTypeRegistry: |
| methods: |
| - add |
| - generate_new_id |
| - get_schema_by_id |
| - get_typing_by_id |
| ScopedState: |
| methods: |
| - sampled_msecs_int |
| - sampled_seconds |
| ScreenDiffIntegrationTestEnvironment: |
| methods: |
| - base_url |
| - notebook_path_to_test_id |
| - test_urls |
| ScriptStackFrame: |
| properties: |
| - endColumn |
| - endLine |
| - procedureId |
| - startColumn |
| - startLine |
| - text |
| ScriptStatistics: |
| properties: |
| - evaluationKind |
| - stackFrames |
| SDFBoundedSourceReader: |
| methods: |
| - display_data |
| - expand |
| - get_windowing |
| SDFProcessElementInvoker: |
| methods: |
| - invoke_process_element |
| - test_method |
| SdfProcessSizedElements: |
| methods: |
| - current_element_progress |
| - monitoring_infos |
| - process |
| - try_split |
| SdfTruncateSizedRestrictions: |
| methods: |
| - current_element_progress |
| - try_split |
| SdkContainerImageBuilder: |
| methods: |
| - build_container_image |
| SdkHarness: |
| methods: |
| - create_worker |
| - run |
| properties: |
| - REQUEST_METHOD_PREFIX |
| SdkHarnessContainerImage: |
| properties: |
| - capabilities |
| - containerImage |
| - environmentId |
| - useSingleCorePerContainer |
| SDKInfo: |
| properties: |
| - language |
| - version |
| SdkVersion: |
| properties: |
| - sdkSupportStatus |
| - version |
| - versionDisplayName |
| SdkWorker: |
| methods: |
| - do_instruction |
| - finalize_bundle |
| - maybe_profile |
| - process_bundle |
| - process_bundle_progress |
| - process_bundle_split |
| - register |
| Secret: |
| properties: |
| - kmsKeyName |
| - secretEnv |
| SecretManagerSecret: |
| properties: |
| - env |
| - versionName |
| Secrets: |
| properties: |
| - inline |
| - secretManager |
| Select: |
| methods: |
| - default_label |
| - expand |
| - infer_output_type |
| SelectMaxBidFn: |
| methods: |
| - process |
| SendDebugCaptureRequest: |
| properties: |
| - componentId |
| - data |
| - dataFormat |
| - location |
| - workerId |
| SendDebugCaptureResponse: {} |
| SendWorkerMessagesRequest: |
| properties: |
| - location |
| - workerMessages |
| SendWorkerMessagesResponse: |
| properties: |
| - workerMessageResponses |
| Sentinel: |
| properties: |
| - sentinel |
| SeqMapTask: |
| properties: |
| - inputs |
| - name |
| - outputInfos |
| - stageName |
| - systemName |
| - userFn |
| SeqMapTaskOutputInfo: |
| properties: |
| - sink |
| - tag |
| Sequence: |
| methods: |
| - make_acquire_fn |
| SequenceCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| - get_estimated_size_and_observables |
| SequenceTypeConstraint: |
| methods: |
| - bind_type_variables |
| - match_type_variables |
| - type_check |
| SeriesBatchConverter: |
| methods: |
| - combine_batches |
| - estimate_byte_size |
| - explode_batch |
| - from_typehints |
| - get_length |
| - produce_batch |
| SeriesToElementsFn: |
| methods: |
| - infer_output_type |
| - process |
| ServiceAccount: |
| properties: |
| - email_address |
| - kind |
| ServiceCallMetric: |
| methods: |
| - bigtable_error_code_to_grpc_status_string |
| - call |
| - convert_to_canonical_status_string |
| Session: |
| methods: |
| - evaluate |
| - lookup |
| Sessions: |
| methods: |
| - assign |
| - from_runner_api_parameter |
| - get_window_coder |
| - merge |
| - to_runner_api_parameter |
| SessionsToStringsDoFn: |
| methods: |
| - process |
| SetHint: {} |
| SetIamPolicyRequest: |
| properties: |
| - policy |
| - updateMask |
| SetRuntimeState: |
| methods: |
| - add |
| - clear |
| - is_modified |
| - read |
| SetStateSpec: |
| methods: |
| - to_runner_api |
| SetupOptions: |
| methods: |
| - validate |
| ShardedKey: |
| methods: |
| - key |
| ShardedKeyCoder: |
| methods: |
| - as_cloud_object |
| - from_type_hint |
| - is_deterministic |
| - to_type_hint |
| ShardedKeyCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| ShardedKeyTypeConstraint: |
| methods: |
| - match_type_variables |
| - type_check |
| ShardEventsDoFn: |
| methods: |
| - process |
| Shared: |
| methods: |
| - acquire |
| ShellTask: |
| properties: |
| - command |
| - exitCode |
| ShortIdCache: |
| methods: |
| - get_infos |
| - get_short_id |
| ShuffleBarrier: |
| methods: |
| - expand |
| SideInputBarrier: |
| methods: |
| - expand |
| SideInputData: |
| methods: |
| - from_runner_api |
| - to_runner_api |
| SideInputError: {} |
| SideInputInfo: |
| properties: |
| - kind |
| - sources |
| - tag |
| SideInputMap: |
| methods: |
| - is_globally_windowed |
| SideInputReadCounter: {} |
| SimpleCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| SimpleInput: |
| methods: |
| - process |
| SimpleInvoker: |
| methods: |
| - invoke_process |
| - invoke_process_batch |
| SimpleKVSink: |
| methods: |
| - finalize_write |
| - initialize_write |
| - open_writer |
| - pre_finalize |
| SimpleKVWriter: |
| methods: |
| - close |
| - write |
| SimpleMapTaskExecutor: |
| methods: |
| - execute |
| - operations |
| SimpleMatcher: {} |
| SimpleOutput: |
| methods: |
| - process |
| SimpleRow: |
| properties: |
| - value |
| SimpleState: |
| methods: |
| - add_state |
| - at |
| - clear_state |
| - clear_timer |
| - get_state |
| - get_window |
| - set_timer |
| SimpleTypeHintError: {} |
| Simulator: |
| methods: |
| - simulate |
| SingleInputTupleCombineFn: |
| methods: |
| - add_input |
| SinglePrecisionFloatCoder: |
| methods: |
| - is_deterministic |
| - to_type_hint |
| SinglePrecisionFloatCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| Singleton: |
| methods: |
| - check |
| - is_subpartitioning_of |
| - partition_fn |
| - reason |
| SingletonCoder: |
| methods: |
| - is_deterministic |
| SingletonCoderImpl: |
| methods: |
| - decode |
| - decode_from_stream |
| - encode |
| - encode_to_stream |
| - estimate_size |
| SingletonElementConsumerSet: |
| methods: |
| - current_element_progress |
| - flush |
| - receive |
| - receive_batch |
| - try_split |
| SingletonStateHandlerFactory: |
| methods: |
| - close |
| - create_state_handler |
| Sink: |
| properties: |
| - codec |
| - spec |
| SizeBasedBufferingClosableOutputStream: |
| methods: |
| - flush |
| - maybe_flush |
| SizeLimiter: |
| methods: |
| - is_triggered |
| SklearnInference: |
| methods: |
| - test_sklearn_mnist_classification |
| - test_sklearn_regression |
| SklearnModelHandlerNumpy: |
| methods: |
| - get_metrics_namespace |
| - get_num_bytes |
| - load_model |
| - run_inference |
| SklearnModelHandlerPandas: |
| methods: |
| - get_metrics_namespace |
| - get_num_bytes |
| - load_model |
| - run_inference |
| SlackDelivery: |
| properties: |
| - webhookUri |
| SlidingWindows: |
| methods: |
| - assign |
| - from_runner_api_parameter |
| - get_window_coder |
| - to_runner_api_parameter |
| SlowCoders: |
| methods: |
| - test_using_slow_impl |
| Smallest: |
| methods: |
| - default_label |
| SMTPDelivery: |
| properties: |
| - fromAddress |
| - password |
| - port |
| - recipientAddresses |
| - senderAddress |
| - server |
| Snapshot: |
| properties: |
| - creationTime |
| - description |
| - diskSizeBytes |
| - id |
| - projectId |
| - pubsubMetadata |
| - region |
| - sourceJobId |
| - state |
| - ttl |
| SnapshotDefinition: |
| properties: |
| - baseTableReference |
| - snapshotTime |
| SnapshotJobRequest: |
| properties: |
| - description |
| - location |
| - snapshotSources |
| - ttl |
| SnippetUtils: {} |
| SortedConcatWithCounters: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| Source: |
| properties: |
| - repoSource |
| - storageSource |
| - storageSourceManifest |
| SourceBase: |
| methods: |
| - is_bounded |
| SourceFork: |
| properties: |
| - primary |
| - primarySource |
| - residual |
| - residualSource |
| SourceGetMetadataRequest: |
| properties: |
| - source |
| SourceGetMetadataResponse: |
| properties: |
| - metadata |
| SourceMetadata: |
| properties: |
| - estimatedSizeBytes |
| - infinite |
| - producesSortedKeys |
| SourceOperationRequest: |
| properties: |
| - getMetadata |
| - name |
| - originalName |
| - split |
| - stageName |
| - systemName |
| SourceOperationResponse: |
| properties: |
| - getMetadata |
| - split |
| SourceProvenance: |
| properties: |
| - fileHashes |
| - resolvedRepoSource |
| - resolvedStorageSource |
| - resolvedStorageSourceManifest |
| SourceSplitOptions: |
| properties: |
| - desiredBundleSizeBytes |
| - desiredShardSizeBytes |
| SourceSplitRequest: |
| properties: |
| - options |
| - source |
| SourceSplitResponse: |
| properties: |
| - bundles |
| - outcome |
| - shards |
| SourceSplitShard: |
| properties: |
| - derivationMode |
| - source |
| SpannerDelete: |
| properties: |
| - URN |
| SpannerHelper: |
| methods: |
| - create_database |
| - create_instance |
| - drop_database |
| - get_emulator_host |
| - insert_values |
| - read_data |
| - shutdown |
| SpannerInsert: |
| properties: |
| - URN |
| SpannerInsertOrUpdate: |
| properties: |
| - URN |
| SpannerIODetails: |
| properties: |
| - databaseId |
| - instanceId |
| - projectId |
| SpannerPartTestRow: |
| properties: |
| - f_int64 |
| - f_string |
| SpannerReplace: |
| properties: |
| - URN |
| SpannerTestKey: |
| properties: |
| - f_string |
| SpannerTestRow: |
| properties: |
| - f_boolean |
| - f_int64 |
| - f_string |
| SpannerUpdate: |
| properties: |
| - URN |
| SparkBeamJob: |
| methods: |
| - cancel |
| - delete |
| - get |
| - get_message_stream |
| - get_state |
| - get_state_stream |
| - post |
| - request |
| - run |
| SparkJarJobServer: |
| methods: |
| - java_arguments |
| - path_to_jar |
| SparkRunner: |
| methods: |
| - create_job_service_handle |
| - default_job_server |
| - run_pipeline |
| SparkRunnerOptions: {} |
| SparkTestPipelineOptions: |
| methods: |
| - view_as |
| SparkUberJarJobServer: |
| methods: |
| - create_beam_job |
| - executable_jar |
| - start |
| - stop |
| SpecialDoFn: |
| methods: |
| - display_data |
| - process |
| SpecialParDo: |
| methods: |
| - display_data |
| SplitInt64: |
| properties: |
| - highBits |
| - lowBits |
| SplitLinesToWordsFn: |
| methods: |
| - process |
| properties: |
| - OUTPUT_TAG_CHARACTER_COUNT |
| - OUTPUT_TAG_SHORT_WORDS |
| SplitNotPossibleError: {} |
| SplitRestrictionFn: |
| methods: |
| - process |
| - start_bundle |
| SplittableParDo: |
| methods: |
| - expand |
| SplittableParDoOverride: |
| methods: |
| - get_replacement_transform_for_applied_ptransform |
| - matches |
| SqlChain: |
| methods: |
| - append |
| - get |
| - to_pipeline |
| properties: |
| - current |
| - nodes |
| - root |
| - user_pipeline |
| SqlNode: |
| methods: |
| - to_pipeline |
| properties: |
| - evaluated |
| - execution_count |
| - next |
| - output_name |
| - query |
| - schemas |
| - source |
| SqlTransform: |
| properties: |
| - URN |
| Stage: |
| methods: |
| - can_fuse |
| - deduplicate_read |
| - executable_stage_transform |
| - fuse |
| - has_as_main_input |
| - is_all_sdk_urns |
| - is_runner_urn |
| - is_stateful |
| - side_inputs |
| StageExecutionDetails: |
| properties: |
| - nextPageToken |
| - workers |
| Stager: |
| methods: |
| - commit_manifest |
| - create_and_stage_job_resources |
| - create_job_resources |
| - extract_staging_tuple_iter |
| - get_sdk_package_name |
| - stage_artifact |
| - stage_job_resources |
| StageSource: |
| properties: |
| - name |
| - originalTransformOrCollection |
| - sizeBytes |
| - userName |
| StageSummary: |
| properties: |
| - endTime |
| - metrics |
| - progress |
| - stageId |
| - startTime |
| - state |
| StandardOptions: |
| properties: |
| - ALL_KNOWN_RUNNERS |
| - DEFAULT_RUNNER |
| - KNOWN_RUNNER_NAMES |
| StandardQueryParameters: |
| properties: |
| - access_token |
| - alt |
| - callback |
| - f__xgafv |
| - fields |
| - key |
| - oauth_token |
| - prettyPrint |
| - quotaUser |
| - trace |
| - upload_protocol |
| - uploadType |
| StandardSqlDataType: |
| properties: |
| - arrayElementType |
| - structType |
| - typeKind |
| StandardSqlField: |
| properties: |
| - name |
| - type |
| StandardSqlStructType: |
| properties: |
| - fields |
| StateBackedIterableCoder: |
| methods: |
| - from_runner_api_parameter |
| - is_deterministic |
| - to_runner_api_parameter |
| properties: |
| - DEFAULT_WRITE_THRESHOLD |
| StateBackedSideInputMap: |
| methods: |
| - is_globally_windowed |
| - reset |
| StateBackedTestElementType: |
| properties: |
| - live_element_count |
| StateCache: |
| methods: |
| - describe_stats |
| - get |
| - invalidate |
| - invalidate_all |
| - is_cache_enabled |
| - peek |
| - put |
| - size |
| StateFamilyConfig: |
| properties: |
| - isRead |
| - stateFamily |
| StatefulLoadGenerator: |
| methods: |
| - expand |
| StatefulOnlineClustering: |
| methods: |
| - process |
| properties: |
| - BIRCH_MODEL_SPEC |
| - DATA_ITEMS_SPEC |
| - EMBEDDINGS_SPEC |
| - UPDATE_COUNTER_SPEC |
| StateHandler: |
| methods: |
| - append_raw |
| - clear |
| - done |
| - get_raw |
| - process_instruction_id |
| StateHandlerFactory: |
| methods: |
| - close |
| - create_state_handler |
| StatelessDoFnInfo: |
| methods: |
| - serialized_dofn_data |
| - to_runner_api |
| properties: |
| - REGISTERED_DOFNS |
| StateSampler: |
| methods: |
| - commit_counters |
| - get_info |
| - scoped_state |
| - stage_name |
| - start |
| - stop |
| - stop_if_still_running |
| StateServicer: |
| methods: |
| - append_raw |
| - checkpoint |
| - clear |
| - commit |
| - done |
| - get_raw |
| - process_instruction_id |
| - restore |
| properties: |
| - StateType |
| StateSpec: |
| methods: |
| - to_runner_api |
| StaticValueProvider: |
| methods: |
| - get |
| - is_accessible |
| Status: |
| properties: |
| - code |
| - details |
| - message |
| Step: |
| properties: |
| - kind |
| - name |
| - properties |
| StopOnExitJobServer: |
| methods: |
| - start |
| - stop |
| StorageBucketAccessControlsDeleteRequest: |
| properties: |
| - bucket |
| - entity |
| - userProject |
| StorageBucketAccessControlsDeleteResponse: {} |
| StorageBucketAccessControlsGetRequest: |
| properties: |
| - bucket |
| - entity |
| - userProject |
| StorageBucketAccessControlsInsertRequest: |
| properties: |
| - bucket |
| - bucketAccessControl |
| - userProject |
| StorageBucketAccessControlsListRequest: |
| properties: |
| - bucket |
| - userProject |
| StorageBucketAccessControlsPatchRequest: |
| properties: |
| - bucket |
| - bucketAccessControl |
| - entity |
| - userProject |
| StorageBucketAccessControlsUpdateRequest: |
| properties: |
| - bucket |
| - bucketAccessControl |
| - entity |
| - userProject |
| StorageBucketsDeleteRequest: |
| properties: |
| - bucket |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - userProject |
| StorageBucketsDeleteResponse: {} |
| StorageBucketsGetIamPolicyRequest: |
| properties: |
| - bucket |
| - userProject |
| StorageBucketsGetRequest: |
| properties: |
| - bucket |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - projection |
| - userProject |
| StorageBucketsInsertRequest: |
| properties: |
| - bucket |
| - predefinedAcl |
| - predefinedDefaultObjectAcl |
| - project |
| - projection |
| - userProject |
| StorageBucketsListRequest: |
| properties: |
| - maxResults |
| - pageToken |
| - prefix |
| - project |
| - projection |
| - userProject |
| StorageBucketsLockRetentionPolicyRequest: |
| properties: |
| - bucket |
| - ifMetagenerationMatch |
| - userProject |
| StorageBucketsPatchRequest: |
| properties: |
| - bucket |
| - bucketResource |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - predefinedAcl |
| - predefinedDefaultObjectAcl |
| - projection |
| - userProject |
| StorageBucketsSetIamPolicyRequest: |
| properties: |
| - bucket |
| - policy |
| - userProject |
| StorageBucketsTestIamPermissionsRequest: |
| properties: |
| - bucket |
| - permissions |
| - userProject |
| StorageBucketsUpdateRequest: |
| properties: |
| - bucket |
| - bucketResource |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - predefinedAcl |
| - predefinedDefaultObjectAcl |
| - projection |
| - userProject |
| StorageChannelsStopResponse: {} |
| StorageDefaultObjectAccessControlsDeleteRequest: |
| properties: |
| - bucket |
| - entity |
| - userProject |
| StorageDefaultObjectAccessControlsDeleteResponse: {} |
| StorageDefaultObjectAccessControlsGetRequest: |
| properties: |
| - bucket |
| - entity |
| - userProject |
| StorageDefaultObjectAccessControlsInsertRequest: |
| properties: |
| - bucket |
| - objectAccessControl |
| - userProject |
| StorageDefaultObjectAccessControlsListRequest: |
| properties: |
| - bucket |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - userProject |
| StorageDefaultObjectAccessControlsPatchRequest: |
| properties: |
| - bucket |
| - entity |
| - objectAccessControl |
| - userProject |
| StorageDefaultObjectAccessControlsUpdateRequest: |
| properties: |
| - bucket |
| - entity |
| - objectAccessControl |
| - userProject |
| StorageNotificationsDeleteRequest: |
| properties: |
| - bucket |
| - notification |
| - userProject |
| StorageNotificationsDeleteResponse: {} |
| StorageNotificationsGetRequest: |
| properties: |
| - bucket |
| - notification |
| - userProject |
| StorageNotificationsInsertRequest: |
| properties: |
| - bucket |
| - notification |
| - userProject |
| StorageNotificationsListRequest: |
| properties: |
| - bucket |
| - userProject |
| StorageObjectAccessControlsDeleteRequest: |
| properties: |
| - bucket |
| - entity |
| - generation |
| - object |
| - userProject |
| StorageObjectAccessControlsDeleteResponse: {} |
| StorageObjectAccessControlsGetRequest: |
| properties: |
| - bucket |
| - entity |
| - generation |
| - object |
| - userProject |
| StorageObjectAccessControlsInsertRequest: |
| properties: |
| - bucket |
| - generation |
| - object |
| - objectAccessControl |
| - userProject |
| StorageObjectAccessControlsListRequest: |
| properties: |
| - bucket |
| - generation |
| - object |
| - userProject |
| StorageObjectAccessControlsPatchRequest: |
| properties: |
| - bucket |
| - entity |
| - generation |
| - object |
| - objectAccessControl |
| - userProject |
| StorageObjectAccessControlsUpdateRequest: |
| properties: |
| - bucket |
| - entity |
| - generation |
| - object |
| - objectAccessControl |
| - userProject |
| StorageObjectsComposeRequest: |
| properties: |
| - composeRequest |
| - destinationBucket |
| - destinationObject |
| - destinationPredefinedAcl |
| - ifGenerationMatch |
| - ifMetagenerationMatch |
| - kmsKeyName |
| - userProject |
| StorageObjectsCopyRequest: |
| properties: |
| - destinationBucket |
| - destinationObject |
| - destinationPredefinedAcl |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - ifSourceGenerationMatch |
| - ifSourceGenerationNotMatch |
| - ifSourceMetagenerationMatch |
| - ifSourceMetagenerationNotMatch |
| - object |
| - projection |
| - sourceBucket |
| - sourceGeneration |
| - sourceObject |
| - userProject |
| StorageObjectsDeleteRequest: |
| properties: |
| - bucket |
| - generation |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - object |
| - userProject |
| StorageObjectsDeleteResponse: {} |
| StorageObjectsGetIamPolicyRequest: |
| properties: |
| - bucket |
| - generation |
| - object |
| - userProject |
| StorageObjectsGetRequest: |
| properties: |
| - bucket |
| - generation |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - object |
| - projection |
| - userProject |
| StorageObjectsInsertRequest: |
| properties: |
| - bucket |
| - contentEncoding |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - kmsKeyName |
| - name |
| - object |
| - predefinedAcl |
| - projection |
| - userProject |
| StorageObjectsListRequest: |
| properties: |
| - bucket |
| - delimiter |
| - includeTrailingDelimiter |
| - maxResults |
| - pageToken |
| - prefix |
| - projection |
| - userProject |
| - versions |
| StorageObjectsPatchRequest: |
| properties: |
| - bucket |
| - generation |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - object |
| - objectResource |
| - predefinedAcl |
| - projection |
| - userProject |
| StorageObjectsRewriteRequest: |
| properties: |
| - destinationBucket |
| - destinationKmsKeyName |
| - destinationObject |
| - destinationPredefinedAcl |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - ifSourceGenerationMatch |
| - ifSourceGenerationNotMatch |
| - ifSourceMetagenerationMatch |
| - ifSourceMetagenerationNotMatch |
| - maxBytesRewrittenPerCall |
| - object |
| - projection |
| - rewriteToken |
| - sourceBucket |
| - sourceGeneration |
| - sourceObject |
| - userProject |
| StorageObjectsSetIamPolicyRequest: |
| properties: |
| - bucket |
| - generation |
| - object |
| - policy |
| - userProject |
| StorageObjectsTestIamPermissionsRequest: |
| properties: |
| - bucket |
| - generation |
| - object |
| - permissions |
| - userProject |
| StorageObjectsUpdateRequest: |
| properties: |
| - bucket |
| - generation |
| - ifGenerationMatch |
| - ifGenerationNotMatch |
| - ifMetagenerationMatch |
| - ifMetagenerationNotMatch |
| - object |
| - objectResource |
| - predefinedAcl |
| - projection |
| - userProject |
| StorageObjectsWatchAllRequest: |
| properties: |
| - bucket |
| - channel |
| - delimiter |
| - includeTrailingDelimiter |
| - maxResults |
| - pageToken |
| - prefix |
| - projection |
| - userProject |
| - versions |
| StorageProjectsServiceAccountGetRequest: |
| properties: |
| - projectId |
| - userProject |
| StorageSource: |
| properties: |
| - bucket |
| - generation |
| - object |
| StorageSourceManifest: |
| properties: |
| - bucket |
| - generation |
| - object |
| StorageV1: |
| properties: |
| - BASE_URL |
| - MESSAGES_MODULE |
| StreamCoderImpl: |
| methods: |
| - decode |
| - encode |
| - estimate_size |
| StreamingApplianceSnapshotConfig: |
| properties: |
| - importStateEndpoint |
| - snapshotId |
| Streamingbuffer: |
| properties: |
| - estimatedBytes |
| - estimatedRows |
| - oldestEntryTime |
| StreamingCache: |
| methods: |
| - capture_keys |
| - capture_paths |
| - capture_size |
| - cleanup |
| - clear |
| - exists |
| - load_pcoder |
| - read |
| - read_multiple |
| - save_pcoder |
| - sink |
| - size |
| - source |
| - write |
| StreamingCacheSink: |
| methods: |
| - expand |
| - path |
| - size_in_bytes |
| StreamingCacheSource: |
| methods: |
| - read |
| StreamingComputationConfig: |
| properties: |
| - computationId |
| - instructions |
| - stageName |
| - systemName |
| - transformUserNameToStateFamily |
| StreamingComputationRanges: |
| properties: |
| - computationId |
| - rangeAssignments |
| StreamingComputationTask: |
| properties: |
| - computationRanges |
| - dataDisks |
| - taskType |
| StreamingConfigTask: |
| properties: |
| - commitStreamChunkSizeBytes |
| - getDataStreamChunkSizeBytes |
| - maxWorkItemCommitBytes |
| - streamingComputationConfigs |
| - userStepToStateFamilyNameMap |
| - windmillServiceEndpoint |
| - windmillServicePort |
| StreamingSetupTask: |
| properties: |
| - drain |
| - receiveWorkPort |
| - snapshotConfig |
| - streamingComputationTopology |
| - workerHarnessPort |
| StreamingSideInputLocation: |
| properties: |
| - stateFamily |
| - tag |
| StreamingStageLocation: |
| properties: |
| - streamId |
| StreamingUserMetricsDoFn: |
| methods: |
| - finish_bundle |
| - process |
| - start_bundle |
| StreamingWordcountDebugging: |
| methods: |
| - test_streaming_wordcount_debugging |
| StreamingWordcountDebuggingIT: |
| methods: |
| - setUp |
| - setup_pubsub |
| - tearDown |
| - test_streaming_wordcount_debugging_it |
| StreamingWordCountIT: |
| methods: |
| - setUp |
| - tearDown |
| - test_streaming_wordcount_it |
| StreamLocation: |
| properties: |
| - customSourceLocation |
| - pubsubLocation |
| - sideInputLocation |
| - streamingStageLocation |
| StringList: |
| properties: |
| - elements |
| StructuredMessage: |
| properties: |
| - messageKey |
| - messageText |
| - parameters |
| StrUtf8Coder: |
| methods: |
| - decode |
| - encode |
| - is_deterministic |
| - to_type_hint |
| SubClass: {} |
| SubprocessJobServer: |
| methods: |
| - local_temp_dir |
| - start |
| - stop |
| - subprocess_cmd_and_endpoint |
| SubprocessSDKEnvironment: |
| methods: |
| - from_command_string |
| - from_options |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| SubprocessSdkWorker: |
| methods: |
| - run |
| SubprocessSdkWorkerHandler: |
| methods: |
| - start_worker |
| - stop_worker |
| SubprocessServer: |
| methods: |
| - local_temp_dir |
| - start |
| - start_process |
| - stop |
| - stop_process |
| SumAccumulator: |
| methods: |
| - update |
| - value |
| SumDoubleAccumulator: |
| methods: |
| - add_input |
| - extract_output |
| - merge |
| SumFloatFn: {} |
| SumInt64Accumulator: |
| methods: |
| - add_input |
| - add_input_n |
| - extract_output |
| - merge |
| SumInt64Fn: {} |
| Summary: |
| methods: |
| - result |
| - summarize |
| SuperClass: {} |
| SwitchingDirectRunner: |
| methods: |
| - is_fnapi_compatible |
| - run_pipeline |
| SynchronousBagRuntimeState: |
| methods: |
| - add |
| - clear |
| - commit |
| - read |
| SynchronousSetRuntimeState: |
| methods: |
| - add |
| - clear |
| - commit |
| - read |
| SyntheticRecordToStrFn: |
| methods: |
| - process |
| SyntheticSDFAsSource: |
| methods: |
| - process |
| SyntheticSDFSourceRestrictionProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_size |
| - split |
| SyntheticSDFStepRestrictionProvider: |
| methods: |
| - create_tracker |
| - initial_restriction |
| - restriction_size |
| - split |
| SyntheticSource: |
| methods: |
| - default_output_coder |
| - element_size |
| - estimate_size |
| - get_range_tracker |
| - read |
| - split |
| SyntheticStep: |
| methods: |
| - finish_bundle |
| - process |
| - start_bundle |
| Table: |
| properties: |
| - clustering |
| - creationTime |
| - description |
| - encryptionConfiguration |
| - etag |
| - expirationTime |
| - externalDataConfiguration |
| - friendlyName |
| - id |
| - kind |
| - labels |
| - lastModifiedTime |
| - location |
| - materializedView |
| - model |
| - numBytes |
| - numLongTermBytes |
| - numPhysicalBytes |
| - numRows |
| - rangePartitioning |
| - requirePartitionFilter |
| - schema |
| - selfLink |
| - snapshotDefinition |
| - streamingBuffer |
| - tableReference |
| - timePartitioning |
| - type |
| - view |
| TableCell: |
| properties: |
| - v |
| TableDataInsertAllRequest: |
| properties: |
| - ignoreUnknownValues |
| - kind |
| - rows |
| - skipInvalidRows |
| - templateSuffix |
| TableDataInsertAllResponse: |
| properties: |
| - insertErrors |
| - kind |
| TableDataList: |
| properties: |
| - etag |
| - kind |
| - pageToken |
| - rows |
| - totalRows |
| TableFieldSchema: |
| properties: |
| - categories |
| - description |
| - fields |
| - mode |
| - name |
| - policyTags |
| - type |
| TableList: |
| properties: |
| - etag |
| - kind |
| - nextPageToken |
| - tables |
| - totalItems |
| TableReference: |
| properties: |
| - datasetId |
| - projectId |
| - tableId |
| TableRow: |
| properties: |
| - f |
| TableRowJsonCoder: |
| methods: |
| - decode |
| - encode |
| TableSchema: |
| properties: |
| - fields |
| TaggedOutput: {} |
| TaskRunnerSettings: |
| properties: |
| - alsologtostderr |
| - baseTaskDir |
| - baseUrl |
| - commandlinesFileName |
| - continueOnException |
| - dataflowApiVersion |
| - harnessCommand |
| - languageHint |
| - logDir |
| - logToSerialconsole |
| - logUploadLocation |
| - oauthScopes |
| - parallelWorkerSettings |
| - streamingWorkerMainClass |
| - taskGroup |
| - taskUser |
| - tempStoragePrefix |
| - vmId |
| - workflowFileName |
| TaxirideIT: |
| methods: |
| - setUp |
| - tearDown |
| - test_aggregation |
| - test_enrich |
| TeamScoresDict: |
| methods: |
| - process |
| TempDir: |
| methods: |
| - create_temp_file |
| - get_path |
| TemplateMetadata: |
| properties: |
| - description |
| - name |
| - parameters |
| TensorRTEngine: |
| methods: |
| - get_engine_attrs |
| TensorRTEngineHandlerNumPy: |
| methods: |
| - batch_elements_kwargs |
| - build_engine |
| - get_metrics_namespace |
| - get_num_bytes |
| - load_model |
| - load_onnx |
| - run_inference |
| Test_NativeWrite: |
| methods: |
| - setUp |
| - test_expand_method_pcollection_errors |
| TestAvroRowWriter: |
| methods: |
| - test_write_row |
| TestAZFSPathParser: |
| methods: |
| - test_azfs_path |
| - test_azfs_path_blob_optional |
| - test_bad_azfs_path |
| - test_bad_azfs_path_blob_optional |
| properties: |
| - BAD_AZFS_PATHS |
| TestBigQueryFileLoads: |
| methods: |
| - test_load_job_id_use_for_copy_job |
| - test_load_job_id_used |
| - test_multiple_partition_files |
| - test_one_load_job_failed_after_waiting |
| - test_records_traverse_transform_with_mocks |
| - test_trigger_load_jobs_with_empty_files |
| - test_triggering_frequency |
| - test_wait_for_load_job_completion |
| TestBigQuerySink: |
| methods: |
| - test_parse_schema_descriptor |
| - test_project_table_display_data |
| - test_table_spec_display_data |
| TestBigQueryToAvroSchema: |
| methods: |
| - test_convert_bigquery_schema_to_avro_schema |
| TestBigQueryToSchema: |
| methods: |
| - test_bad_schema_public_api_direct_read |
| - test_bad_schema_public_api_export |
| - test_check_conversion_with_empty_schema |
| - test_check_schema_conversions |
| - test_check_schema_conversions_with_timestamp |
| - test_unsupported_callable |
| - test_unsupported_mode |
| - test_unsupported_query_direct_read |
| - test_unsupported_query_export |
| - test_unsupported_type |
| - test_unsupported_value_provider |
| TestBigQueryWrapper: |
| methods: |
| - test_delete_dataset_retries_fail |
| - test_delete_dataset_retries_for_timeouts |
| - test_delete_non_existing_dataset |
| - test_delete_non_existing_table |
| - test_delete_table_retries_fail |
| - test_delete_table_retries_for_timeouts |
| - test_get_or_create_dataset_created |
| - test_get_or_create_dataset_fetched |
| - test_get_or_create_table |
| - test_get_or_create_table_intermittent_exception |
| - test_get_or_create_table_invalid_tablename |
| - test_get_or_create_table_race_condition |
| - test_get_query_location |
| - test_insert_rows_sets_metric_on_failure |
| - test_perform_load_job_source_mutual_exclusivity |
| - test_perform_load_job_with_load_job_id |
| - test_perform_load_job_with_source_stream |
| - test_start_query_job_priority_configuration |
| - test_temporary_dataset_is_unique |
| - test_user_agent_insert_all |
| - test_user_agent_passed |
| - test_wait_for_job_retries_fail |
| - test_wait_for_job_returns_true_when_job_is_done |
| - verify_write_call_metric |
| TestBQJobNames: |
| methods: |
| - test_matches_template |
| - test_random_in_name |
| - test_simple_names |
| TestChangePointAnalysis: |
| methods: |
| - setUp |
| - test_alert_on_data_with_change_point |
| - test_alert_on_data_with_reported_change_point |
| - test_change_point_outside_inspection_window_is_not_a_valid_alert |
| - test_duplicate_change_point |
| - test_duplicate_change_points_are_not_valid_alerts |
| - test_edivisive_means |
| - test_is_changepoint_in_valid_window |
| - test_no_alerts_when_no_change_points |
| - test_validate_config |
| TestCheckSchemaEqual: |
| methods: |
| - test_descriptions |
| - test_field_order |
| - test_simple_schemas |
| TestClock: |
| methods: |
| - advance_time |
| - time |
| TestCoerceToKvType: |
| methods: |
| - test_coercion_fail |
| - test_coercion_success |
| TestCompressedFile: |
| methods: |
| - setUp |
| - tearDown |
| - test_concatenated_compressed_file |
| - test_read_and_seek_back_to_beginning |
| - test_read_from_end_returns_no_data |
| - test_seek_cur |
| - test_seek_outside |
| - test_seek_set |
| - test_seekable_disabled_on_append |
| - test_seekable_disabled_on_write |
| - test_seekable_enabled_on_read |
| - test_tell |
| properties: |
| - content |
| - read_block_size |
| TestConcatPosition: |
| methods: |
| - test_invalid_position_type |
| - test_valid_position_type |
| TestConcatSource: |
| methods: |
| - setUp |
| - test_estimate_size |
| - test_read |
| - test_split |
| TestCounterCell: |
| methods: |
| - test_basic_operations |
| - test_parallel_access |
| - test_start_time_set |
| properties: |
| - NUM_ITERATIONS |
| - NUM_THREADS |
| TestCustomWindows: |
| methods: |
| - assign |
| - get_window_coder |
| TestDataflowMetrics: |
| methods: |
| - setup_mock_client_result |
| - test_cache_functions |
| - test_query_counters |
| - test_query_structured_metrics |
| - test_system_counters_set_labels_and_step_name |
| - test_translate_portable_job_step_name |
| properties: |
| - ONLY_COUNTERS_LIST |
| - STRUCTURED_COUNTER_LIST |
| - SYSTEM_COUNTERS_LIST |
| TestDataflowOptions: {} |
| TestDataflowRunner: |
| methods: |
| - build_console_url |
| - run_pipeline |
| - wait_until_in_state |
| TestDeidentifyFn: |
| methods: |
| - test_deidentify_called |
| TestDeidentifyText: |
| methods: |
| - test_exception_raised_when_no_config_is_provided |
| TestDicomSearch: |
| methods: |
| - test_client_search_notfound |
| - test_missing_parameters |
| - test_param_dict_passing |
| - test_Qido_search_small_buffer_flush |
| - test_successful_search |
| - test_wrong_input_type |
| TestDicomStoreInstance: |
| methods: |
| - test_destination_notfound |
| - test_missing_parameters |
| - test_store_byte_file |
| - test_store_byte_file_small_buffer_flush |
| - test_store_fileio_file |
| - test_store_fileio_file_small_buffer_flush |
| TestDirectRunner: |
| methods: |
| - run_pipeline |
| TestDistributionCell: |
| methods: |
| - test_basic_operations |
| - test_integer_only |
| - test_parallel_access |
| - test_start_time_set |
| properties: |
| - NUM_ITERATIONS |
| - NUM_THREADS |
| TestDownloaderStream: |
| methods: |
| - test_file_attributes |
| - test_read |
| - test_read_buffered |
| - test_read_empty |
| TestDynamicSplitRequest: |
| methods: |
| - test_invalid_progress_type |
| - test_valid_progress_type |
| TestDynamicSplitResultWithPosition: |
| methods: |
| - test_invalid_stop_position_type |
| - test_valid_stop_position_type |
| TestEnd2EndWriteAndRead: |
| methods: |
| - create_inputs |
| - test_end2end |
| - test_end2end_auto_compression |
| - test_end2end_auto_compression_unsharded |
| - test_end2end_example_proto |
| - test_end2end_read_write_read |
| TestEnvironment: |
| methods: |
| - context |
| - fake_pandas_module |
| TestErrorHandlingCall: |
| methods: |
| - setUpClass |
| - tearDownClass |
| - test_check_output_pip_install_non_existing_package |
| - test_oserror_check_output_message |
| TestErrorHandlingCheckCall: |
| methods: |
| - setUpClass |
| - tearDownClass |
| - test_check_call_pip_install_non_existing_package |
| - test_oserror_check_call |
| - test_oserror_check_call_message |
| TestErrorHandlingCheckOutput: |
| methods: |
| - setUpClass |
| - tearDownClass |
| - test_check_output_pip_install_non_existing_package |
| - test_oserror_check_output_message |
| TestFastAvro: {} |
| TestFileBasedSink: |
| methods: |
| - run_temp_dir_check |
| - test_empty_write |
| - test_file_sink_display_data |
| - test_file_sink_dst_matches_src |
| - test_file_sink_multi_shards |
| - test_file_sink_rename_error |
| - test_file_sink_src_missing |
| - test_file_sink_writing |
| - test_fixed_shard_write |
| - test_pre_finalize |
| - test_pre_finalize_error |
| - test_static_value_provider_empty_write |
| - test_temp_dir_gcs |
| - test_temp_dir_local |
| - test_temp_dir_uniqueness |
| TestFileBasedSource: |
| methods: |
| - setUp |
| - test_estimate_size_of_file |
| - test_estimate_size_of_pattern |
| - test_estimate_size_with_sampling_different_sizes |
| - test_estimate_size_with_sampling_same_size |
| - test_fully_read_file_pattern |
| - test_fully_read_file_pattern_with_empty_files |
| - test_fully_read_single_file |
| - test_read_auto_pattern |
| - test_read_auto_pattern_compressed_and_uncompressed |
| - test_read_auto_single_file_bzip2 |
| - test_read_auto_single_file_gzip |
| - test_read_file_bzip2 |
| - test_read_file_gzip |
| - test_read_pattern_bzip2 |
| - test_read_pattern_gzip |
| - test_read_splits_file_pattern |
| - test_read_splits_single_file |
| - test_single_file_display_data |
| - test_source_file |
| - test_source_file_unsplittable |
| - test_source_pattern |
| - test_source_pattern_unsplittable |
| - test_splits_get_coder_from_fbs |
| - test_splits_into_subranges |
| - test_string_or_value_provider_only |
| - test_unsplittable_does_not_split |
| - test_validation_directory_non_empty |
| - test_validation_failing |
| - test_validation_file_exists |
| - test_validation_file_missing_verification_disabled |
| TestFileSystem: |
| methods: |
| - setUp |
| - test_match_glob |
| - test_translate_pattern |
| TestFileSystemWithDirs: |
| methods: |
| - setUp |
| TestFormatToQido: |
| methods: |
| - test_failed_convert |
| - test_normal_convert |
| properties: |
| - expected_invalid_pubsub_dict |
| - expected_valid_pubsub_dict |
| - invalid_pubsub_string |
| - valid_pubsub_string |
| TestGaugeCell: |
| methods: |
| - test_basic_operations |
| - test_combine_appropriately |
| - test_integer_only |
| - test_start_time_set |
| TestGCSIO: |
| methods: |
| - setUp |
| - test_bad_file_modes |
| - test_checksum |
| - test_context_manager |
| - test_copy |
| - test_copy_batch |
| - test_copytree |
| - test_default_bucket_name |
| - test_default_bucket_name_failure |
| - test_delete |
| - test_delete_batch |
| - test_downloader_fail_non_existent_object |
| - test_downloader_fail_to_get_project_number |
| - test_downloader_fail_when_getting_metadata |
| - test_downloader_fail_when_reading |
| - test_downloader_monitoring_info |
| - test_empty_batches |
| - test_exists |
| - test_exists_failure |
| - test_file_close |
| - test_file_flush |
| - test_file_iterator |
| - test_file_mode |
| - test_file_random_seek |
| - test_file_read_line |
| - test_file_status |
| - test_file_write |
| - test_full_file_read |
| - test_last_updated |
| - test_list_prefix |
| - test_mime_binary_encoding |
| - test_num_retries |
| - test_rename |
| - test_retry_func |
| - test_size |
| - test_uploader_monitoring_info |
| - test_user_agent_passed |
| TestGCSPathParser: |
| methods: |
| - test_bad_gcs_path |
| - test_bad_gcs_path_object_optional |
| - test_gcs_path |
| - test_gcs_path_object_optional |
| properties: |
| - BAD_GCS_PATHS |
| TestGeneratorWrapper: |
| methods: |
| - test_functions_as_regular_generator |
| TestGetYieldedType: |
| methods: |
| - test_iterables |
| - test_not_iterable |
| TestGroupBy: |
| methods: |
| - test_aggregate |
| - test_fields |
| - test_lambdas |
| - test_pickled_field |
| TestHelperFunctions: |
| methods: |
| - test_dict_printable_fields |
| TestHistogramCell: |
| methods: |
| - test_basic_operations |
| - test_parallel_access |
| properties: |
| - NUM_ITERATIONS |
| - NUM_THREADS |
| TestIamPermissionsRequest: |
| properties: |
| - permissions |
| TestIamPermissionsResponse: |
| properties: |
| - kind |
| - permissions |
| TestingFileSystem: |
| methods: |
| - checksum |
| - copy |
| - create |
| - delete |
| - exists |
| - has_dirs |
| - join |
| - last_updated |
| - metadata |
| - mkdirs |
| - open |
| - rename |
| - scheme |
| - size |
| - split |
| TestInspectFn: |
| methods: |
| - test_inspect_called |
| TestInspectText: |
| methods: |
| - test_exception_raised_then_no_config_provided |
| TestJobServicePlan: |
| methods: |
| - get_pipeline_options |
| TestJsonRowWriter: |
| methods: |
| - test_write_row |
| TestJsonToDictCoder: |
| methods: |
| - test_coder_is_pickable |
| - test_null_fields_are_preserved |
| - test_record_and_repeatable_field_is_properly_converted |
| - test_record_field_is_properly_converted |
| - test_repeatable_field_is_properly_converted |
| - test_values_are_converted |
| TestMatchers: |
| methods: |
| - test_metric_update_basic |
| - test_structured_name_matcher_basic |
| TestMetricKey: |
| methods: |
| - test_equality_for_key_with_labels |
| - test_equality_for_key_with_no_labels |
| - test_inequality_for_key_with_labels |
| TestMetricsContainer: |
| methods: |
| - test_add_to_counter |
| - test_get_cumulative_or_updates |
| TestMultiReadFromPubSubOverride: |
| methods: |
| - test_expand_with_multiple_sources |
| - test_expand_with_multiple_sources_and_attributes |
| - test_expand_with_multiple_sources_and_other_options |
| - test_expand_with_wrong_source |
| TestNativeSink: |
| methods: |
| - test_on_direct_runner |
| - test_repr_method |
| - test_writer_method |
| TestNativeSource: |
| methods: |
| - test_reader_method |
| - test_repr_method |
| TestOffsetRestrictionProvider: |
| methods: |
| - restriction_size |
| TestOptions: |
| methods: |
| - validate |
| TestParDoAnnotations: |
| methods: |
| - test_pep484_annotations |
| - test_with_side_input |
| TestParquet: |
| methods: |
| - setUp |
| - tearDown |
| - test_batched_read |
| - test_dynamic_work_rebalancing |
| - test_int96_type_conversion |
| - test_min_bundle_size |
| - test_read_all_from_parquet_file_pattern |
| - test_read_all_from_parquet_many_file_patterns |
| - test_read_all_from_parquet_many_single_files |
| - test_read_all_from_parquet_single_file |
| - test_read_all_from_parquet_with_filename |
| - test_read_display_data |
| - test_read_reentrant |
| - test_read_with_splitting |
| - test_read_with_splitting_multiple_row_group |
| - test_read_without_splitting |
| - test_read_without_splitting_multiple_row_group |
| - test_selective_columns |
| - test_sink_display_data |
| - test_sink_transform |
| - test_sink_transform_batched |
| - test_sink_transform_compliant_nested_type |
| - test_sink_transform_compressed |
| - test_sink_transform_int96 |
| - test_sink_transform_multiple_row_group |
| - test_source_display_data |
| - test_split_points |
| - test_write_batched_display_data |
| - test_write_display_data |
| TestParquetIT: |
| methods: |
| - setUp |
| - tearDown |
| - test_parquetio_it |
| TestPartitionFiles: |
| methods: |
| - test_partition |
| - test_partition_files_dofn_file_split |
| - test_partition_files_dofn_size_split |
| TestPipeline: |
| methods: |
| - get_full_options_as_args |
| - get_option |
| - get_pipeline_options |
| - run |
| properties: |
| - pytest_test_pipeline_options |
| TestPipeStream: |
| methods: |
| - test_pipe_stream |
| - test_pipe_stream_rewind_buffer |
| TestPTransformAnnotations: |
| methods: |
| - test_annotations_with_arbitrary_input_and_output |
| - test_annotations_with_arbitrary_output |
| - test_annotations_with_none_input |
| - test_annotations_with_none_output |
| - test_annotations_with_pbegin |
| - test_annotations_with_pdone |
| - test_annotations_without_any_internal_type |
| - test_annotations_without_any_typehints |
| - test_annotations_without_input_internal_type |
| - test_annotations_without_input_pcollection_wrapper |
| - test_annotations_without_input_typehint |
| - test_annotations_without_output_internal_type |
| - test_annotations_without_output_pcollection_wrapper |
| - test_annotations_without_output_typehint |
| - test_mixed_annotations_are_converted_to_beam_annotations |
| - test_nested_typing_annotations_are_converted_to_beam_annotations |
| - test_pep484_annotations |
| - test_pipe_operator_as_union |
| - test_typing_module_annotations_are_converted_to_beam_annotations |
| TestPTransformFn: |
| methods: |
| - test_type_checking_fail |
| - test_type_checking_success |
| - test_type_hints_arg |
| TestPubsubMessage: |
| methods: |
| - test_eq |
| - test_hash |
| - test_payload_invalid |
| - test_payload_publish_invalid |
| - test_payload_valid |
| - test_proto_conversion |
| - test_repr |
| TestPubSubReadEvaluator: |
| methods: |
| - finish_bundle |
| - process_element |
| - start_bundle |
| TestPubSubSink: |
| methods: |
| - test_display_data |
| TestPubSubSource: |
| methods: |
| - test_display_data_no_subscription |
| - test_display_data_subscription |
| - test_display_data_topic |
| TestPytorchModelHandlerForInferenceOnly: {} |
| TestPytorchModelHandlerKeyedTensorForInferenceOnly: {} |
| TestReadAllFromTFRecord: |
| methods: |
| - test_process_auto |
| - test_process_deflate |
| - test_process_glob |
| - test_process_glob_with_empty_file |
| - test_process_gzip |
| - test_process_multiple |
| - test_process_multiple_globs |
| - test_process_single |
| - test_process_with_filename |
| TestReaderPosition: |
| methods: |
| - test_invalid_concat_position_type |
| - test_valid_concat_position_type |
| TestReaderProgress: |
| methods: |
| - test_out_of_bounds_percent_complete |
| - test_percent_complete_property |
| - test_position_property |
| TestReadFromBigQuery: |
| methods: |
| - setUpClass |
| - tearDown |
| - test_create_temp_dataset_exception |
| - test_get_destination_uri_empty_runtime_vp |
| - test_get_destination_uri_fallback_temp_location |
| - test_get_destination_uri_none |
| - test_get_destination_uri_runtime_vp |
| - test_get_destination_uri_static_vp |
| - test_query_job_exception |
| - test_read_export_exception |
| - test_temp_dataset_is_configurable |
| TestReadFromPubSub: |
| methods: |
| - test_read_data_success |
| - test_read_message_id_label_unsupported |
| - test_read_messages_success |
| - test_read_messages_timestamp_attribute_fail_parse |
| - test_read_messages_timestamp_attribute_milli_success |
| - test_read_messages_timestamp_attribute_missing |
| - test_read_messages_timestamp_attribute_rfc3339_success |
| - test_read_strings_success |
| - test_runner_api_transformation_properties_none |
| - test_runner_api_transformation_with_subscription |
| - test_runner_api_transformation_with_topic |
| TestReadFromPubSubOverride: |
| methods: |
| - test_expand_with_both_topic_and_subscription |
| - test_expand_with_no_topic_or_subscription |
| - test_expand_with_other_options |
| - test_expand_with_subscription |
| - test_expand_with_topic |
| TestReadFromTFRecord: |
| methods: |
| - test_process_auto |
| - test_process_deflate |
| - test_process_gzip_auto |
| - test_process_gzip_with_coder |
| - test_process_gzip_without_coder |
| - test_process_multiple |
| - test_process_single |
| TestRowAsDictJsonCoder: |
| methods: |
| - json_compliance_exception |
| - test_decimal_in_row_as_dict |
| - test_ensure_ascii |
| - test_invalid_json_inf |
| - test_invalid_json_nan |
| - test_invalid_json_neg_inf |
| - test_row_as_dict |
| TestS3IO: |
| methods: |
| - setUp |
| - test_checksum |
| - test_context_manager |
| - test_copy |
| - test_copy_paths |
| - test_copy_paths_error |
| - test_copy_tree |
| - test_delete |
| - test_delete_files |
| - test_delete_files_with_errors |
| - test_delete_paths |
| - test_delete_tree |
| - test_exists |
| - test_file_close |
| - test_file_flush |
| - test_file_iterator |
| - test_file_mime_type |
| - test_file_mode |
| - test_file_random_seek |
| - test_file_read_line |
| - test_file_status |
| - test_file_write |
| - test_full_file_read |
| - test_last_updated |
| - test_list_prefix |
| - test_midsize_file |
| - test_rename |
| - test_rename_files |
| - test_rename_files_with_errors |
| - test_rename_files_with_errors_directory |
| - test_size |
| - test_zerosize_file |
| TestS3PathParser: |
| methods: |
| - test_bad_s3_path |
| - test_bad_s3_path_object_optional |
| - test_s3_path |
| - test_s3_path_object_optional |
| properties: |
| - BAD_S3_PATHS |
| TestSingleFileSource: |
| methods: |
| - setUp |
| - test_estimates_size |
| - test_produce_split_with_start_and_end_positions |
| - test_produces_splits_desiredsize_large_than_size |
| - test_produces_splits_desiredsize_smaller_than_size |
| - test_read_range_at_beginning |
| - test_read_range_at_end |
| - test_read_range_at_middle |
| - test_source_creation_display_data |
| - test_source_creation_fails_for_non_number_offsets |
| - test_source_creation_fails_if_start_lg_stop |
| TestStager: |
| methods: |
| - commit_manifest |
| - stage_artifact |
| TestStatefulDoFn: |
| methods: |
| - on_expiry_1 |
| - on_expiry_2 |
| - on_expiry_3 |
| - on_expiry_family |
| - process |
| properties: |
| - BUFFER_STATE_1 |
| - BUFFER_STATE_2 |
| - EXPIRY_TIMER_1 |
| - EXPIRY_TIMER_2 |
| - EXPIRY_TIMER_3 |
| - EXPIRY_TIMER_FAMILY |
| TestStream: |
| methods: |
| - add_elements |
| - advance_processing_time |
| - advance_watermark_to |
| - advance_watermark_to_infinity |
| - expand |
| - from_runner_api_parameter |
| - get_windowing |
| - to_runner_api_parameter |
| TestStreamIntegrationTests: |
| methods: |
| - setUpClass |
| - test_basic_execution |
| - test_multiple_outputs |
| - test_multiple_outputs_with_watermark_advancement |
| TestStreamServiceController: |
| methods: |
| - Events |
| - start |
| - stop |
| TestTableReferenceParser: |
| methods: |
| - test_calling_with_all_arguments |
| - test_calling_with_callable |
| - test_calling_with_fully_qualified_table_ref |
| - test_calling_with_insufficient_table_ref |
| - test_calling_with_partially_qualified_table_ref |
| - test_calling_with_table_reference |
| - test_calling_with_value_provider |
| TestTableRowJsonCoder: |
| methods: |
| - json_compliance_exception |
| - test_invalid_json_inf |
| - test_invalid_json_nan |
| - test_invalid_json_neg_inf |
| - test_row_and_no_schema |
| - test_row_as_table_row |
| TestTableSchemaParser: |
| methods: |
| - test_parse_table_schema_from_json |
| TestTFRecordSink: |
| methods: |
| - test_write_record_multiple |
| - test_write_record_single |
| TestTFRecordUtil: |
| methods: |
| - setUp |
| - test_compatibility_read_write |
| - test_masked_crc32c |
| - test_masked_crc32c_crcmod |
| - test_read_record |
| - test_read_record_invalid_data_mask |
| - test_read_record_invalid_length_mask |
| - test_read_record_invalid_record |
| - test_write_record |
| TestUploaderStream: |
| methods: |
| - test_file_attributes |
| - test_write |
| - test_write_buffered |
| - test_write_empty |
| TestWriteBigTable: |
| methods: |
| - generate_row |
| - setUp |
| - test_write_metrics |
| - verify_write_call_metric |
| properties: |
| - TABLE_PREFIX |
| TestWriteGroupedRecordsToFile: |
| methods: |
| - test_files_are_created |
| - test_multiple_files |
| TestWriteRecordsToFile: |
| methods: |
| - test_files_created |
| - test_many_files |
| - test_records_are_spilled |
| properties: |
| - maxDiff |
| TestWriteStringsToPubSubOverride: |
| methods: |
| - test_expand |
| - test_expand_deprecated |
| TestWriteToBigQuery: |
| methods: |
| - setUp |
| - tearDown |
| - test_copy_load_job_exception |
| - test_dict_schema_parsing |
| - test_load_job_exception |
| - test_none_schema_parsing |
| - test_noop_dict_schema_parsing |
| - test_noop_schema_parsing |
| - test_schema_autodetect_not_allowed_with_avro_file_loads |
| - test_streaming_triggering_frequency_with_auto_sharding |
| - test_streaming_triggering_frequency_without_auto_sharding |
| - test_string_schema_parsing |
| - test_table_schema_parsing |
| - test_table_schema_parsing_end_to_end |
| - test_to_from_runner_api |
| TestWriteToPubSub: |
| methods: |
| - test_runner_api_transformation |
| - test_runner_api_transformation_properties_none |
| - test_write_messages_deprecated |
| - test_write_messages_success |
| - test_write_messages_unsupported_features |
| - test_write_messages_with_attributes_error |
| - test_write_messages_with_attributes_success |
| TestWriteToTFRecord: |
| methods: |
| - test_write_record_auto |
| - test_write_record_gzip |
| TextRenderer: |
| methods: |
| - option |
| - render_pipeline_graph |
| TextSink: |
| methods: |
| - flush |
| - open |
| - write |
| TfIdf: |
| methods: |
| - expand |
| TfIdfIT: |
| methods: |
| - test_basics |
| TFModelWrapperWithSignature: |
| methods: |
| - call |
| TFXRunInferenceTests: |
| methods: |
| - test_tfx_run_inference_mobilenetv2 |
| ThreadsafeRestrictionTracker: |
| methods: |
| - check_done |
| - current_progress |
| - current_restriction |
| - defer_remainder |
| - deferred_status |
| - is_bounded |
| - try_claim |
| - try_split |
| ThreadsafeWatermarkEstimator: |
| methods: |
| - current_watermark |
| - get_estimator_state |
| - observe_timestamp |
| ThrowingStateHandler: |
| methods: |
| - blocking_get |
| - clear |
| - done |
| - extend |
| - process_instruction_id |
| TimeBasedBufferingClosableOutputStream: |
| methods: |
| - close |
| - flush |
| TimeDomain: |
| methods: |
| - from_string |
| - is_event_time |
| - to_runner_api |
| properties: |
| - DEPENDENT_REAL_TIME |
| - REAL_TIME |
| - WATERMARK |
| TimePartitioning: |
| properties: |
| - expirationMs |
| - field |
| - requirePartitionFilter |
| - type |
| TimerCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| TimerFiring: {} |
| TimerInfo: {} |
| TimerSpec: |
| methods: |
| - to_runner_api |
| properties: |
| - prefix |
| TimeSpan: |
| properties: |
| - endTime |
| - startTime |
| Timestamp: |
| methods: |
| - from_proto |
| - from_rfc3339 |
| - from_utc_datetime |
| - now |
| - of |
| - predecessor |
| - seconds |
| - to_proto |
| - to_rfc3339 |
| - to_utc_datetime |
| TimestampBoundMode: |
| properties: |
| - EXACT_STALENESS |
| - MAX_STALENESS |
| - MIN_READ_TIMESTAMP |
| - READ_TIMESTAMP |
| - STRONG |
| TimestampCoder: |
| methods: |
| - is_deterministic |
| TimestampCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| TimestampCombiner: |
| methods: |
| - get_impl |
| properties: |
| - OUTPUT_AT_EARLIEST |
| - OUTPUT_AT_EARLIEST_TRANSFORMED |
| - OUTPUT_AT_EOW |
| - OUTPUT_AT_LATEST |
| TimestampCombinerImpl: |
| methods: |
| - assign_output_time |
| - combine |
| - combine_all |
| - merge |
| TimestampedValue: {} |
| TimestampPrefixingWindowCoder: |
| methods: |
| - as_cloud_object |
| - is_deterministic |
| - to_type_hint |
| TimestampPrefixingWindowCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - estimate_size |
| TimeUnit: |
| properties: |
| - DAYS |
| - HOURS |
| - MICROSECONDS |
| - MILLISECONDS |
| - NANOSECONDS |
| - SECONDS |
| TimingInfo: |
| methods: |
| - processing_time |
| - watermark |
| ToBytesCoder: |
| methods: |
| - decode |
| - encode |
| - is_deterministic |
| ToDict: |
| methods: |
| - expand |
| ToDictCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| Tokenize: |
| methods: |
| - process |
| - setup |
| ToList: |
| methods: |
| - expand |
| ToListCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| Top: |
| methods: |
| - Largest |
| - LargestPerKey |
| - Smallest |
| - SmallestPerKey |
| TopClass: {} |
| TopCombineFn: |
| methods: |
| - add_input |
| - compact |
| - create_accumulator |
| - display_data |
| - extract_output |
| - merge_accumulators |
| TopologyConfig: |
| properties: |
| - computations |
| - dataDiskAssignments |
| - forwardingKeyBits |
| - persistentStateVersion |
| - userStageToComputationNameMap |
| TopPerMonth: |
| methods: |
| - expand |
| TopPerPrefix: |
| methods: |
| - expand |
| ToSet: |
| methods: |
| - expand |
| ToSetCombineFn: |
| methods: |
| - add_input |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| ToString: |
| methods: |
| - Element |
| - Iterables |
| properties: |
| - Kvs |
| ToStringParDo: |
| methods: |
| - expand |
| TrainingOptions: |
| properties: |
| - autoArima |
| - autoArimaMaxOrder |
| - batchSize |
| - dataFrequency |
| - dataSplitColumn |
| - dataSplitEvalFraction |
| - dataSplitMethod |
| - distanceType |
| - dropout |
| - earlyStop |
| - feedbackType |
| - hiddenUnits |
| - holidayRegion |
| - horizon |
| - includeDrift |
| - initialLearnRate |
| - inputLabelColumns |
| - itemColumn |
| - kmeansInitializationColumn |
| - kmeansInitializationMethod |
| - l1Regularization |
| - l2Regularization |
| - labelClassWeights |
| - learnRate |
| - learnRateStrategy |
| - lossType |
| - maxIterations |
| - maxTreeDepth |
| - minRelativeProgress |
| - minSplitLoss |
| - modelUri |
| - nonSeasonalOrder |
| - numClusters |
| - numFactors |
| - optimizationStrategy |
| - preserveInputStructs |
| - subsample |
| - timeSeriesDataColumn |
| - timeSeriesIdColumn |
| - timeSeriesTimestampColumn |
| - userColumn |
| - walsAlpha |
| - warmStart |
| TrainingRun: |
| properties: |
| - dataSplitResult |
| - evaluationMetrics |
| - globalExplanations |
| - results |
| - startTime |
| - trainingOptions |
| TransactionInfo: |
| properties: |
| - transactionId |
| TransformContext: |
| methods: |
| - add_data_channel_coder |
| - add_or_get_coder_id |
| - length_prefix_pcoll_coders |
| - maybe_length_prefixed_and_safe_coder |
| - maybe_length_prefixed_coder |
| - parents_map |
| - with_state_iterables |
| TransformError: {} |
| TransformEvaluatorRegistry: |
| methods: |
| - get_evaluator |
| - get_root_bundle_provider |
| - should_execute_serially |
| TransformExecutor: |
| methods: |
| - attempt_call |
| - call |
| TransformIOCounter: |
| methods: |
| - add_bytes_read |
| - update_current_step |
| TransformNames: |
| properties: |
| - COLLECTION_TO_SINGLETON |
| - COMBINE |
| - CREATE_PCOLLECTION |
| - DO |
| - FLATTEN |
| - GROUP |
| - READ |
| - WRITE |
| TransformResult: {} |
| TransformSummary: |
| properties: |
| - displayData |
| - id |
| - inputCollectionName |
| - kind |
| - name |
| - outputCollectionName |
| TriggerContext: |
| methods: |
| - add_state |
| - clear_state |
| - clear_timer |
| - get_current_time |
| - get_state |
| - set_timer |
| TriggerCopyJobs: |
| methods: |
| - display_data |
| - finish_bundle |
| - process |
| - process_one |
| - start_bundle |
| properties: |
| - TRIGGER_DELETE_TEMP_TABLES |
| TriggerDriver: |
| methods: |
| - process_elements |
| - process_entire_key |
| - process_timer |
| TriggerEmailAlert: |
| methods: |
| - process |
| - setup |
| TriggerFn: |
| methods: |
| - from_runner_api |
| - has_ontime_pane |
| - may_lose_data |
| - on_element |
| - on_fire |
| - on_merge |
| - reset |
| - should_fire |
| - to_runner_api |
| TriggerLoadJobs: |
| methods: |
| - display_data |
| - finish_bundle |
| - process |
| - start_bundle |
| properties: |
| - ONGOING_JOBS |
| - TEMP_TABLES |
| TriggerMergeContext: |
| methods: |
| - merge |
| TripleParDo: |
| methods: |
| - expand |
| TupleCoder: |
| methods: |
| - as_cloud_object |
| - as_deterministic_coder |
| - coders |
| - from_runner_api_parameter |
| - from_type_hint |
| - is_deterministic |
| - is_kv_coder |
| - key_coder |
| - to_runner_api_parameter |
| - to_type_hint |
| - value_coder |
| TupleCoderImpl: {} |
| TupleCombineFn: |
| methods: |
| - add_input |
| - with_common_input |
| TupleHint: {} |
| TupleSequenceCoder: |
| methods: |
| - as_deterministic_coder |
| - from_type_hint |
| - is_deterministic |
| - value_coder |
| TupleSequenceCoderImpl: {} |
| TypeCheckCombineFn: |
| methods: |
| - add_input |
| - compact |
| - create_accumulator |
| - extract_output |
| - merge_accumulators |
| - setup |
| - teardown |
| TypeCheckError: {} |
| TypeCheckVisitor: |
| methods: |
| - enter_composite_transform |
| - leave_composite_transform |
| - visit_transform |
| TypeCheckWrapperDoFn: |
| methods: |
| - process |
| - type_check |
| - wrapper |
| TypeConstraint: |
| methods: |
| - bind_type_variables |
| - match_type_variables |
| - type_check |
| - visit |
| TypeInferenceError: {} |
| TypeOptions: |
| methods: |
| - validate |
| TypesAreAllTested: |
| methods: |
| - test_all_types_are_tested |
| TypeVariable: |
| methods: |
| - bind_type_variables |
| - match_type_variables |
| UberJarBeamJob: |
| methods: |
| - artifact_staging_endpoint |
| - prepare |
| properties: |
| - ARTIFACT_FOLDER |
| - PIPELINE_FOLDER |
| - PIPELINE_MANIFEST |
| - PIPELINE_NAME |
| - PIPELINE_OPTIONS_PATH |
| - PIPELINE_PATH |
| UnbatchPandas: |
| methods: |
| - expand |
| UnboundedOffsetRestrictionTracker: |
| methods: |
| - is_bounded |
| UnboundedThreadPoolExecutor: |
| methods: |
| - shutdown |
| - submit |
| UnionHint: {} |
| UnmergedState: |
| methods: |
| - get_global_state |
| - set_global_state |
| UnorderedList: {} |
| Unreify: |
| methods: |
| - process |
| UnsplittableRangeTracker: |
| methods: |
| - fraction_consumed |
| - position_at_fraction |
| - set_current_position |
| - set_split_points_unclaimed_callback |
| - split_points |
| - start_position |
| - stop_position |
| - try_claim |
| - try_split |
| UnsplittableRestrictionTracker: |
| methods: |
| - try_split |
| UnusableUnpickledDeferredBase: {} |
| UpdateBitbucketServerConfigOperationMetadata: |
| properties: |
| - bitbucketServerConfig |
| - completeTime |
| - createTime |
| UpdateDestinationSchema: |
| methods: |
| - display_data |
| - finish_bundle |
| - process |
| - start_bundle |
| UpdateGitHubEnterpriseConfigOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - githubEnterpriseConfig |
| UpdateGitLabConfigOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - gitlabConfig |
| UpdateWorkerPoolOperationMetadata: |
| properties: |
| - completeTime |
| - createTime |
| - workerPool |
| Uploader: |
| methods: |
| - finish |
| - put |
| UploaderStream: |
| methods: |
| - close |
| - tell |
| - writable |
| - write |
| UploadPartRequest: {} |
| UploadPartResponse: {} |
| UploadRequest: {} |
| UploadResponse: {} |
| UploadToDicomStore: |
| methods: |
| - expand |
| UserDefinedFunctionResource: |
| properties: |
| - inlineCode |
| - resourceUri |
| UserMetricsDoFn: |
| methods: |
| - finish_bundle |
| - process |
| - start_bundle |
| UserPipelineTracker: |
| methods: |
| - add_derived_pipeline |
| - add_user_pipeline |
| - clear |
| - evict |
| - get_pipeline |
| - get_user_pipeline |
| UserScore: |
| methods: |
| - expand |
| UserScoreIT: |
| methods: |
| - setUp |
| - test_user_score_it |
| - test_userscore_output_checksum_on_small_input |
| properties: |
| - DEFAULT_EXPECTED_CHECKSUM |
| - DEFAULT_INPUT_FILE |
| - DEFAULT_OUTPUT_FILE |
| UserSessionActivity: |
| methods: |
| - process |
| UserStateContext: |
| methods: |
| - commit |
| - get_state |
| - get_timer |
| UseSdfBoundedSourcesTests: |
| methods: |
| - test_sdf_wrap_range_source |
| - test_sdf_wrapper_overrides_read |
| ValidateResponse: |
| properties: |
| - errorMessage |
| - queryInfo |
| ValueProvider: |
| methods: |
| - get |
| - is_accessible |
| ValueProviderTests: |
| methods: |
| - setUp |
| - tearDown |
| - test_choices |
| - test_experiments_options_setup |
| - test_experiments_setup |
| - test_nested_value_provider_caches_value |
| - test_nested_value_provider_wrap_runtime |
| - test_nested_value_provider_wrap_static |
| - test_runtime_value_provider_keyword_argument |
| - test_runtime_value_provider_positional_argument |
| - test_set_runtime_option |
| - test_static_value_provider_choices |
| - test_static_value_provider_keyword_argument |
| - test_static_value_provider_positional_argument |
| - test_static_value_provider_type_cast |
| VariableBytes: |
| methods: |
| - argument |
| - argument_type |
| - language_type |
| - to_language_type |
| - urn |
| VariableString: |
| methods: |
| - argument |
| - argument_type |
| - language_type |
| - to_language_type |
| - urn |
| VarIntCoder: |
| methods: |
| - as_cloud_object |
| - is_deterministic |
| - to_type_hint |
| VarIntCoderImpl: |
| methods: |
| - decode |
| - decode_from_stream |
| - encode |
| - encode_to_stream |
| - estimate_size |
| VideoIntelligenceMlTestIT: |
| methods: |
| - test_label_detection_with_video_context |
| properties: |
| - VIDEO_PATH |
| ViewDefinition: |
| properties: |
| - query |
| - useLegacySql |
| - userDefinedFunctionResources |
| VisionMlTestIT: |
| methods: |
| - test_text_detection_with_language_hint |
| Volume: |
| properties: |
| - name |
| - path |
| WalltimeWatermarkEstimator: |
| methods: |
| - current_watermark |
| - default_provider |
| - get_estimator_state |
| - observe_timestamp |
| Warning: |
| properties: |
| - priority |
| - text |
| WatermarkEstimator: |
| methods: |
| - current_watermark |
| - get_estimator_state |
| - observe_timestamp |
| WatermarkEstimatorProvider: |
| methods: |
| - create_watermark_estimator |
| - estimator_state_coder |
| - initial_estimator_state |
| WatermarkEvent: |
| methods: |
| - to_runner_api |
| WatermarkManager: |
| methods: |
| - get_pcoll_node |
| - get_stage_node |
| - set_pcoll_watermark |
| WatermarkPolicy: |
| methods: |
| - validate_param |
| properties: |
| - ARRIVAL_TIME |
| - PROCESSING_TYPE |
| WebhookConfig: |
| properties: |
| - secret |
| - state |
| WeightedValue: |
| methods: |
| - value |
| - weight |
| WindowedBatch: |
| methods: |
| - as_windowed_values |
| - from_windowed_values |
| - with_values |
| WindowedTypeConstraint: |
| methods: |
| - type_check |
| WindowedValue: |
| methods: |
| - timestamp |
| - with_value |
| WindowedValueCoder: |
| methods: |
| - as_cloud_object |
| - is_deterministic |
| - is_kv_coder |
| - key_coder |
| - value_coder |
| WindowedValueCoderImpl: |
| methods: |
| - decode_from_stream |
| - encode_to_stream |
| - get_estimated_size_and_observables |
| WindowedValueHolder: |
| methods: |
| - from_row |
| WindowedValueHolderMeta: {} |
| WindowFn: |
| methods: |
| - assign |
| - get_transformed_output_time |
| - get_window_coder |
| - is_merging |
| - merge |
| WindowGroupingBuffer: |
| methods: |
| - append |
| - encoded_items |
| Windowing: |
| methods: |
| - from_runner_api |
| - is_default |
| - to_runner_api |
| WindowInto: |
| methods: |
| - expand |
| - from_runner_api_parameter |
| - get_windowing |
| - infer_output_type |
| - to_runner_api_parameter |
| WinningBids: |
| methods: |
| - expand |
| WithTypeHints: |
| methods: |
| - default_type_hints |
| - get_type_hints |
| - with_input_types |
| - with_output_types |
| WontImplementError: {} |
| WordCountIT: |
| methods: |
| - test_wordcount_fnapi_it |
| - test_wordcount_impersonation_it |
| - test_wordcount_it |
| - test_wordcount_it_with_prebuilt_sdk_container_cloud_build |
| - test_wordcount_it_with_prebuilt_sdk_container_local_docker |
| - test_wordcount_it_with_use_sibling_sdk_workers |
| properties: |
| - DEFAULT_CHECKSUM |
| WordExtractingDoFn: |
| methods: |
| - process |
| WorkerConfig: |
| properties: |
| - diskSizeGb |
| - machineType |
| WorkerDetails: |
| properties: |
| - workerName |
| - workItems |
| WorkerHandler: |
| methods: |
| - artifact_api_service_descriptor |
| - close |
| - control_api_service_descriptor |
| - create |
| - data_api_service_descriptor |
| - logging_api_service_descriptor |
| - register_environment |
| - start_worker |
| - state_api_service_descriptor |
| - stop_worker |
| properties: |
| - control_conn |
| - data_conn |
| WorkerHandlerManager: |
| methods: |
| - close_all |
| - get_process_bundle_descriptor |
| - get_worker |
| - get_worker_handlers |
| - register_process_bundle_descriptor |
| WorkerHealthReport: |
| properties: |
| - msg |
| - pods |
| - reportInterval |
| - vmBrokenCode |
| - vmIsBroken |
| - vmIsHealthy |
| - vmStartupTime |
| WorkerHealthReportResponse: |
| properties: |
| - reportInterval |
| WorkerIdInterceptor: |
| methods: |
| - intercept_stream_stream |
| - intercept_stream_unary |
| - intercept_unary_stream |
| - intercept_unary_unary |
| WorkerLifecycleEvent: |
| properties: |
| - containerStartTime |
| - event |
| - metadata |
| WorkerMessage: |
| properties: |
| - labels |
| - time |
| - workerHealthReport |
| - workerLifecycleEvent |
| - workerMessageCode |
| - workerMetrics |
| - workerShutdownNotice |
| WorkerMessageCode: |
| properties: |
| - code |
| - parameters |
| WorkerMessageResponse: |
| properties: |
| - workerHealthReportResponse |
| - workerMetricsResponse |
| - workerShutdownNoticeResponse |
| WorkerOptions: |
| methods: |
| - validate |
| WorkerPool: |
| properties: |
| - annotations |
| - createTime |
| - deleteTime |
| - displayName |
| - etag |
| - name |
| - privatePoolV1Config |
| - state |
| - uid |
| - updateTime |
| WorkerSettings: |
| properties: |
| - baseUrl |
| - reportingEnabled |
| - servicePath |
| - shuffleServicePath |
| - tempStoragePrefix |
| - workerId |
| WorkerShutdownNotice: |
| properties: |
| - reason |
| WorkerShutdownNoticeResponse: {} |
| WorkItem: |
| properties: |
| - configuration |
| - id |
| - initialReportIndex |
| - jobId |
| - leaseExpireTime |
| - mapTask |
| - packages |
| - projectId |
| - reportStatusInterval |
| - seqMapTask |
| - shellTask |
| - sourceOperationTask |
| - streamingComputationTask |
| - streamingConfigTask |
| - streamingSetupTask |
| WorkItemDetails: |
| properties: |
| - attemptId |
| - endTime |
| - metrics |
| - progress |
| - startTime |
| - state |
| - taskId |
| WorkItemServiceState: |
| properties: |
| - completeWorkStatus |
| - harnessData |
| - hotKeyDetection |
| - leaseExpireTime |
| - metricShortId |
| - nextReportIndex |
| - reportStatusInterval |
| - splitRequest |
| - suggestedStopPoint |
| - suggestedStopPosition |
| WorkItemStatus: |
| properties: |
| - completed |
| - counterUpdates |
| - dynamicSourceSplit |
| - errors |
| - metricUpdates |
| - progress |
| - reportedProgress |
| - reportIndex |
| - requestedLeaseDuration |
| - sourceFork |
| - sourceOperationResponse |
| - stopPosition |
| - totalThrottlerWaitTimeSeconds |
| - workItemId |
| Write: |
| methods: |
| - display_data |
| - expand |
| - from_runner_api_parameter |
| - to_runner_api_parameter |
| WriteCache: |
| methods: |
| - write_cache |
| WriteDisposition: |
| methods: |
| - VerifyParam |
| properties: |
| - APPEND |
| - EMPTY |
| - TRUNCATE |
| WriteEventDoFn: |
| methods: |
| - process |
| WriteGroupedRecordsToFile: |
| methods: |
| - process |
| WriteImpl: |
| methods: |
| - expand |
| WriteIndexDoFn: |
| methods: |
| - process |
| WriteInstruction: |
| properties: |
| - input |
| - sink |
| WriteMutation: |
| methods: |
| - delete |
| - insert |
| - insert_or_update |
| - replace |
| - update |
| Writer: |
| methods: |
| - at_capacity |
| - close |
| - write |
| WriteRecordsToFile: |
| methods: |
| - display_data |
| - finish_bundle |
| - process |
| - start_bundle |
| properties: |
| - UNWRITTEN_RECORD_TAG |
| - WRITTEN_FILE_TAG |
| WriteResult: |
| methods: |
| - destination_copy_jobid_pairs |
| - destination_file_pairs |
| - destination_load_jobid_pairs |
| - failed_rows |
| - failed_rows_with_errors |
| - validate |
| WriteToAvro: |
| methods: |
| - display_data |
| - expand |
| WriteToBigQuery: |
| methods: |
| - expand |
| - get_schema |
| WriteToBigTable: |
| methods: |
| - expand |
| WriteToDatastore: {} |
| WriteToFiles: |
| methods: |
| - expand |
| properties: |
| - DEFAULT_SHARDING |
| - MAX_NUM_WRITERS_PER_BUNDLE |
| WriteToJdbc: |
| properties: |
| - URN |
| WriteToKafka: |
| properties: |
| - byte_array_serializer |
| - URN |
| WriteToKinesis: |
| properties: |
| - URN |
| WriteToKVSink: |
| methods: |
| - expand |
| WriteToMongoDB: |
| methods: |
| - expand |
| WriteToParquet: |
| methods: |
| - display_data |
| - expand |
| WriteToParquetBatched: |
| methods: |
| - display_data |
| - expand |
| WriteToPubSub: |
| methods: |
| - expand |
| properties: |
| - URN |
| WriteToPubSubLite: |
| methods: |
| - expand |
| WriteToSnowflake: |
| methods: |
| - expand |
| properties: |
| - URN |
| WriteToSpanner: |
| methods: |
| - display_data |
| - expand |
| WriteToSpannerSchema: |
| properties: |
| - commit_deadline |
| - database_id |
| - emulator_host |
| - grouping_factor |
| - host |
| - instance_id |
| - max_batch_size_bytes |
| - max_cumulative_backoff |
| - max_number_mutations |
| - max_number_rows |
| - project_id |
| - table |
| WriteToTestSink: |
| methods: |
| - expand |
| WriteToText: |
| methods: |
| - expand |
| WriteToTFRecord: |
| methods: |
| - expand |
| WriteUserEvent: |
| methods: |
| - expand |
| WriteViaPandas: |
| methods: |
| - expand |
| Xyz: |
| methods: |
| - foo |
