feast.infra.offline_stores.contrib package

Subpackages

• feast.infra.offline_stores.contrib.athena_offline_store package
  • Subpackages
    • feast.infra.offline_stores.contrib.athena_offline_store.tests package
      • Submodules
      • feast.infra.offline_stores.contrib.athena_offline_store.tests.data_source module
      • Module contents
  • Submodules
  • feast.infra.offline_stores.contrib.athena_offline_store.athena module
    • AthenaOfflineStore
      • AthenaOfflineStore.get_historical_features()
      • AthenaOfflineStore.pull_all_from_table_or_query()
      • AthenaOfflineStore.pull_latest_from_table_or_query()
      • AthenaOfflineStore.write_logged_features()
    • AthenaOfflineStoreConfig
      • AthenaOfflineStoreConfig.data_source
      • AthenaOfflineStoreConfig.database
      • AthenaOfflineStoreConfig.region
      • AthenaOfflineStoreConfig.s3_staging_location
      • AthenaOfflineStoreConfig.type
      • AthenaOfflineStoreConfig.workgroup
    • AthenaRetrievalJob
      • AthenaRetrievalJob.full_feature_names
      • AthenaRetrievalJob.get_temp_s3_path()
      • AthenaRetrievalJob.get_temp_table_dml_header()
      • AthenaRetrievalJob.metadata
      • AthenaRetrievalJob.on_demand_feature_views
      • AthenaRetrievalJob.persist()
      • AthenaRetrievalJob.to_athena()
  • feast.infra.offline_stores.contrib.athena_offline_store.athena_source module
    • AthenaLoggingDestination
      • AthenaLoggingDestination.from_proto()
      • AthenaLoggingDestination.table_name
      • AthenaLoggingDestination.to_data_source()
      • AthenaLoggingDestination.to_proto()
    • AthenaOptions
      • AthenaOptions.from_proto()
      • AthenaOptions.to_proto()
    • AthenaSource
      • AthenaSource.created_timestamp_column
      • AthenaSource.data_source
      • AthenaSource.database
      • AthenaSource.date_partition_column
      • AthenaSource.description
      • AthenaSource.field_mapping
      • AthenaSource.from_proto()
      • AthenaSource.get_table_column_names_and_types()
      • AthenaSource.get_table_query_string()
      • AthenaSource.name
      • AthenaSource.owner
      • AthenaSource.query
      • AthenaSource.source_datatype_to_feast_value_type()
      • AthenaSource.table
      • AthenaSource.tags
      • AthenaSource.timestamp_field
      • AthenaSource.to_proto()
      • AthenaSource.validate()
    • SavedDatasetAthenaStorage
      • SavedDatasetAthenaStorage.athena_options
      • SavedDatasetAthenaStorage.from_proto()
      • SavedDatasetAthenaStorage.to_data_source()
      • SavedDatasetAthenaStorage.to_proto()
  • Module contents
• feast.infra.offline_stores.contrib.mssql_offline_store package
  • Subpackages
    • feast.infra.offline_stores.contrib.mssql_offline_store.tests package
      • Submodules
      • feast.infra.offline_stores.contrib.mssql_offline_store.tests.data_source module
      • Module contents
  • Submodules
  • feast.infra.offline_stores.contrib.mssql_offline_store.mssql module
    • MsSqlServerOfflineStore
      • MsSqlServerOfflineStore.get_historical_features()
      • MsSqlServerOfflineStore.offline_write_batch()
      • MsSqlServerOfflineStore.pull_all_from_table_or_query()
      • MsSqlServerOfflineStore.pull_latest_from_table_or_query()
      • MsSqlServerOfflineStore.write_logged_features()
    • MsSqlServerOfflineStoreConfig
      • MsSqlServerOfflineStoreConfig.connection_string
      • MsSqlServerOfflineStoreConfig.type
    • MsSqlServerRetrievalJob
      • MsSqlServerRetrievalJob.full_feature_names
      • MsSqlServerRetrievalJob.metadata
      • MsSqlServerRetrievalJob.on_demand_feature_views
      • MsSqlServerRetrievalJob.persist()
      • MsSqlServerRetrievalJob.supports_remote_storage_export()
      • MsSqlServerRetrievalJob.to_remote_storage()
    • make_engine()
  • feast.infra.offline_stores.contrib.mssql_offline_store.mssqlserver_source module
    • MsSqlServerOptions
      • MsSqlServerOptions.connection_str
      • MsSqlServerOptions.from_proto()
      • MsSqlServerOptions.table_ref
      • MsSqlServerOptions.to_proto()
    • MsSqlServerSource
      • MsSqlServerSource.created_timestamp_column
      • MsSqlServerSource.date_partition_column
      • MsSqlServerSource.description
      • MsSqlServerSource.field_mapping
      • MsSqlServerSource.from_proto()
      • MsSqlServerSource.get_table_column_names_and_types()
      • MsSqlServerSource.get_table_query_string()
      • MsSqlServerSource.mssqlserver_options
      • MsSqlServerSource.name
      • MsSqlServerSource.owner
      • MsSqlServerSource.source_datatype_to_feast_value_type()
      • MsSqlServerSource.table_ref
      • MsSqlServerSource.tags
      • MsSqlServerSource.timestamp_field
      • MsSqlServerSource.to_proto()
      • MsSqlServerSource.validate()
  • Module contents
• feast.infra.offline_stores.contrib.postgres_offline_store package
  • Subpackages
    • feast.infra.offline_stores.contrib.postgres_offline_store.tests package
      • Submodules
      • feast.infra.offline_stores.contrib.postgres_offline_store.tests.data_source module
      • Module contents
  • Submodules
  • feast.infra.offline_stores.contrib.postgres_offline_store.postgres module
    • PostgreSQLOfflineStore
      • PostgreSQLOfflineStore.get_historical_features()
      • PostgreSQLOfflineStore.pull_all_from_table_or_query()
      • PostgreSQLOfflineStore.pull_latest_from_table_or_query()
    • PostgreSQLOfflineStoreConfig
      • PostgreSQLOfflineStoreConfig.type
    • PostgreSQLRetrievalJob
      • PostgreSQLRetrievalJob.full_feature_names
      • PostgreSQLRetrievalJob.metadata
      • PostgreSQLRetrievalJob.on_demand_feature_views
      • PostgreSQLRetrievalJob.persist()
      • PostgreSQLRetrievalJob.to_sql()
    • build_point_in_time_query()
  • feast.infra.offline_stores.contrib.postgres_offline_store.postgres_source module
    • PostgreSQLOptions
      • PostgreSQLOptions.from_proto()
      • PostgreSQLOptions.to_proto()
    • PostgreSQLSource
      • PostgreSQLSource.created_timestamp_column
      • PostgreSQLSource.date_partition_column
      • PostgreSQLSource.description
      • PostgreSQLSource.field_mapping
      • PostgreSQLSource.from_proto()
      • PostgreSQLSource.get_table_column_names_and_types()
      • PostgreSQLSource.get_table_query_string()
      • PostgreSQLSource.name
      • PostgreSQLSource.owner
      • PostgreSQLSource.source_datatype_to_feast_value_type()
      • PostgreSQLSource.tags
      • PostgreSQLSource.timestamp_field
      • PostgreSQLSource.to_proto()
      • PostgreSQLSource.validate()
    • SavedDatasetPostgreSQLStorage
      • SavedDatasetPostgreSQLStorage.from_proto()
      • SavedDatasetPostgreSQLStorage.postgres_options
      • SavedDatasetPostgreSQLStorage.to_data_source()
      • SavedDatasetPostgreSQLStorage.to_proto()
  • Module contents
• feast.infra.offline_stores.contrib.spark_offline_store package
  • Subpackages
    • feast.infra.offline_stores.contrib.spark_offline_store.tests package
      • Submodules
      • feast.infra.offline_stores.contrib.spark_offline_store.tests.data_source module
      • Module contents
  • Submodules
  • feast.infra.offline_stores.contrib.spark_offline_store.spark module
    • SparkOfflineStore
      • SparkOfflineStore.get_historical_features()
      • SparkOfflineStore.offline_write_batch()
      • SparkOfflineStore.pull_all_from_table_or_query()
      • SparkOfflineStore.pull_latest_from_table_or_query()
    • SparkOfflineStoreConfig
      • SparkOfflineStoreConfig.region
      • SparkOfflineStoreConfig.spark_conf
      • SparkOfflineStoreConfig.staging_location
      • SparkOfflineStoreConfig.type
    • SparkRetrievalJob
      • SparkRetrievalJob.full_feature_names
      • SparkRetrievalJob.metadata
      • SparkRetrievalJob.on_demand_feature_views
      • SparkRetrievalJob.persist()
      • SparkRetrievalJob.supports_remote_storage_export()
      • SparkRetrievalJob.to_remote_storage()
      • SparkRetrievalJob.to_spark_df()
    • get_spark_session_or_start_new_with_repoconfig()
  • feast.infra.offline_stores.contrib.spark_offline_store.spark_source module
    • SavedDatasetSparkStorage
      • SavedDatasetSparkStorage.from_proto()
      • SavedDatasetSparkStorage.spark_options
      • SavedDatasetSparkStorage.to_data_source()
      • SavedDatasetSparkStorage.to_proto()
    • SparkOptions
      • SparkOptions.allowed_formats
      • SparkOptions.file_format
      • SparkOptions.from_proto()
      • SparkOptions.path
      • SparkOptions.query
      • SparkOptions.table
      • SparkOptions.to_proto()
    • SparkSource
      • SparkSource.created_timestamp_column
      • SparkSource.date_partition_column
      • SparkSource.description
      • SparkSource.field_mapping
      • SparkSource.file_format
      • SparkSource.from_proto()
      • SparkSource.get_table_column_names_and_types()
      • SparkSource.get_table_query_string()
      • SparkSource.name
      • SparkSource.owner
      • SparkSource.path
      • SparkSource.query
      • SparkSource.source_datatype_to_feast_value_type()
      • SparkSource.table
      • SparkSource.tags
      • SparkSource.timestamp_field
      • SparkSource.to_proto()
      • SparkSource.validate()
    • SparkSourceFormat
      • SparkSourceFormat.avro
      • SparkSourceFormat.csv
      • SparkSourceFormat.delta
      • SparkSourceFormat.json
      • SparkSourceFormat.parquet
  • Module contents
• feast.infra.offline_stores.contrib.trino_offline_store package
  • Subpackages
    • feast.infra.offline_stores.contrib.trino_offline_store.connectors package
      • Submodules
      • feast.infra.offline_stores.contrib.trino_offline_store.connectors.upload module
      • Module contents
    • feast.infra.offline_stores.contrib.trino_offline_store.test_config package
      • Submodules
      • feast.infra.offline_stores.contrib.trino_offline_store.test_config.manual_tests module
      • Module contents
    • feast.infra.offline_stores.contrib.trino_offline_store.tests package
      • Submodules
      • feast.infra.offline_stores.contrib.trino_offline_store.tests.data_source module
      • Module contents
  • Submodules
  • feast.infra.offline_stores.contrib.trino_offline_store.trino module
    • AuthConfig
      • AuthConfig.config
      • AuthConfig.config_only_nullable_for_oauth2()
      • AuthConfig.to_trino_auth()
      • AuthConfig.type
    • BasicAuthModel
      • BasicAuthModel.password
      • BasicAuthModel.username
    • CertificateAuthModel
      • CertificateAuthModel.cert
      • CertificateAuthModel.key
    • JWTAuthModel
      • JWTAuthModel.token
    • KerberosAuthModel
      • KerberosAuthModel.ca_bundle
      • KerberosAuthModel.config
      • KerberosAuthModel.delegate
      • KerberosAuthModel.force_preemptive
      • KerberosAuthModel.hostname_override
      • KerberosAuthModel.mutual_authentication
      • KerberosAuthModel.principal
      • KerberosAuthModel.sanitize_mutual_error_response
      • KerberosAuthModel.service_name
    • TrinoOfflineStore
      • TrinoOfflineStore.get_historical_features()
      • TrinoOfflineStore.pull_all_from_table_or_query()
      • TrinoOfflineStore.pull_latest_from_table_or_query()
    • TrinoOfflineStoreConfig
      • TrinoOfflineStoreConfig.auth
      • TrinoOfflineStoreConfig.catalog
      • TrinoOfflineStoreConfig.connector
      • TrinoOfflineStoreConfig.dataset
      • TrinoOfflineStoreConfig.extra_credential
      • TrinoOfflineStoreConfig.host
      • TrinoOfflineStoreConfig.http_scheme
      • TrinoOfflineStoreConfig.port
      • TrinoOfflineStoreConfig.source
      • TrinoOfflineStoreConfig.type
      • TrinoOfflineStoreConfig.user
      • TrinoOfflineStoreConfig.verify
    • TrinoRetrievalJob
      • TrinoRetrievalJob.full_feature_names
      • TrinoRetrievalJob.metadata
      • TrinoRetrievalJob.on_demand_feature_views
      • TrinoRetrievalJob.persist()
      • TrinoRetrievalJob.to_sql()
      • TrinoRetrievalJob.to_trino()
  • feast.infra.offline_stores.contrib.trino_offline_store.trino_queries module
    • Query
      • Query.cancel()
      • Query.close()
      • Query.execute()
    • QueryStatus
      • QueryStatus.CANCELLED
      • QueryStatus.COMPLETED
      • QueryStatus.ERROR
      • QueryStatus.PENDING
      • QueryStatus.RUNNING
    • Results
      • Results.columns
      • Results.columns_names
      • Results.data
      • Results.pyarrow_schema
      • Results.schema
      • Results.to_dataframe()
    • Trino
      • Trino.create_query()
      • Trino.execute_query()
  • feast.infra.offline_stores.contrib.trino_offline_store.trino_source module
    • SavedDatasetTrinoStorage
      • SavedDatasetTrinoStorage.from_proto()
      • SavedDatasetTrinoStorage.to_data_source()
      • SavedDatasetTrinoStorage.to_proto()
      • SavedDatasetTrinoStorage.trino_options
    • TrinoOptions
      • TrinoOptions.from_proto()
      • TrinoOptions.query
      • TrinoOptions.table
      • TrinoOptions.to_proto()
    • TrinoSource
      • TrinoSource.created_timestamp_column
      • TrinoSource.date_partition_column
      • TrinoSource.description
      • TrinoSource.field_mapping
      • TrinoSource.from_proto()
      • TrinoSource.get_table_column_names_and_types()
      • TrinoSource.get_table_query_string()
      • TrinoSource.name
      • TrinoSource.owner
      • TrinoSource.query
      • TrinoSource.source_datatype_to_feast_value_type()
      • TrinoSource.table
      • TrinoSource.tags
      • TrinoSource.timestamp_field
      • TrinoSource.to_proto()
      • TrinoSource.trino_options
      • TrinoSource.validate()
  • feast.infra.offline_stores.contrib.trino_offline_store.trino_type_map module
    • pa_to_trino_value_type()
    • trino_to_feast_value_type()
    • trino_to_pa_value_type()
  • Module contents

Submodules

feast.infra.offline_stores.contrib.athena_repo_configuration module

feast.infra.offline_stores.contrib.mssql_repo_configuration module

feast.infra.offline_stores.contrib.postgres_repo_configuration module

feast.infra.offline_stores.contrib.spark_repo_configuration module

feast.infra.offline_stores.contrib.trino_repo_configuration module

Module contents