gfw.common.beam.transforms.FakeWriteToBigQuery#

class FakeWriteToBigQuery(**kwargs)[source]#

A fake WriteToBigQuery transform for testing purposes.

Methods

annotations

default_label

default_type_hints

display_data

Returns the display data associated to a pipeline component.

expand

Overrides the expand method to do nothing.

from_runner_api

get_dict_table_schema

Transform the table schema into a dictionary instance.

get_resource_hints

get_table_schema_from_string

Transform the string table schema into a TableSchema instance.

get_type_hints

Gets and/or initializes type hints for this object.

get_windowing

Returns the window function to be associated with transform's output.

infer_output_type

register_urn

runner_api_requires_keyed_input

table_schema_to_dict

Create a dictionary representation of table schema for serialization

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

Annotates the input type of a PTransform with a type-hint.

with_output_types

Annotates the output type of a PTransform with a type-hint.

with_resource_hints

Adds resource hints to the PTransform.

Attributes

label

pipeline

side_inputs

expand(pcoll)[source]#

Overrides the expand method to do nothing.

Return type:

PCollection[Any]