apache_beam.transforms.enrichment_handlers package

Submodules

• apache_beam.transforms.enrichment_handlers.bigquery module
  • BigQueryEnrichmentHandler
    • BigQueryEnrichmentHandler.create_row_key()
    • BigQueryEnrichmentHandler.get_cache_key()
    • BigQueryEnrichmentHandler.batch_elements_kwargs()
• apache_beam.transforms.enrichment_handlers.bigtable module
  • BigTableEnrichmentHandler
    • BigTableEnrichmentHandler.get_cache_key()
• apache_beam.transforms.enrichment_handlers.cloudsql module
  • CustomQueryConfig
    • CustomQueryConfig.query_fn
  • TableFieldsQueryConfig
    • TableFieldsQueryConfig.table_id
    • TableFieldsQueryConfig.where_clause_template
    • TableFieldsQueryConfig.where_clause_fields
  • TableFunctionQueryConfig
    • TableFunctionQueryConfig.table_id
    • TableFunctionQueryConfig.where_clause_template
    • TableFunctionQueryConfig.where_clause_value_fn
  • DatabaseTypeAdapter
    • DatabaseTypeAdapter.POSTGRESQL
    • DatabaseTypeAdapter.MYSQL
    • DatabaseTypeAdapter.SQLSERVER
    • DatabaseTypeAdapter.to_sqlalchemy_dialect()
  • ConnectionConfig
    • ConnectionConfig.get_connector_handler()
    • ConnectionConfig.get_db_url()
  • CloudSQLConnectionConfig
    • CloudSQLConnectionConfig.db_adapter
    • CloudSQLConnectionConfig.instance_connection_uri
    • CloudSQLConnectionConfig.user
    • CloudSQLConnectionConfig.password
    • CloudSQLConnectionConfig.db_id
    • CloudSQLConnectionConfig.refresh_strategy
    • CloudSQLConnectionConfig.connector_kwargs
    • CloudSQLConnectionConfig.connect_kwargs
    • CloudSQLConnectionConfig.get_connector_handler()
    • CloudSQLConnectionConfig.get_db_url()
  • ExternalSQLDBConnectionConfig
    • ExternalSQLDBConnectionConfig.db_adapter
    • ExternalSQLDBConnectionConfig.host
    • ExternalSQLDBConnectionConfig.port
    • ExternalSQLDBConnectionConfig.user
    • ExternalSQLDBConnectionConfig.password
    • ExternalSQLDBConnectionConfig.db_id
    • ExternalSQLDBConnectionConfig.connect_kwargs
    • ExternalSQLDBConnectionConfig.get_connector_handler()
    • ExternalSQLDBConnectionConfig.get_db_url()
  • CloudSQLEnrichmentHandler
    • CloudSQLEnrichmentHandler.create_row_key()
    • CloudSQLEnrichmentHandler.get_cache_key()
    • CloudSQLEnrichmentHandler.batch_elements_kwargs()
• apache_beam.transforms.enrichment_handlers.feast_feature_store module
  • FeastFeatureStoreEnrichmentHandler
    • FeastFeatureStoreEnrichmentHandler.get_cache_key()
• apache_beam.transforms.enrichment_handlers.utils module
  • ExceptionLevel
    • ExceptionLevel.RAISE
    • ExceptionLevel.WARN
    • ExceptionLevel.QUIET
• apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store module
  • VertexAIFeatureStoreEnrichmentHandler
    • VertexAIFeatureStoreEnrichmentHandler.get_cache_key()
  • VertexAIFeatureStoreLegacyEnrichmentHandler
    • VertexAIFeatureStoreLegacyEnrichmentHandler.get_cache_key()