Skip to main content
Version: v3.0.0

Move data between offline and online

Offline to online​

To push existing data from offline Feature store into online, run:

Blocking approach:

feature_set.materialize_online()

Non-Blocking approach:

future = feature_set.materialize_online_async()
note

Feature set must have a primary key and time travel column defined in order to materialize the offline store into online.

More information about asynchronous methods is available at Asynchronous methods.

Subsequent calls to materialization only push the new records since the last call to online.

Online to offline​

There is a background process that periodically starts online to offline ingestion, but in case there is a need to push existing data from online Feature store into offline earlier than scheduled, then run:

Blocking approach:

feature_set.start_online_offline_ingestion()

Non-Blocking approach:

job = feature_set.start_online_offline_ingestion_async()
Feedback