feast.infra.online_stores.contrib.hbase_online_store package

Submodules

feast.infra.online_stores.contrib.hbase_online_store.hbase module

class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseConnection(store_config: HbaseOnlineStoreConfig)

Bases: object

Hbase connecttion to connect to hbase.

store_config

Online store config for Hbase store.

close() → None

Close the happybase connection.

property real_conn: Connection

Stores the real happybase Connection to connect to hbase.

class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseOnlineStore

Bases: OnlineStore

Online feature store for Hbase.

_conn

Happybase Connection to connect to hbase thrift server.

Type:

happybase.connection.Connection

online_read(config: RepoConfig, table: FeatureView, entity_keys: List[EntityKey], requested_features: List[str] | None = None) → List[Tuple[datetime | None, Dict[str, Value] | None]]

Retrieve feature values from the Hbase online store.

Parameters:

• config – The RepoConfig for the current FeatureStore.

• table – Feast FeatureView.

• entity_keys – a list of entity keys that should be read from the FeatureStore.

• requested_features – a list of requested feature names.

online_write_batch(config: RepoConfig, table: FeatureView, data: List[Tuple[EntityKey, Dict[str, Value], datetime, datetime | None]], progress: Callable[[int], Any] | None) → None

Write a batch of feature rows to Hbase online store.

Parameters:

• config – The RepoConfig for the current FeatureStore.

• table – Feast FeatureView.

• data – a list of quadruplets containing Feature data. Each quadruplet contains an Entity Key,

• values (a dict containing feature) –

• row (an event timestamp for the) –

• and –

• exists. (the created timestamp for the row if it) –

• progress – Optional function to be called once every mini-batch of rows is written to

• progress. (the online store. Can be used to display) –

teardown(config: RepoConfig, tables: Sequence[FeatureView], entities: Sequence[Entity])

Delete tables from the Hbase Online Store.

Parameters:

• config – The RepoConfig for the current FeatureStore.

• tables – Tables to delete from the feature repo.

update(config: RepoConfig, tables_to_delete: Sequence[FeatureView], tables_to_keep: Sequence[FeatureView], entities_to_delete: Sequence[Entity], entities_to_keep: Sequence[Entity], partial: bool)

Update tables from the Hbase Online Store.

Parameters:

• config – The RepoConfig for the current FeatureStore.

• tables_to_delete – Tables to delete from the Hbase Online Store.

• tables_to_keep – Tables to keep in the Hbase Online Store.

class feast.infra.online_stores.contrib.hbase_online_store.hbase.HbaseOnlineStoreConfig(*, type: typing_extensions.Literal[hbase] = 'hbase', host: str, port: str)

Bases: FeastConfigBaseModel

Online store config for Hbase store

host: str

Hostname of Hbase Thrift server

port: str

Port in which Hbase Thrift server is running

type: typing_extensions.Literal[hbase]

Online store type selector

Module contents