apache_beam.yaml.examples.testing.input_data module

apache_beam.yaml.examples.testing.input_data.text_data()

apache_beam.yaml.examples.testing.input_data.word_count_jinja_parameter_data()

apache_beam.yaml.examples.testing.input_data.word_count_jinja_template_data(test_name: str) → list[str]

apache_beam.yaml.examples.testing.input_data.iceberg_dynamic_destinations_users_data()

apache_beam.yaml.examples.testing.input_data.products_csv()

apache_beam.yaml.examples.testing.input_data.youtube_comments_csv()

apache_beam.yaml.examples.testing.input_data.spanner_orders_data()

apache_beam.yaml.examples.testing.input_data.shipments_data()

apache_beam.yaml.examples.testing.input_data.bigtable_data()

apache_beam.yaml.examples.testing.input_data.bigquery_data()

apache_beam.yaml.examples.testing.input_data.pubsub_messages_data()

Provides a list of PubsubMessage objects for testing.

apache_beam.yaml.examples.testing.input_data.pubsub_taxi_ride_events_data()

Provides a list of PubsubMessage objects for testing taxi ride events.

apache_beam.yaml.examples.testing.input_data.kafka_messages_data()

Provides a list of Kafka messages for testing.

class apache_beam.yaml.examples.testing.input_data.TaxiRideEventSchema(ride_id, longitude, latitude, passenger_count, meter_reading, timestamp, ride_status)

Bases: NamedTuple

Create new instance of TaxiRideEventSchema(ride_id, longitude, latitude, passenger_count, meter_reading, timestamp, ride_status)

ride_id: str

Alias for field number 0

longitude: float

Alias for field number 1

latitude: float

Alias for field number 2

passenger_count: int

Alias for field number 3

meter_reading: float

Alias for field number 4

timestamp: str

Alias for field number 5

ride_status: str

Alias for field number 6

apache_beam.yaml.examples.testing.input_data.system_logs_csv()

apache_beam.yaml.examples.testing.input_data.system_logs_data()

apache_beam.yaml.examples.testing.input_data.embedding_data()

apache_beam.yaml.examples.testing.input_data.system_logs_embedding_data()