Index

A

AbstractProducer (class in feast.loaders.abstract_producer) AbstractStagingClient (class in feast.staging.storage_client) add_CoreServiceServicer_to_server() (in module feast.protos.feast.core.CoreService_pb2_grpc) add_feature() (feast.feature_table.FeatureTable method) (feast.FeatureTable method) add_ServingServiceServicer_to_server() (in module feast.protos.feast.serving.ServingService_pb2_grpc) apply() (feast.Client method) (feast.client.Client method) (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) apply_entity() (feast.Client method) (feast.client.Client method) (feast.registry.Registry method) apply_feature_table() (feast.Client method) (feast.client.Client method) (feast.registry.Registry method) apply_feature_view() (feast.registry.Registry method)

apply_total() (in module feast.repo_operations) ApplyEntity() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) ApplyFeatureTable() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) arbitrary_types_allowed (feast.repo_config.FeastBaseModel.Config attribute) archive_project() (feast.Client method) (feast.client.Client method) ArchiveProject() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) assert_offline_store_supports_data_source() (in module feast.infra.offline_stores.helpers) AUTH_PROVIDER (feast.constants.ConfigOptions attribute) AUTH_TOKEN (feast.constants.ConfigOptions attribute) AuthProvider (class in feast.constants) AvroFormat (class in feast.data_format) AZURE_BLOB_ACCOUNT_ACCESS_KEY (feast.constants.ConfigOptions attribute) AZURE_BLOB_ACCOUNT_NAME (feast.constants.ConfigOptions attribute) AzureBlobClient (class in feast.staging.storage_client)

B

BATCH_BIGQUERY (feast.data_source.SourceType attribute) (feast.SourceType attribute) BATCH_FEATURE_REQUEST_WAIT_TIME_SECONDS (feast.constants.ConfigOptions attribute) BATCH_FILE (feast.data_source.SourceType attribute) (feast.SourceType attribute) BATCH_INGESTION_PRODUCTION_TIMEOUT (feast.constants.ConfigOptions attribute) batch_source (feast.feature_table.FeatureTable property) (feast.FeatureTable property) bigquery_options (feast.BigQuerySource property) (feast.data_source.BigQuerySource property), [1] BigQueryOfflineStore (class in feast.infra.offline_stores.bigquery) BigQueryOfflineStoreConfig (class in feast.repo_config), [1] BigQueryOptions (class in feast.data_source), [1]

BigQueryRetrievalJob (class in feast.infra.offline_stores.bigquery) BigQuerySource (class in feast) (class in feast.data_source), [1] BOOL (feast.value_type.ValueType attribute) (feast.ValueType attribute) BOOL_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute) bootstrap_servers (feast.data_source.KafkaOptions property) bq_to_feast_value_type() (in module feast.type_map) build_point_in_time_query() (in module feast.infra.offline_stores.bigquery) BYTES (feast.value_type.ValueType attribute) (feast.ValueType attribute) BYTES_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute)

C

cache_being_updated (feast.registry.Registry attribute) cache_ttl_seconds (feast.repo_config.RegistryConfig attribute), [1] cached_registry_proto (feast.registry.Registry attribute) cached_registry_proto_created (feast.registry.Registry attribute) cached_registry_proto_ttl (feast.registry.Registry attribute) check_env_and_configure() (feast.telemetry.Telemetry method) cli_check_repo() (in module feast.repo_operations) Client (class in feast) (class in feast.client) compute_datastore_entity_id() (in module feast.infra.gcp) Config (class in feast.config) config (feast.Client property) (feast.client.Client property) (feast.feature_store.FeatureStore attribute), [1] (feast.FeatureStore attribute) CONFIG_FEAST_ENV_VAR_PREFIX (in module feast.constants) CONFIG_FILE_DEFAULT_DIRECTORY (in module feast.constants) CONFIG_FILE_NAME (in module feast.constants) CONFIG_FILE_SECTION (in module feast.constants) ConfigMeta (class in feast.constants) ConfigOptions (class in feast.constants) ConfluentProducer (class in feast.loaders.abstract_producer) CORE_ENABLE_SSL (feast.constants.ConfigOptions attribute) core_secure (feast.Client property) (feast.client.Client property)

CORE_SERVER_SSL_CERT (feast.constants.ConfigOptions attribute) core_url (feast.Client property) (feast.client.Client property) CORE_URL (feast.constants.ConfigOptions attribute) CoreService (class in feast.protos.feast.core.CoreService_pb2_grpc) CoreServiceServicer (class in feast.protos.feast.core.CoreService_pb2_grpc) CoreServiceStub (class in feast.protos.feast.core.CoreService_pb2_grpc) create_bq_view_of_joined_features_and_entities() (in module feast.staging.entities) create_customer_daily_profile_df() (in module feast.driver_test_data) create_driver_hourly_stats_df() (in module feast.driver_test_data) create_orders_df() (in module feast.driver_test_data) create_project() (feast.Client method) (feast.client.Client method) created_timestamp (feast.Entity property) (feast.entity.Entity property), [1] (feast.feature_table.FeatureTable property) (feast.feature_view.FeatureView attribute) (feast.FeatureTable property) (feast.FeatureView attribute) created_timestamp_column (feast.data_source.DataSource property), [1] (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) CreateProject() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method)

D

DATAPROC_CLUSTER_NAME (feast.constants.ConfigOptions attribute) DATAPROC_EXECUTOR_CORES (feast.constants.ConfigOptions attribute) DATAPROC_EXECUTOR_INSTANCES (feast.constants.ConfigOptions attribute) DATAPROC_EXECUTOR_MEMORY (feast.constants.ConfigOptions attribute) DATAPROC_PROJECT (feast.constants.ConfigOptions attribute) DATAPROC_REGION (feast.constants.ConfigOptions attribute) dataset (feast.repo_config.BigQueryOfflineStoreConfig attribute), [1] DataSource (class in feast.data_source), [1] DatastoreOnlineStoreConfig (class in feast.repo_config), [1] date_partition_column (feast.data_source.DataSource property), [1] DATETIME_COLUMN (in module feast.constants) DEADLETTER_PATH (feast.constants.ConfigOptions attribute) defaults() (feast.constants.ConfigOptions method) delete_feature_table() (feast.Client method) (feast.client.Client method) (feast.registry.Registry method) delete_feature_view() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) (feast.registry.Registry method)

DeleteFeatureTable() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) description (feast.Entity property) (feast.entity.Entity property), [1] DOUBLE (feast.value_type.ValueType attribute) (feast.ValueType attribute) DOUBLE_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute) download_file() (feast.staging.storage_client.AbstractStagingClient method) (feast.staging.storage_client.AzureBlobClient method) (feast.staging.storage_client.GCSClient method) (feast.staging.storage_client.LocalFSClient method) (feast.staging.storage_client.S3Client method) dtype (feast.Feature property) (feast.feature.Feature property), [1]

E

EMR_CLUSTER_ID (feast.constants.ConfigOptions attribute) EMR_CLUSTER_TEMPLATE_PATH (feast.constants.ConfigOptions attribute) EMR_LOG_LOCATION (feast.constants.ConfigOptions attribute) EMR_REGION (feast.constants.ConfigOptions attribute) ENABLE_AUTH (feast.constants.ConfigOptions attribute) entities (feast.feature_table.FeatureTable property) (feast.feature_view.FeatureView attribute) (feast.FeatureTable property) (feast.FeatureView attribute) (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) (feast.repo_operations.ParsedRepo property)

Entity (class in feast) (class in feast.entity), [1] entity_selections (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) EntityNotFoundException event_timestamp_column (feast.data_source.DataSource property), [1] (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) EventTimestampType (class in feast.driver_test_data) exists() (feast.config.Config method) export_dataframe_to_local() (in module feast.loaders.file) export_source_to_staging_location() (in module feast.loaders.file) extra (feast.repo_config.FeastBaseModel.Config attribute)

F

feast module feast.cli module feast.client module feast.config module feast.constants module feast.data_format module feast.data_source module, [1] feast.driver_test_data module feast.entity module, [1] feast.errors module feast.feature module, [1] feast.feature_store module, [1] feast.feature_table module feast.feature_view module, [1] feast.infra module feast.infra.gcp module feast.infra.key_encoding_utils module feast.infra.local module feast.infra.offline_stores module feast.infra.offline_stores.bigquery module feast.infra.offline_stores.file module feast.infra.offline_stores.helpers module feast.infra.offline_stores.offline_store module feast.infra.provider module feast.loaders module feast.loaders.abstract_producer module feast.loaders.file module feast.loaders.ingest module feast.loaders.yaml module feast.names module feast.online_response module feast.protos module feast.protos.feast module feast.protos.feast.core module feast.protos.feast.core.CoreService_pb2 module feast.protos.feast.core.CoreService_pb2_grpc module feast.protos.feast.core.DataFormat_pb2 module feast.protos.feast.core.DataFormat_pb2_grpc module feast.protos.feast.core.DataSource_pb2 module feast.protos.feast.core.DataSource_pb2_grpc module feast.protos.feast.core.Entity_pb2 module feast.protos.feast.core.Entity_pb2_grpc module feast.protos.feast.core.Feature_pb2 module feast.protos.feast.core.Feature_pb2_grpc module feast.protos.feast.core.FeatureTable_pb2 module feast.protos.feast.core.FeatureTable_pb2_grpc module feast.protos.feast.core.FeatureView_pb2 module feast.protos.feast.core.FeatureView_pb2_grpc module feast.protos.feast.core.Registry_pb2 module feast.protos.feast.core.Registry_pb2_grpc module feast.protos.feast.core.Store_pb2 module feast.protos.feast.core.Store_pb2_grpc module feast.protos.feast.serving module feast.protos.feast.serving.ServingService_pb2 module feast.protos.feast.serving.ServingService_pb2_grpc module feast.protos.feast.storage module feast.protos.feast.storage.Redis_pb2 module feast.protos.feast.storage.Redis_pb2_grpc module

feast.protos.feast.types module feast.protos.feast.types.EntityKey_pb2 module feast.protos.feast.types.EntityKey_pb2_grpc module feast.protos.feast.types.Field_pb2 module feast.protos.feast.types.Field_pb2_grpc module feast.protos.feast.types.Value_pb2 module feast.protos.feast.types.Value_pb2_grpc module feast.registry module feast.repo_config module, [1] feast.repo_operations module feast.staging module feast.staging.entities module feast.staging.storage_client module feast.telemetry module feast.type_map module feast.utils module feast.value_type module feast.version module feast.wait module FEAST_CONFIG_FILE_ENV (in module feast.constants) feast_value_type_to_python_type() (in module feast.type_map) FeastBaseModel (class in feast.repo_config) FeastBaseModel.Config (class in feast.repo_config) FeastConfigError, [1] FeastEntityDFMissingColumnsError FeastExtrasDependencyImportError FeastObjectNotFoundException FeastOfflineStoreUnsupportedDataSource FeastProviderClassImportError FeastProviderLoginError FeastProviderModuleImportError FeastProviderNotImplementedError Feature (class in feast) (class in feast.feature), [1] feature_tables (feast.repo_operations.ParsedRepo property) feature_views (feast.repo_operations.ParsedRepo property) FeatureRef (class in feast.feature), [1] features (feast.feature_table.FeatureTable property) (feast.feature_view.FeatureView attribute) (feast.FeatureTable property) (feast.FeatureView attribute) (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) FeatureStore (class in feast) (class in feast.feature_store), [1] FeatureTable (class in feast) (class in feast.feature_table) FeatureTableNotFoundException FeatureView (class in feast) (class in feast.feature_view), [1] FeatureViewNotFoundException FeatureViewQueryContext (class in feast.infra.offline_stores.bigquery) field_mapping (feast.data_source.DataSource property), [1] field_values (feast.online_response.OnlineResponse property) file_format (feast.data_source.FileOptions property), [1] file_options (feast.data_source.FileSource property), [1] (feast.FileSource property) file_url (feast.data_source.FileOptions property), [1] FileFormat (class in feast.data_format) FileOfflineStore (class in feast.infra.offline_stores.file) FileOfflineStoreConfig (class in feast.repo_config), [1] FileOptions (class in feast.data_source), [1] FileRetrievalJob (class in feast.infra.offline_stores.file) FileSource (class in feast) (class in feast.data_source), [1] FLOAT (feast.value_type.ValueType attribute) (feast.ValueType attribute) FLOAT_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute) flush() (feast.loaders.abstract_producer.AbstractProducer method) (feast.loaders.abstract_producer.ConfluentProducer method) (feast.loaders.abstract_producer.KafkaPythonProducer method) format_options() (feast.cli.NoOptionDefaultFormat method) from_dict() (feast.Entity class method) (feast.entity.Entity class method), [1] (feast.feature_table.FeatureTable class method) (feast.FeatureTable class method) from_proto() (feast.data_format.FileFormat class method) (feast.data_format.StreamFormat class method) (feast.data_source.BigQueryOptions class method), [1] (feast.data_source.DataSource static method), [1] (feast.data_source.FileOptions class method), [1] (feast.data_source.KafkaOptions class method) (feast.data_source.KinesisOptions class method) (feast.Entity class method) (feast.entity.Entity class method), [1] (feast.Feature class method) (feast.feature.Feature class method), [1] (feast.feature.FeatureRef class method), [1] (feast.feature_table.FeatureTable class method) (feast.feature_view.FeatureView class method), [1] (feast.FeatureTable class method) (feast.FeatureView class method) from_str() (feast.feature.FeatureRef class method), [1] from_yaml() (feast.Entity class method) (feast.entity.Entity class method), [1] (feast.feature_table.FeatureTable class method) (feast.FeatureTable class method)

G

GcpProvider (class in feast.infra.gcp) GCSClient (class in feast.staging.storage_client) GCSRegistryStore (class in feast.registry) generate_project_name() (in module feast.repo_operations) get() (feast.config.Config method) get_entity() (feast.Client method) (feast.client.Client method) (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) (feast.registry.Registry method) get_feature_table() (feast.Client method) (feast.client.Client method) (feast.registry.Registry method) get_feature_view() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) (feast.registry.Registry method) get_feature_view_query_context() (in module feast.infra.offline_stores.bigquery) get_historical_features() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) (feast.infra.gcp.GcpProvider method) (feast.infra.local.LocalProvider method) (feast.infra.offline_stores.bigquery.BigQueryOfflineStore static method) (feast.infra.offline_stores.file.FileOfflineStore static method) (feast.infra.offline_stores.offline_store.OfflineStore static method) (feast.infra.provider.Provider method) get_ignore_files() (in module feast.repo_operations) get_offline_store_from_config() (in module feast.infra.offline_stores.helpers) get_online_features() (feast.Client method) (feast.client.Client method) (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method)

get_producer() (in module feast.loaders.abstract_producer) get_provider() (in module feast.infra.provider) get_registry_config() (feast.repo_config.RepoConfig method) (feast.RepoConfig method) get_registry_proto() (feast.registry.GCSRegistryStore method) (feast.registry.LocalRegistryStore method) (feast.registry.RegistryStore method) get_repo_files() (in module feast.repo_operations) get_staging_client() (in module feast.staging.storage_client) get_table_column_names_and_types() (feast.BigQuerySource method) (feast.data_source.BigQuerySource method) (feast.data_source.FileSource method) (feast.FileSource method) get_table_query_string() (feast.BigQuerySource method) (feast.data_source.BigQuerySource method), [1] get_version() (in module feast.version) getboolean() (feast.config.Config method) GetEntity() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) GetFeastCoreVersion() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) GetFeastServingInfo() (feast.protos.feast.serving.ServingService_pb2_grpc.ServingService static method) (feast.protos.feast.serving.ServingService_pb2_grpc.ServingServiceServicer method) GetFeatureTable() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) getfloat() (feast.config.Config method) getint() (feast.config.Config method) GetOnlineFeaturesV2() (feast.protos.feast.serving.ServingService_pb2_grpc.ServingService static method) (feast.protos.feast.serving.ServingService_pb2_grpc.ServingServiceServicer method) GOOGLE (feast.constants.AuthProvider attribute) GRPC_CONNECTION_TIMEOUT (feast.constants.ConfigOptions attribute) GRPC_CONNECTION_TIMEOUT_APPLY (feast.constants.ConfigOptions attribute)

H

HISTORICAL_FEATURE_OUTPUT_FORMAT (feast.constants.ConfigOptions attribute)

HISTORICAL_FEATURE_OUTPUT_LOCATION (feast.constants.ConfigOptions attribute)

I

ingest() (feast.Client method) (feast.client.Client method) INGESTION_DROP_INVALID_ROWS (feast.constants.ConfigOptions attribute) init_repo() (in module feast.repo_operations) input (feast.feature_view.FeatureView attribute) (feast.FeatureView attribute) INT32 (feast.value_type.ValueType attribute) (feast.ValueType attribute) INT32_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute)

INT64 (feast.value_type.ValueType attribute) (feast.ValueType attribute) INT64_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute) is_valid() (feast.Entity method) (feast.entity.Entity method), [1] (feast.feature_table.FeatureTable method) (feast.feature_view.FeatureView method), [1] (feast.FeatureTable method) (feast.FeatureView method)

J

JOB_SERVICE_ENABLE_CONTROL_LOOP (feast.constants.ConfigOptions attribute) JOB_SERVICE_ENABLE_SSL (feast.constants.ConfigOptions attribute) job_service_secure (feast.Client property) (feast.client.Client property) JOB_SERVICE_SERVER_SSL_CERT (feast.constants.ConfigOptions attribute)

job_service_url (feast.Client property) (feast.client.Client property) JOB_SERVICE_URL (feast.constants.ConfigOptions attribute) join_key (feast.Entity property) (feast.entity.Entity property), [1]

K

kafka_options (feast.data_source.KafkaSource property) (feast.KafkaSource property) KafkaOptions (class in feast.data_source) KafkaPythonProducer (class in feast.loaders.abstract_producer) KafkaSource (class in feast) (class in feast.data_source)

kinesis_options (feast.data_source.KinesisSource property) (feast.KinesisSource property) KinesisOptions (class in feast.data_source) KinesisSource (class in feast) (class in feast.data_source)

L

labels (feast.Entity property) (feast.entity.Entity property), [1] (feast.Feature property) (feast.feature.Feature property), [1] (feast.feature_table.FeatureTable property) (feast.FeatureTable property) last_updated_timestamp (feast.Entity property) (feast.entity.Entity property), [1] (feast.feature_table.FeatureTable property) (feast.feature_view.FeatureView attribute) (feast.FeatureTable property) (feast.FeatureView attribute) list_entities() (feast.Client method) (feast.client.Client method) (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) (feast.registry.Registry method) list_feature_tables() (feast.Client method) (feast.client.Client method) (feast.registry.Registry method) list_feature_views() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) (feast.registry.Registry method) list_features_by_ref() (feast.Client method) (feast.client.Client method)

list_files() (feast.staging.storage_client.AbstractStagingClient method) (feast.staging.storage_client.AzureBlobClient method) (feast.staging.storage_client.GCSClient method) (feast.staging.storage_client.LocalFSClient method) (feast.staging.storage_client.S3Client method) list_projects() (feast.Client method) (feast.client.Client method) ListEntities() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) ListFeatures() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) ListFeatureTables() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) ListProjects() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) ListStores() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) load_repo_config() (in module feast.repo_config) LocalFSClient (class in feast.staging.storage_client) LocalProvider (class in feast.infra.local) LocalRegistryStore (class in feast.registry) log() (feast.telemetry.Telemetry method) log_exception() (feast.telemetry.Telemetry method) log_exceptions() (in module feast.telemetry) log_exceptions_and_usage() (in module feast.telemetry)

M

make_tzaware() (in module feast.utils) materialization_intervals (feast.feature_view.FeatureView attribute) (feast.FeatureView attribute) materialize() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) materialize_incremental() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) materialize_single_feature_view() (feast.infra.gcp.GcpProvider method) (feast.infra.local.LocalProvider method) (feast.infra.provider.Provider method) max_age (feast.feature_table.FeatureTable property) (feast.FeatureTable property) message_format (feast.data_source.KafkaOptions property) module feast feast.cli feast.client feast.config feast.constants feast.data_format feast.data_source, [1] feast.driver_test_data feast.entity, [1] feast.errors feast.feature, [1] feast.feature_store, [1] feast.feature_table feast.feature_view, [1] feast.infra feast.infra.gcp feast.infra.key_encoding_utils feast.infra.local feast.infra.offline_stores feast.infra.offline_stores.bigquery feast.infra.offline_stores.file feast.infra.offline_stores.helpers feast.infra.offline_stores.offline_store feast.infra.provider feast.loaders feast.loaders.abstract_producer feast.loaders.file feast.loaders.ingest feast.loaders.yaml feast.names feast.online_response feast.protos feast.protos.feast feast.protos.feast.core feast.protos.feast.core.CoreService_pb2 feast.protos.feast.core.CoreService_pb2_grpc feast.protos.feast.core.DataFormat_pb2 feast.protos.feast.core.DataFormat_pb2_grpc feast.protos.feast.core.DataSource_pb2 feast.protos.feast.core.DataSource_pb2_grpc feast.protos.feast.core.Entity_pb2 feast.protos.feast.core.Entity_pb2_grpc feast.protos.feast.core.Feature_pb2 feast.protos.feast.core.Feature_pb2_grpc feast.protos.feast.core.FeatureTable_pb2 feast.protos.feast.core.FeatureTable_pb2_grpc feast.protos.feast.core.FeatureView_pb2 feast.protos.feast.core.FeatureView_pb2_grpc feast.protos.feast.core.Registry_pb2 feast.protos.feast.core.Registry_pb2_grpc feast.protos.feast.core.Store_pb2 feast.protos.feast.core.Store_pb2_grpc feast.protos.feast.serving feast.protos.feast.serving.ServingService_pb2 feast.protos.feast.serving.ServingService_pb2_grpc feast.protos.feast.storage feast.protos.feast.storage.Redis_pb2 feast.protos.feast.storage.Redis_pb2_grpc feast.protos.feast.types feast.protos.feast.types.EntityKey_pb2 feast.protos.feast.types.EntityKey_pb2_grpc feast.protos.feast.types.Field_pb2 feast.protos.feast.types.Field_pb2_grpc feast.protos.feast.types.Value_pb2 feast.protos.feast.types.Value_pb2_grpc feast.registry feast.repo_config, [1] feast.repo_operations feast.staging feast.staging.entities feast.staging.storage_client feast.telemetry feast.type_map feast.utils feast.value_type feast.version feast.wait

most_recent_end_time (feast.feature_view.FeatureView property) (feast.FeatureView property)

N

name (feast.Entity property) (feast.entity.Entity property), [1] (feast.Feature property) (feast.feature.Feature property), [1] (feast.feature_table.FeatureTable property) (feast.feature_view.FeatureView attribute) (feast.FeatureTable property) (feast.FeatureView attribute) (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute)

namespace (feast.repo_config.DatastoreOnlineStoreConfig attribute), [1] NoOptionDefaultFormat (class in feast.cli) not_valid_name() (in module feast.repo_operations)

O

OAUTH (feast.constants.AuthProvider attribute) OAUTH_AUDIENCE (feast.constants.ConfigOptions attribute) OAUTH_CLIENT_ID (feast.constants.ConfigOptions attribute) OAUTH_CLIENT_SECRET (feast.constants.ConfigOptions attribute) OAUTH_GRANT_TYPE (feast.constants.ConfigOptions attribute) OAUTH_TOKEN_REQUEST_URL (feast.constants.ConfigOptions attribute) offline_store (feast.repo_config.RepoConfig attribute), [1] (feast.RepoConfig attribute) OfflineStore (class in feast.infra.offline_stores.offline_store) online (feast.feature_view.FeatureView attribute) (feast.FeatureView attribute)

online_read() (feast.infra.gcp.GcpProvider method) (feast.infra.local.LocalProvider method) (feast.infra.provider.Provider method) online_store (feast.repo_config.RepoConfig attribute), [1] (feast.RepoConfig attribute) online_write_batch() (feast.infra.gcp.GcpProvider method) (feast.infra.local.LocalProvider method) (feast.infra.provider.Provider method) OnlineResponse (class in feast.online_response) Option (class in feast.constants)

P

pa_column_to_proto_column() (in module feast.type_map) pa_column_to_timestamp_proto_column() (in module feast.type_map) pa_to_feast_value_attr() (in module feast.type_map) pa_to_feast_value_type() (in module feast.type_map) pa_to_value_type() (in module feast.type_map) ParquetFormat (class in feast.data_format) parse_repo() (in module feast.repo_operations) ParsedRepo (class in feast.repo_operations) path (feast.data_source.FileSource property), [1] (feast.FileSource property) (feast.repo_config.RegistryConfig attribute), [1] (feast.repo_config.SqliteOnlineStoreConfig attribute), [1] print_results() (feast.loaders.abstract_producer.AbstractProducer method) produce() (feast.loaders.abstract_producer.AbstractProducer method) (feast.loaders.abstract_producer.ConfluentProducer method) (feast.loaders.abstract_producer.KafkaPythonProducer method) project (feast.Client property) (feast.client.Client property)

PROJECT (feast.constants.ConfigOptions attribute) project (feast.feature_store.FeatureStore property), [1] (feast.FeatureStore property) (feast.repo_config.RepoConfig attribute), [1] (feast.RepoConfig attribute) project_id (feast.repo_config.DatastoreOnlineStoreConfig attribute), [1] ProtoFormat (class in feast.data_format) Provider (class in feast.infra.provider) provider (feast.repo_config.RepoConfig attribute), [1] (feast.RepoConfig attribute) pull_latest_from_table_or_query() (feast.infra.offline_stores.bigquery.BigQueryOfflineStore static method) (feast.infra.offline_stores.file.FileOfflineStore static method) (feast.infra.offline_stores.offline_store.OfflineStore static method) py_path_to_module() (in module feast.repo_operations) python_type_to_feast_value_type() (in module feast.type_map) python_value_to_proto_value() (in module feast.type_map)

Q

query (feast.BigQuerySource property) (feast.data_source.BigQueryOptions property), [1] (feast.data_source.BigQuerySource property) (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute)

R

read_feastignore() (in module feast.repo_operations) record_format (feast.data_source.KinesisOptions property) REDIS_HOST (feast.constants.ConfigOptions attribute) REDIS_PORT (feast.constants.ConfigOptions attribute) REDIS_SSL (feast.constants.ConfigOptions attribute) refresh() (feast.registry.Registry method) refresh_registry() (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method) region (feast.data_source.KinesisOptions property) Registry (class in feast.registry) registry (feast.repo_config.RepoConfig attribute), [1] (feast.RepoConfig attribute)

registry_dump() (in module feast.repo_operations) REGISTRY_PATH (feast.constants.ConfigOptions attribute) RegistryConfig (class in feast.repo_config), [1] RegistryStore (class in feast.registry) replace_str_in_file() (in module feast.repo_operations) repo_path (feast.feature_store.FeatureStore attribute), [1] (feast.FeatureStore attribute) RepoConfig (class in feast) (class in feast.repo_config), [1] RetrievalJob (class in feast.infra.offline_stores.offline_store)

S

S3_ENDPOINT_URL (feast.constants.ConfigOptions attribute) S3Client (class in feast.staging.storage_client) save() (feast.config.Config method) serialize_entity_key() (in module feast.infra.key_encoding_utils) SERVING_ENABLE_SSL (feast.constants.ConfigOptions attribute) serving_secure (feast.Client property) (feast.client.Client property) SERVING_SERVER_SSL_CERT (feast.constants.ConfigOptions attribute) serving_url (feast.Client property) (feast.client.Client property) SERVING_URL (feast.constants.ConfigOptions attribute) ServingService (class in feast.protos.feast.serving.ServingService_pb2_grpc) ServingServiceServicer (class in feast.protos.feast.serving.ServingService_pb2_grpc) ServingServiceStub (class in feast.protos.feast.serving.ServingService_pb2_grpc) set() (feast.config.Config method) set_project() (feast.Client method) (feast.client.Client method) source_datatype_to_feast_value_type() (feast.BigQuerySource static method) (feast.data_source.BigQuerySource static method) (feast.data_source.FileSource static method) (feast.FileSource static method) SourceType (class in feast) (class in feast.data_source), [1] SPARK_BQ_MATERIALIZATION_DATASET (feast.constants.ConfigOptions attribute) SPARK_BQ_MATERIALIZATION_PROJECT (feast.constants.ConfigOptions attribute) SPARK_HOME (feast.constants.ConfigOptions attribute)

SPARK_INGESTION_JAR (feast.constants.ConfigOptions attribute) SPARK_K8S_JOB_TEMPLATE_PATH (feast.constants.ConfigOptions attribute) SPARK_K8S_NAMESPACE (feast.constants.ConfigOptions attribute) SPARK_K8S_USE_INCLUSTER_CONFIG (feast.constants.ConfigOptions attribute) SPARK_LAUNCHER (feast.constants.ConfigOptions attribute) SPARK_STAGING_LOCATION (feast.constants.ConfigOptions attribute) SPARK_STANDALONE_MASTER (feast.constants.ConfigOptions attribute) SqliteOnlineStoreConfig (class in feast.repo_config), [1] stage_entities_to_bq() (in module feast.staging.entities) stage_entities_to_fs() (in module feast.staging.entities) STATSD_ENABLED (feast.constants.ConfigOptions attribute) STATSD_HOST (feast.constants.ConfigOptions attribute) STATSD_PORT (feast.constants.ConfigOptions attribute) STENCIL_URL (feast.constants.ConfigOptions attribute) STREAM_KAFKA (feast.data_source.SourceType attribute) (feast.SourceType attribute) STREAM_KINESIS (feast.data_source.SourceType attribute) (feast.SourceType attribute) stream_name (feast.data_source.KinesisOptions property) stream_source (feast.feature_table.FeatureTable property) (feast.FeatureTable property) StreamFormat (class in feast.data_format) STRING (feast.value_type.ValueType attribute) (feast.ValueType attribute) STRING_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute)

T

table_ref (feast.BigQuerySource property) (feast.data_source.BigQueryOptions property), [1] (feast.data_source.BigQuerySource property) (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) table_reference_from_string() (in module feast.staging.entities) table_subquery (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) tags (feast.feature_view.FeatureView attribute) (feast.FeatureView attribute) teardown() (in module feast.repo_operations) teardown_infra() (feast.infra.gcp.GcpProvider method) (feast.infra.local.LocalProvider method) (feast.infra.provider.Provider method) Telemetry (class in feast.telemetry) TELEMETRY (feast.constants.ConfigOptions attribute) telemetry_id (feast.telemetry.Telemetry property) to_bigquery() (feast.infra.offline_stores.bigquery.BigQueryRetrievalJob method) to_df() (feast.infra.offline_stores.bigquery.BigQueryRetrievalJob method) (feast.infra.offline_stores.file.FileRetrievalJob method) (feast.infra.offline_stores.offline_store.RetrievalJob method) to_dict() (feast.Entity method) (feast.entity.Entity method), [1] (feast.feature_table.FeatureTable method) (feast.FeatureTable method) (feast.online_response.OnlineResponse method) to_proto() (feast.BigQuerySource method) (feast.data_format.AvroFormat method) (feast.data_format.FileFormat method) (feast.data_format.ParquetFormat method) (feast.data_format.ProtoFormat method) (feast.data_format.StreamFormat method) (feast.data_source.BigQueryOptions method), [1] (feast.data_source.BigQuerySource method), [1] (feast.data_source.DataSource method), [1] (feast.data_source.FileOptions method), [1] (feast.data_source.FileSource method), [1] (feast.data_source.KafkaOptions method) (feast.data_source.KafkaSource method) (feast.data_source.KinesisOptions method) (feast.data_source.KinesisSource method) (feast.Entity method) (feast.entity.Entity method), [1] (feast.Feature method) (feast.feature.Feature method), [1] (feast.feature.FeatureRef method), [1] (feast.feature_table.FeatureTable method) (feast.feature_view.FeatureView method), [1] (feast.FeatureTable method) (feast.FeatureView method) (feast.FileSource method) (feast.KafkaSource method) (feast.KinesisSource method)

to_spec_proto() (feast.Entity method) (feast.entity.Entity method), [1] (feast.feature_table.FeatureTable method) (feast.FeatureTable method) to_tfx_schema_feature_type() (feast.value_type.ValueType method) (feast.ValueType method) to_yaml() (feast.Entity method) (feast.entity.Entity method), [1] (feast.feature_table.FeatureTable method) (feast.FeatureTable method) topic (feast.data_source.KafkaOptions property) ttl (feast.feature_view.FeatureView attribute) (feast.FeatureView attribute) (feast.infra.offline_stores.bigquery.FeatureViewQueryContext attribute) type (feast.repo_config.BigQueryOfflineStoreConfig attribute), [1] (feast.repo_config.DatastoreOnlineStoreConfig attribute), [1] (feast.repo_config.FileOfflineStoreConfig attribute), [1] (feast.repo_config.SqliteOnlineStoreConfig attribute), [1] TZ_AWARE_FIXED_OFFSET (feast.driver_test_data.EventTimestampType attribute) TZ_AWARE_US_PACIFIC (feast.driver_test_data.EventTimestampType attribute) TZ_AWARE_UTC (feast.driver_test_data.EventTimestampType attribute) TZ_NAIVE (feast.driver_test_data.EventTimestampType attribute)

U

UNIX_TIMESTAMP (feast.value_type.ValueType attribute) (feast.ValueType attribute) UNIX_TIMESTAMP_LIST (feast.value_type.ValueType attribute) (feast.ValueType attribute) UNKNOWN (feast.data_source.SourceType attribute) (feast.SourceType attribute) (feast.value_type.ValueType attribute) (feast.ValueType attribute) update_infra() (feast.infra.gcp.GcpProvider method) (feast.infra.local.LocalProvider method) (feast.infra.provider.Provider method)

update_registry_proto() (feast.registry.GCSRegistryStore method) (feast.registry.LocalRegistryStore method) (feast.registry.RegistryStore method) UpdateStore() (feast.protos.feast.core.CoreService_pb2_grpc.CoreService static method) (feast.protos.feast.core.CoreService_pb2_grpc.CoreServiceServicer method) upload_fileobj() (feast.staging.storage_client.AbstractStagingClient method) (feast.staging.storage_client.AzureBlobClient method) (feast.staging.storage_client.GCSClient method) (feast.staging.storage_client.LocalFSClient method) (feast.staging.storage_client.S3Client method)

V

value_type (feast.Entity property) (feast.entity.Entity property), [1] ValueType (class in feast) (class in feast.value_type)

version() (feast.Client method) (feast.client.Client method) (feast.feature_store.FeatureStore method), [1] (feast.FeatureStore method)

W

wait_retry_backoff() (in module feast.wait)

write_batch_size (feast.repo_config.DatastoreOnlineStoreConfig attribute), [1] write_concurrency (feast.repo_config.DatastoreOnlineStoreConfig attribute), [1]

Y

yaml_loader() (in module feast.loaders.yaml)